@InterfaceAudience.Public public class EdgeProperty extends Object
EdgeProperty
defines the relation between the source and
destination vertices of an edge. The relation consists of defining their
communication pattern and dependencies. It also defines the user code that
actually does the job of writing out data at the source and reading that data
at the destination via the @link InputDescriptor
and @link
OutputDescriptor
Modifier and Type | Class and Description |
---|---|
static class |
EdgeProperty.DataMovementType
Defines the manner of data movement between source and destination tasks.
|
static class |
EdgeProperty.DataSourceType
Determines the lifetime of the data produced on this edge by a source task.
|
static class |
EdgeProperty.SchedulingType
Determines when the destination task is eligible to run, once the source
task is eligible to run.
|
public static EdgeProperty create(EdgeProperty.DataMovementType dataMovementType, EdgeProperty.DataSourceType dataSourceType, EdgeProperty.SchedulingType schedulingType, OutputDescriptor edgeSource, InputDescriptor edgeDestination)
EdgeProperty.DataMovementType
sdataMovementType
- dataSourceType
- schedulingType
- edgeSource
- The OutputDescriptor
that generates data on the edge.edgeDestination
- The InputDescriptor
which will consume data from the edge.public static EdgeProperty create(EdgeManagerPluginDescriptor edgeManagerDescriptor, EdgeProperty.DataSourceType dataSourceType, EdgeProperty.SchedulingType schedulingType, OutputDescriptor edgeSource, InputDescriptor edgeDestination)
edgeManagerDescriptor
- the EdgeManager specifications. This can be null if the edge
manager will be setup at runtimedataSourceType
- schedulingType
- edgeSource
- The OutputDescriptor
that generates data on the edge.edgeDestination
- The InputDescriptor
which will consume data from the edge.@InterfaceAudience.Private public static EdgeProperty create(EdgeManagerPluginDescriptor edgeManagerDescriptor, EdgeProperty.DataMovementType dataMovementType, EdgeProperty.DataSourceType dataSourceType, EdgeProperty.SchedulingType schedulingType, OutputDescriptor edgeSource, InputDescriptor edgeDestination)
public EdgeProperty.DataMovementType getDataMovementType()
EdgeProperty.DataMovementType
EdgeProperty.DataMovementType
public EdgeProperty.DataSourceType getDataSourceType()
EdgeProperty.DataSourceType
EdgeProperty.DataSourceType
public EdgeProperty.SchedulingType getSchedulingType()
EdgeProperty.SchedulingType
EdgeProperty.SchedulingType
public InputDescriptor getEdgeDestination()
InputDescriptor
which will consume data from the edge.public OutputDescriptor getEdgeSource()
OutputDescriptor
which produces data on the edge.@InterfaceAudience.Private public EdgeManagerPluginDescriptor getEdgeManagerDescriptor()
EdgeManagerPluginDescriptor
if a custom edge was setup, null otherwise.Copyright © 2016 Apache Software Foundation. All rights reserved.