org.apache.ignite.internal.processors.platform

Class PlatformNoopProcessor

java.lang.Object

org.apache.ignite.internal.processors.GridProcessorAdapter

org.apache.ignite.internal.processors.platform.PlatformNoopProcessor

All Implemented Interfaces:

GridComponent, GridProcessor, PlatformProcessor

public class PlatformNoopProcessor
extends GridProcessorAdapter
implements PlatformProcessor

No-op processor.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.ignite.internal.GridComponent

GridComponent.DiscoveryDataExchangeType

Field Summary

Fields inherited from class org.apache.ignite.internal.processors.GridProcessorAdapter

ctx, log

Constructor Summary

Constructors

Constructor and Description
PlatformNoopProcessor(GridKernalContext ctx)

Method Summary

Methods

Modifier and Type	Method and Description
PlatformTarget	affinity(String name) Get affinity.
void	awaitStart() Await until platform processor is safe to use (i.e.
PlatformTarget	cache(String name) Get cache.
PlatformTarget	compute(PlatformTarget grp) Create interop compute.
PlatformContext	context() Gets platform context.
PlatformTarget	createCache(String name) Create cache.
PlatformTarget	dataStreamer(String cacheName, boolean keepPortable) Get data streamer.
long	environmentPointer() Get environment pointer associated with this processor.
PlatformTarget	events(PlatformTarget grp) Create interop events.
PlatformTarget	extensions() Get platform extensions.
PlatformTarget	getOrCreateCache(String name) Get or create cache.
Ignite	ignite() Gets owning Ignite instance.
PlatformTarget	message(PlatformTarget grp) Create interop messaging.
PlatformTarget	projection() Get projection.
void	registerStore(PlatformCacheStore store, boolean convertPortable) Register cache store.
void	releaseStart() Notify processor that it is safe to use.
PlatformTarget	services(PlatformTarget grp) Create interop services.
PlatformTarget	transactions() Get transactions.

Methods inherited from class org.apache.ignite.internal.processors.GridProcessorAdapter

assertParameter, collectDiscoveryData, discoveryDataType, onDisconnected, onDiscoveryDataReceived, onKernalStart, onKernalStop, onReconnected, printMemoryStats, start, stop, toString, validateNode

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.ignite.internal.GridComponent

collectDiscoveryData, discoveryDataType, onDisconnected, onDiscoveryDataReceived, onKernalStart, onKernalStop, onReconnected, printMemoryStats, start, stop, validateNode

Constructor Detail

PlatformNoopProcessor

public PlatformNoopProcessor(GridKernalContext ctx)

Method Detail

ignite

public Ignite ignite()

Gets owning Ignite instance.

Specified by:

ignite in interface PlatformProcessor

Returns:

Ignite instance.

environmentPointer

public long environmentPointer()

Get environment pointer associated with this processor.

Specified by:

environmentPointer in interface PlatformProcessor

Returns:

Environment pointer.

context

public PlatformContext context()

Gets platform context.

Specified by:

context in interface PlatformProcessor

Returns:

Platform context.

releaseStart

public void releaseStart()

Notify processor that it is safe to use.

Specified by:

releaseStart in interface PlatformProcessor

awaitStart

public void awaitStart()
                throws IgniteCheckedException

Await until platform processor is safe to use (i.e. has been called.

Specified by:

awaitStart in interface PlatformProcessor

Throws:

IgniteCheckedException - If failed.

cache

public PlatformTarget cache(@Nullable
                   String name)
                     throws IgniteCheckedException

Get cache.

Specified by:

cache in interface PlatformProcessor

Parameters:

name - Cache name.

Returns:

Cache.

Throws:

IgniteCheckedException - If failed.

createCache

public PlatformTarget createCache(@Nullable
                         String name)
                           throws IgniteCheckedException

Create cache.

Specified by:

createCache in interface PlatformProcessor

Parameters:

name - Cache name.

Returns:

Cache.

Throws:

IgniteCheckedException - If failed.

getOrCreateCache

public PlatformTarget getOrCreateCache(@Nullable
                              String name)
                                throws IgniteCheckedException

Get or create cache.

Specified by:

getOrCreateCache in interface PlatformProcessor

Parameters:

name - Cache name.

Returns:

Cache.

Throws:

IgniteCheckedException - If failed.

affinity

public PlatformTarget affinity(@Nullable
                      String name)
                        throws IgniteCheckedException

Get affinity.

Specified by:

affinity in interface PlatformProcessor

Parameters:

name - Cache name.

Returns:

Affinity.

Throws:

IgniteCheckedException - If failed.

dataStreamer

public PlatformTarget dataStreamer(@Nullable
                          String cacheName,
                          boolean keepPortable)
                            throws IgniteCheckedException

Get data streamer.

Specified by:

dataStreamer in interface PlatformProcessor

Parameters:

cacheName - Cache name.

keepPortable - Portable flag.

Returns:

Data streamer.

Throws:

IgniteCheckedException - If failed.

transactions

public PlatformTarget transactions()

Get transactions.

Specified by:

transactions in interface PlatformProcessor

Returns:

Transactions.

projection

public PlatformTarget projection()
                          throws IgniteCheckedException

Get projection.

Specified by:

projection in interface PlatformProcessor

Returns:

Projection.

Throws:

IgniteCheckedException - If failed.

compute

public PlatformTarget compute(PlatformTarget grp)

Create interop compute.

Specified by:

compute in interface PlatformProcessor

Parameters:

grp - Cluster group.

Returns:

Compute instance.

message

public PlatformTarget message(PlatformTarget grp)

Create interop messaging.

Specified by:

message in interface PlatformProcessor

Parameters:

grp - Cluster group.

Returns:

Messaging instance.

events

public PlatformTarget events(PlatformTarget grp)

Create interop events.

Specified by:

events in interface PlatformProcessor

Parameters:

grp - Cluster group.

Returns:

Events instance.

services

public PlatformTarget services(PlatformTarget grp)

Create interop services.

Specified by:

services in interface PlatformProcessor

Parameters:

grp - Cluster group.

Returns:

Services instance.

extensions

public PlatformTarget extensions()

Get platform extensions. Override this method to provide any additional targets and operations you need.

Specified by:

extensions in interface PlatformProcessor

Returns:

Platform extensions.

registerStore

public void registerStore(PlatformCacheStore store,
                 boolean convertPortable)
                   throws IgniteCheckedException

Register cache store.

Specified by:

registerStore in interface PlatformProcessor

Parameters:

store - Store.

convertPortable - Convert portable flag.

Throws:

IgniteCheckedException - If failed.