org.apache.flink.streaming.api.operators.collect

类 CollectSinkOperator<IN>

java.lang.Object

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

org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator<Object,SinkFunction<IN>>

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

org.apache.flink.streaming.api.operators.collect.CollectSinkOperator<IN>

类型参数:

IN - type of results to be written into the sink.

所有已实现的接口:

Serializable, org.apache.flink.api.common.state.CheckpointListener, org.apache.flink.runtime.operators.coordination.OperatorEventHandler, Input<IN>, KeyContext, OneInputStreamOperator<IN,Object>, OutputTypeConfigurable<Object>, SetupableStreamOperator<Object>, StreamOperator<Object>, StreamOperatorStateHandler.CheckpointedStreamOperator

public class CollectSinkOperator<IN>
extends StreamSink<IN>
implements org.apache.flink.runtime.operators.coordination.OperatorEventHandler

A StreamSink that collects query results and sends them back to the client.

另请参阅:

序列化表格

字段概要

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

userFunction

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

chainingStrategy, config, latencyStats, LOG, metrics, output, processingTimeService

构造器概要

构造器

构造器和说明
CollectSinkOperator(org.apache.flink.api.common.typeutils.TypeSerializer<IN> serializer, long maxBytesPerBatch, String accumulatorName)

方法概要

限定符和类型	方法和说明
void	finish() This method is called at the end of data processing.
CompletableFuture<org.apache.flink.runtime.jobgraph.OperatorID>	getOperatorIdFuture()
void	handleOperatorEvent(org.apache.flink.runtime.operators.coordination.OperatorEvent evt)

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

open, processElement, processWatermark, reportOrForwardLatencyMarker

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

close, 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, getTimeServiceManager, getUserCodeClassloader, initializeState, isUsingCustomRawKeyedState, prepareSnapshotPreBarrier, processLatencyMarker, processLatencyMarker1, processLatencyMarker2, processWatermark1, processWatermark2, processWatermarkStatus, processWatermarkStatus1, processWatermarkStatus2, setChainingStrategy, setCurrentKey, setKeyContextElement1, setKeyContextElement2, setProcessingTimeService, snapshotState

从类继承的方法 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, getMetricGroup, getOperatorID, initializeState, 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, processWatermarkStatus

构造器详细资料

CollectSinkOperator

public CollectSinkOperator(org.apache.flink.api.common.typeutils.TypeSerializer<IN> serializer,
                           long maxBytesPerBatch,
                           String accumulatorName)

方法详细资料

handleOperatorEvent

public void handleOperatorEvent(org.apache.flink.runtime.operators.coordination.OperatorEvent evt)

指定者:

handleOperatorEvent 在接口中 org.apache.flink.runtime.operators.coordination.OperatorEventHandler

finish

public void finish()
            throws Exception

从接口复制的说明: StreamOperator

This method is called at the end of data processing.

The method is expected to flush all remaining buffered data. Exceptions during this flushing of buffered data should be propagated, in order to cause the operation to be recognized as failed, because the last data items are not processed properly.

After this method is called, no more records can be produced for the downstream operators.

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:This method does not need to close any resources. You should release external resources in the StreamOperator.close() method.

指定者:

finish 在接口中 StreamOperator<Object>

覆盖:

finish 在类中 AbstractUdfStreamOperator<Object,SinkFunction<IN>>

抛出:

Exception - An exception in this method causes the operator to fail.

getOperatorIdFuture

public CompletableFuture<org.apache.flink.runtime.jobgraph.OperatorID> getOperatorIdFuture()