public class DataSourceTask<OT> extends AbstractInvokable
InputFormat
to create records from the input.InputFormat
Constructor and Description |
---|
DataSourceTask(Environment environment)
Create an Invokable task and set its environment.
|
Modifier and Type | Method and Description |
---|---|
void |
cancel()
This method is called when a task is canceled either as a result of a user abort or an
execution failure.
|
DistributedRuntimeUDFContext |
createRuntimeContext() |
void |
invoke()
Starts the execution.
|
abortCheckpointOnBarrier, cleanUp, dispatchOperatorEvent, getCurrentNumberOfSubtasks, getEnvironment, getExecutionConfig, getIndexInSubtaskGroup, getJobConfiguration, getTaskConfiguration, getUserCodeClassLoader, isUsingNonBlockingInput, maybeInterruptOnCancel, notifyCheckpointAbortAsync, notifyCheckpointCompleteAsync, notifyCheckpointSubsumedAsync, restore, triggerCheckpointAsync, triggerCheckpointOnBarrier
public DataSourceTask(Environment environment)
environment
- The environment assigned to this invokable.public void invoke() throws Exception
TaskInvokable
This method is called by the task manager when the actual execution of the task starts.
All resources should be cleaned up by calling TaskInvokable.cleanUp(Throwable)
()} after the
method returns.
invoke
in interface TaskInvokable
invoke
in class AbstractInvokable
Exception
public void cancel() throws Exception
TaskInvokable
cancel
in interface TaskInvokable
cancel
in class AbstractInvokable
Exception
public DistributedRuntimeUDFContext createRuntimeContext()
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.