Package com.gigaspaces.internal.cluster.node

Class ReplicationBlobstoreBulkContext

java.lang.Object
com.gigaspaces.internal.cluster.node.ReplicationBlobstoreBulkContext
public class ReplicationBlobstoreBulkContext extends Object
Since:
11.0.0 Contains context for incoming replication blobstore bulks
Author:
Boris

  • Constructor Details

    • ReplicationBlobstoreBulkContext

      public ReplicationBlobstoreBulkContext(int bulkId)

  • Method Details

    • getBulkId

      public int getBulkId()

    • isPartOfBlobstoreBulk

      public boolean isPartOfBlobstoreBulk()

    • shouldFlush

      public boolean shouldFlush()

    • setBulkReplicationInfo

      public void setBulkReplicationInfo(int bulkId)

    • nonBulkArrived

      public void nonBulkArrived()

    • getBlobStoreReplicationBulkConsumeHelper

      public BlobStoreReplicationBulkConsumeHelper getBlobStoreReplicationBulkConsumeHelper()

    • setBlobStoreReplicationBulkConsumeHelper

      public void setBlobStoreReplicationBulkConsumeHelper(BlobStoreReplicationBulkConsumeHelper blobStoreReplicationBulkConsumeHelper)