org.gridgain.grid.kernal.processors.ggfs

Class GridGgfsProcessorAdapter

java.lang.Object

org.gridgain.grid.kernal.processors.GridProcessorAdapter

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

All Implemented Interfaces:

GridComponent, GridProcessor

Direct Known Subclasses:

GridNoopGgfsProcessor

public abstract class GridGgfsProcessorAdapter
extends GridProcessorAdapter

GGFS processor adapter.

Field Summary

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

ctx, log

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	GridGgfsProcessorAdapter(GridKernalContext ctx) Constructor.

Method Summary

Methods

Modifier and Type	Method and Description
abstract GridComputeJob	createJob(GridGgfsJob job, String ggfsName, GridGgfsPath path, long start, long length, GridGgfsRecordResolver recRslv) Create compute job for the given GGFS job.
abstract Collection<GridIpcServerEndpoint>	endpoints(String name) Gets server endpoints for particular GGFS.
abstract GridGgfs	ggfs(String name) Gets GGFS instance.
abstract Collection<GridGgfs>	ggfss() Gets all GGFS instances.

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

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

Methods inherited from class java.lang.Object

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

Constructor Detail

GridGgfsProcessorAdapter

protected GridGgfsProcessorAdapter(GridKernalContext ctx)

Constructor.

Parameters:

ctx - Kernal context.

Method Detail

ggfss

public abstract Collection<GridGgfs> ggfss()

Gets all GGFS instances.

Returns:

Collection of GGFS instances.

ggfs

@Nullable
public abstract GridGgfs ggfs(@Nullable
                     String name)

Gets GGFS instance.

Parameters:

name - (Nullable) GGFS name.

Returns:

GGFS instance.

endpoints

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

Gets server endpoints for particular GGFS.

Parameters:

name - GGFS name.

Returns:

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

createJob

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

Create compute job for the given GGFS job.

Parameters:

job - GGFS job.

ggfsName - GGFS name.

path - Path.

start - Start position.

length - Length.

recRslv - Record resolver.

Returns:

Compute job.