Class PlatformAffinityFunctionTarget
- java.lang.Object
-
- org.apache.ignite.internal.processors.platform.PlatformAbstractTarget
-
- org.apache.ignite.internal.processors.platform.cache.affinity.PlatformAffinityFunctionTarget
-
- All Implemented Interfaces:
PlatformTarget
public class PlatformAffinityFunctionTarget extends PlatformAbstractTarget
Platform affinity function target: to be invoked when Platform function calls base implementation of one of the AffinityFunction methods.
-
-
Field Summary
-
Fields inherited from class org.apache.ignite.internal.processors.platform.PlatformAbstractTarget
ERROR, FALSE, log, platformCtx, TRUE
-
-
Constructor Summary
Constructors Modifier Constructor Description protectedPlatformAffinityFunctionTarget(PlatformContext platformCtx, AffinityFunction baseFunc)Constructor.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description longprocessInStreamOutLong(int type, BinaryRawReaderEx reader)Process IN operation.voidprocessOutStream(int type, BinaryRawWriterEx writer)Process OUT operation.-
Methods inherited from class org.apache.ignite.internal.processors.platform.PlatformAbstractTarget
convertException, platformContext, processInLongOutLong, processInObjectStreamOutObjectStream, processInStreamAsync, processInStreamOutLong, processInStreamOutObject, processInStreamOutStream, processOutObject, readAndListenFuture, readAndListenFuture, readAndListenFuture, throwUnsupported, wrapListenable
-
-
-
-
Constructor Detail
-
PlatformAffinityFunctionTarget
protected PlatformAffinityFunctionTarget(PlatformContext platformCtx, AffinityFunction baseFunc)
Constructor.- Parameters:
platformCtx- Context.baseFunc- Function to wrap.
-
-
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.
-
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.
-
-