public class FunctionGroupOperator extends org.apache.flink.streaming.api.operators.AbstractStreamOperator<Message> implements org.apache.flink.streaming.api.operators.OneInputStreamOperator<Message,Message>
Modifier and Type | Method and Description |
---|---|
void |
initializeState(org.apache.flink.runtime.state.StateInitializationContext context) |
void |
processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<Message> record) |
void |
snapshotState(org.apache.flink.runtime.state.StateSnapshotContext context) |
close, dispose, getChainingStrategy, getContainingTask, getCurrentKey, getExecutionConfig, getInternalTimerService, getKeyedStateBackend, getKeyedStateStore, getMetricGroup, getOperatorConfig, getOperatorID, getOperatorName, getOperatorStateBackend, getOrCreateKeyedState, getPartitionedState, getPartitionedState, getProcessingTimeService, getRuntimeContext, getUserCodeClassloader, initializeState, notifyCheckpointComplete, numEventTimeTimers, numProcessingTimeTimers, open, prepareSnapshotPreBarrier, processLatencyMarker, processLatencyMarker1, processLatencyMarker2, processWatermark, processWatermark1, processWatermark2, reportOrForwardLatencyMarker, setChainingStrategy, setCurrentKey, setKeyContextElement1, setKeyContextElement2, setup, snapshotState
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
processLatencyMarker, processWatermark
close, dispose, getChainingStrategy, getMetricGroup, getOperatorID, initializeState, open, prepareSnapshotPreBarrier, setChainingStrategy, setKeyContextElement1, setKeyContextElement2, snapshotState
public void processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<Message> record) throws java.lang.InterruptedException
public void initializeState(org.apache.flink.runtime.state.StateInitializationContext context) throws java.lang.Exception
initializeState
in class org.apache.flink.streaming.api.operators.AbstractStreamOperator<Message>
java.lang.Exception
public void snapshotState(org.apache.flink.runtime.state.StateSnapshotContext context) throws java.lang.Exception
snapshotState
in class org.apache.flink.streaming.api.operators.AbstractStreamOperator<Message>
java.lang.Exception
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.