Class PlatformTransactions
- java.lang.Object
-
- org.apache.ignite.internal.processors.platform.PlatformAbstractTarget
-
- org.apache.ignite.internal.processors.platform.transactions.PlatformTransactions
-
- All Implemented Interfaces:
PlatformTarget
public class PlatformTransactions extends PlatformAbstractTarget
Native transaction wrapper implementation.
-
-
Field Summary
Fields Modifier and Type Field Description static intOP_CACHE_CONFIG_PARAMETERSstatic intOP_CLOSEstatic intOP_COMMITstatic intOP_COMMIT_ASYNCstatic intOP_LOCAL_ACTIVE_REMOVEstatic intOP_LOCAL_ACTIVE_TXstatic intOP_METRICSstatic intOP_PREPAREstatic intOP_RESET_METRICSstatic intOP_ROLLBACKstatic intOP_ROLLBACK_ASYNCstatic intOP_SET_ROLLBACK_ONLYstatic intOP_STARTstatic intOP_STATE-
Fields inherited from class org.apache.ignite.internal.processors.platform.PlatformAbstractTarget
ERROR, FALSE, log, platformCtx, TRUE
-
-
Constructor Summary
Constructors Constructor Description PlatformTransactions(PlatformContext platformCtx)Constructor.PlatformTransactions(PlatformContext platformCtx, String lbl)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.voidprocessOutStream(int type, BinaryRawWriterEx writer)Process OUT operation.-
Methods inherited from class org.apache.ignite.internal.processors.platform.PlatformAbstractTarget
convertException, platformContext, processInObjectStreamOutObjectStream, processInStreamAsync, processInStreamOutLong, processInStreamOutObject, processOutObject, readAndListenFuture, readAndListenFuture, readAndListenFuture, throwUnsupported, wrapListenable
-
-
-
-
Field Detail
-
OP_CACHE_CONFIG_PARAMETERS
public static final int OP_CACHE_CONFIG_PARAMETERS
- See Also:
- Constant Field Values
-
OP_METRICS
public static final int OP_METRICS
- See Also:
- Constant Field Values
-
OP_START
public static final int OP_START
- See Also:
- Constant Field Values
-
OP_COMMIT
public static final int OP_COMMIT
- See Also:
- Constant Field Values
-
OP_ROLLBACK
public static final int OP_ROLLBACK
- See Also:
- Constant Field Values
-
OP_CLOSE
public static final int OP_CLOSE
- See Also:
- Constant Field Values
-
OP_STATE
public static final int OP_STATE
- See Also:
- Constant Field Values
-
OP_SET_ROLLBACK_ONLY
public static final int OP_SET_ROLLBACK_ONLY
- See Also:
- Constant Field Values
-
OP_COMMIT_ASYNC
public static final int OP_COMMIT_ASYNC
- See Also:
- Constant Field Values
-
OP_ROLLBACK_ASYNC
public static final int OP_ROLLBACK_ASYNC
- See Also:
- Constant Field Values
-
OP_RESET_METRICS
public static final int OP_RESET_METRICS
- See Also:
- Constant Field Values
-
OP_PREPARE
public static final int OP_PREPARE
- See Also:
- Constant Field Values
-
OP_LOCAL_ACTIVE_TX
public static final int OP_LOCAL_ACTIVE_TX
- See Also:
- Constant Field Values
-
OP_LOCAL_ACTIVE_REMOVE
public static final int OP_LOCAL_ACTIVE_REMOVE
- See Also:
- Constant Field Values
-
-
Constructor Detail
-
PlatformTransactions
public PlatformTransactions(PlatformContext platformCtx)
Constructor.- Parameters:
platformCtx- Context.
-
PlatformTransactions
public PlatformTransactions(PlatformContext platformCtx, String lbl)
Constructor.- Parameters:
platformCtx- Context.lbl- Label.
-
-
Method Detail
-
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.
-
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.
-
processOutStream
public void processOutStream(int type, BinaryRawWriterEx writer) throws IgniteCheckedExceptionProcess OUT operation.- Specified by:
processOutStreamin interfacePlatformTarget- Overrides:
processOutStreamin classPlatformAbstractTarget- Parameters:
type- Type.writer- Binary writer.- Throws:
IgniteCheckedException- In case of exception.
-
-