| 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.