Package | Description |
---|---|
org.apache.tez.dag.api |
Modifier and Type | Method and Description |
---|---|
static OutputDescriptor |
OutputDescriptor.create(String outputClassName) |
OutputDescriptor |
EdgeProperty.getEdgeSource() |
OutputDescriptor |
DataSinkDescriptor.getOutputDescriptor()
Get the
OutputDescriptor for this DataSinkDescriptor |
Modifier and Type | Method and Description |
---|---|
static EdgeProperty |
EdgeProperty.create(EdgeManagerPluginDescriptor edgeManagerDescriptor,
org.apache.tez.dag.api.EdgeProperty.DataSourceType dataSourceType,
org.apache.tez.dag.api.EdgeProperty.SchedulingType schedulingType,
OutputDescriptor edgeSource,
InputDescriptor edgeDestination)
Setup an Edge which uses a custom EdgeManager
|
static EdgeProperty |
EdgeProperty.create(org.apache.tez.dag.api.EdgeProperty.DataMovementType dataMovementType,
org.apache.tez.dag.api.EdgeProperty.DataSourceType dataSourceType,
org.apache.tez.dag.api.EdgeProperty.SchedulingType schedulingType,
OutputDescriptor edgeSource,
InputDescriptor edgeDestination)
Setup an EdgeProperty which makes use of one of the provided
EdgeProperty.DataMovementType s |
static DataSinkDescriptor |
DataSinkDescriptor.create(OutputDescriptor outputDescriptor,
OutputCommitterDescriptor committerDescriptor,
org.apache.hadoop.security.Credentials credentials)
Create a
DataSinkDescriptor |
Constructor and Description |
---|
DataSinkDescriptor(OutputDescriptor outputDescriptor,
OutputCommitterDescriptor committerDescriptor,
org.apache.hadoop.security.Credentials credentials)
Deprecated.
|
Copyright © 2015 Apache Software Foundation. All rights reserved.