Environment (flink 1.10-SNAPSHOT API)

All Known Implementing Classes:

RuntimeEnvironment, SavepointEnvironment
```
public interface Environment
```
The Environment gives the code executed in a task access to the task's properties (such as name, parallelism), the configurations, the data stream readers and writers, as well as the various components that are provided by the TaskManager, such as memory manager, I/O manager, ...

Method Summary

All Methods Instance Methods Abstract Methods
Modifier and Type	Method and Description
`void`	`acknowledgeCheckpoint(long checkpointId, CheckpointMetrics checkpointMetrics)` Confirms that the invokable has successfully completed all steps it needed to to for the checkpoint with the give checkpoint-ID.
`void`	`acknowledgeCheckpoint(long checkpointId, CheckpointMetrics checkpointMetrics, TaskStateSnapshot subtaskState)` Confirms that the invokable has successfully completed all required steps for the checkpoint with the give checkpoint-ID.
`void`	`declineCheckpoint(long checkpointId, Throwable cause)` Declines a checkpoint.
`void`	`failExternally(Throwable cause)` Marks task execution failed for an external reason (a reason other than the task code itself throwing an exception).
`AccumulatorRegistry`	`getAccumulatorRegistry()` Return the registry for accumulators which are periodically sent to the job manager.
`InputGate[]`	`getAllInputGates()`
`ResultPartitionWriter[]`	`getAllWriters()`
`BroadcastVariableManager`	`getBroadcastVariableManager()`
`Map<String,Future<Path>>`	`getDistributedCacheEntries()`
`ExecutionConfig`	`getExecutionConfig()` Returns the job specific `ExecutionConfig`.
`ExecutionAttemptID`	`getExecutionId()` Gets the ID of the task execution attempt.
`GlobalAggregateManager`	`getGlobalAggregateManager()`
`InputGate`	`getInputGate(int index)`
`InputSplitProvider`	`getInputSplitProvider()` Returns the input split provider assigned to this environment.
`IOManager`	`getIOManager()` Returns the current `IOManager`.
`Configuration`	`getJobConfiguration()` Returns the job-wide configuration object that was attached to the JobGraph.
`JobID`	`getJobID()` Returns the ID of the job that the task belongs to.
`JobVertexID`	`getJobVertexId()` Gets the ID of the JobVertex for which this task executes a parallel subtask.
`MemoryManager`	`getMemoryManager()` Returns the current `MemoryManager`.
`TaskMetricGroup`	`getMetricGroup()` Returns the task specific metric group.
`Configuration`	`getTaskConfiguration()` Returns the task-wide configuration object, originally attached to the job vertex.
`TaskEventDispatcher`	`getTaskEventDispatcher()`
`TaskInfo`	`getTaskInfo()` Returns the `TaskInfo` object associated with this subtask
`TaskKvStateRegistry`	`getTaskKvStateRegistry()` Returns the registry for `InternalKvState` instances.
`TaskManagerRuntimeInfo`	`getTaskManagerInfo()` Gets the task manager info, with configuration and hostname.
`TaskStateManager`	`getTaskStateManager()`
`ClassLoader`	`getUserClassLoader()` Returns the user code class loader
`ResultPartitionWriter`	`getWriter(int index)`

- Method Detail
  - getExecutionConfig
```
ExecutionConfig getExecutionConfig()
```
    Returns the job specific ExecutionConfig.
    
    Returns:
    
    The execution configuration associated with the current job.
  - getJobID
```
JobID getJobID()
```
    Returns the ID of the job that the task belongs to.
    
    Returns:
    
    the ID of the job from the original job graph
  - getJobVertexId
```
JobVertexID getJobVertexId()
```
    Gets the ID of the JobVertex for which this task executes a parallel subtask.
    
    Returns:
    
    The JobVertexID of this task.
  - getExecutionId
```
ExecutionAttemptID getExecutionId()
```
    Gets the ID of the task execution attempt.
    
    Returns:
    
    The ID of the task execution attempt.
  - getTaskConfiguration
```
Configuration getTaskConfiguration()
```
    Returns the task-wide configuration object, originally attached to the job vertex.
    
    Returns:
    
    The task-wide configuration
  - getTaskManagerInfo
```
TaskManagerRuntimeInfo getTaskManagerInfo()
```
    Gets the task manager info, with configuration and hostname.
    
    Returns:
    
    The task manager info, with configuration and hostname.
  - getMetricGroup
```
TaskMetricGroup getMetricGroup()
```
    Returns the task specific metric group.
    
    Returns:
    
    The MetricGroup of this task.
  - getJobConfiguration
```
Configuration getJobConfiguration()
```
    Returns the job-wide configuration object that was attached to the JobGraph.
    
    Returns:
    
    The job-wide configuration
  - getTaskInfo
```
TaskInfo getTaskInfo()
```
    Returns the TaskInfo object associated with this subtask
    
    Returns:
    
    TaskInfo for this subtask
  - getInputSplitProvider
```
InputSplitProvider getInputSplitProvider()
```
    Returns the input split provider assigned to this environment.
    
    Returns:
    
    The input split provider or null if no such provider has been assigned to this environment.
  - getIOManager
```
IOManager getIOManager()
```
    Returns the current IOManager.
    
    Returns:
    
    the current IOManager.
  - getMemoryManager
```
MemoryManager getMemoryManager()
```
    Returns the current MemoryManager.
    
    Returns:
    
    the current MemoryManager.
  - getUserClassLoader
```
ClassLoader getUserClassLoader()
```
    Returns the user code class loader
  - getDistributedCacheEntries
```
Map<String,Future<Path>> getDistributedCacheEntries()
```
  - getBroadcastVariableManager
```
BroadcastVariableManager getBroadcastVariableManager()
```
  - getTaskStateManager
```
TaskStateManager getTaskStateManager()
```
  - getGlobalAggregateManager
```
GlobalAggregateManager getGlobalAggregateManager()
```
  - getAccumulatorRegistry
```
AccumulatorRegistry getAccumulatorRegistry()
```
    Return the registry for accumulators which are periodically sent to the job manager.
    
    Returns:
    
    the registry
  - getTaskKvStateRegistry
```
TaskKvStateRegistry getTaskKvStateRegistry()
```
    Returns the registry for InternalKvState instances.
    
    Returns:
    
    KvState registry
  - acknowledgeCheckpoint
```
void acknowledgeCheckpoint(long checkpointId,
                           CheckpointMetrics checkpointMetrics)
```
    Confirms that the invokable has successfully completed all steps it needed to to for the checkpoint with the give checkpoint-ID. This method does not include any state in the checkpoint.
    
    Parameters:
    
    checkpointId - ID of this checkpoint
    
    checkpointMetrics - metrics for this checkpoint
  - acknowledgeCheckpoint
```
void acknowledgeCheckpoint(long checkpointId,
                           CheckpointMetrics checkpointMetrics,
                           TaskStateSnapshot subtaskState)
```
    Confirms that the invokable has successfully completed all required steps for the checkpoint with the give checkpoint-ID. This method does include the given state in the checkpoint.
    
    Parameters:
    
    checkpointId - ID of this checkpoint
    
    checkpointMetrics - metrics for this checkpoint
    
    subtaskState - All state handles for the checkpointed state
  - declineCheckpoint
```
void declineCheckpoint(long checkpointId,
                       Throwable cause)
```
    Declines a checkpoint. This tells the checkpoint coordinator that this task will not be able to successfully complete a certain checkpoint.
    
    Parameters:
    
    checkpointId - The ID of the declined checkpoint.
    
    cause - An optional reason why the checkpoint was declined.
  - failExternally
```
void failExternally(Throwable cause)
```
    Marks task execution failed for an external reason (a reason other than the task code itself throwing an exception). If the task is already in a terminal state (such as FINISHED, CANCELED, FAILED), or if the task is already canceling this does nothing. Otherwise it sets the state to FAILED, and, if the invokable code is running, starts an asynchronous thread that aborts that code.
    This method never blocks.
  - getWriter
```
ResultPartitionWriter getWriter(int index)
```
  - getAllWriters
```
ResultPartitionWriter[] getAllWriters()
```
  - getInputGate
```
InputGate getInputGate(int index)
```
  - getAllInputGates
```
InputGate[] getAllInputGates()
```
  - getTaskEventDispatcher
```
TaskEventDispatcher getTaskEventDispatcher()
```

Back to Flink Website

Interface Environment

Method Summary

Method Detail

getExecutionConfig

getJobID

getJobVertexId

getExecutionId

getTaskConfiguration

getTaskManagerInfo

getMetricGroup

getJobConfiguration

getTaskInfo

getInputSplitProvider

getIOManager

getMemoryManager

getUserClassLoader

getDistributedCacheEntries

getBroadcastVariableManager

getTaskStateManager

getGlobalAggregateManager

getAccumulatorRegistry

getTaskKvStateRegistry

acknowledgeCheckpoint

acknowledgeCheckpoint

declineCheckpoint

failExternally

getWriter

getAllWriters

getInputGate

getAllInputGates

getTaskEventDispatcher