org.gridgain.grid.kernal.processors.ggfs

Class GridNoopGgfsProcessor

java.lang.Object

org.gridgain.grid.kernal.processors.GridProcessorAdapter

org.gridgain.grid.kernal.processors.ggfs.GridGgfsProcessorAdapter

org.gridgain.grid.kernal.processors.ggfs.GridNoopGgfsProcessor

All Implemented Interfaces:

GridComponent, GridProcessor

public class GridNoopGgfsProcessor
extends GridGgfsProcessorAdapter

Nop GGFS processor implementation.

Field Summary

Fields inherited from class org.gridgain.grid.kernal.processors.GridProcessorAdapter

ctx, log

Constructor Summary

Constructors

Constructor and Description
GridNoopGgfsProcessor(GridKernalContext ctx) Constructor.

Method Summary

Methods

Modifier and Type	Method and Description
GridComputeJob	createJob(GridGgfsJob job, String ggfsName, GridGgfsPath path, long start, long length, GridGgfsRecordResolver recRslv) Create compute job for the given GGFS job.
Collection<GridIpcServerEndpoint>	endpoints(String name) Gets server endpoints for particular GGFS.
GridGgfs	ggfs(String name) Gets GGFS instance.
Collection<GridGgfs>	ggfss() Gets all GGFS instances.
void	printMemoryStats() Prints memory statistics (sizes of internal structures, etc.).

Methods inherited from class org.gridgain.grid.kernal.processors.GridProcessorAdapter

addAttributes, assertParameter, collectDiscoveryData, onDiscoveryDataReceived, onKernalStart, onKernalStop, start, stop, toString, validateNode

Methods inherited from class java.lang.Object

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

Constructor Detail

GridNoopGgfsProcessor

public GridNoopGgfsProcessor(GridKernalContext ctx)

Constructor.

Parameters:

ctx - Kernal context.

Method Detail

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

ggfss

public Collection<GridGgfs> ggfss()

Gets all GGFS instances.

Specified by:

ggfss in class GridGgfsProcessorAdapter

Returns:

Collection of GGFS instances.

ggfs

@Nullable
public GridGgfs ggfs(@Nullable
                     String name)

Gets GGFS instance.

Specified by:

ggfs in class GridGgfsProcessorAdapter

Parameters:

name - (Nullable) GGFS name.

Returns:

GGFS instance.

endpoints

public Collection<GridIpcServerEndpoint> endpoints(@Nullable
                                          String name)

Gets server endpoints for particular GGFS.

Specified by:

endpoints in class GridGgfsProcessorAdapter

Parameters:

name - GGFS name.

Returns:

Collection of endpoints or null in case GGFS is not defined.

createJob

@Nullable
public GridComputeJob createJob(GridGgfsJob job,
                                @Nullable
                                String ggfsName,
                                GridGgfsPath path,
                                long start,
                                long length,
                                GridGgfsRecordResolver recRslv)

Create compute job for the given GGFS job.

Specified by:

createJob in class GridGgfsProcessorAdapter

Parameters:

job - GGFS job.

ggfsName - GGFS name.

path - Path.

start - Start position.

length - Length.

recRslv - Record resolver.

Returns:

Compute job.