org.apache.ignite.internal.processors.igfs

Class IgfsProcessorAdapter

java.lang.Object

org.apache.ignite.internal.processors.GridProcessorAdapter

org.apache.ignite.internal.processors.igfs.IgfsProcessorAdapter

All Implemented Interfaces:

GridComponent, IgniteChangeGlobalStateSupport, GridProcessor

Direct Known Subclasses:

IgfsNoopProcessor, IgfsProcessor

public abstract class IgfsProcessorAdapter
extends GridProcessorAdapter
implements IgniteChangeGlobalStateSupport

Ignite file system processor adapter.

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

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

Method Summary

Methods

Modifier and Type	Method and Description
abstract ComputeJob	createJob(IgfsJob job, String igfsName, IgfsPath path, long start, long length, IgfsRecordResolver recRslv) Create compute job for the given IGFS job.
abstract Collection<IpcServerEndpoint>	endpoints(String name) Gets server endpoints for particular IGFS.
abstract IgniteFileSystem	igfs(String name) Gets IGFS instance.
abstract Collection<IgniteFileSystem>	igfss() Gets all IGFS instances.

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

assertParameter, collectGridNodeData, collectJoiningNodeData, discoveryDataType, onDisconnected, onGridDataReceived, onJoiningNodeDataReceived, onKernalStart, onKernalStop, onReconnected, printMemoryStats, start, stop, toString, validateNode

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.ignite.internal.processors.cluster.IgniteChangeGlobalStateSupport

onActivate, onDeActivate

Constructor Detail

IgfsProcessorAdapter

protected IgfsProcessorAdapter(GridKernalContext ctx)

Constructor.

Parameters:

ctx - Kernal context.

Method Detail

igfss

public abstract Collection<IgniteFileSystem> igfss()

Gets all IGFS instances.

Returns:

Collection of IGFS instances.

igfs

@Nullable
public abstract IgniteFileSystem igfs(String name)

Gets IGFS instance.

Parameters:

name - (Nullable) IGFS name.

Returns:

IGFS instance.

endpoints

public abstract Collection<IpcServerEndpoint> endpoints(String name)

Gets server endpoints for particular IGFS.

Parameters:

name - IGFS name.

Returns:

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

createJob

@Nullable
public abstract ComputeJob createJob(IgfsJob job,
                            @Nullable
                            String igfsName,
                            IgfsPath path,
                            long start,
                            long length,
                            IgfsRecordResolver recRslv)

Create compute job for the given IGFS job.

Parameters:

job - IGFS job.

igfsName - IGFS name.

path - Path.

start - Start position.

length - Length.

recRslv - Record resolver.

Returns:

Compute job.