Return the partitions currently in the source of data. The idea is is that if a new partition is added and a prior transaction is replayed, it doesn’t emit tuples for the new partition because it knows what partitions were in that transaction.
boolean isReady(long txid)
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.