public interface PipelinerContext
Modifier and Type | Method and Description |
---|---|
default int |
accumulatorMaxBatchMillis()
Returns the maximum number of millis allowed since the first objective before processing is triggered.
|
default int |
accumulatorMaxIdleMillis()
Returns the maximum number of millis between objectives before processing is triggered.
|
default int |
accumulatorMaxObjectives()
Returns the maximum number of objectives to accumulate before processing is triggered.
|
ServiceDirectory |
directory()
Returns the service directory which can be used to obtain references
to various supporting services.
|
FlowObjectiveStore |
store()
Returns the Objective Store where data can be stored and retrieved.
|
ServiceDirectory directory()
FlowObjectiveStore store()
default int accumulatorMaxObjectives()
default int accumulatorMaxIdleMillis()
default int accumulatorMaxBatchMillis()