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

Interface HadoopIgfs

All Known Subinterfaces:

HadoopIgfsEx

All Known Implementing Classes:

HadoopIgfsInProc, HadoopIgfsOutProc, HadoopIgfsWrapper

public interface HadoopIgfs

Facade for communication with grid.

Method Summary

Modifier and Type	Method and Description
Collection<IgfsBlockLocation>	affinity(IgfsPath path, long start, long len) Command to get affinity for given path, offset and length.
HadoopIgfsStreamDelegate	append(IgfsPath path, boolean create, Map<String,String> props) Open file for output appending data to the end of a file.
void	close(boolean force) Close connection.
IgfsPathSummary	contentSummary(IgfsPath path) Gets path summary.
HadoopIgfsStreamDelegate	create(IgfsPath path, boolean overwrite, boolean colocate, int replication, long blockSize, Map<String,String> props) Command to create file and open it for output.
Boolean	delete(IgfsPath path, boolean recursive) Command to delete given path.
IgfsStatus	fsStatus() Performs status request.
IgfsHandshakeResponse	handshake(String logDir) Perform handshake.
IgfsFile	info(IgfsPath path) Command to retrieve file info for some IGFS path.
Collection<IgfsFile>	listFiles(IgfsPath path) Command to get list of files in directory.
Collection<IgfsPath>	listPaths(IgfsPath path) Command to get directory listing.
Boolean	mkdirs(IgfsPath path, Map<String,String> props) Command to create directories.
HadoopIgfsStreamDelegate	open(IgfsPath path) Command to open file for reading.
HadoopIgfsStreamDelegate	open(IgfsPath path, int seqReadsBeforePrefetch) Command to open file for reading.
Boolean	rename(IgfsPath src, IgfsPath dest) Command to rename given path.
Boolean	setTimes(IgfsPath path, long accessTime, long modificationTime) Sets last access time and last modification time for a file.
IgfsFile	update(IgfsPath path, Map<String,String> props) Command to update file properties.

Method Detail

handshake

IgfsHandshakeResponse handshake(String logDir)
                         throws IgniteCheckedException,
                                IOException

Perform handshake.

Parameters:

logDir - Log directory.

Returns:

Future with handshake result.

Throws:

IgniteCheckedException - If failed.

IOException

close

void close(boolean force)

Close connection.

Parameters:

force - Force flag.

info

IgfsFile info(IgfsPath path)
       throws IgniteCheckedException,
              IOException

Command to retrieve file info for some IGFS path.

Parameters:

path - Path to get file info for.

Returns:

Future for info operation.

Throws:

IgniteCheckedException - If failed.

IOException

update

IgfsFile update(IgfsPath path,
                Map<String,String> props)
         throws IgniteCheckedException,
                IOException

Command to update file properties.

Parameters:

path - IGFS path to update properties.

props - Properties to update.

Returns:

Future for update operation.

Throws:

IgniteCheckedException - If failed.

IOException

setTimes

Boolean setTimes(IgfsPath path,
                 long accessTime,
                 long modificationTime)
          throws IgniteCheckedException,
                 IOException

Sets last access time and last modification time for a file.

Parameters:

path - Path to update times.

accessTime - Last access time to set.

modificationTime - Last modification time to set.

Throws:

IgniteCheckedException - If failed.

IOException

rename

Boolean rename(IgfsPath src,
               IgfsPath dest)
        throws IgniteCheckedException,
               IOException

Command to rename given path.

Parameters:

src - Source path.

dest - Destination path.

Returns:

Future for rename operation.

Throws:

IgniteCheckedException - If failed.

IOException

delete

Boolean delete(IgfsPath path,
               boolean recursive)
        throws IgniteCheckedException,
               IOException

Command to delete given path.

Parameters:

path - Path to delete.

recursive - True if deletion is recursive.

Returns:

Future for delete operation.

Throws:

IgniteCheckedException - If failed.

IOException

affinity

Collection<IgfsBlockLocation> affinity(IgfsPath path,
                                       long start,
                                       long len)
                                throws IgniteCheckedException,
                                       IOException

Command to get affinity for given path, offset and length.

Parameters:

path - Path to get affinity for.

start - Start position (offset).

len - Data length.

Returns:

Future for affinity command.

Throws:

IgniteCheckedException - If failed.

IOException

contentSummary

IgfsPathSummary contentSummary(IgfsPath path)
                        throws IgniteCheckedException,
                               IOException

Gets path summary.

Parameters:

path - Path to get summary for.

Returns:

Future that will be completed when summary is received.

Throws:

IgniteCheckedException - If failed.

IOException

mkdirs

Boolean mkdirs(IgfsPath path,
               Map<String,String> props)
        throws IgniteCheckedException,
               IOException

Command to create directories.

Parameters:

path - Path to create.

Returns:

Future for mkdirs operation.

Throws:

IgniteCheckedException - If failed.

IOException

listFiles

Collection<IgfsFile> listFiles(IgfsPath path)
                        throws IgniteCheckedException,
                               IOException

Command to get list of files in directory.

Parameters:

path - Path to list.

Returns:

Future for listFiles operation.

Throws:

IgniteCheckedException - If failed.

IOException

listPaths

Collection<IgfsPath> listPaths(IgfsPath path)
                        throws IgniteCheckedException,
                               IOException

Command to get directory listing.

Parameters:

path - Path to list.

Returns:

Future for listPaths operation.

Throws:

IgniteCheckedException - If failed.

IOException

fsStatus

IgfsStatus fsStatus()
             throws IgniteCheckedException,
                    IOException

Performs status request.

Returns:

Status response.

Throws:

IgniteCheckedException - If failed.

IOException

open

HadoopIgfsStreamDelegate open(IgfsPath path)
                       throws IgniteCheckedException,
                              IOException

Command to open file for reading.

Parameters:

path - File path to open.

Returns:

Future for open operation.

Throws:

IgniteCheckedException - If failed.

IOException

open

HadoopIgfsStreamDelegate open(IgfsPath path,
                              int seqReadsBeforePrefetch)
                       throws IgniteCheckedException,
                              IOException

Command to open file for reading.

Parameters:

path - File path to open.

Returns:

Future for open operation.

Throws:

IgniteCheckedException - If failed.

IOException

create

HadoopIgfsStreamDelegate create(IgfsPath path,
                                boolean overwrite,
                                boolean colocate,
                                int replication,
                                long blockSize,
                                @Nullable
                                Map<String,String> props)
                         throws IgniteCheckedException,
                                IOException

Command to create file and open it for output.

Parameters:

path - Path to file.

overwrite - If true then old file contents will be lost.

colocate - If true and called on data node, file will be written on that node.

replication - Replication factor.

props - File properties for creation.

Returns:

Stream descriptor.

Throws:

IgniteCheckedException - If failed.

IOException

append

HadoopIgfsStreamDelegate append(IgfsPath path,
                                boolean create,
                                @Nullable
                                Map<String,String> props)
                         throws IgniteCheckedException,
                                IOException

Open file for output appending data to the end of a file.

Parameters:

path - Path to file.

create - If true, file will be created if does not exist.

props - File properties.

Returns:

Stream descriptor.

Throws:

IgniteCheckedException - If failed.

IOException