public class CascadeConnector extends java.lang.Object
Cascade
instance from a collection of Flow
instance.
Note order is not significant when adding passing Flow instances to the connect
method. This connector will order them based on their dependencies, if any.
One Flow is dependent on another if the first sinks (produces) output that the second Flow sources (consumes) as
input. A sink and source are considered equivalent if the fully qualified identifier, typically Tap.getFullIdentifier(Object)
from either are equals()
.
Note that checkpoint sink Taps from an upstream Flow may be the sources to downstream Flow instances.
The CascadeDef
is a convenience class for dynamically defining a Cascade that can be passed to the
connect(CascadeDef)
method.
Use the CascadeProps
fluent helper class to create global properties to pass to the CascadeConnector
constructor.CascadeDef
,
CascadeProps
Constructor and Description |
---|
CascadeConnector()
Constructor CascadeConnector creates a new CascadeConnector instance.
|
CascadeConnector(java.util.Map<java.lang.Object,java.lang.Object> properties)
Constructor CascadeConnector creates a new CascadeConnector instance.
|
Modifier and Type | Method and Description |
---|---|
Cascade |
connect(CascadeDef cascadeDef) |
Cascade |
connect(java.util.Collection<Flow> flows)
|
Cascade |
connect(Flow... flows)
|
Cascade |
connect(java.lang.String name,
java.util.Collection<Flow> flows)
|
Cascade |
connect(java.lang.String name,
Flow... flows)
|
public CascadeConnector()
@ConstructorProperties(value="properties") public CascadeConnector(java.util.Map<java.lang.Object,java.lang.Object> properties)
properties
- of type Mappublic Cascade connect(java.util.Collection<Flow> flows)
Flow
objects, it will connect them and return a new Cascade
instance. The name
of the Cascade is derived from the given Flow instances.flows
- of type Collectionpublic Cascade connect(java.lang.String name, java.util.Collection<Flow> flows)
name
- of type Stringflows
- of type Collectionpublic Cascade connect(Flow... flows)
Flow
objects, it will connect them and return a new Cascade
instance. The name
of the Cascade is derived from the given Flow instances.flows
- of type Flowpublic Cascade connect(java.lang.String name, Flow... flows)
name
- of type Stringflows
- of type Flowpublic Cascade connect(CascadeDef cascadeDef)
Copyright © 2007-2015 Xplenty, Inc. All Rights Reserved.