OUT
- The output type of the operator@Internal public abstract class SourceReaderOperator<OUT> extends AbstractStreamOperator<OUT> implements PushingAsyncDataInput<OUT>
PushingAsyncDataInput
for naturally compatible with one input processing in runtime
stack.
Note: We are expecting this to be changed to the concrete class once SourceReader interface is introduced.
AbstractStreamOperator.CountingOutput<OUT>
PushingAsyncDataInput.DataOutput<T>
AvailabilityProvider.AvailabilityHelper
chainingStrategy, config, latencyStats, LOG, metrics, output, timeServiceManager
AVAILABLE
Constructor and Description |
---|
SourceReaderOperator() |
close, dispose, getChainingStrategy, getContainingTask, getCurrentKey, getExecutionConfig, getInternalTimerService, getKeyedStateBackend, getKeyedStateStore, getMetricGroup, getOperatorConfig, getOperatorID, getOperatorName, getOperatorStateBackend, getOrCreateKeyedState, getPartitionedState, getPartitionedState, getProcessingTimeService, getRuntimeContext, getUserCodeClassloader, initializeState, initializeState, notifyCheckpointComplete, numEventTimeTimers, numProcessingTimeTimers, open, prepareSnapshotPreBarrier, processLatencyMarker, processLatencyMarker1, processLatencyMarker2, processWatermark, processWatermark1, processWatermark2, reportOrForwardLatencyMarker, setChainingStrategy, setCurrentKey, setKeyContextElement1, setKeyContextElement2, setup, snapshotState, snapshotState
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
emitNext
getAvailableFuture, isApproximatelyAvailable, isAvailable
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.