Package org.apache.ignite.internal.processors.datastreamer

Class DataStreamProcessor<K,V>

java.lang.Object

org.apache.ignite.internal.processors.GridProcessorAdapter

org.apache.ignite.internal.processors.datastreamer.DataStreamProcessor<K,V>

All Implemented Interfaces:

GridComponent, GridProcessor

public class DataStreamProcessor<K,V>
extends GridProcessorAdapter

Data stream 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, diagnosticLog, log

Constructor Summary

Constructors

Constructor	Description
DataStreamProcessor(GridKernalContext ctx)

Method Summary

Modifier and Type	Method	Description
DataStreamerImpl<K,V>	dataStreamer(@Nullable String cacheName)
static byte	ioPolicy(@Nullable IgniteClosure<ClusterNode,Byte> rslvr, ClusterNode node)	Get IO policy for particular node with provided resolver.
void	onDisconnected(IgniteFuture<?> reconnectFut)	Client disconnected callback.
void	onKernalStop(boolean cancel)	Callback to notify that kernal is about to stop.
void	printMemoryStats()	Prints memory statistics (sizes of internal structures, etc.).
void	start()	Starts grid component.

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

assertParameter, collectGridNodeData, collectJoiningNodeData, discoveryDataType, onGridDataReceived, onJoiningNodeDataReceived, onKernalStart, onReconnected, stop, toString, validateNode, validateNode

Methods inherited from class java.lang.Object

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

Constructor Detail

DataStreamProcessor

public DataStreamProcessor(GridKernalContext ctx)

Parameters:

ctx - Kernal context.

Method Detail

start

public void start()
           throws IgniteCheckedException

Starts grid component.

Specified by:

start in interface GridComponent

Overrides:

start in class GridProcessorAdapter

Throws:

IgniteCheckedException - Throws in case of any errors.

onKernalStop

public void onKernalStop(boolean cancel)

Callback to notify that kernal is about to stop.

Specified by:

onKernalStop in interface GridComponent

Overrides:

onKernalStop in class GridProcessorAdapter

Parameters:

cancel - Flag indicating whether jobs should be canceled.

onDisconnected

public void onDisconnected(IgniteFuture<?> reconnectFut)
                    throws IgniteCheckedException

Client disconnected callback.

Specified by:

onDisconnected in interface GridComponent

Overrides:

onDisconnected in class GridProcessorAdapter

Parameters:

reconnectFut - Reconnect future.

Throws:

IgniteCheckedException - If failed.

dataStreamer

public DataStreamerImpl<K,V> dataStreamer(@Nullable
                                                @Nullable String cacheName)

Parameters:

cacheName - Cache name (null for default cache).

Returns:

Data loader.

ioPolicy

public static byte ioPolicy(@Nullable
                            @Nullable IgniteClosure<ClusterNode,Byte> rslvr,
                            ClusterNode node)

Get IO policy for particular node with provided resolver.

Parameters:

rslvr - Resolver.

node - Node.

Returns:

IO policy.

printMemoryStats

public void printMemoryStats()

Prints memory statistics (sizes of internal structures, etc.). NOTE: this method is for testing and profiling purposes only.

Specified by:

printMemoryStats in interface GridComponent

Overrides:

printMemoryStats in class GridProcessorAdapter