@Incubating public interface FlowScope
dataflow actions
, anonymous, parameterized and
isolated pieces of work that are triggered solely based on the availability of their input parameters.Modifier and Type | Interface | Description |
---|---|---|
static interface |
FlowScope.Registration<P extends FlowParameters> |
Represents a registered
dataflow action . |
Modifier and Type | Method | Description |
---|---|---|
<P extends FlowParameters> |
always(java.lang.Class<? extends FlowAction<P>> action,
Action<? super FlowActionSpec<P>> configure) |
Registers a
dataflow action that's always part of the dataflow graph. |
<P extends FlowParameters> FlowScope.Registration<P> always(java.lang.Class<? extends FlowAction<P>> action, Action<? super FlowActionSpec<P>> configure)
dataflow action
that's always part of the dataflow graph.P
- the parameters defined by the given dataflow action
type.action
- the dataflow action
type.configure
- configuration for the given dataflow action
parameters.FlowScope.Registration
object representing the registered action.