@Internal public class SourceReaderStreamTask<T> extends StreamTask<T,SourceReaderOperator<T>>
StreamTask
for executing the SourceReaderOperator
.StreamTask.AsyncCheckpointRunnable
configuration, headOperator, inputProcessor, LOG, mailboxProcessor, operatorChain, stateBackend, timerService, TRIGGER_THREAD_GROUP
Constructor and Description |
---|
SourceReaderStreamTask(Environment env) |
Modifier and Type | Method and Description |
---|---|
void |
init() |
abortCheckpointOnBarrier, advanceToEndOfEventTime, cancel, cancelTask, cleanup, createRecordWriterDelegate, createStreamTaskStateInitializer, declineCheckpoint, finalize, finishTask, getAccumulatorMap, getAsyncOperationsThreadPool, getCancelables, getCheckpointLock, getCheckpointStorage, getCompletionFuture, getConfiguration, getMailboxExecutorFactory, getName, getProcessingTimeService, getStreamStatusMaintainer, handleAsyncException, handleCheckpointException, invoke, isCanceled, isFailing, isRunning, notifyCheckpointCompleteAsync, processInput, setupNumRecordsInCounter, toString, triggerCheckpointAsync, triggerCheckpointOnBarrier
getCurrentNumberOfSubtasks, getEnvironment, getExecutionConfig, getIndexInSubtaskGroup, getJobConfiguration, getTaskConfiguration, getUserCodeClassLoader, setShouldInterruptOnCancel, shouldInterruptOnCancel
public SourceReaderStreamTask(Environment env)
public void init()
init
in class StreamTask<T,SourceReaderOperator<T>>
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.