Package | Description |
---|---|
org.apache.flink.streaming.api.collector.selector | |
org.apache.flink.streaming.api.datastream | |
org.apache.flink.streaming.api.functions | |
org.apache.flink.streaming.api.graph | |
org.apache.flink.streaming.api.operators | |
org.apache.flink.streaming.api.scala | |
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.
|
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 . |
WindowedStream<T,K,W> |
WindowedStream.sideOutputLateData(OutputTag<T> outputTag)
Send late arriving data to the side output identified by the given
OutputTag . |
AllWindowedStream<T,W> |
AllWindowedStream.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 |
---|---|
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 the side output identified by the given
OutputTag . |
<X> void |
AbstractStreamOperator.CountingOutput.collect(OutputTag<X> outputTag,
StreamRecord<X> record) |
Modifier and Type | Class and Description |
---|---|
class |
OutputTag<T>
An
OutputTag is a typed and named tag to use for tagging side outputs
of an operator. |
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. |
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. |
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,
LegacyWindowOperatorType legacyWindowOperatorType)
Creates a new
WindowOperator based on the given policies and user functions. |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.