Package org.apache.flink.streaming.runtime.tasks

Class SourceOperatorStreamTask<T>

java.lang.Object

org.apache.flink.streaming.runtime.tasks.StreamTask<T,SourceOperator<T,?>>

org.apache.flink.streaming.runtime.tasks.SourceOperatorStreamTask<T>

All Implemented Interfaces:

org.apache.flink.runtime.jobgraph.tasks.CheckpointableTask, org.apache.flink.runtime.jobgraph.tasks.CoordinatedTask, org.apache.flink.runtime.jobgraph.tasks.TaskInvokable, org.apache.flink.runtime.taskmanager.AsyncExceptionHandler, ContainingTaskDetails

@Internal
public class SourceOperatorStreamTask<T>
extends StreamTask<T,SourceOperator<T,?>>

A subclass of StreamTask for executing the SourceOperator.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	SourceOperatorStreamTask.AsyncDataOutputToOutput<T>	Implementation of PushingAsyncDataInput.DataOutput that wraps a specific Output.

Nested classes/interfaces inherited from class org.apache.flink.streaming.runtime.tasks.StreamTask

StreamTask.CanEmitBatchOfRecordsChecker

Field Summary

Fields inherited from class org.apache.flink.streaming.runtime.tasks.StreamTask

checkpointStorage, configuration, inputProcessor, LOG, mailboxProcessor, mainOperator, operatorChain, recordWriter, stateBackend, systemTimerService, timerService, TRIGGER_THREAD_GROUP

Constructor Summary

Constructors

Constructor	Description
SourceOperatorStreamTask(org.apache.flink.runtime.execution.Environment env)

Method Summary

Modifier and Type	Method	Description
protected void	advanceToEndOfEventTime()	Emits the MAX_WATERMARK so that all registered timers are fired.
protected void	declineCheckpoint(long checkpointId)
void	init()
Future<Void>	notifyCheckpointAbortAsync(long checkpointId, long latestCompletedCheckpointId)
Future<Void>	notifyCheckpointSubsumedAsync(long checkpointId)
CompletableFuture<Boolean>	triggerCheckpointAsync(org.apache.flink.runtime.checkpoint.CheckpointMetaData checkpointMetaData, org.apache.flink.runtime.checkpoint.CheckpointOptions checkpointOptions)

Methods inherited from class org.apache.flink.streaming.runtime.tasks.StreamTask

abortCheckpointOnBarrier, afterInvoke, cancel, cancelTask, cleanUp, cleanUpInternal, createRecordWriterDelegate, createStreamTaskStateInitializer, dispatchOperatorEvent, endData, finalize, getAsyncCheckpointStartDelayNanos, getAsyncOperationsThreadPool, getCancelables, getCanEmitBatchOfRecords, getCheckpointBarrierHandler, getCheckpointStorage, getCompletionFuture, getConfiguration, getEnvironment, getMailboxExecutorFactory, getName, getProcessingTimeServiceFactory, handleAsyncException, hasMail, invoke, isCanceled, isFailing, isMailboxLoopRunning, isRunning, isUsingNonBlockingInput, maybeInterruptOnCancel, notifyCheckpointCompleteAsync, notifyEndOfData, processInput, restore, runMailboxLoop, runMailboxStep, runSingleMailboxLoop, setSynchronousSavepoint, setupNumRecordsInCounter, toString, triggerCheckpointOnBarrier

Methods inherited from class java.lang.Object

clone, equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.flink.streaming.runtime.tasks.ContainingTaskDetails

getExecutionConfig, getIndexInSubtaskGroup, getJobConfiguration, getUserCodeClassLoader

Constructor Detail

SourceOperatorStreamTask

public SourceOperatorStreamTask(org.apache.flink.runtime.execution.Environment env)
                         throws Exception

Throws:

Exception

Method Detail

init

public void init()
          throws Exception

Specified by:

init in class StreamTask<T,SourceOperator<T,?>>

Throws:

Exception

triggerCheckpointAsync

public CompletableFuture<Boolean> triggerCheckpointAsync(org.apache.flink.runtime.checkpoint.CheckpointMetaData checkpointMetaData,
                                                         org.apache.flink.runtime.checkpoint.CheckpointOptions checkpointOptions)

Specified by:

triggerCheckpointAsync in interface org.apache.flink.runtime.jobgraph.tasks.CheckpointableTask

Overrides:

triggerCheckpointAsync in class StreamTask<T,SourceOperator<T,?>>

advanceToEndOfEventTime

protected void advanceToEndOfEventTime()

Description copied from class: StreamTask

Emits the MAX_WATERMARK so that all registered timers are fired.

This is used by the source task when the job is TERMINATED. In the case, we want all the timers registered throughout the pipeline to fire and the related state (e.g. windows) to be flushed.

For tasks other than the source task, this method does nothing.

Overrides:

advanceToEndOfEventTime in class StreamTask<T,SourceOperator<T,?>>

declineCheckpoint

protected void declineCheckpoint(long checkpointId)

Overrides:

declineCheckpoint in class StreamTask<T,SourceOperator<T,?>>

notifyCheckpointAbortAsync

public Future<Void> notifyCheckpointAbortAsync(long checkpointId,
                                               long latestCompletedCheckpointId)

Specified by:

notifyCheckpointAbortAsync in interface org.apache.flink.runtime.jobgraph.tasks.CheckpointableTask

Overrides:

notifyCheckpointAbortAsync in class StreamTask<T,SourceOperator<T,?>>

notifyCheckpointSubsumedAsync

public Future<Void> notifyCheckpointSubsumedAsync(long checkpointId)

Specified by:

notifyCheckpointSubsumedAsync in interface org.apache.flink.runtime.jobgraph.tasks.CheckpointableTask

Overrides:

notifyCheckpointSubsumedAsync in class StreamTask<T,SourceOperator<T,?>>