org.apache.ignite.internal.processors.hadoop.impl.delegate

Class HadoopIgfsSecondaryFileSystemDelegateImpl

java.lang.Object

org.apache.ignite.internal.processors.hadoop.impl.delegate.HadoopIgfsSecondaryFileSystemDelegateImpl

All Implemented Interfaces:

IgfsSecondaryFileSystem, HadoopIgfsSecondaryFileSystemDelegate, LifecycleAware

public class HadoopIgfsSecondaryFileSystemDelegateImpl
extends Object
implements HadoopIgfsSecondaryFileSystemDelegate

Secondary file system implementation.

Constructor Summary

Constructors

Constructor and Description
HadoopIgfsSecondaryFileSystemDelegateImpl(IgniteHadoopIgfsSecondaryFileSystem proxy) Constructor.

Method Summary

Modifier and Type	Method and Description
Collection<IgfsBlockLocation>	affinity(IgfsPath path, long start, long len, long maxLen)
OutputStream	append(IgfsPath path, int bufSize, boolean create, Map<String,String> props)
static IgfsException	cast(String msg, IOException e) Cast IO exception to IGFS exception.
OutputStream	create(IgfsPath path, boolean overwrite)
OutputStream	create(IgfsPath path, int bufSize, boolean overwrite, int replication, long blockSize, Map<String,String> props)
boolean	delete(IgfsPath path, boolean recursive)
boolean	exists(IgfsPath path)
IgfsFile	info(IgfsPath path)
Collection<IgfsFile>	listFiles(IgfsPath path)
Collection<IgfsPath>	listPaths(IgfsPath path)
void	mkdirs(IgfsPath path)
void	mkdirs(IgfsPath path, Map<String,String> props)
IgfsSecondaryFileSystemPositionedReadable	open(IgfsPath path, int bufSize)
void	rename(IgfsPath src, IgfsPath dest)
void	setTimes(IgfsPath path, long modificationTime, long accessTime)
void	start()
void	stop()
String	toString()
IgfsFile	update(IgfsPath path, Map<String,String> props)
long	usedSpaceSize()

Methods inherited from class java.lang.Object

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

Constructor Detail

HadoopIgfsSecondaryFileSystemDelegateImpl

public HadoopIgfsSecondaryFileSystemDelegateImpl(IgniteHadoopIgfsSecondaryFileSystem proxy)

Constructor.

Parameters:

proxy - Proxy.

Method Detail

exists

public boolean exists(IgfsPath path)

Specified by:

exists in interface IgfsSecondaryFileSystem

update

@Nullable
public IgfsFile update(IgfsPath path,
                                 Map<String,String> props)

Specified by:

update in interface IgfsSecondaryFileSystem

rename

public void rename(IgfsPath src,
                   IgfsPath dest)

Specified by:

rename in interface IgfsSecondaryFileSystem

delete

public boolean delete(IgfsPath path,
                      boolean recursive)

Specified by:

delete in interface IgfsSecondaryFileSystem

mkdirs

public void mkdirs(IgfsPath path)

Specified by:

mkdirs in interface IgfsSecondaryFileSystem

mkdirs

public void mkdirs(IgfsPath path,
                   @Nullable
                   Map<String,String> props)

Specified by:

mkdirs in interface IgfsSecondaryFileSystem

listPaths

public Collection<IgfsPath> listPaths(IgfsPath path)

Specified by:

listPaths in interface IgfsSecondaryFileSystem

listFiles

public Collection<IgfsFile> listFiles(IgfsPath path)

Specified by:

listFiles in interface IgfsSecondaryFileSystem

open

public IgfsSecondaryFileSystemPositionedReadable open(IgfsPath path,
                                                      int bufSize)

Specified by:

open in interface IgfsSecondaryFileSystem

create

public OutputStream create(IgfsPath path,
                           boolean overwrite)

Specified by:

create in interface IgfsSecondaryFileSystem

create

public OutputStream create(IgfsPath path,
                           int bufSize,
                           boolean overwrite,
                           int replication,
                           long blockSize,
                           @Nullable
                           Map<String,String> props)

Specified by:

create in interface IgfsSecondaryFileSystem

append

public OutputStream append(IgfsPath path,
                           int bufSize,
                           boolean create,
                           @Nullable
                           Map<String,String> props)

Specified by:

append in interface IgfsSecondaryFileSystem

info

public IgfsFile info(IgfsPath path)

Specified by:

info in interface IgfsSecondaryFileSystem

usedSpaceSize

public long usedSpaceSize()

Specified by:

usedSpaceSize in interface IgfsSecondaryFileSystem

setTimes

public void setTimes(IgfsPath path,
                     long modificationTime,
                     long accessTime)
              throws IgniteException

Specified by:

setTimes in interface IgfsSecondaryFileSystem

Throws:

IgniteException

affinity

public Collection<IgfsBlockLocation> affinity(IgfsPath path,
                                              long start,
                                              long len,
                                              long maxLen)
                                       throws IgniteException

Specified by:

affinity in interface IgfsSecondaryFileSystem

Throws:

IgniteException

start

public void start()

Specified by:

start in interface LifecycleAware

stop

public void stop()

Specified by:

stop in interface LifecycleAware

cast

public static IgfsException cast(String msg,
                                 IOException e)

Cast IO exception to IGFS exception.

Parameters:

msg - Error message.

e - IO exception.

Returns:

IGFS exception.

toString

public String toString()

Overrides:

toString in class Object