org.apache.ignite.internal.processors.igfs.client

Class IgfsClientAffinityCallable

java.lang.Object

org.apache.ignite.internal.processors.igfs.client.IgfsClientAbstractCallable<Collection<IgfsBlockLocation>>

org.apache.ignite.internal.processors.igfs.client.IgfsClientAffinityCallable

All Implemented Interfaces:

Serializable, Callable<Collection<IgfsBlockLocation>>, Binarylizable, IgniteCallable<Collection<IgfsBlockLocation>>

public class IgfsClientAffinityCallable
extends IgfsClientAbstractCallable<Collection<IgfsBlockLocation>>

IGFS client affinity callable.

See Also:

Serialized Form

Field Summary

Fields inherited from class org.apache.ignite.internal.processors.igfs.client.IgfsClientAbstractCallable

igfsName, path, user

Constructor Summary

Constructors

Constructor and Description
IgfsClientAffinityCallable() Default constructor.
IgfsClientAffinityCallable(String igfsName, String user, IgfsPath path, long start, long len, long maxLen) Constructor.

Method Summary

Methods

Modifier and Type	Method and Description
protected Collection<IgfsBlockLocation>	call0(IgfsContext ctx) Execute task.
void	readBinary0(BinaryRawReader reader) Read binary.
String	toString()
void	writeBinary0(BinaryRawWriter writer) Write binary.

Methods inherited from class org.apache.ignite.internal.processors.igfs.client.IgfsClientAbstractCallable

call, readBinary, writeBinary

Methods inherited from class java.lang.Object

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

Constructor Detail

IgfsClientAffinityCallable

public IgfsClientAffinityCallable()

Default constructor.

IgfsClientAffinityCallable

public IgfsClientAffinityCallable(@Nullable
                          String igfsName,
                          @Nullable
                          String user,
                          IgfsPath path,
                          long start,
                          long len,
                          long maxLen)

Constructor.

Parameters:

igfsName - IGFS name.

user - IGFS user name.

path - Path.

start - Start.

len - Length.

maxLen - Maximum length.

Method Detail

call0

protected Collection<IgfsBlockLocation> call0(IgfsContext ctx)
                                       throws Exception

Execute task.

Specified by:

call0 in class IgfsClientAbstractCallable<Collection<IgfsBlockLocation>>

Parameters:

ctx - IGFS ocntext.

Returns:

Result.

Throws:

Exception - If failed.

writeBinary0

public void writeBinary0(BinaryRawWriter writer)
                  throws BinaryObjectException

Write binary.

Overrides:

writeBinary0 in class IgfsClientAbstractCallable<Collection<IgfsBlockLocation>>

Parameters:

writer - Raw writer.

Throws:

BinaryObjectException

readBinary0

public void readBinary0(BinaryRawReader reader)
                 throws BinaryObjectException

Read binary.

Overrides:

readBinary0 in class IgfsClientAbstractCallable<Collection<IgfsBlockLocation>>

Parameters:

reader - Raw reader.

Throws:

BinaryObjectException

toString

public String toString()

Overrides:

toString in class Object