Package | Description |
---|---|
org.apache.flink.cep | |
org.apache.flink.cep.operator | |
org.apache.flink.streaming.api.collector.selector | |
org.apache.flink.streaming.api.datastream | |
org.apache.flink.streaming.api.functions | |
org.apache.flink.streaming.api.functions.co | |
org.apache.flink.streaming.api.functions.windowing | |
org.apache.flink.streaming.api.graph | |
org.apache.flink.streaming.api.operators | |
org.apache.flink.streaming.api.transformations | |
org.apache.flink.streaming.runtime.io | |
org.apache.flink.streaming.runtime.operators.windowing |
This package contains the operators that implement the various window operations
on data streams.
|
org.apache.flink.streaming.runtime.operators.windowing.functions |
Modifier and Type | Method and Description |
---|---|
<L,R> SingleOutputStreamOperator<R> |
PatternStream.flatSelect(OutputTag<L> timeoutOutputTag,
PatternFlatTimeoutFunction<T,L> patternFlatTimeoutFunction,
PatternFlatSelectFunction<T,R> patternFlatSelectFunction)
Applies a flat select function to the detected pattern sequence.
|
<L,R> SingleOutputStreamOperator<R> |
PatternStream.flatSelect(OutputTag<L> timeoutOutputTag,
PatternFlatTimeoutFunction<T,L> patternFlatTimeoutFunction,
TypeInformation<R> outTypeInfo,
PatternFlatSelectFunction<T,R> patternFlatSelectFunction)
Applies a flat select function to the detected pattern sequence.
|
<L,R> SingleOutputStreamOperator<R> |
PatternStream.select(OutputTag<L> timeoutOutputTag,
PatternTimeoutFunction<T,L> patternTimeoutFunction,
PatternSelectFunction<T,R> patternSelectFunction)
Applies a select function to the detected pattern sequence.
|
<L,R> SingleOutputStreamOperator<R> |
PatternStream.select(OutputTag<L> timeoutOutputTag,
PatternTimeoutFunction<T,L> patternTimeoutFunction,
TypeInformation<R> outTypeInfo,
PatternSelectFunction<T,R> patternSelectFunction)
Applies a select function to the detected pattern sequence.
|
Modifier and Type | Method and Description |
---|---|
static <IN,OUT1,OUT2> |
CEPOperatorUtils.createTimeoutPatternStream(DataStream<IN> inputStream,
Pattern<IN,?> pattern,
EventComparator<IN> comparator,
PatternFlatSelectFunction<IN,OUT1> selectFunction,
TypeInformation<OUT1> outTypeInfo,
OutputTag<OUT2> outputTag,
PatternFlatTimeoutFunction<IN,OUT2> timeoutFunction)
Creates a data stream containing results of
PatternFlatSelectFunction to fully matching event patterns and
also timed out partially matched with applied PatternFlatTimeoutFunction as a sideoutput. |
static <IN,OUT1,OUT2> |
CEPOperatorUtils.createTimeoutPatternStream(DataStream<IN> inputStream,
Pattern<IN,?> pattern,
EventComparator<IN> comparator,
PatternSelectFunction<IN,OUT1> selectFunction,
TypeInformation<OUT1> outTypeInfo,
OutputTag<OUT2> outputTag,
PatternTimeoutFunction<IN,OUT2> timeoutFunction)
Creates a data stream containing results of
PatternSelectFunction to fully matching event patterns and
also timed out partially matched with applied PatternTimeoutFunction as a sideoutput. |
Constructor and Description |
---|
FlatSelectTimeoutCepOperator(TypeSerializer<IN> inputSerializer,
boolean isProcessingTime,
NFACompiler.NFAFactory<IN> nfaFactory,
EventComparator<IN> comparator,
AfterMatchSkipStrategy skipStrategy,
PatternFlatSelectFunction<IN,OUT1> flatSelectFunction,
PatternFlatTimeoutFunction<IN,OUT2> flatTimeoutFunction,
OutputTag<OUT2> outputTag) |
SelectTimeoutCepOperator(TypeSerializer<IN> inputSerializer,
boolean isProcessingTime,
NFACompiler.NFAFactory<IN> nfaFactory,
EventComparator<IN> comparator,
AfterMatchSkipStrategy skipStrategy,
PatternSelectFunction<IN,OUT1> flatSelectFunction,
PatternTimeoutFunction<IN,OUT2> flatTimeoutFunction,
OutputTag<OUT2> outputTag) |
TimestampedSideOutputCollector(OutputTag<T> outputTag,
Output<?> output)
Creates a new
TimestampedSideOutputCollector that wraps the given Output and collects
results into sideoutput corresponding to OutputTag . |
Modifier and Type | Method and Description |
---|---|
<X> void |
DirectedOutput.collect(OutputTag<X> outputTag,
StreamRecord<X> record) |
Modifier and Type | Method and Description |
---|---|
<X> DataStream<X> |
SingleOutputStreamOperator.getSideOutput(OutputTag<X> sideOutputTag)
Gets the
DataStream that contains the elements that are emitted from an operation
into the side output with the given OutputTag . |
AllWindowedStream<T,W> |
AllWindowedStream.sideOutputLateData(OutputTag<T> outputTag)
Send late arriving data to the side output identified by the given
OutputTag . |
WindowedStream<T,K,W> |
WindowedStream.sideOutputLateData(OutputTag<T> outputTag)
Send late arriving data to the side output identified by the given
OutputTag . |
Modifier and Type | Method and Description |
---|---|
abstract <X> void |
ProcessFunction.Context.output(OutputTag<X> outputTag,
X value)
Emits a record to the side output identified by the
OutputTag . |
Modifier and Type | Method and Description |
---|---|
abstract <X> void |
CoProcessFunction.Context.output(OutputTag<X> outputTag,
X value)
Emits a record to the side output identified by the
OutputTag . |
Modifier and Type | Method and Description |
---|---|
<X> void |
InternalProcessApplyWindowContext.output(OutputTag<X> outputTag,
X value) |
abstract <X> void |
ProcessAllWindowFunction.Context.output(OutputTag<X> outputTag,
X value)
Emits a record to the side output identified by the
OutputTag . |
abstract <X> void |
ProcessWindowFunction.Context.output(OutputTag<X> outputTag,
X value)
Emits a record to the side output identified by the
OutputTag . |
<X> void |
InternalProcessApplyAllWindowContext.output(OutputTag<X> outputTag,
X value) |
Modifier and Type | Method and Description |
---|---|
OutputTag |
StreamEdge.getOutputTag() |
Modifier and Type | Method and Description |
---|---|
void |
StreamGraph.addVirtualSideOutputNode(Integer originalId,
Integer virtualId,
OutputTag outputTag)
Adds a new virtual node that is used to connect a downstream vertex to only the outputs with
the selected side-output
OutputTag . |
<T> TypeSerializer<T> |
StreamConfig.getTypeSerializerSideOut(OutputTag<?> outputTag,
ClassLoader cl) |
void |
StreamConfig.setTypeSerializerSideOut(OutputTag<?> outputTag,
TypeSerializer<?> serializer) |
Constructor and Description |
---|
StreamEdge(StreamNode sourceVertex,
StreamNode targetVertex,
int typeNumber,
List<String> selectedNames,
StreamPartitioner<?> outputPartitioner,
OutputTag outputTag) |
Modifier and Type | Method and Description |
---|---|
<X> void |
Output.collect(OutputTag<X> outputTag,
StreamRecord<X> record)
Emits a record the side output identified by the given
OutputTag . |
<X> void |
AbstractStreamOperator.CountingOutput.collect(OutputTag<X> outputTag,
StreamRecord<X> record) |
Modifier and Type | Method and Description |
---|---|
OutputTag<T> |
SideOutputTransformation.getOutputTag() |
Constructor and Description |
---|
SideOutputTransformation(StreamTransformation<?> input,
OutputTag<T> tag) |
Modifier and Type | Method and Description |
---|---|
<X> void |
RecordWriterOutput.collect(OutputTag<X> outputTag,
StreamRecord<X> record) |
Constructor and Description |
---|
RecordWriterOutput(StreamRecordWriter<SerializationDelegate<StreamRecord<OUT>>> recordWriter,
TypeSerializer<OUT> outSerializer,
OutputTag outputTag,
StreamStatusProvider streamStatusProvider) |
Modifier and Type | Field and Description |
---|---|
protected OutputTag<IN> |
WindowOperator.lateDataOutputTag
OutputTag to use for late arriving events. |
Modifier and Type | Method and Description |
---|---|
<X> void |
WindowOperator.WindowContext.output(OutputTag<X> outputTag,
X value) |
Constructor and Description |
---|
EvictingWindowOperator(WindowAssigner<? super IN,W> windowAssigner,
TypeSerializer<W> windowSerializer,
KeySelector<IN,K> keySelector,
TypeSerializer<K> keySerializer,
StateDescriptor<? extends ListState<StreamRecord<IN>>,?> windowStateDescriptor,
InternalWindowFunction<Iterable<IN>,OUT,K,W> windowFunction,
Trigger<? super IN,? super W> trigger,
Evictor<? super IN,? super W> evictor,
long allowedLateness,
OutputTag<IN> lateDataOutputTag) |
WindowOperator(WindowAssigner<? super IN,W> windowAssigner,
TypeSerializer<W> windowSerializer,
KeySelector<IN,K> keySelector,
TypeSerializer<K> keySerializer,
StateDescriptor<? extends AppendingState<IN,ACC>,?> windowStateDescriptor,
InternalWindowFunction<ACC,OUT,K,W> windowFunction,
Trigger<? super IN,? super W> trigger,
long allowedLateness,
OutputTag<IN> lateDataOutputTag)
Creates a new
WindowOperator based on the given policies and user functions. |
Modifier and Type | Method and Description |
---|---|
<X> void |
InternalWindowFunction.InternalWindowContext.output(OutputTag<X> outputTag,
X value) |
<X> void |
InternalProcessWindowContext.output(OutputTag<X> outputTag,
X value) |
<X> void |
InternalProcessAllWindowContext.output(OutputTag<X> outputTag,
X value) |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.