Package | Description |
---|---|
org.apache.tez.runtime.api |
Modifier and Type | Interface and Description |
---|---|
interface |
LogicalInput
An
Input which handles all incoming physical connections on an
edge. |
Modifier and Type | Class and Description |
---|---|
class |
AbstractLogicalInput
An abstract class which should be the base class for all implementations of LogicalInput.
|
class |
MergedLogicalInput
A LogicalInput that is used to merge the data from multiple inputs and provide a
single
Reader to read that data. |
Modifier and Type | Method and Description |
---|---|
Input |
ProcessorContext.waitForAnyInputReady(Collection<Input> inputs)
Blocking call which returns when any of the specified Inputs is ready for
consumption.
|
Modifier and Type | Method and Description |
---|---|
List<Input> |
MergedLogicalInput.getInputs() |
Modifier and Type | Method and Description |
---|---|
abstract void |
MergedLogicalInput.setConstituentInputIsReady(Input input)
Used by the framework to inform the MergedInput that one of it's constituent Inputs is ready.
|
Modifier and Type | Method and Description |
---|---|
void |
ProcessorContext.waitForAllInputsReady(Collection<Input> inputs)
Blocking call which returns only after all of the specified Inputs are
ready for consumption.
|
Input |
ProcessorContext.waitForAnyInputReady(Collection<Input> inputs)
Blocking call which returns when any of the specified Inputs is ready for
consumption.
|
Constructor and Description |
---|
MergedLogicalInput(MergedInputContext context,
List<Input> inputs)
Constructor an instance of the MergedLogicalInputs.
|
Copyright © 2015 Apache Software Foundation. All rights reserved.