org.gridgain.grid.kernal.processors.streamer

Class GridStreamerStageWrapper

java.lang.Object

org.gridgain.grid.kernal.processors.streamer.GridStreamerStageWrapper

All Implemented Interfaces:

GridStreamerStage<Object>

public class GridStreamerStageWrapper
extends Object
implements GridStreamerStage<Object>

Stage wrapper that handles metrics calculation and time measurement.

Constructor Summary

Constructors

Constructor and Description
GridStreamerStageWrapper(GridStreamerStage<Object> delegate, int idx)

Method Summary

Methods

Modifier and Type	Method and Description
int	index()
String	name() Gets streamer stage name.
String	nextStageName()
void	nextStageName(String nextStageName)
Map<String,Collection<?>>	run(GridStreamerContext ctx, Collection<Object> evts) Stage execution routine.
String	toString()
GridStreamerStage	unwrap()

Methods inherited from class java.lang.Object

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

Constructor Detail

GridStreamerStageWrapper

public GridStreamerStageWrapper(GridStreamerStage<Object> delegate,
                        int idx)

Parameters:

delegate - Delegate stage.

idx - Index.

Method Detail

index

public int index()

Returns:

Stage index.

nextStageName

@Nullable
public String nextStageName()

Returns:

Next stage name in pipeline or null if this is the last stage.

nextStageName

public void nextStageName(String nextStageName)

Parameters:

nextStageName - Next stage name in pipeline.

name

public String name()

Gets streamer stage name.

Specified by:

name in interface GridStreamerStage<Object>

Returns:

Name of the stage.

run

public Map<String,Collection<?>> run(GridStreamerContext ctx,
                            Collection<Object> evts)
                              throws GridException

Stage execution routine. After the passed in events are processed, stage can emit another set of events to be processed. The returned events can be mapped to different stages. Events for every returned stage will be passed to GridStreamerEventRouter which will determine on which node the stage should be executed.

Generally, event stage execution graph if fully controlled by return values of this method, while node execution graph is controlled by GridStreamerEventRouter.route(GridStreamerContext, String, Object) method.

Specified by:

run in interface GridStreamerStage<Object>

Parameters:

ctx - Streamer context.

evts - Input events.

Returns:

Map of stage name to collection of events.

Throws:

GridException - If failed.

unwrap

public GridStreamerStage unwrap()

Returns:

Delegate.

toString

public String toString()

Overrides:

toString in class Object