Skip to content

Commit

Permalink
[minor] Add Javadocs to CEP PatternStream
Browse files Browse the repository at this point in the history
  • Loading branch information
aljoscha committed Oct 26, 2020
1 parent 1fe0214 commit fb0532f
Showing 1 changed file with 14 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -64,14 +64,28 @@ PatternStream<T> withComparator(final EventComparator<T> comparator) {
return new PatternStream<>(builder.withComparator(comparator));
}

/**
* Send late arriving data to the side output identified by the given {@link OutputTag}. A record
* is considered late after the watermark has passed its timestamp.
*
* <p>You can get the stream of late data using
* {@link SingleOutputStreamOperator#getSideOutput(OutputTag)} on the
* {@link SingleOutputStreamOperator} resulting from the pattern processing operations.
*/
public PatternStream<T> sideOutputLateData(OutputTag<T> lateDataOutputTag) {
return new PatternStream<>(builder.withLateDataOutputTag(lateDataOutputTag));
}

/**
* Sets the time characteristic to processing time.
*/
public PatternStream<T> inProcessingTime() {
return new PatternStream<>(builder.inProcessingTime());
}

/**
* Sets the time characteristic to event time.
*/
public PatternStream<T> inEventTime() {
return new PatternStream<>(builder.inEventTime());
}
Expand Down

0 comments on commit fb0532f

Please sign in to comment.