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,
OperatorChain<?,?> operatorChain) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
CompletableFuture<?> |
getAvailableFuture() |
CompletableFuture<Void> |
prepareSnapshot(ChannelStateWriter channelStateWriter,
long checkpointId) |
InputStatus |
processInput() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
isApproximatelyAvailable, isAvailable
public StreamOneInputProcessor(StreamTaskInput<IN> input, PushingAsyncDataInput.DataOutput<IN> output, OperatorChain<?,?> operatorChain)
public CompletableFuture<?> getAvailableFuture()
getAvailableFuture
in interface AvailabilityProvider
public InputStatus processInput() throws Exception
processInput
in interface StreamInputProcessor
AvailabilityProvider.getAvailableFuture()
.Exception
public CompletableFuture<Void> prepareSnapshot(ChannelStateWriter channelStateWriter, long checkpointId) throws IOException
prepareSnapshot
in interface StreamInputProcessor
IOException
public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
IOException
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.