Class and Description |
---|
InputGate
An input gate consumes one or more partitions of a single produced intermediate result.
|
Class and Description |
---|
InputChannel.BufferAndAvailability
A combination of a
Buffer and a flag indicating availability of further buffers,
and the backlog length indicating how many non-event buffers are available in the
subpartition. |
InputChannelID
Identifier for input channels.
|
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.
|
Class and Description |
---|
InputGate
An input gate consumes one or more partitions of a single produced intermediate result.
|
Class and Description |
---|
RemoteInputChannel
An input channel, which requests a remote partition queue.
|
Class and 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
Identifier for input channels.
|
InputGate
An input gate consumes one or more partitions of a single produced intermediate result.
|
InputGateListener
Listener interface implemented by consumers of
InputGate instances
that want to be notified of availability of buffer or event instances. |
SingleInputGate
An input gate consumes one or more partitions of a single produced intermediate result.
|
Class and Description |
---|
InputGate
An input gate consumes one or more partitions of a single produced intermediate result.
|
SingleInputGate
An input gate consumes one or more partitions of a single produced intermediate result.
|
Class and Description |
---|
BufferOrEvent
Either type for
Buffer or AbstractEvent instances tagged with the channel index,
from which they were received. |
InputGate
An input gate consumes one or more partitions of a single produced intermediate result.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.