@Internal public interface StreamTaskInput extends NullableAsyncDataInput<StreamElement>, Closeable
Modifier and Type | Field and Description |
---|---|
static int |
UNSPECIFIED |
AVAILABLE
Modifier and Type | Method and Description |
---|---|
int |
getInputIndex()
Returns the input index of this input.
|
int |
getLastChannel() |
pollNextNullable
isAvailable, isFinished
static final int UNSPECIFIED
int getLastChannel()
StreamElement
, or UNSPECIFIED
if
it is unspecified.int getInputIndex()
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.