Interface JoinExecutionStrategy

All Known Implementing Classes:
JoinExecutionStrategyImpl

public interface JoinExecutionStrategy
Strategy for executing a join.
  • Method Details

    • join

      void join(EventBean[][] newDataPerStream, EventBean[][] oldDataPerStream)
      Execute join. The first dimension in the 2-dim arrays is the stream that generated the events, and the second dimension is the actual events generated.
      Parameters:
      newDataPerStream - - new events for each stream
      oldDataPerStream - - old events for each stream
    • staticJoin

      A static join is for use with iterating over join statements.
      Returns:
      set of rows, each row with two or more events, one for each stream