Class Stream

Direct Known Subclasses:
HistogramReaderStream, InternalStream, LimitedStream, MergeStream, OutputStream, SelectStream, TableReaderStream

public abstract class Stream extends Object
Streams are means to transport tuples.
  • Field Details

  • Constructor Details

  • Method Details

    • doStart

      public abstract void doStart()
      Start emitting tuples.
    • getDefinition

      public TupleDefinition getDefinition()
    • emitTuple

      public void emitTuple(Tuple tuple)
    • getName

      public String getName()
    • setName

      public void setName(String streamName)
    • addSubscriber

      public void addSubscriber(StreamSubscriber s)
    • removeSubscriber

      public void removeSubscriber(StreamSubscriber s)
    • getColumnDefinition

      public ColumnDefinition getColumnDefinition(String colName)
    • start

      public final void start()
      Start the stream by changing the state and calling doStart()

      If the stream is already started, do nothing.

    • isRunning

      protected boolean isRunning()
    • quitting

      protected boolean quitting()
    • close

      public final void close()
      Closes the stream by changing the state, calling doClose() sand then sending the streamClosed signal to all subscribed clients.

      if the stream is already closed, do nothing.

    • doClose

      protected abstract void doClose()
    • getState

      public int getState()
    • isClosed

      public boolean isClosed()
    • getDataCount

      public long getDataCount()
    • getSubscriberCount

      public int getSubscriberCount()
    • getSubscribers

      public Collection<StreamSubscriber> getSubscribers()
    • exceptionHandler

      public void exceptionHandler(Stream.ExceptionHandler h)
    • toString

      public String toString()
      toString in class Object