public class BroadcastVariableReceiverOperator<OUT> extends org.apache.flink.streaming.api.operators.AbstractStreamOperatorV2<OUT> implements org.apache.flink.streaming.api.operators.MultipleInputStreamOperator<OUT>, org.apache.flink.streaming.api.operators.BoundedMultiInput, Serializable
BroadcastContext
.Modifier and Type | Method and Description |
---|---|
void |
endInput(int i) |
List<org.apache.flink.streaming.api.operators.Input> |
getInputs() |
void |
initializeState(org.apache.flink.runtime.state.StateInitializationContext context) |
void |
snapshotState(org.apache.flink.runtime.state.StateSnapshotContext context) |
close, finish, getCurrentKey, getExecutionConfig, getInternalTimerService, getKeyedStateBackend, getKeyedStateStore, getMetricGroup, getOperatorConfig, getOperatorID, getOperatorName, getOperatorStateBackend, getOrCreateKeyedState, getPartitionedState, getPartitionedState, getProcessingTimeService, getRuntimeContext, getTimeServiceManager, getUserCodeClassloader, initializeState, internalSetKeyContextElement, isUsingCustomRawKeyedState, notifyCheckpointAborted, notifyCheckpointComplete, open, prepareSnapshotPreBarrier, processWatermark, processWatermarkStatus, reportOrForwardLatencyMarker, reportWatermark, setCurrentKey, setKeyContextElement1, setKeyContextElement2, snapshotState
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
close, finish, getMetricGroup, getOperatorID, initializeState, open, prepareSnapshotPreBarrier, setKeyContextElement1, setKeyContextElement2, snapshotState
public List<org.apache.flink.streaming.api.operators.Input> getInputs()
getInputs
in interface org.apache.flink.streaming.api.operators.MultipleInputStreamOperator<OUT>
public void endInput(int i) throws Exception
endInput
in interface org.apache.flink.streaming.api.operators.BoundedMultiInput
Exception
public void snapshotState(org.apache.flink.runtime.state.StateSnapshotContext context) throws Exception
public void initializeState(org.apache.flink.runtime.state.StateInitializationContext context) throws Exception
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.