IN
- The type of the record that can be read with this record reader.@Internal public final class StreamOneInputProcessor<IN> extends Object implements StreamInputProcessor
OneInputStreamTask
.AvailabilityProvider.AvailabilityHelper
AVAILABLE
Constructor and Description |
---|
StreamOneInputProcessor(StreamTaskInput<IN> input,
PushingAsyncDataInput.DataOutput<IN> output,
Object lock,
OperatorChain<?,?> operatorChain) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
CompletableFuture<?> |
getAvailableFuture() |
InputStatus |
processInput() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
isApproximatelyAvailable, isAvailable
public StreamOneInputProcessor(StreamTaskInput<IN> input, PushingAsyncDataInput.DataOutput<IN> output, Object lock, OperatorChain<?,?> operatorChain)
public CompletableFuture<?> getAvailableFuture()
getAvailableFuture
in interface AvailabilityProvider
public InputStatus processInput() throws Exception
processInput
in interface StreamInputProcessor
AvailabilityProvider.getAvailableFuture()
.Exception
public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
IOException
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.