Package | Description |
---|---|
org.apache.tez.dag.api |
Modifier and Type | Method and Description |
---|---|
DataSourceDescriptor |
DataSourceDescriptor.addURIsForCredentials(Collection<URI> uris)
This method can be used to specify a list of URIs for which Credentials
need to be obtained so that the job can run.
|
static DataSourceDescriptor |
DataSourceDescriptor.create(InputDescriptor inputDescriptor,
InputInitializerDescriptor initializerDescriptor,
org.apache.hadoop.security.Credentials credentials)
Create a
DataSourceDescriptor when the data shard calculation
happens in the App Master at runtime |
static DataSourceDescriptor |
DataSourceDescriptor.create(InputDescriptor inputDescriptor,
InputInitializerDescriptor initializerDescriptor,
int numShards,
org.apache.hadoop.security.Credentials credentials,
VertexLocationHint locationHint,
Map<String,org.apache.hadoop.yarn.api.records.LocalResource> additionalLocalFiles)
Create a
DataSourceDescriptor when the data shard calculation
happens in the client at compile time |
Modifier and Type | Method and Description |
---|---|
Vertex |
Vertex.addDataSource(String inputName,
DataSourceDescriptor dataSourceDescriptor)
Specifies an external data source for a Vertex.
|
Copyright © 2024 Apache Software Foundation. All rights reserved.