Environment (flink-runtime 0.9.0-milestone-1 API)

All Known Implementing Classes:

RuntimeEnvironment
```
public interface Environment
```
The user code of every task runs inside an Environment object. The environment provides important services to the task. It keeps track of setting up the communication channels and provides access to input splits, memory manager, etc.

Method Summary

All Methods Instance Methods Abstract Methods
Modifier and Type	Method and Description
`InputGate[]`	`getAllInputGates()`
`ResultPartitionWriter[]`	`getAllWriters()`
`BroadcastVariableManager`	`getBroadcastVariableManager()`
`Map<String,FutureTask<Path>>`	`getCopyTask()`
`int`	`getIndexInSubtaskGroup()` Returns the index of this subtask in the subtask group.
`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 configuration object which was attached to the original `JobGraph`.
`JobID`	`getJobID()` Returns the ID of the job from the original job graph.
`akka.actor.ActorRef`	`getJobManager()` Returns the proxy object for the accumulator protocol.
`JobVertexID`	`getJobVertexId()` Gets the ID of the jobVertex that this task corresponds to.
`MemoryManager`	`getMemoryManager()` Returns the current `MemoryManager`.
`int`	`getNumberOfSubtasks()` Returns the current number of subtasks the respective task is split into.
`Configuration`	`getTaskConfiguration()` Returns the task configuration object which was attached to the original JobVertex.
`String`	`getTaskName()` Returns the name of the task running in this environment.
`String`	`getTaskNameWithSubtasks()`
`ClassLoader`	`getUserClassLoader()` Returns the user code class loader
`ResultPartitionWriter`	`getWriter(int index)`

- Method Detail
  - getJobID
```
JobID getJobID()
```
    Returns the ID of the job from the original job graph. It is used by the library cache manager to find the required libraries for executing the assigned Nephele task.
    
    Returns:
    
    the ID of the job from the original job graph
  - getJobVertexId
```
JobVertexID getJobVertexId()
```
    Gets the ID of the jobVertex that this task corresponds to.
    
    Returns:
    
    The JobVertexID of this task.
  - getTaskConfiguration
```
Configuration getTaskConfiguration()
```
    Returns the task configuration object which was attached to the original JobVertex.
    
    Returns:
    
    the task configuration object which was attached to the original JobVertex.
  - getJobConfiguration
```
Configuration getJobConfiguration()
```
    Returns the job configuration object which was attached to the original JobGraph.
    
    Returns:
    
    the job configuration object which was attached to the original JobGraph
  - getNumberOfSubtasks
```
int getNumberOfSubtasks()
```
    Returns the current number of subtasks the respective task is split into.
    
    Returns:
    
    the current number of subtasks the respective task is split into
  - getIndexInSubtaskGroup
```
int getIndexInSubtaskGroup()
```
    Returns the index of this subtask in the subtask group.
    
    Returns:
    
    the index of this subtask in the subtask group
  - 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.
  - getTaskName
```
String getTaskName()
```
    Returns the name of the task running in this environment.
    
    Returns:
    
    the name of the task running in this environment
  - getTaskNameWithSubtasks
```
String getTaskNameWithSubtasks()
```
  - getJobManager
```
akka.actor.ActorRef getJobManager()
```
    Returns the proxy object for the accumulator protocol.
  - getUserClassLoader
```
ClassLoader getUserClassLoader()
```
    Returns the user code class loader
  - getCopyTask
```
Map<String,FutureTask<Path>> getCopyTask()
```
  - getBroadcastVariableManager
```
BroadcastVariableManager getBroadcastVariableManager()
```
  - getWriter
```
ResultPartitionWriter getWriter(int index)
```
  - getAllWriters
```
ResultPartitionWriter[] getAllWriters()
```
  - getInputGate
```
InputGate getInputGate(int index)
```
  - getAllInputGates
```
InputGate[] getAllInputGates()
```

Interface Environment

Method Summary

Method Detail

getJobID

getJobVertexId

getTaskConfiguration

getJobConfiguration

getNumberOfSubtasks

getIndexInSubtaskGroup

getInputSplitProvider

getIOManager

getMemoryManager

getTaskName

getTaskNameWithSubtasks

getJobManager

getUserClassLoader

getCopyTask

getBroadcastVariableManager

getWriter

getAllWriters

getInputGate

getAllInputGates