Interface | Description |
---|---|
InputGate |
An input gate consumes one or more partitions of a single produced intermediate result.
|
Class | Description |
---|---|
BufferOrEvent |
Either type for
Buffer or AbstractEvent instances tagged with the channel index,
from which they were received. |
InputChannel |
An input channel consumes a single
ResultSubpartitionView . |
InputChannelID | |
LocalInputChannel |
An input channel, which requests a local subpartition.
|
RemoteInputChannel |
An input channel, which requests a remote partition queue.
|
SingleInputGate |
An input gate consumes one or more partitions of a single produced intermediate result.
|
UnionInputGate |
Input gate wrapper to union the input from multiple input gates.
|
UnknownInputChannel |
An input channel place holder to be replaced by either a
RemoteInputChannel
or LocalInputChannel at runtime. |
Exception | Description |
---|---|
RemoteInputChannel.BufferReorderingException |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.