Package com.qfs.plan

Interface IPartitionTransactionContent

All Superinterfaces:
ITransactionContent
All Known Implementing Classes:
AIncrementalPartitionTransactionContent, APartitionTransactionContent, DropPartitionTransactionContent, IncrementalPartitionTransactionContent, IncrementalPartitionTransactionContentDeleteFirst, InitialPartitionTransactionContent
public interface IPartitionTransactionContent extends ITransactionContent
Holder for all the records belonging to a partition and modified by a transaction.

Do not keep any strong reference to this in non transient objects instance to prevent memory leaks.

Author:
ActiveViam

  • Method Details

    • getPartitionId

      int getPartitionId()
      The id of the partition this content belongs to.
      Returns:
      the id of the partition linked to this content

    • getPartitionPool

      IMixedWorkloadPool getPartitionPool()
      Get the IMixedWorkloadPool attached to the partition this content belongs to.
      Returns:
      the pool of the partition

    • createReader

      IPartitionTransactionContentReader createReader()
      Create a IPartitionTransactionContentReader able to read this transaction content.
      Returns:
      a reader able to read this content

    • publishToListeners

      void publishToListeners(Collection<? extends IAsyncCompositeSelectionListener> listeners, CountedCompleter<?> parent)
      Publish this content to the listeners.

      This method will invoke a publication task in the pool attached to the partition. Make sure to call this method in the relevant pool to avoid potential deadlock.

      Parameters:
      listeners - the listeners to publish this content to.
      parent - parent completer to notify at the end of the publication