Class ProcessOperator<IN,OUT>
- java.lang.Object
-
- org.apache.flink.streaming.api.operators.AbstractStreamOperator<OUT>
-
- org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator<OUT,OneInputStreamProcessFunction<IN,OUT>>
-
- org.apache.flink.datastream.impl.operators.ProcessOperator<IN,OUT>
-
- All Implemented Interfaces:
Serializable
,CheckpointListener
,BoundedOneInput
,Input<IN>
,KeyContext
,KeyContextHandler
,OneInputStreamOperator<IN,OUT>
,OutputTypeConfigurable<OUT>
,StreamOperator<OUT>
,StreamOperatorStateHandler.CheckpointedStreamOperator
,UserFunctionProvider<OneInputStreamProcessFunction<IN,OUT>>
,YieldingOperator<OUT>
- Direct Known Subclasses:
KeyedProcessOperator
public class ProcessOperator<IN,OUT> extends AbstractUdfStreamOperator<OUT,OneInputStreamProcessFunction<IN,OUT>> implements OneInputStreamOperator<IN,OUT>, BoundedOneInput
Operator forOneInputStreamProcessFunction
.- See Also:
- Serialized Form
-
-
Field Summary
Fields Modifier and Type Field Description protected DefaultRuntimeContext
context
protected NonPartitionedContext<OUT>
nonPartitionedContext
protected TimestampCollector<OUT>
outputCollector
protected DefaultPartitionedContext
partitionedContext
-
Fields inherited from class org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator
userFunction
-
Fields inherited from class org.apache.flink.streaming.api.operators.AbstractStreamOperator
config, lastRecordAttributes1, lastRecordAttributes2, latencyStats, LOG, metrics, output, processingTimeService, stateHandler, stateKeySelector1, stateKeySelector2, timeServiceManager
-
-
Constructor Summary
Constructors Constructor Description ProcessOperator(OneInputStreamProcessFunction<IN,OUT> userFunction)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected Object
currentKey()
void
endInput()
It is notified that no more data will arrive from the input.protected NonPartitionedContext<OUT>
getNonPartitionedContext()
protected TimestampCollector<OUT>
getOutputCollector()
protected ProcessingTimeManager
getProcessingTimeManager()
void
open()
This method is called immediately before any elements are processed, it should contain the operator's initialization logic, e.g. state initialization.void
processElement(StreamRecord<IN> element)
Processes one element that arrived on this input of theMultipleInputStreamOperator
.-
Methods inherited from class org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator
close, finish, getUserFunction, getUserFunctionParameters, initializeState, notifyCheckpointAborted, notifyCheckpointComplete, setOutputType, setup, snapshotState
-
Methods inherited from class org.apache.flink.streaming.api.operators.AbstractStreamOperator
getContainingTask, getCurrentKey, getExecutionConfig, getInternalTimerService, getKeyedStateBackend, getKeyedStateStore, getMetricGroup, getOperatorConfig, getOperatorID, getOperatorName, getOperatorStateBackend, getOrCreateKeyedState, getPartitionedState, getPartitionedState, getProcessingTimeService, getRuntimeContext, getStateKeySelector1, getStateKeySelector2, getTimeServiceManager, getUserCodeClassloader, hasKeyContext1, hasKeyContext2, initializeState, isUsingCustomRawKeyedState, prepareSnapshotPreBarrier, processLatencyMarker, processLatencyMarker1, processLatencyMarker2, processRecordAttributes, processRecordAttributes1, processRecordAttributes2, processWatermark, processWatermark1, processWatermark2, processWatermarkStatus, processWatermarkStatus1, processWatermarkStatus2, reportOrForwardLatencyMarker, setCurrentKey, setKeyContextElement1, setKeyContextElement2, setMailboxExecutor, setProcessingTimeService, snapshotState, useSplittableTimers
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface org.apache.flink.api.common.state.CheckpointListener
notifyCheckpointAborted, notifyCheckpointComplete
-
Methods inherited from interface org.apache.flink.streaming.api.operators.Input
processLatencyMarker, processRecordAttributes, processWatermark, processWatermarkStatus
-
Methods inherited from interface org.apache.flink.streaming.api.operators.KeyContext
getCurrentKey, setCurrentKey
-
Methods inherited from interface org.apache.flink.streaming.api.operators.KeyContextHandler
hasKeyContext
-
Methods inherited from interface org.apache.flink.streaming.api.operators.OneInputStreamOperator
setKeyContextElement
-
Methods inherited from interface org.apache.flink.streaming.api.operators.StreamOperator
close, finish, getMetricGroup, getOperatorAttributes, getOperatorID, initializeState, prepareSnapshotPreBarrier, setKeyContextElement1, setKeyContextElement2, snapshotState
-
-
-
-
Field Detail
-
context
protected transient DefaultRuntimeContext context
-
partitionedContext
protected transient DefaultPartitionedContext partitionedContext
-
nonPartitionedContext
protected transient NonPartitionedContext<OUT> nonPartitionedContext
-
outputCollector
protected transient TimestampCollector<OUT> outputCollector
-
-
Constructor Detail
-
ProcessOperator
public ProcessOperator(OneInputStreamProcessFunction<IN,OUT> userFunction)
-
-
Method Detail
-
open
public void open() throws Exception
Description copied from class:AbstractStreamOperator
This method is called immediately before any elements are processed, it should contain the operator's initialization logic, e.g. state initialization.The default implementation does nothing.
- Specified by:
open
in interfaceStreamOperator<IN>
- Overrides:
open
in classAbstractUdfStreamOperator<OUT,OneInputStreamProcessFunction<IN,OUT>>
- Throws:
Exception
- An exception in this method causes the operator to fail.
-
processElement
public void processElement(StreamRecord<IN> element) throws Exception
Description copied from interface:Input
Processes one element that arrived on this input of theMultipleInputStreamOperator
. This method is guaranteed to not be called concurrently with other methods of the operator.- Specified by:
processElement
in interfaceInput<IN>
- Throws:
Exception
-
getOutputCollector
protected TimestampCollector<OUT> getOutputCollector()
-
endInput
public void endInput() throws Exception
Description copied from interface:BoundedOneInput
It is notified that no more data will arrive from the input.WARNING: It is not safe to use this method to commit any transactions or other side effects! You can use this method to flush any buffered data that can later on be committed e.g. in a
CheckpointListener.notifyCheckpointComplete(long)
.NOTE: Given it is semantically very similar to the
StreamOperator.finish()
method. It might be dropped in favour of the other method at some point in time.- Specified by:
endInput
in interfaceBoundedOneInput
- Throws:
Exception
-
currentKey
protected Object currentKey()
-
getProcessingTimeManager
protected ProcessingTimeManager getProcessingTimeManager()
-
getNonPartitionedContext
protected NonPartitionedContext<OUT> getNonPartitionedContext()
-
-