Package | Description |
---|---|
org.apache.flink.runtime.operators.coordination | |
org.apache.flink.streaming.api.operators | |
org.apache.flink.streaming.api.operators.collect |
Modifier and Type | Method and Description |
---|---|
void |
OperatorEventDispatcher.registerEventHandler(OperatorID operator,
OperatorEventHandler handler)
Register a listener that is notified every time an OperatorEvent is sent from the
OperatorCoordinator (of the operator with the given OperatorID) to this subtask.
|
Modifier and Type | Class and Description |
---|---|
class |
SourceOperator<OUT,SplitT extends SourceSplit>
Base source operator only used for integrating the source reader which is proposed by FLIP-27.
|
Modifier and Type | Class and Description |
---|---|
class |
CollectSinkOperator<IN>
A
StreamSink that collects query results and sends them back to the client. |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.