public class MQComputationRunner extends Object implements Runnable, MQRebalanceListener
Modifier and Type | Field and Description |
---|---|
static Duration |
READ_TIMEOUT |
Constructor and Description |
---|
MQComputationRunner(Supplier<Computation> supplier,
ComputationMetadataMapping metadata,
List<MQPartition> defaultAssignment,
MQManager<Record> mqManager) |
Modifier and Type | Method and Description |
---|---|
void |
drain() |
Watermark |
getLowWatermark() |
void |
onPartitionsAssigned(Collection<MQPartition> partitions) |
void |
onPartitionsRevoked(Collection<MQPartition> partitions) |
void |
run() |
void |
stop() |
boolean |
waitForAssignments(Duration timeout) |
public static final Duration READ_TIMEOUT
public MQComputationRunner(Supplier<Computation> supplier, ComputationMetadataMapping metadata, List<MQPartition> defaultAssignment, MQManager<Record> mqManager)
public void stop()
public void drain()
public boolean waitForAssignments(Duration timeout) throws InterruptedException
InterruptedException
public Watermark getLowWatermark()
public void onPartitionsRevoked(Collection<MQPartition> partitions)
onPartitionsRevoked
in interface MQRebalanceListener
public void onPartitionsAssigned(Collection<MQPartition> partitions)
onPartitionsAssigned
in interface MQRebalanceListener
Copyright © 2017 Nuxeo. All rights reserved.