Deleting a Stream

To delete a stream, call the Admin.deleteStream(String streamPathAndName) method.

Example

public void deleteStreamUtilFunction(String streamPathAndName) throws IllegalArgumentException, IOException{
	Admin streamAdmin = Streams.newAdmin(conf);
	streamAdmin.deleteStream(streamPathAndName);
	streamAdmin.close();
}

The Javadoc is located here.