JavaScript is disabled on your browser.
java.lang.Object
org.apache.flink.streaming.api.operators.AbstractStreamOperator<java.lang.Void>
org.apache.flink.statefun.flink.core.feedback.FeedbackSinkOperator<V>
Nested Class Summary
Nested classes/interfaces inherited from class org.apache.flink.streaming.api.operators.AbstractStreamOperator
org.apache.flink.streaming.api.operators.AbstractStreamOperator.CountingOutput<OUT>
Field Summary
Fields inherited from class org.apache.flink.streaming.api.operators.AbstractStreamOperator
chainingStrategy, config, latencyStats, LOG, metrics, output, timeServiceManager
Method Summary
Methods inherited from class org.apache.flink.streaming.api.operators.AbstractStreamOperator
getChainingStrategy, getContainingTask, getCurrentKey, getExecutionConfig, getInternalTimerService, getKeyedStateBackend, getKeyedStateStore, getMetricGroup, getOperatorConfig, getOperatorID, getOperatorName, getOperatorStateBackend, getOrCreateKeyedState, getPartitionedState, getPartitionedState, getProcessingTimeService, getRuntimeContext, getUserCodeClassloader, initializeState, initializeState, notifyCheckpointComplete, numEventTimeTimers, numProcessingTimeTimers, processLatencyMarker, processLatencyMarker1, processLatencyMarker2, processWatermark, processWatermark1, processWatermark2, reportOrForwardLatencyMarker, setChainingStrategy, setCurrentKey, setKeyContextElement1, setKeyContextElement2, setup, snapshotState, snapshotState
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.streaming.api.operators.OneInputStreamOperator
processLatencyMarker, processWatermark
Methods inherited from interface org.apache.flink.streaming.api.operators.StreamOperator
getChainingStrategy, getMetricGroup, getOperatorID, initializeState, setChainingStrategy, setKeyContextElement1, setKeyContextElement2, snapshotState
Methods inherited from interface org.apache.flink.runtime.state.CheckpointListener
notifyCheckpointComplete
Methods inherited from interface org.apache.flink.streaming.api.operators.KeyContext
getCurrentKey, setCurrentKey
Copyright © 2014–2020 The Apache Software Foundation . All rights reserved.