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()