org.apache.flink.datastream.impl.operators

类 KeyedTwoInputBroadcastProcessOperator<KEY,IN1,IN2,OUT>

java.lang.Object

org.apache.flink.streaming.api.operators.AbstractStreamOperator<OUT>

org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator<OUT,org.apache.flink.datastream.api.function.TwoInputBroadcastStreamProcessFunction<IN1,IN2,OUT>>

org.apache.flink.datastream.impl.operators.TwoInputBroadcastProcessOperator<IN1,IN2,OUT>

org.apache.flink.datastream.impl.operators.KeyedTwoInputBroadcastProcessOperator<KEY,IN1,IN2,OUT>

所有已实现的接口:

Serializable, org.apache.flink.api.common.state.CheckpointListener, org.apache.flink.streaming.api.operators.BoundedMultiInput, org.apache.flink.streaming.api.operators.KeyContext, org.apache.flink.streaming.api.operators.KeyContextHandler, org.apache.flink.streaming.api.operators.OutputTypeConfigurable<OUT>, org.apache.flink.streaming.api.operators.SetupableStreamOperator<OUT>, org.apache.flink.streaming.api.operators.StreamOperator<OUT>, org.apache.flink.streaming.api.operators.StreamOperatorStateHandler.CheckpointedStreamOperator, org.apache.flink.streaming.api.operators.Triggerable<KEY,org.apache.flink.runtime.state.VoidNamespace>, org.apache.flink.streaming.api.operators.TwoInputStreamOperator<IN1,IN2,OUT>, org.apache.flink.streaming.api.operators.UserFunctionProvider<org.apache.flink.datastream.api.function.TwoInputBroadcastStreamProcessFunction<IN1,IN2,OUT>>, org.apache.flink.streaming.api.operators.YieldingOperator<OUT>

public class KeyedTwoInputBroadcastProcessOperator<KEY,IN1,IN2,OUT>
extends TwoInputBroadcastProcessOperator<IN1,IN2,OUT>
implements org.apache.flink.streaming.api.operators.Triggerable<KEY,org.apache.flink.runtime.state.VoidNamespace>

Operator for TwoInputBroadcastStreamProcessFunction in KeyedPartitionStream.

另请参阅:

序列化表格

字段概要

从类继承的字段 org.apache.flink.datastream.impl.operators.TwoInputBroadcastProcessOperator

collector, context, nonPartitionedContext, partitionedContext

从类继承的字段 org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator

userFunction

从类继承的字段 org.apache.flink.streaming.api.operators.AbstractStreamOperator

chainingStrategy, config, lastRecordAttributes1, lastRecordAttributes2, latencyStats, LOG, metrics, output, processingTimeService, stateHandler, stateKeySelector1, stateKeySelector2, timeServiceManager

构造器概要

构造器

构造器和说明
KeyedTwoInputBroadcastProcessOperator(org.apache.flink.datastream.api.function.TwoInputBroadcastStreamProcessFunction<IN1,IN2,OUT> userFunction)
KeyedTwoInputBroadcastProcessOperator(org.apache.flink.datastream.api.function.TwoInputBroadcastStreamProcessFunction<IN1,IN2,OUT> userFunction, org.apache.flink.api.java.functions.KeySelector<OUT,KEY> outKeySelector)

方法概要

限定符和类型	方法和说明
protected Object	currentKey()
protected org.apache.flink.datastream.api.context.NonPartitionedContext<OUT>	getNonPartitionedContext()
protected TimestampCollector<OUT>	getOutputCollector()
protected org.apache.flink.datastream.api.context.ProcessingTimeManager	getProcessingTimeManager()
void	onEventTime(org.apache.flink.streaming.api.operators.InternalTimer<KEY,org.apache.flink.runtime.state.VoidNamespace> timer)
void	onProcessingTime(org.apache.flink.streaming.api.operators.InternalTimer<KEY,org.apache.flink.runtime.state.VoidNamespace> timer)
void	open()
void	setKeyContextElement1(org.apache.flink.streaming.runtime.streamrecord.StreamRecord record)

从类继承的方法 org.apache.flink.datastream.impl.operators.TwoInputBroadcastProcessOperator

endInput, processElement1, processElement2

从类继承的方法 org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator

close, finish, getUserFunction, getUserFunctionParameters, initializeState, notifyCheckpointAborted, notifyCheckpointComplete, setOutputType, setup, snapshotState

从类继承的方法 org.apache.flink.streaming.api.operators.AbstractStreamOperator

getChainingStrategy, 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, setChainingStrategy, setCurrentKey, setKeyContextElement2, setMailboxExecutor, setProcessingTimeService, snapshotState, useSplittableTimers

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

从接口继承的方法 org.apache.flink.streaming.api.operators.TwoInputStreamOperator

processLatencyMarker1, processLatencyMarker2, processRecordAttributes1, processRecordAttributes2, processWatermark1, processWatermark2, processWatermarkStatus1, processWatermarkStatus2

从接口继承的方法 org.apache.flink.streaming.api.operators.StreamOperator

close, finish, getMetricGroup, getOperatorAttributes, getOperatorID, initializeState, prepareSnapshotPreBarrier, setKeyContextElement2, snapshotState

从接口继承的方法 org.apache.flink.api.common.state.CheckpointListener

notifyCheckpointAborted, notifyCheckpointComplete

从接口继承的方法 org.apache.flink.streaming.api.operators.KeyContext

getCurrentKey, setCurrentKey

从接口继承的方法 org.apache.flink.streaming.api.operators.KeyContextHandler

hasKeyContext

构造器详细资料

KeyedTwoInputBroadcastProcessOperator

public KeyedTwoInputBroadcastProcessOperator(org.apache.flink.datastream.api.function.TwoInputBroadcastStreamProcessFunction<IN1,IN2,OUT> userFunction)

KeyedTwoInputBroadcastProcessOperator

public KeyedTwoInputBroadcastProcessOperator(org.apache.flink.datastream.api.function.TwoInputBroadcastStreamProcessFunction<IN1,IN2,OUT> userFunction,
                                             @Nullable
                                             org.apache.flink.api.java.functions.KeySelector<OUT,KEY> outKeySelector)

方法详细资料

open

public void open()
          throws Exception

指定者:

open 在接口中 org.apache.flink.streaming.api.operators.StreamOperator<OUT>

覆盖:

open 在类中 TwoInputBroadcastProcessOperator<IN1,IN2,OUT>

抛出:

Exception

getOutputCollector

protected TimestampCollector<OUT> getOutputCollector()

覆盖:

getOutputCollector 在类中 TwoInputBroadcastProcessOperator<IN1,IN2,OUT>

currentKey

protected Object currentKey()

覆盖:

currentKey 在类中 TwoInputBroadcastProcessOperator<IN1,IN2,OUT>

getProcessingTimeManager

protected org.apache.flink.datastream.api.context.ProcessingTimeManager getProcessingTimeManager()

覆盖:

getProcessingTimeManager 在类中 TwoInputBroadcastProcessOperator<IN1,IN2,OUT>

onEventTime

public void onEventTime(org.apache.flink.streaming.api.operators.InternalTimer<KEY,org.apache.flink.runtime.state.VoidNamespace> timer)
                 throws Exception

指定者:

onEventTime 在接口中 org.apache.flink.streaming.api.operators.Triggerable<KEY,org.apache.flink.runtime.state.VoidNamespace>

抛出:

Exception

onProcessingTime

public void onProcessingTime(org.apache.flink.streaming.api.operators.InternalTimer<KEY,org.apache.flink.runtime.state.VoidNamespace> timer)
                      throws Exception

指定者:

onProcessingTime 在接口中 org.apache.flink.streaming.api.operators.Triggerable<KEY,org.apache.flink.runtime.state.VoidNamespace>

抛出:

Exception

getNonPartitionedContext

protected org.apache.flink.datastream.api.context.NonPartitionedContext<OUT> getNonPartitionedContext()

覆盖:

getNonPartitionedContext 在类中 TwoInputBroadcastProcessOperator<IN1,IN2,OUT>

setKeyContextElement1

public void setKeyContextElement1(org.apache.flink.streaming.runtime.streamrecord.StreamRecord record)
                           throws Exception

指定者:

setKeyContextElement1 在接口中 org.apache.flink.streaming.api.operators.StreamOperator<OUT>

覆盖:

setKeyContextElement1 在类中 org.apache.flink.streaming.api.operators.AbstractStreamOperator<OUT>

抛出:

Exception