org.apache.ignite.internal.processors.platform.compute

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.

Field Summary

Fields

Modifier and Type	Field and Description
protected ThreadLocal<IgniteFuture<?>>	curFut Future for previous asynchronous operation.

Fields inherited from class org.apache.ignite.internal.processors.platform.PlatformAbstractTarget

FALSE, log, platformCtx, TRUE

Constructor Summary

Constructors

Constructor and Description
PlatformCompute(PlatformContext platformCtx, IgniteComputeImpl compute) Constructor.

Method Summary

Methods

Modifier and Type	Method and Description
protected IgniteCompute	computeForTask(Collection<UUID> nodeIds) Get compute object for the given node IDs.
protected IgniteFuture	currentFuture()
protected Object	executeJavaTask(BinaryRawReaderEx reader, boolean async) Execute task taking arguments from the given reader.
void	executeNative(long taskPtr, long topVer) Execute native full-fledged task.
protected long	processInStreamOutLong(int type, BinaryRawReaderEx reader) Process IN operation.
protected void	processInStreamOutStream(int type, BinaryRawReaderEx reader, BinaryRawWriterEx writer) Process IN-OUT operation.
protected Collection<UUID>	readNodeIds(BinaryRawReaderEx reader) Read node IDs.
void	withNoFailover() Set "withNoFailover" state.
void	withTimeout(long timeout) Set "withTimeout" state.

Methods inherited from class org.apache.ignite.internal.processors.platform.PlatformAbstractTarget

convertException, currentFutureWrapped, futureWriter, inObjectStreamOutStream, inStreamOutLong, inStreamOutObject, inStreamOutStream, listenFuture, listenFutureForOperation, outLong, outObject, outStream, platformContext, processInObjectStreamOutStream, processInStreamOutObject, processOutLong, processOutObject, processOutStream, throwUnsupported

Methods inherited from class java.lang.Object

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

Field Detail

curFut

protected ThreadLocal<IgniteFuture<?>> curFut

Future for previous asynchronous operation.

Constructor Detail

PlatformCompute

public PlatformCompute(PlatformContext platformCtx,
               IgniteComputeImpl compute)

Constructor.

Parameters:

platformCtx - Context.

compute - Compute instance.

Method Detail

processInStreamOutLong

protected long processInStreamOutLong(int type,
                          BinaryRawReaderEx reader)
                               throws IgniteCheckedException

Process IN operation.

Overrides:

processInStreamOutLong in class PlatformAbstractTarget

Parameters:

type - Type.

reader - Portable reader.

Returns:

Result.

Throws:

IgniteCheckedException - In case of exception.

processInStreamOutStream

protected void processInStreamOutStream(int type,
                            BinaryRawReaderEx reader,
                            BinaryRawWriterEx writer)
                                 throws IgniteCheckedException

Process IN-OUT operation.

Overrides:

processInStreamOutStream in class PlatformAbstractTarget

Parameters:

type - Type.

reader - Portable reader.

writer - Portable writer.

Throws:

IgniteCheckedException - In case of exception.

executeNative

public void executeNative(long taskPtr,
                 long topVer)

Execute native full-fledged task.

Parameters:

taskPtr - Pointer to the task.

topVer - Topology version.

withTimeout

public void withTimeout(long timeout)

Set "withTimeout" state.

Parameters:

timeout - Timeout (milliseconds).

withNoFailover

public void withNoFailover()

Set "withNoFailover" state.

currentFuture

protected IgniteFuture currentFuture()
                              throws IgniteCheckedException

Overrides:

currentFuture in class PlatformAbstractTarget

Returns:

current future.

Throws:

IgniteCheckedException

executeJavaTask

protected Object executeJavaTask(BinaryRawReaderEx reader,
                     boolean async)

Execute task taking arguments from the given reader.

Parameters:

reader - Reader.

Returns:

Task result.

readNodeIds

protected Collection<UUID> readNodeIds(BinaryRawReaderEx reader)

Read node IDs.

Parameters:

reader - Reader.

Returns:

Node IDs.

computeForTask

protected IgniteCompute computeForTask(Collection<UUID> nodeIds)

Get compute object for the given node IDs.

Parameters:

nodeIds - Node IDs.

Returns:

Compute object.