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 Summary

Constructors

Constructor and Description
ReplicationBlobstoreBulkContext(int bulkId)

Method Summary

Modifier and Type	Method and Description
BlobStoreReplicationBulkConsumeHelper	getBlobStoreReplicationBulkConsumeHelper()
int	getBulkId()
boolean	isPartOfBlobstoreBulk()
void	nonBulkArrived()
void	setBlobStoreReplicationBulkConsumeHelper(BlobStoreReplicationBulkConsumeHelper blobStoreReplicationBulkConsumeHelper)
void	setBulkReplicationInfo(int bulkId)
boolean	shouldFlush()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ReplicationBlobstoreBulkContext

public ReplicationBlobstoreBulkContext(int bulkId)

Method Detail

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)