public static interface IPartitionedTransactionalSpout.Coordinator
Modifier and Type | Method and Description |
---|---|
void |
close() |
boolean |
isReady()
Returns true if its ok to emit start a new transaction, false otherwise (will skip this transaction).
|
int |
numPartitions()
Return the number of partitions currently in the source of data.
|
int numPartitions()
boolean isReady()
void close()
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.