Package | Description |
---|---|
org.apache.tez.common | |
org.apache.tez.dag.api | |
org.apache.tez.runtime.api |
Modifier and Type | Method and Description |
---|---|
static UserPayload |
TezUtils.createUserPayloadFromConf(org.apache.hadoop.conf.Configuration conf)
Convert a Configuration to a
UserPayload |
Modifier and Type | Method and Description |
---|---|
static org.apache.hadoop.conf.Configuration |
TezUtils.createConfFromUserPayload(UserPayload payload)
Convert an instance of
UserPayload to Configuration |
Modifier and Type | Method and Description |
---|---|
static UserPayload |
UserPayload.create(ByteBuffer payload)
Create a UserPayload instance which encapsulates a
ByteBuffer . |
static UserPayload |
UserPayload.create(ByteBuffer payload,
int version)
Create an explicitly versioned UserPayload instance which encapsulates a
ByteBuffer . |
UserPayload |
VertexManagerPluginContext.getUserPayload()
Get the payload set for the plugin
|
UserPayload |
EntityDescriptor.getUserPayload() |
UserPayload |
EdgeManagerPluginContext.getUserPayload()
Returns the payload specified by the user for the edge.
|
Modifier and Type | Method and Description |
---|---|
T |
EntityDescriptor.setUserPayload(UserPayload userPayload)
Set user payload for this entity descriptor
|
Modifier and Type | Method and Description |
---|---|
UserPayload |
InputInitializerContext.getInputUserPayload()
Get the user payload for the input
|
UserPayload |
OutputCommitterContext.getOutputUserPayload()
Get the User Payload for the Output
|
UserPayload |
TaskContext.getUserPayload()
Get the User Payload for the Input/Output/Processor
|
UserPayload |
OutputCommitterContext.getUserPayload()
Get the User Payload for the OutputCommitter
|
UserPayload |
MergedInputContext.getUserPayload()
Get the user payload for this input
|
UserPayload |
InputInitializerContext.getUserPayload()
Get the user payload for the initializer
|
Copyright © 2015 Apache Software Foundation. All rights reserved.