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

Interface HadoopIgfsEx

All Superinterfaces:

HadoopIgfs

All Known Implementing Classes:

HadoopIgfsInProc, HadoopIgfsOutProc

public interface HadoopIgfsEx
extends HadoopIgfs

Extended IGFS server interface.

Method Summary

Modifier and Type	Method and Description
void	addEventListener(HadoopIgfsStreamDelegate delegate, HadoopIgfsStreamEventListener lsnr) Adds event listener that will be invoked when connection with server is lost or remote error has occurred.
void	closeStream(HadoopIgfsStreamDelegate delegate) Close server stream.
void	flush(HadoopIgfsStreamDelegate delegate) Flush output stream.
IgfsModeResolver	modeResolver()
IgniteInternalFuture<byte[]>	readData(HadoopIgfsStreamDelegate delegate, long pos, int len, byte[] outBuf, int outOff, int outLen) Asynchronously reads specified amount of bytes from opened input stream.
void	removeEventListener(HadoopIgfsStreamDelegate delegate) Removes event listener that will be invoked when connection with server is lost or remote error has occurred.
String	user() The user this Igfs instance works on behalf of.
void	writeData(HadoopIgfsStreamDelegate delegate, byte[] data, int off, int len) Writes data to the stream with given streamId.

Methods inherited from interface org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfs

affinity, append, close, contentSummary, create, delete, fsStatus, handshake, info, listFiles, listPaths, mkdirs, open, open, rename, setTimes, update

Method Detail

addEventListener

void addEventListener(HadoopIgfsStreamDelegate delegate,
                      HadoopIgfsStreamEventListener lsnr)

Adds event listener that will be invoked when connection with server is lost or remote error has occurred. If connection is closed already, callback will be invoked synchronously inside this method.

Parameters:

delegate - Stream delegate.

lsnr - Event listener.

removeEventListener

void removeEventListener(HadoopIgfsStreamDelegate delegate)

Removes event listener that will be invoked when connection with server is lost or remote error has occurred.

Parameters:

delegate - Stream delegate.

readData

IgniteInternalFuture<byte[]> readData(HadoopIgfsStreamDelegate delegate,
                                      long pos,
                                      int len,
                                      @Nullable
                                      byte[] outBuf,
                                      int outOff,
                                      int outLen)

Asynchronously reads specified amount of bytes from opened input stream.

Parameters:

delegate - Stream delegate.

pos - Position to read from.

len - Data length to read.

outBuf - Optional output buffer. If buffer length is less then len, all remaining bytes will be read into new allocated buffer of length {len - outBuf.length} and this buffer will be the result of read future.

outOff - Output offset.

outLen - Output length.

Returns:

Read data.

writeData

void writeData(HadoopIgfsStreamDelegate delegate,
               byte[] data,
               int off,
               int len)
        throws IOException

Writes data to the stream with given streamId. This method does not return any future since no response to write request is sent.

Parameters:

delegate - Stream delegate.

data - Data to write.

off - Offset.

len - Length.

Throws:

IOException - If failed.

closeStream

void closeStream(HadoopIgfsStreamDelegate delegate)
          throws IOException

Close server stream.

Parameters:

delegate - Stream delegate.

Throws:

IOException - If failed.

flush

void flush(HadoopIgfsStreamDelegate delegate)
    throws IOException

Flush output stream.

Parameters:

delegate - Stream delegate.

Throws:

IOException - If failed.

user

String user()

The user this Igfs instance works on behalf of.

Returns:

the user name.

modeResolver

IgfsModeResolver modeResolver()
                       throws IgniteCheckedException

Returns:

Mode resolver.

Throws:

IgniteCheckedException - On error.