| Modifier and Type | Method and Description |
|---|---|
void |
PlatformLogger.setContext(PlatformContext ctx)
Sets the context.
|
| Modifier and Type | Class and Description |
|---|---|
class |
PlatformContextImpl
Implementation of platform context.
|
| Modifier and Type | Field and Description |
|---|---|
protected PlatformContext |
PlatformAbstractPredicate.ctx
Interop processor.
|
protected PlatformContext |
PlatformExtendedException.ctx
Platform context.
|
protected PlatformContext |
PlatformTargetProxyImpl.platformCtx
Context.
|
protected PlatformContext |
PlatformAbstractTarget.platformCtx
Context.
|
| Modifier and Type | Method and Description |
|---|---|
PlatformContext |
PlatformExtendedException.context() |
PlatformContext |
PlatformNoopProcessor.context()
Gets platform context.
|
PlatformContext |
PlatformProcessorImpl.context()
Gets platform context.
|
PlatformContext |
PlatformProcessor.context()
Gets platform context.
|
PlatformContext |
PlatformAbstractTarget.platformContext() |
| Constructor and Description |
|---|
PlatformAbstractPredicate(Object pred,
long ptr,
PlatformContext ctx)
Constructor.
|
PlatformAbstractTarget(PlatformContext platformCtx)
Constructor.
|
PlatformExtendedException(Throwable cause,
PlatformContext ctx)
Constructor.
|
PlatformTargetProxyImpl(PlatformTarget target,
PlatformContext platformCtx) |
| Constructor and Description |
|---|
PlatformBinaryProcessor(PlatformContext platformCtx)
Constructor.
|
| Constructor and Description |
|---|
PlatformCache(PlatformContext platformCtx,
IgniteCache cache,
boolean keepBinary)
Constructor.
|
PlatformCache(PlatformContext platformCtx,
IgniteCache cache,
boolean keepBinary,
PlatformCacheExtension[] exts)
Constructor.
|
PlatformCacheEntryFilterImpl(Object pred,
long ptr,
PlatformContext ctx)
Constructor.
|
PlatformCacheIterator(PlatformContext platformCtx,
Iterator<javax.cache.Cache.Entry> iter)
Constructor.
|
PlatformCachePartialUpdateException(CachePartialUpdateCheckedException cause,
PlatformContext ctx,
boolean keepBinary)
Constructor.
|
| Modifier and Type | Method and Description |
|---|---|
static List<List<ClusterNode>> |
PlatformAffinityUtils.readPartitionAssignment(BinaryRawReader reader,
PlatformContext ctx)
Reads the partition assignment.
|
static void |
PlatformAffinityUtils.writeAffinityFunctionContext(AffinityFunctionContext affCtx,
BinaryRawWriterEx writer,
PlatformContext ctx)
Writes the affinity function context.
|
static void |
PlatformAffinityUtils.writePartitionAssignment(Collection<List<ClusterNode>> partitions,
BinaryRawWriterEx writer,
PlatformContext ctx)
Writes the partition assignment to a stream.
|
| Constructor and Description |
|---|
PlatformAffinity(PlatformContext platformCtx,
GridKernalContext igniteCtx,
String name)
Constructor.
|
PlatformAffinityFunctionTarget(PlatformContext platformCtx,
AffinityFunction baseFunc)
Constructor.
|
| Modifier and Type | Field and Description |
|---|---|
protected PlatformContext |
PlatformContinuousQueryImpl.platformCtx
Context.
|
| Constructor and Description |
|---|
PlatformAbstractQueryCursor(PlatformContext platformCtx,
QueryCursorEx<T> cursor,
int batchSize)
Constructor.
|
PlatformContinuousQueryImpl(PlatformContext platformCtx,
long ptr,
boolean hasFilter,
Object filter)
Constructor.
|
PlatformContinuousQueryProxy(PlatformContext platformCtx,
PlatformContinuousQuery qry)
Constructor.
|
PlatformFieldsQueryCursor(PlatformContext platformCtx,
QueryCursorEx<List<?>> cursor,
int batchSize)
Constructor.
|
PlatformQueryCursor(PlatformContext platformCtx,
QueryCursorEx<javax.cache.Cache.Entry> cursor,
int batchSize)
Constructor.
|
| Constructor and Description |
|---|
PlatformClusterGroup(PlatformContext platformCtx,
ClusterGroupEx prj)
Constructor.
|
PlatformClusterNodeFilterImpl(Object pred,
PlatformContext ctx)
Constructor.
|
| Modifier and Type | Field and Description |
|---|---|
protected PlatformContext |
PlatformAbstractTask.ctx
Platform context.
|
| Modifier and Type | Method and Description |
|---|---|
protected boolean |
PlatformAbstractJob.createJob(PlatformContext ctx)
Create job in native platform if needed.
|
Object |
PlatformFullJob.execute0(PlatformContext ctx)
Internal job execution routine.
|
Object |
PlatformClosureJob.execute0(PlatformContext ctx)
Internal job execution routine.
|
protected abstract Object |
PlatformAbstractJob.execute0(PlatformContext ctx)
Internal job execution routine.
|
protected Object |
PlatformAbstractJob.runLocal(PlatformContext ctx,
boolean cancel)
Run local job.
|
| Constructor and Description |
|---|
PlatformAbstractTask(PlatformContext ctx,
long taskPtr)
Constructor.
|
PlatformBalancingMultiClosureTask(PlatformContext ctx,
long taskPtr)
Constructor.
|
PlatformBalancingSingleClosureAffinityTask(PlatformContext ctx,
long taskPtr)
Constructor.
|
PlatformBalancingSingleClosureTask(PlatformContext ctx,
long taskPtr)
Constructor.
|
PlatformBroadcastingMultiClosureTask(PlatformContext ctx,
long taskPtr)
Constructor.
|
PlatformBroadcastingSingleClosureTask(PlatformContext ctx,
long taskPtr)
Constructor.
|
PlatformCompute(PlatformContext platformCtx,
ClusterGroup grp,
String platformAttr)
Constructor.
|
PlatformFullJob(PlatformContext ctx,
PlatformAbstractTask task,
long ptr,
Object job)
Constructor.
|
PlatformFullTask(PlatformContext ctx,
IgniteComputeImpl compute,
long taskPtr,
long topVer)
Constructor.
|
| Constructor and Description |
|---|
PlatformDataStreamer(PlatformContext platformCtx,
String cacheName,
DataStreamerImpl ldr,
boolean keepBinary)
Constructor.
|
PlatformStreamReceiverImpl(Object pred,
long ptr,
boolean keepBinary,
PlatformContext ctx)
Constructor.
|
| Modifier and Type | Method and Description |
|---|---|
static PlatformAtomicReference |
PlatformAtomicReference.createInstance(PlatformContext ctx,
String name,
long memPtr,
boolean create)
Creates an instance or returns null.
|
| Constructor and Description |
|---|
PlatformAtomicLong(PlatformContext ctx,
GridCacheAtomicLongImpl atomicLong)
Ctor.
|
PlatformAtomicSequence(PlatformContext ctx,
IgniteAtomicSequence atomicSeq)
Ctor.
|
| Modifier and Type | Field and Description |
|---|---|
protected PlatformContext |
PlatformDotNetCacheStore.platformCtx
Interop processor.
|
| Constructor and Description |
|---|
PlatformDotNetServiceImpl(Object svc,
PlatformContext ctx,
boolean srvKeepBinary)
Constructor.
|
| Constructor and Description |
|---|
PlatformEventFilterListenerImpl(long hnd,
PlatformContext ctx)
Constructor.
|
PlatformEvents(PlatformContext platformCtx,
IgniteEvents events)
Ctor.
|
| Modifier and Type | Field and Description |
|---|---|
protected PlatformContext |
PlatformMessageLocalFilter.platformCtx |
| Constructor and Description |
|---|
PlatformMessageFilterImpl(Object pred,
long ptr,
PlatformContext ctx)
Constructor.
|
PlatformMessageLocalFilter(long hnd,
PlatformContext ctx)
Constructor.
|
PlatformMessaging(PlatformContext platformCtx,
IgniteMessaging messaging)
Ctor.
|
| Modifier and Type | Field and Description |
|---|---|
protected PlatformContext |
PlatformAbstractService.platformCtx
Context.
|
| Constructor and Description |
|---|
PlatformAbstractService(Object svc,
PlatformContext ctx,
boolean srvKeepBinary)
Constructor.
|
PlatformServices(PlatformContext platformCtx,
IgniteServices services,
boolean srvKeepBinary)
Ctor.
|
| Constructor and Description |
|---|
PlatformTransactions(PlatformContext platformCtx)
Constructor.
|
| Modifier and Type | Method and Description |
|---|---|
static PlatformContext |
PlatformUtils.platformContext(Ignite grid)
Gets interop context for the grid.
|
| Modifier and Type | Method and Description |
|---|---|
static void |
PlatformUtils.applyContinuousQueryEvents(PlatformContext ctx,
long lsnrPtr,
Iterable<javax.cache.event.CacheEntryEvent> evts)
Apply continuous query events to listener.
|
static boolean |
PlatformUtils.evaluateContinuousQueryEvent(PlatformContext ctx,
long filterPtr,
javax.cache.event.CacheEntryEvent evt)
Evaluate the filter.
|
static PlatformListenable |
PlatformFutureUtils.listen(PlatformContext ctx,
IgniteFuture fut,
long futPtr,
int typ,
PlatformFutureUtils.Writer writer,
PlatformTarget target)
Listen future.
|
static PlatformListenable |
PlatformFutureUtils.listen(PlatformContext ctx,
IgniteFuture fut,
long futPtr,
int typ,
PlatformTarget target)
Listen future.
|
static PlatformListenable |
PlatformFutureUtils.listen(PlatformContext ctx,
IgniteInternalFuture fut,
long futPtr,
int typ,
PlatformFutureUtils.Writer writer,
PlatformTarget target)
Listen future.
|
static PlatformListenable |
PlatformFutureUtils.listen(PlatformContext ctx,
IgniteInternalFuture fut,
long futPtr,
int typ,
PlatformTarget target)
Listen future.
|
static PlatformListenable |
PlatformFutureUtils.listen(PlatformContext ctx,
IgniteInternalFuture fut,
long futPtr,
PlatformFutureUtils.Writer writer,
PlatformTarget target)
Listen future.
|
static void |
PlatformFutureUtils.listen(PlatformContext ctx,
PlatformListenable listenable,
long futPtr,
int typ,
PlatformFutureUtils.Writer writer,
PlatformTarget target)
Listen future.
|
static Object |
PlatformUtils.readInvocationResult(PlatformContext ctx,
BinaryRawReaderEx reader)
Reads invocation result (of a job/service/etc) using a common protocol.
|
| Constructor and Description |
|---|
PlatformListenableTarget(PlatformListenable listenable,
PlatformContext platformCtx)
Constructor.
|
Follow @ApacheIgnite
Ignite Fabric : ver. 1.9.0 Release Date : March 2 2017