org.apache.ignite.internal.processors.streamer

Class GridStreamProcessor

java.lang.Object

org.apache.ignite.internal.processors.GridProcessorAdapter

org.apache.ignite.internal.processors.streamer.GridStreamProcessor

All Implemented Interfaces:

GridComponent, GridProcessor

public class GridStreamProcessor
extends GridProcessorAdapter

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
GridStreamProcessor(GridKernalContext ctx)

Method Summary

Methods

Modifier and Type	Method and Description
void	onKernalStart() Callback that notifies that kernal has successfully started, including all managers and processors.
void	onKernalStop(boolean cancel) Callback to notify that kernal is about to stop.
void	onUndeployed(ClassLoader ldr) Callback for undeployed class loaders.
void	start() Starts grid component.
void	stop(boolean cancel) Stops grid component.
IgniteStreamer	streamer()
IgniteStreamer	streamer(String name)
Collection<IgniteStreamer>	streamers()

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

assertParameter, collectDiscoveryData, discoveryDataType, onDiscoveryDataReceived, printMemoryStats, toString, validateNode

Methods inherited from class java.lang.Object

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

Constructor Detail

GridStreamProcessor

public GridStreamProcessor(GridKernalContext ctx)

Parameters:

ctx - Kernal context.

Method Detail

onKernalStart

public void onKernalStart()
                   throws IgniteCheckedException

Callback that notifies that kernal has successfully started, including all managers and processors.

Specified by:

onKernalStart in interface GridComponent

Overrides:

onKernalStart in class GridProcessorAdapter

Throws:

IgniteCheckedException - Thrown in case of any errors.

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.

stop

public void stop(boolean cancel)
          throws IgniteCheckedException

Stops grid component.

Specified by:

stop in interface GridComponent

Overrides:

stop in class GridProcessorAdapter

Parameters:

cancel - If true, then all ongoing tasks or jobs for relevant components need to be cancelled.

Throws:

IgniteCheckedException - Thrown in case of any errors.

streamer

public IgniteStreamer streamer()

Returns:

Default no-name streamer.

streamer

public IgniteStreamer streamer(@Nullable
                      String name)

Parameters:

name - Streamer name.

Returns:

Streamer for given name.

streamers

public Collection<IgniteStreamer> streamers()

Returns:

All configured streamers.

onUndeployed

public void onUndeployed(ClassLoader ldr)

Callback for undeployed class loaders.

Parameters:

ldr - Class loader.