Class PlatformAffinity
- java.lang.Object
-
- org.apache.ignite.internal.processors.platform.PlatformAbstractTarget
-
- org.apache.ignite.internal.processors.platform.cache.affinity.PlatformAffinity
-
- All Implemented Interfaces:
PlatformTarget
public class PlatformAffinity extends PlatformAbstractTarget
Affinity wrapper for platforms.
-
-
Field Summary
Fields Modifier and Type Field Description static intOP_AFFINITY_KEYstatic intOP_ALL_PARTITIONSstatic intOP_BACKUP_PARTITIONSstatic intOP_IS_BACKUPstatic intOP_IS_PRIMARYstatic intOP_IS_PRIMARY_OR_BACKUPstatic intOP_MAP_KEY_TO_NODEstatic intOP_MAP_KEY_TO_PRIMARY_AND_BACKUPSstatic intOP_MAP_KEYS_TO_NODESstatic intOP_MAP_PARTITION_TO_NODEstatic intOP_MAP_PARTITION_TO_PRIMARY_AND_BACKUPSstatic intOP_MAP_PARTITIONS_TO_NODESstatic intOP_PARTITIONstatic intOP_PARTITIONSstatic intOP_PRIMARY_PARTITIONS-
Fields inherited from class org.apache.ignite.internal.processors.platform.PlatformAbstractTarget
ERROR, FALSE, log, platformCtx, TRUE
-
-
Constructor Summary
Constructors Constructor Description PlatformAffinity(PlatformContext platformCtx, @Nullable String name)Constructor.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description longprocessInLongOutLong(int type, long val)Process IN operation.longprocessInStreamOutLong(int type, BinaryRawReaderEx reader)Process IN operation.voidprocessInStreamOutStream(int type, BinaryRawReaderEx reader, BinaryRawWriterEx writer)Process IN-OUT operation.-
Methods inherited from class org.apache.ignite.internal.processors.platform.PlatformAbstractTarget
convertException, platformContext, processInObjectStreamOutObjectStream, processInStreamAsync, processInStreamOutLong, processInStreamOutObject, processOutObject, processOutStream, readAndListenFuture, readAndListenFuture, readAndListenFuture, throwUnsupported, wrapListenable
-
-
-
-
Field Detail
-
OP_AFFINITY_KEY
public static final int OP_AFFINITY_KEY
- See Also:
- Constant Field Values
-
OP_ALL_PARTITIONS
public static final int OP_ALL_PARTITIONS
- See Also:
- Constant Field Values
-
OP_BACKUP_PARTITIONS
public static final int OP_BACKUP_PARTITIONS
- See Also:
- Constant Field Values
-
OP_IS_BACKUP
public static final int OP_IS_BACKUP
- See Also:
- Constant Field Values
-
OP_IS_PRIMARY
public static final int OP_IS_PRIMARY
- See Also:
- Constant Field Values
-
OP_IS_PRIMARY_OR_BACKUP
public static final int OP_IS_PRIMARY_OR_BACKUP
- See Also:
- Constant Field Values
-
OP_MAP_KEY_TO_NODE
public static final int OP_MAP_KEY_TO_NODE
- See Also:
- Constant Field Values
-
OP_MAP_KEY_TO_PRIMARY_AND_BACKUPS
public static final int OP_MAP_KEY_TO_PRIMARY_AND_BACKUPS
- See Also:
- Constant Field Values
-
OP_MAP_KEYS_TO_NODES
public static final int OP_MAP_KEYS_TO_NODES
- See Also:
- Constant Field Values
-
OP_MAP_PARTITION_TO_NODE
public static final int OP_MAP_PARTITION_TO_NODE
- See Also:
- Constant Field Values
-
OP_MAP_PARTITION_TO_PRIMARY_AND_BACKUPS
public static final int OP_MAP_PARTITION_TO_PRIMARY_AND_BACKUPS
- See Also:
- Constant Field Values
-
OP_MAP_PARTITIONS_TO_NODES
public static final int OP_MAP_PARTITIONS_TO_NODES
- See Also:
- Constant Field Values
-
OP_PARTITION
public static final int OP_PARTITION
- See Also:
- Constant Field Values
-
OP_PRIMARY_PARTITIONS
public static final int OP_PRIMARY_PARTITIONS
- See Also:
- Constant Field Values
-
OP_PARTITIONS
public static final int OP_PARTITIONS
- See Also:
- Constant Field Values
-
-
Constructor Detail
-
PlatformAffinity
public PlatformAffinity(PlatformContext platformCtx, @Nullable @Nullable String name) throws IgniteCheckedException
Constructor.- Parameters:
platformCtx- Context.name- Cache name.- Throws:
IgniteCheckedException
-
-
Method Detail
-
processInStreamOutLong
public long processInStreamOutLong(int type, BinaryRawReaderEx reader) throws IgniteCheckedExceptionProcess IN operation.- Specified by:
processInStreamOutLongin interfacePlatformTarget- Overrides:
processInStreamOutLongin classPlatformAbstractTarget- Parameters:
type- Type.reader- Binary reader.- Returns:
- Result.
- Throws:
IgniteCheckedException- In case of exception.
-
processInStreamOutStream
public void processInStreamOutStream(int type, BinaryRawReaderEx reader, BinaryRawWriterEx writer) throws IgniteCheckedExceptionProcess IN-OUT operation.- Specified by:
processInStreamOutStreamin interfacePlatformTarget- Overrides:
processInStreamOutStreamin classPlatformAbstractTarget- Parameters:
type- Type.reader- Binary reader.writer- Binary writer.- Throws:
IgniteCheckedException- In case of exception.
-
processInLongOutLong
public long processInLongOutLong(int type, long val) throws IgniteCheckedExceptionProcess IN operation.- Specified by:
processInLongOutLongin interfacePlatformTarget- Overrides:
processInLongOutLongin classPlatformAbstractTarget- Parameters:
type- Type.val- Value.- Returns:
- Result.
- Throws:
IgniteCheckedException- In case of exception.
-
-