org.apache.flink.streaming.api.operators

类 PartitionReduceOperator<IN>

java.lang.Object

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

org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator<IN,org.apache.flink.api.common.functions.ReduceFunction<IN>>

org.apache.flink.streaming.api.operators.PartitionReduceOperator<IN>

所有已实现的接口:

Serializable, org.apache.flink.api.common.state.CheckpointListener, BoundedOneInput, Input<IN>, KeyContext, KeyContextHandler, OneInputStreamOperator<IN,IN>, org.apache.flink.streaming.api.operators.OutputTypeConfigurable<IN>, SetupableStreamOperator<IN>, StreamOperator<IN>, StreamOperatorStateHandler.CheckpointedStreamOperator, UserFunctionProvider<org.apache.flink.api.common.functions.ReduceFunction<IN>>, YieldingOperator<IN>

@Internal
public class PartitionReduceOperator<IN>
extends AbstractUdfStreamOperator<IN,org.apache.flink.api.common.functions.ReduceFunction<IN>>
implements OneInputStreamOperator<IN,IN>, BoundedOneInput

The PartitionReduceOperator is used to apply the reduce transformation on all records of each partition. Each partition contains all records of a subtask.

另请参阅:

序列化表格

字段概要

从类继承的字段 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

构造器概要

构造器

构造器和说明
PartitionReduceOperator(org.apache.flink.api.common.functions.ReduceFunction<IN> reduceFunction)

方法概要

限定符和类型	方法和说明
void	endInput() It is notified that no more data will arrive from the input.
OperatorAttributes	getOperatorAttributes() Called to get the OperatorAttributes of the operator.
void	processElement(StreamRecord<IN> element) Processes one element that arrived on this input of the MultipleInputStreamOperator.

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

close, finish, getUserFunction, getUserFunctionParameters, initializeState, notifyCheckpointAborted, notifyCheckpointComplete, open, 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, setKeyContextElement1, 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.OneInputStreamOperator

setKeyContextElement

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

close, finish, getMetricGroup, getOperatorID, initializeState, open, prepareSnapshotPreBarrier, setKeyContextElement1, 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.Input

processLatencyMarker, processRecordAttributes, processWatermark, processWatermarkStatus

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

hasKeyContext

构造器详细资料

PartitionReduceOperator

public PartitionReduceOperator(org.apache.flink.api.common.functions.ReduceFunction<IN> reduceFunction)

方法详细资料

processElement

public void processElement(StreamRecord<IN> element)
                    throws Exception

从接口复制的说明: Input

Processes one element that arrived on this input of the MultipleInputStreamOperator. This method is guaranteed to not be called concurrently with other methods of the operator.

指定者:

processElement 在接口中 Input<IN>

抛出:

Exception

endInput

public void endInput()
              throws Exception

从接口复制的说明: 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.

指定者:

endInput 在接口中 BoundedOneInput

抛出:

Exception

getOperatorAttributes

public OperatorAttributes getOperatorAttributes()

从接口复制的说明: StreamOperator

Called to get the OperatorAttributes of the operator. If there is no defined attribute, a default OperatorAttributes is built.

指定者:

getOperatorAttributes 在接口中 StreamOperator<IN>

返回:

OperatorAttributes of the operator.