Package | Description |
---|---|
org.apache.tez.dag.api | |
org.apache.tez.runtime.api.events |
Modifier and Type | Method and Description |
---|---|
void |
VertexManagerPluginContext.addRootInputEvents(String inputName,
Collection<InputDataInformationEvent> events)
Allows a VertexManagerPlugin to assign Events for Root Inputs
For regular Event Routing changes - the EdgeManager should be configured
via the setVertexParallelism method
|
Modifier and Type | Method and Description |
---|---|
static InputDataInformationEvent |
InputDataInformationEvent.createWithObjectPayload(int srcIndex,
Object userPayloadDeserialized) |
static InputDataInformationEvent |
InputDataInformationEvent.createWithSerializedPath(int srcIndex,
String serializedPath) |
static InputDataInformationEvent |
InputDataInformationEvent.createWithSerializedPayload(int srcIndex,
ByteBuffer userPayload)
Provide a serialized form of the payload
|
Copyright © 2024 Apache Software Foundation. All rights reserved.