public class RemoteChannelStateChecker extends Object
PartitionProducerStateProvider
.
The method isProducerReadyOrAbortConsumption
determines whether the partition producer
is in a producing state, ready for consumption. Otherwise it aborts the consumption.
Constructor and Description |
---|
RemoteChannelStateChecker(ResultPartitionID resultPartitionId,
String taskNameWithSubtask) |
Modifier and Type | Method and Description |
---|---|
boolean |
isProducerReadyOrAbortConsumption(PartitionProducerStateProvider.ResponseHandle responseHandle) |
public RemoteChannelStateChecker(ResultPartitionID resultPartitionId, String taskNameWithSubtask)
public boolean isProducerReadyOrAbortConsumption(PartitionProducerStateProvider.ResponseHandle responseHandle)
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.