Modifier and Type | Method and Description |
---|---|
<L,R> SingleOutputStreamOperator<R> |
PatternStream.flatSelect(OutputTag<L> timedOutPartialMatchesTag,
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> timedOutPartialMatchesTag,
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> timedOutPartialMatchesTag,
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> timedOutPartialMatchesTag,
PatternTimeoutFunction<T,L> patternTimeoutFunction,
TypeInformation<R> outTypeInfo,
PatternSelectFunction<T,R> patternSelectFunction)
Applies a select function to the detected pattern sequence.
|
PatternStream<T> |
PatternStream.sideOutputLateData(OutputTag<T> lateDataOutputTag) |
Modifier and Type | Method and Description |
---|---|
<X> void |
PatternProcessFunction.Context.output(OutputTag<X> outputTag,
X value)
Emits a record to the side output identified by the
OutputTag . |
Constructor and Description |
---|
PatternTimeoutFlatSelectAdapter(PatternFlatSelectFunction<IN,OUT> flatSelectFunction,
PatternFlatTimeoutFunction<IN,T> flatTimeoutFunction,
OutputTag<T> timedOutPartialMatchesTag) |
PatternTimeoutSelectAdapter(PatternSelectFunction<IN,OUT> selectFunction,
PatternTimeoutFunction<IN,T> timeoutFunction,
OutputTag<T> timedOutPartialMatchesTag) |
Constructor and Description |
---|
CepOperator(TypeSerializer<IN> inputSerializer,
boolean isProcessingTime,
NFACompiler.NFAFactory<IN> nfaFactory,
EventComparator<IN> comparator,
AfterMatchSkipStrategy afterMatchSkipStrategy,
PatternProcessFunction<IN,OUT> function,
OutputTag<IN> lateDataOutputTag) |
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 . |
abstract <X> void |
KeyedProcessFunction.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 . |
abstract <X> void |
ProcessJoinFunction.Context.output(OutputTag<X> outputTag,
X value)
Emits a record to the side output identified by the
OutputTag . |
abstract <X> void |
KeyedCoProcessFunction.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) |
StreamEdge(StreamNode sourceVertex,
StreamNode targetVertex,
int typeNumber,
List<String> selectedNames,
StreamPartitioner<?> outputPartitioner,
OutputTag outputTag,
ShuffleMode shuffleMode) |
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(Transformation<?> input,
OutputTag<T> tag) |
Modifier and Type | Method and Description |
---|---|
<X> void |
RecordWriterOutput.collect(OutputTag<X> outputTag,
StreamRecord<X> record) |
Constructor and Description |
---|
RecordWriterOutput(RecordWriter<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–2020 The Apache Software Foundation. All rights reserved.