| Interface | Description |
|---|---|
| BarrierTransceiver |
A BarrierTransceiver describes an operator's barrier checkpointing behavior used for
fault tolerance.
|
| InputSplitProvider |
An input split provider can be successively queried to provide a series of
InputSplit objects a
task is supposed to consume in the course of its execution. |
| OperatorStateCarrier |
This is an interface meant to be implemented by any invokable that has to support state recovery.
|
| Class | Description |
|---|---|
| AbstractInvokable |
This is the abstract base class for every task that can be executed ba a TaskManager.
|
| InputSplitIterator<T extends InputSplit> |
The input split iterator allows a task to iterate over all input splits it is supposed to
consume.
|
Copyright © 2014–2015 The Apache Software Foundation. All rights reserved.