Class PlatformContinuousQueryProxy
- java.lang.Object
-
- org.apache.ignite.internal.processors.platform.PlatformAbstractTarget
-
- org.apache.ignite.internal.processors.platform.cache.query.PlatformContinuousQueryProxy
-
- All Implemented Interfaces:
PlatformTarget
public class PlatformContinuousQueryProxy extends PlatformAbstractTarget
Proxy that implements PlatformTarget.
-
-
Field Summary
-
Fields inherited from class org.apache.ignite.internal.processors.platform.PlatformAbstractTarget
ERROR, FALSE, log, platformCtx, TRUE
-
-
Constructor Summary
Constructors Constructor Description PlatformContinuousQueryProxy(PlatformContext platformCtx, PlatformContinuousQuery qry)Constructor.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description longprocessInLongOutLong(int type, long val)Process IN operation.PlatformTargetprocessOutObject(int type)Process OUT operation.-
Methods inherited from class org.apache.ignite.internal.processors.platform.PlatformAbstractTarget
convertException, platformContext, processInObjectStreamOutObjectStream, processInStreamAsync, processInStreamOutLong, processInStreamOutLong, processInStreamOutObject, processInStreamOutStream, processOutStream, readAndListenFuture, readAndListenFuture, readAndListenFuture, throwUnsupported, wrapListenable
-
-
-
-
Constructor Detail
-
PlatformContinuousQueryProxy
public PlatformContinuousQueryProxy(PlatformContext platformCtx, PlatformContinuousQuery qry)
Constructor.- Parameters:
platformCtx- Context.
-
-
Method Detail
-
processOutObject
public PlatformTarget processOutObject(int type) throws IgniteCheckedException
Process OUT operation.- Specified by:
processOutObjectin interfacePlatformTarget- Overrides:
processOutObjectin classPlatformAbstractTarget- Parameters:
type- Type.- 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.
-
-