org.apache.ignite.internal.processors.platform

Interface PlatformContext

public interface PlatformContext

Platform context. Acts as an entry point for platform operations.

Method Summary

Methods

Modifier and Type	Method and Description
void	addNode(ClusterNode node) Sends node info to native platform, if necessary.
PlatformCacheEntryFilter	createCacheEntryFilter(Object filter, long ptr) Create cache entry filter.
PlatformCacheEntryProcessor	createCacheEntryProcessor(Object proc, long ptr) Create cache entry processor.
PlatformJob	createClosureJob(Object task, long ptr, Object job) Create closure job.
PlatformClusterNodeFilter	createClusterNodeFilter(Object filter) Create cluster node filter.
PlatformContinuousQuery	createContinuousQuery(long ptr, boolean hasFilter, Object filter)
PlatformContinuousQueryFilter	createContinuousQueryFilter(Object filter) Create continuous query filter to be deployed on remote node.
PlatformJob	createJob(Object task, long ptr, Object job) Create job.
PlatformEventFilterListener	createLocalEventFilter(long hnd) Create local event filter.
PlatformNativeException	createNativeException(Object cause) Create native exception.
PlatformEventFilterListener	createRemoteEventFilter(Object pred, int... types) Create remote event filter.
PlatformMessageFilter	createRemoteMessageFilter(Object filter, long ptr) Create remote message filter.
PlatformStreamReceiver	createStreamReceiver(Object rcv, long ptr, boolean keepPortable) Create stream receiver.
PlatformCallbackGateway	gateway() Gets platform callback gateway.
boolean	isEventTypeSupported(int evtTyp) Check whether the given event type is supported.
GridKernalContext	kernalContext() Gets kernal context.
PlatformMemoryManager	memory() Gets platform memory manager.
void	processMetadata(PortableRawReaderEx reader) Process metadata from the platform.
PortableRawReaderEx	reader(PlatformInputStream in) Get memory reader.
PortableRawReaderEx	reader(PlatformMemory mem) Get memory reader.
void	writeAllMetadata(PortableRawWriterEx writer) Write all available metadata.
void	writeClusterMetrics(PortableRawWriterEx writer, ClusterMetrics metrics) Write cluster metrics.
void	writeEvent(PortableRawWriterEx writer, Event evt) Write event.
void	writeMetadata(PortableRawWriterEx writer, int typeId) Write metadata for the given type ID.
void	writeNode(PortableRawWriterEx writer, ClusterNode node) Writes a node id to a stream and sends node info to native platform, if necessary.
void	writeNodes(PortableRawWriterEx writer, Collection<ClusterNode> nodes) Writes multiple node ids to a stream and sends node info to native platform, if necessary.
PortableRawWriterEx	writer(PlatformMemory mem) Get memory writer.
PortableRawWriterEx	writer(PlatformOutputStream out) Get memory writer.

Method Detail

kernalContext

GridKernalContext kernalContext()

Gets kernal context.

Returns:

Kernal context.

memory

PlatformMemoryManager memory()

Gets platform memory manager.

Returns:

Memory manager.

gateway

PlatformCallbackGateway gateway()

Gets platform callback gateway.

Returns:

Callback gateway.

reader

PortableRawReaderEx reader(PlatformMemory mem)

Get memory reader.

Parameters:

mem - Memory.

Returns:

Reader.

reader

PortableRawReaderEx reader(PlatformInputStream in)

Get memory reader.

Parameters:

in - Input.

Returns:

Reader.

writer

PortableRawWriterEx writer(PlatformMemory mem)

Get memory writer.

Parameters:

mem - Memory.

Returns:

Writer.

writer

PortableRawWriterEx writer(PlatformOutputStream out)

Get memory writer.

Parameters:

out - Output.

Returns:

Writer.

addNode

void addNode(ClusterNode node)

Sends node info to native platform, if necessary.

Parameters:

node - Node.

writeNode

void writeNode(PortableRawWriterEx writer,
             ClusterNode node)

Writes a node id to a stream and sends node info to native platform, if necessary.

Parameters:

writer - Writer.

node - Node.

writeNodes

void writeNodes(PortableRawWriterEx writer,
              Collection<ClusterNode> nodes)

Writes multiple node ids to a stream and sends node info to native platform, if necessary.

Parameters:

writer - Writer.

nodes - Nodes.

processMetadata

void processMetadata(PortableRawReaderEx reader)

Process metadata from the platform.

Parameters:

reader - Reader.

writeMetadata

void writeMetadata(PortableRawWriterEx writer,
                 int typeId)

Write metadata for the given type ID.

Parameters:

writer - Writer.

typeId - Type ID.

writeAllMetadata

void writeAllMetadata(PortableRawWriterEx writer)

Write all available metadata.

Parameters:

writer - Writer.

writeClusterMetrics

void writeClusterMetrics(PortableRawWriterEx writer,
                       @Nullable
                       ClusterMetrics metrics)

Write cluster metrics.

Parameters:

writer - Writer.

metrics - Metrics.

createContinuousQuery

PlatformContinuousQuery createContinuousQuery(long ptr,
                                            boolean hasFilter,
                                            @Nullable
                                            Object filter)

Parameters:

ptr - Pointer to continuous query deployed on the platform.

hasFilter - Whether filter exists.

filter - Filter.

Returns:

Platform continuous query.

createContinuousQueryFilter

PlatformContinuousQueryFilter createContinuousQueryFilter(Object filter)

Create continuous query filter to be deployed on remote node.

Parameters:

filter - Native filter.

Returns:

Filter.

createRemoteMessageFilter

PlatformMessageFilter createRemoteMessageFilter(Object filter,
                                              long ptr)

Create remote message filter.

Parameters:

filter - Native filter.

ptr - Pointer of deployed native filter.

Returns:

Filter.

isEventTypeSupported

boolean isEventTypeSupported(int evtTyp)

Check whether the given event type is supported.

Parameters:

evtTyp - Event type.

Returns:

True if supported.

writeEvent

void writeEvent(PortableRawWriterEx writer,
              Event evt)

Write event.

Parameters:

writer - Writer.

evt - Event.

createLocalEventFilter

PlatformEventFilterListener createLocalEventFilter(long hnd)

Create local event filter.

Parameters:

hnd - Native handle.

Returns:

Filter.

createRemoteEventFilter

PlatformEventFilterListener createRemoteEventFilter(Object pred,
                                                  int... types)

Create remote event filter.

Parameters:

pred - Native predicate.

types - Event types.

Returns:

Filter.

createNativeException

PlatformNativeException createNativeException(Object cause)

Create native exception.

Parameters:

cause - Native cause.

Returns:

Exception.

createJob

PlatformJob createJob(Object task,
                    long ptr,
                    @Nullable
                    Object job)

Create job.

Parameters:

task - Task.

ptr - Pointer.

job - Native job.

Returns:

job.

createClosureJob

PlatformJob createClosureJob(Object task,
                           long ptr,
                           Object job)

Create closure job.

Parameters:

task - Native task.

ptr - Pointer.

job - Native job.

Returns:

Closure job.

createCacheEntryProcessor

PlatformCacheEntryProcessor createCacheEntryProcessor(Object proc,
                                                    long ptr)

Create cache entry processor.

Parameters:

proc - Native processor.

ptr - Pointer.

Returns:

Entry processor.

createCacheEntryFilter

PlatformCacheEntryFilter createCacheEntryFilter(Object filter,
                                              long ptr)

Create cache entry filter.

Parameters:

filter - Native filter.

ptr - Pointer.

Returns:

Entry filter.

createStreamReceiver

PlatformStreamReceiver createStreamReceiver(Object rcv,
                                          long ptr,
                                          boolean keepPortable)

Create stream receiver.

Parameters:

rcv - Native receiver.

ptr - Pointer.

keepPortable - Keep portable flag.

Returns:

Stream receiver.

createClusterNodeFilter

PlatformClusterNodeFilter createClusterNodeFilter(Object filter)

Create cluster node filter.

Parameters:

filter - Native filter.

Returns:

Cluster node filter.