@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.