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–2020 The Apache Software Foundation. All rights reserved.