org.apache.flink.cep.operator

Class TimestampedSideOutputCollector<T>

java.lang.Object

org.apache.flink.cep.operator.TimestampedSideOutputCollector<T>

Type Parameters:

T - The type of the elements that can be emitted.

All Implemented Interfaces:

Collector<T>

@Internal
public class TimestampedSideOutputCollector<T>
extends Object
implements Collector<T>

Wrapper around an Output for user functions that expect a Collector. Before giving the TimestampedSideOutputCollector to a user function you must set the timestamp that should be attached to emitted elements. Most operators would set the timestamp of the incoming StreamRecord here.

This version emits results into a SideOutput specified by given OutputTag

Constructor Summary

Constructors

Constructor and Description
TimestampedSideOutputCollector(OutputTag<T> outputTag, Output<?> output) Creates a new TimestampedSideOutputCollector that wraps the given Output and collects results into sideoutput corresponding to OutputTag.

Method Summary

Modifier and Type	Method and Description
void	close() Closes the collector.
void	collect(T record) Emits a record.
void	eraseTimestamp()
void	setAbsoluteTimestamp(long timestamp)
void	setTimestamp(StreamRecord<?> timestampBase)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TimestampedSideOutputCollector

public TimestampedSideOutputCollector(OutputTag<T> outputTag,
                                      Output<?> output)

Creates a new TimestampedSideOutputCollector that wraps the given Output and collects results into sideoutput corresponding to OutputTag.

Method Detail

collect

public void collect(T record)

Description copied from interface: Collector

Emits a record.

Specified by:

collect in interface Collector<T>

Parameters:

record - The record to collect.

setTimestamp

public void setTimestamp(StreamRecord<?> timestampBase)

setAbsoluteTimestamp

public void setAbsoluteTimestamp(long timestamp)

eraseTimestamp

public void eraseTimestamp()

close

public void close()

Description copied from interface: Collector

Closes the collector. If any data was buffered, that data will be flushed.

Specified by:

close in interface Collector<T>