Class PlatformCompute
- java.lang.Object
-
- org.apache.ignite.internal.processors.platform.PlatformAbstractTarget
-
- org.apache.ignite.internal.processors.platform.compute.PlatformCompute
-
- All Implemented Interfaces:
PlatformTarget
public class PlatformCompute extends PlatformAbstractTarget
Interop compute.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description protected classPlatformCompute.ComputeConvertingFutureWraps ComputeTaskFuture as IgniteInternalFuture.
-
Field Summary
-
Fields inherited from class org.apache.ignite.internal.processors.platform.PlatformAbstractTarget
ERROR, FALSE, log, platformCtx, TRUE
-
-
Constructor Summary
Constructors Constructor Description PlatformCompute(PlatformContext platformCtx, ClusterGroup grp, String platformAttr)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected ObjectexecuteJavaTask(BinaryRawReaderEx reader, boolean async)Execute task taking arguments from the given reader.longprocessInLongOutLong(int type, long val)Process IN operation.PlatformTargetprocessInStreamOutObject(int type, BinaryRawReaderEx reader)Process IN-OUT operation.voidprocessInStreamOutStream(int type, BinaryRawReaderEx reader, BinaryRawWriterEx writer)Process IN-OUT operation.protected Collection<UUID>readNodeIds(BinaryRawReaderEx reader)Read node IDs.-
Methods inherited from class org.apache.ignite.internal.processors.platform.PlatformAbstractTarget
convertException, platformContext, processInObjectStreamOutObjectStream, processInStreamAsync, processInStreamOutLong, processInStreamOutLong, processOutObject, processOutStream, readAndListenFuture, readAndListenFuture, readAndListenFuture, throwUnsupported, wrapListenable
-
-
-
-
Constructor Detail
-
PlatformCompute
public PlatformCompute(PlatformContext platformCtx, ClusterGroup grp, String platformAttr)
- Parameters:
platformCtx- Platform context.grp- Cluster group associated with this compute instance.
-
-
Method Detail
-
processInStreamOutObject
public PlatformTarget processInStreamOutObject(int type, BinaryRawReaderEx reader) throws IgniteCheckedException
Process IN-OUT operation.- Specified by:
processInStreamOutObjectin interfacePlatformTarget- Overrides:
processInStreamOutObjectin classPlatformAbstractTarget- Parameters:
type- Type.reader- Binary reader.- 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.
-
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.
-
executeJavaTask
protected Object executeJavaTask(BinaryRawReaderEx reader, boolean async) throws IgniteCheckedException
Execute task taking arguments from the given reader.- Parameters:
reader- Reader.async- Execute asynchronously flag.- Returns:
- Task result.
- Throws:
IgniteCheckedException- On error.
-
readNodeIds
protected Collection<UUID> readNodeIds(BinaryRawReaderEx reader)
Read node IDs.- Parameters:
reader- Reader.- Returns:
- Node IDs.
-
-