public class StreamTaskExternallyInducedSourceInput<T> extends StreamTaskSourceInput<T>
StreamTaskSourceInput
for ExternallyInducedSourceReader
.PushingAsyncDataInput.DataOutput<T>
AvailabilityProvider.AvailabilityHelper
UNSPECIFIED
AVAILABLE
Constructor and Description |
---|
StreamTaskExternallyInducedSourceInput(SourceOperator<T,?> operator,
Consumer<Long> checkpointTriggeringHook,
int inputGateIndex,
int inputIndex) |
Modifier and Type | Method and Description |
---|---|
void |
blockUntil(CompletableFuture<?> blockFuture) |
DataInputStatus |
emitNext(PushingAsyncDataInput.DataOutput<T> output)
Pushes elements to the output from current data input, and returns the input status to
indicate whether there are more available data in current input.
|
CompletableFuture<?> |
getAvailableFuture() |
blockConsumption, checkpointStarted, checkpointStopped, close, convertToPriorityEvent, getChannelInfos, getInputGateIndex, getInputIndex, getNumberOfInputChannels, getOperator, getOperatorID, prepareSnapshot, resumeConsumption
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
and, isApproximatelyAvailable, isAvailable, or
public StreamTaskExternallyInducedSourceInput(SourceOperator<T,?> operator, Consumer<Long> checkpointTriggeringHook, int inputGateIndex, int inputIndex)
public void blockUntil(CompletableFuture<?> blockFuture)
public DataInputStatus emitNext(PushingAsyncDataInput.DataOutput<T> output) throws Exception
PushingAsyncDataInput
This method should be non blocking.
emitNext
in interface PushingAsyncDataInput<T>
emitNext
in class StreamTaskSourceInput<T>
Exception
public CompletableFuture<?> getAvailableFuture()
getAvailableFuture
in interface AvailabilityProvider
getAvailableFuture
in class StreamTaskSourceInput<T>
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.