public class EpochManager extends Object
For more details please refer to FLIP-425.
Modifier and Type | Class and Description |
---|---|
static class |
EpochManager.Epoch
All inputs are segment into distinct epochs, marked by the arrival of non-record inputs.
|
static class |
EpochManager.ParallelMode
This enum defines whether parallel execution between epochs is allowed.
|
Constructor and Description |
---|
EpochManager(AsyncExecutionController<?> aec) |
Modifier and Type | Method and Description |
---|---|
void |
completeOneRecord(EpochManager.Epoch epoch)
Complete one record in the specific epoch.
|
void |
onNonRecord(Runnable action,
EpochManager.ParallelMode parallelMode)
Add a non-record to the current epoch, close current epoch and open a new epoch.
|
EpochManager.Epoch |
onRecord()
Add a record to the current epoch and return the current open epoch, the epoch will be
associated with the
RecordContext of this record. |
public EpochManager(AsyncExecutionController<?> aec)
public EpochManager.Epoch onRecord()
RecordContext
of this record. Must be invoked within task thread.public void onNonRecord(Runnable action, EpochManager.ParallelMode parallelMode)
action
- the action associated with this non-record.parallelMode
- the parallel mode for this epoch.public void completeOneRecord(EpochManager.Epoch epoch)
epoch
- the specific epochCopyright © 2014–2024 The Apache Software Foundation. All rights reserved.