public class StreamControlImpl extends StandardMBean implements StreamControl
| Modifier and Type | Method and Description |
|---|---|
String |
getName()
Returns the stream name
|
long |
getNumEmittedTuples()
Returns the number of tuples that have transited through the stream
|
String |
getSchema()
Returns the tuple definition
|
int |
getSubscriberCount() |
List<String> |
getSubscribers()
Returns a list of subscriber.toString()
|
String |
getType()
Returns the class name of the stream object
|
cacheMBeanInfo, getAttribute, getAttributes, getCachedMBeanInfo, getClassName, getConstructors, getDescription, getDescription, getDescription, getDescription, getDescription, getDescription, getDescription, getImpact, getImplementation, getImplementationClass, getMBeanInfo, getMBeanInterface, getParameterName, getParameterName, invoke, postDeregister, postRegister, preDeregister, preRegister, setAttribute, setAttributes, setImplementationpublic String getName()
StreamControlgetName in interface StreamControlpublic long getNumEmittedTuples()
StreamControlgetNumEmittedTuples in interface StreamControlpublic String getType()
StreamControlgetType in interface StreamControlpublic String getSchema()
StreamControlgetSchema in interface StreamControlpublic int getSubscriberCount()
getSubscriberCount in interface StreamControlpublic List<String> getSubscribers()
StreamControlgetSubscribers in interface StreamControlCopyright © 2017 Space Applications Services. All rights reserved.