Package com.espertech.esper.common.client.soda

Class ProjectedStream

java.lang.Object
com.espertech.esper.common.client.soda.Stream
com.espertech.esper.common.client.soda.ProjectedStream
All Implemented Interfaces:
Serializable
Direct Known Subclasses:
FilterStream, PatternStream
public abstract class ProjectedStream extends Stream
Abstract base class for streams that can be projected via views providing data window, uniqueness or other projections or deriving further information from streams.
See Also:

  • Constructor Details

    • ProjectedStream

      public ProjectedStream()
      Ctor.

    • ProjectedStream

      protected ProjectedStream(List<View> views, String optStreamName)
      Ctor.
      Parameters:
      views - is a list of views upon the stream
      optStreamName - is the stream as-name, or null if unnamed

  • Method Details

    • toEPLProjectedStream

      public abstract void toEPLProjectedStream(StringWriter writer, EPStatementFormatter formatter)
      Represent as textual.
      Parameters:
      writer - to output to
      formatter - for newline-whitespace formatting

    • toEPLProjectedStreamType

      public abstract void toEPLProjectedStreamType(StringWriter writer)
      Represent type as textual non complete.
      Parameters:
      writer - to output to

    • addView

      public ProjectedStream addView(String namespace, String name)
      Adds an un-parameterized view to the stream.
      Parameters:
      namespace - is the view namespace, for example "win" for most data windows
      name - is the view name, for example "length" for a length window
      Returns:
      stream

    • addView

      public ProjectedStream addView(String namespace, String name, List<Expression> parameters)
      Adds a parameterized view to the stream.
      Parameters:
      namespace - is the view namespace, for example "win" for most data windows
      name - is the view name, for example "length" for a length window
      parameters - is a list of view parameters
      Returns:
      stream

    • addView

      public ProjectedStream addView(String namespace, String name, Expression... parameters)
      Adds a parameterized view to the stream.
      Parameters:
      namespace - is the view namespace, for example "win" for most data windows
      name - is the view name, for example "length" for a length window
      parameters - is a list of view parameters
      Returns:
      stream

    • addView

      public ProjectedStream addView(String name, Expression... parameters)
      Adds a parameterized view to the stream.
      Parameters:
      name - is the view name, for example "length" for a length window
      parameters - is a list of view parameters
      Returns:
      stream

    • addView

      public ProjectedStream addView(View view)
      Add a view to the stream.
      Parameters:
      view - to add
      Returns:
      stream

    • getViews

      public List<View> getViews()
      Returns the list of views added to the stream.
      Returns:
      list of views

    • setViews

      public void setViews(List<View> views)
      Sets the list of views onto the stream.
      Parameters:
      views - list of views

    • toEPLStream

      public void toEPLStream(StringWriter writer, EPStatementFormatter formatter)
      Renders the clause in textual representation.
      Specified by:
      toEPLStream in class Stream
      Parameters:
      writer - to output to
      formatter - for newline-whitespace formatting

    • toEPLStreamType

      public void toEPLStreamType(StringWriter writer)
      Description copied from class: Stream
      Renders the stream type under a non-complete textual representation for tool use
      Specified by:
      toEPLStreamType in class Stream
      Parameters:
      writer - to output to

    • isUnidirectional

      public boolean isUnidirectional()
      Returns true if the stream as unidirectional, for use in unidirectional joins.
      Returns:
      true for unidirectional stream, applicable only for joins

    • setUnidirectional

      public void setUnidirectional(boolean isUnidirectional)
      Set to true to indicate that a stream is unidirectional, for use in unidirectional joins.
      Parameters:
      isUnidirectional - true for unidirectional stream, applicable only for joins

    • unidirectional

      public ProjectedStream unidirectional(boolean isUnidirectional)
      Set to unidirectional.
      Parameters:
      isUnidirectional - try if unidirectional
      Returns:
      stream

    • isRetainUnion

      public boolean isRetainUnion()
      Returns true if multiple data window shall be treated as a union.
      Returns:
      retain union

    • setRetainUnion

      public void setRetainUnion(boolean retainUnion)
      Set to true to have multiple data window be treated as a union.
      Parameters:
      retainUnion - indicator to union

    • isRetainIntersection

      public boolean isRetainIntersection()
      Returns true if multiple data window shall be treated as an intersection.
      Returns:
      retain intersection

    • setRetainIntersection

      public void setRetainIntersection(boolean retainIntersection)
      Set to true to have multiple data window be treated as a intersection.
      Parameters:
      retainIntersection - indicator to intersection

    • toEPLViews

      protected static void toEPLViews(StringWriter writer, List<View> views)
      Renders the views onto the projected stream.
      Parameters:
      writer - to render to
      views - to render

    • toEPLStreamOptions

      public void toEPLStreamOptions(StringWriter writer)
      Description copied from class: Stream
      Renders the stream in textual representation any stream options, if present.
      Specified by:
      toEPLStreamOptions in class Stream
      Parameters:
      writer - to output to