| 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() |
| 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.DataMovementTypes |
| Constructor and Description |
|---|
DataSinkDescriptor(OutputDescriptor outputDescriptor,
OutputCommitterDescriptor committerDescriptor,
org.apache.hadoop.security.Credentials credentials)
Create a
DataSinkDescriptor |
Copyright © 2014 Apache Software Foundation. All rights reserved.