org.apache.ignite.internal.processors.cache

Class CacheOperationContext

java.lang.Object

org.apache.ignite.internal.processors.cache.CacheOperationContext

All Implemented Interfaces:

Serializable

public class CacheOperationContext
extends Object
implements Serializable

Cache operation context.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static boolean	DFLT_ALLOW_ATOMIC_OPS_IN_TX

Constructor Summary

Constructors

Constructor and Description
CacheOperationContext() Constructor with default values.
CacheOperationContext(boolean skipStore, @Nullable UUID subjId, boolean keepBinary, @Nullable javax.cache.expiry.ExpiryPolicy expiryPlc, boolean noRetries, @Nullable Byte dataCenterId, boolean recovery, boolean readRepair, boolean allowAtomicOpsInTx)

Method Summary

Modifier and Type	Method and Description
boolean	allowedAtomicOpsInTx()
@Nullable Byte	dataCenterId() Gets data center ID.
@Nullable javax.cache.expiry.ExpiryPolicy	expiry()
CacheOperationContext	forSubjectId(UUID subjId) See IgniteInternalCache.forSubjectId(UUID).
boolean	hasDataCenterId()
boolean	isKeepBinary()
CacheOperationContext	keepBinary() See IgniteInternalCache.keepBinary().
boolean	noRetries()
boolean	readRepair()
boolean	recovery()
CacheOperationContext	setAllowAtomicOpsInTx()
CacheOperationContext	setDataCenterId(byte dataCenterId)
CacheOperationContext	setNoRetries(boolean noRetries)
CacheOperationContext	setReadRepair(boolean readRepair)
CacheOperationContext	setRecovery(boolean recovery)
CacheOperationContext	setSkipStore(boolean skipStore) See IgniteInternalCache.setSkipStore(boolean).
boolean	skipStore()
@Nullable UUID	subjectId() Gets client ID for which this projection was created.
String	toString()
CacheOperationContext	withExpiryPolicy(javax.cache.expiry.ExpiryPolicy plc) See IgniteInternalCache.withExpiryPolicy(ExpiryPolicy).

Methods inherited from class java.lang.Object

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

Field Detail

DFLT_ALLOW_ATOMIC_OPS_IN_TX

public static final boolean DFLT_ALLOW_ATOMIC_OPS_IN_TX

Constructor Detail

CacheOperationContext

public CacheOperationContext()

Constructor with default values.

CacheOperationContext

public CacheOperationContext(boolean skipStore,
                             @Nullable
                             @Nullable UUID subjId,
                             boolean keepBinary,
                             @Nullable
                             @Nullable javax.cache.expiry.ExpiryPolicy expiryPlc,
                             boolean noRetries,
                             @Nullable
                             @Nullable Byte dataCenterId,
                             boolean recovery,
                             boolean readRepair,
                             boolean allowAtomicOpsInTx)

Parameters:

skipStore - Skip store flag.

subjId - Subject ID.

keepBinary - Keep binary flag.

expiryPlc - Expiry policy.

dataCenterId - Data center id.

readRepair - Read-repair flag.

Method Detail

isKeepBinary

public boolean isKeepBinary()

Returns:

Keep binary flag.

hasDataCenterId

public boolean hasDataCenterId()

Returns:

True if data center id is set otherwise false.

keepBinary

public CacheOperationContext keepBinary()

See IgniteInternalCache.keepBinary().

Returns:

New instance of CacheOperationContext with keep binary flag.

subjectId

@Nullable
public @Nullable UUID subjectId()

Gets client ID for which this projection was created.

Returns:

Client ID.

dataCenterId

@Nullable
public @Nullable Byte dataCenterId()

Gets data center ID.

Returns:

Datacenter ID.

forSubjectId

public CacheOperationContext forSubjectId(UUID subjId)

See IgniteInternalCache.forSubjectId(UUID).

Parameters:

subjId - Subject id.

Returns:

New instance of CacheOperationContext with specific subject id.

skipStore

public boolean skipStore()

Returns:

Skip store.

setSkipStore

public CacheOperationContext setSkipStore(boolean skipStore)

See IgniteInternalCache.setSkipStore(boolean).

Parameters:

skipStore - Skip store flag.

Returns:

New instance of CacheOperationContext with skip store flag.

expiry

@Nullable
public @Nullable javax.cache.expiry.ExpiryPolicy expiry()

Returns:

ExpiryPolicy associated with this projection.

withExpiryPolicy

public CacheOperationContext withExpiryPolicy(javax.cache.expiry.ExpiryPolicy plc)

See IgniteInternalCache.withExpiryPolicy(ExpiryPolicy).

Parameters:

plc - ExpiryPolicy to associate with this projection.

Returns:

New instance of CacheOperationContext with skip store flag.

setNoRetries

public CacheOperationContext setNoRetries(boolean noRetries)

Parameters:

noRetries - No retries flag.

Returns:

Operation context.

setDataCenterId

public CacheOperationContext setDataCenterId(byte dataCenterId)

Parameters:

dataCenterId - Data center id.

Returns:

Operation context.

setRecovery

public CacheOperationContext setRecovery(boolean recovery)

Parameters:

recovery - Recovery flag.

Returns:

New instance of CacheOperationContext with recovery flag.

setReadRepair

public CacheOperationContext setReadRepair(boolean readRepair)

Parameters:

readRepair - Read Repair flag.

Returns:

New instance of CacheOperationContext with Read Repair flag.

recovery

public boolean recovery()

Returns:

Partition recover flag.

readRepair

public boolean readRepair()

Returns:

Read Repair flag.

noRetries

public boolean noRetries()

Returns:

No retries flag.

setAllowAtomicOpsInTx

public CacheOperationContext setAllowAtomicOpsInTx()

Returns:

Operation context.

allowedAtomicOpsInTx

public boolean allowedAtomicOpsInTx()

Returns:

Allow in transactions flag.

toString

public String toString()

Overrides:

toString in class Object