Interface StreamControl

    • Method Detail

      • getName

        String getName()
        Returns the stream name
      • getType

        String getType()
        Returns the class name of the stream object
      • getSchema

        String getSchema()
        Returns the tuple definition
      • getNumEmittedTuples

        long getNumEmittedTuples()
        Returns the number of tuples that have transited through the stream
      • getSubscriberCount

        int getSubscriberCount()
      • getSubscribers

        List<String> getSubscribers()
        Returns a list of subscriber.toString()