public class UnionInputGate extends Object implements InputGate
Each input gate has input channels attached from which it reads data. At each input gate, the input channels have unique IDs from 0 (inclusive) to the number of input channels (exclusive).
+---+---+ +---+---+---+ | 0 | 1 | | 0 | 1 | 2 | +--------------+--------------+ | Input gate 0 | Input gate 1 | +--------------+--------------+The union input gate maps these IDs from 0 to the *total* number of input channels across all unioned input gates, e.g. the channels of input gate 0 keep their original indexes and the channel indexes of input gate 1 are set off by 2 to 2--4.
+---+---++---+---+---+ | 0 | 1 || 2 | 3 | 4 | +--------------------+ | Union input gate | +--------------------+It is possible to recursively union union input gates.
Constructor and Description |
---|
UnionInputGate(InputGate... inputGates) |
Modifier and Type | Method and Description |
---|---|
BufferOrEvent |
getNextBufferOrEvent() |
int |
getNumberOfInputChannels()
Returns the total number of input channels across all unioned input gates.
|
int |
getPageSize() |
boolean |
isFinished() |
void |
registerListener(EventListener<InputGate> listener) |
void |
requestPartitions() |
void |
sendTaskEvent(TaskEvent event) |
public UnionInputGate(InputGate... inputGates)
public int getNumberOfInputChannels()
getNumberOfInputChannels
in interface InputGate
public boolean isFinished()
isFinished
in interface InputGate
public void requestPartitions() throws IOException, InterruptedException
requestPartitions
in interface InputGate
IOException
InterruptedException
public BufferOrEvent getNextBufferOrEvent() throws IOException, InterruptedException
getNextBufferOrEvent
in interface InputGate
IOException
InterruptedException
public void sendTaskEvent(TaskEvent event) throws IOException
sendTaskEvent
in interface InputGate
IOException
public void registerListener(EventListener<InputGate> listener)
registerListener
in interface InputGate
public int getPageSize()
getPageSize
in interface InputGate
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.