Uses of Class
org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsStreamDelegate

Packages that use HadoopIgfsStreamDelegate

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

Uses of HadoopIgfsStreamDelegate in org.apache.ignite.internal.processors.hadoop.impl.igfs

Methods in org.apache.ignite.internal.processors.hadoop.impl.igfs that return HadoopIgfsStreamDelegate

Modifier and Type	Method and Description
HadoopIgfsStreamDelegate	HadoopIgfsOutProc.append(IgfsPath path, boolean create, Map<String,String> props) Open file for output appending data to the end of a file.
HadoopIgfsStreamDelegate	HadoopIgfsInProc.append(IgfsPath path, boolean create, Map<String,String> props) Open file for output appending data to the end of a file.
HadoopIgfsStreamDelegate	HadoopIgfs.append(IgfsPath path, boolean create, Map<String,String> props) Open file for output appending data to the end of a file.
HadoopIgfsStreamDelegate	HadoopIgfsWrapper.append(IgfsPath path, boolean create, Map<String,String> props) Open file for output appending data to the end of a file.
HadoopIgfsStreamDelegate	HadoopIgfsOutProc.create(IgfsPath path, boolean overwrite, boolean colocate, int replication, long blockSize, Map<String,String> props) Command to create file and open it for output.
HadoopIgfsStreamDelegate	HadoopIgfsInProc.create(IgfsPath path, boolean overwrite, boolean colocate, int replication, long blockSize, Map<String,String> props) Command to create file and open it for output.
HadoopIgfsStreamDelegate	HadoopIgfs.create(IgfsPath path, boolean overwrite, boolean colocate, int replication, long blockSize, Map<String,String> props) Command to create file and open it for output.
HadoopIgfsStreamDelegate	HadoopIgfsWrapper.create(IgfsPath path, boolean overwrite, boolean colocate, int replication, long blockSize, Map<String,String> props) Command to create file and open it for output.
HadoopIgfsStreamDelegate	HadoopIgfsOutProc.open(IgfsPath path) Command to open file for reading.
HadoopIgfsStreamDelegate	HadoopIgfsInProc.open(IgfsPath path) Command to open file for reading.
HadoopIgfsStreamDelegate	HadoopIgfs.open(IgfsPath path) Command to open file for reading.
HadoopIgfsStreamDelegate	HadoopIgfsWrapper.open(IgfsPath path) Command to open file for reading.
HadoopIgfsStreamDelegate	HadoopIgfsOutProc.open(IgfsPath path, int seqReadsBeforePrefetch) Command to open file for reading.
HadoopIgfsStreamDelegate	HadoopIgfsInProc.open(IgfsPath path, int seqReadsBeforePrefetch) Command to open file for reading.
HadoopIgfsStreamDelegate	HadoopIgfs.open(IgfsPath path, int seqReadsBeforePrefetch) Command to open file for reading.
HadoopIgfsStreamDelegate	HadoopIgfsWrapper.open(IgfsPath path, int seqReadsBeforePrefetch) Command to open file for reading.

Methods in org.apache.ignite.internal.processors.hadoop.impl.igfs with parameters of type HadoopIgfsStreamDelegate

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

Constructors in org.apache.ignite.internal.processors.hadoop.impl.igfs with parameters of type HadoopIgfsStreamDelegate

Constructor and Description
HadoopIgfsInputStream(HadoopIgfsStreamDelegate delegate, long limit, int bufSize, org.apache.commons.logging.Log log, IgfsLogger clientLog, long logStreamId) Creates input stream.
HadoopIgfsOutputStream(HadoopIgfsStreamDelegate delegate, org.apache.commons.logging.Log log, IgfsLogger clientLog, long logStreamId) Creates light output stream.