public class StreamControlImpl extends StandardMBean implements StreamControl
| Constructor and Description |
|---|
StreamControlImpl(Stream stream) |
| 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 StreamControlImpl(Stream stream) throws NotCompliantMBeanException
NotCompliantMBeanExceptionpublic 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 © 2018 Space Applications Services. All rights reserved.