Uses of Class
org.apache.ignite.igfs.IgfsInputStream

Packages that use IgfsInputStream

Package	Description
org.apache.ignite	Contains entry-point Ignite & HPC APIs.
org.apache.ignite.igfs.mapreduce	Contains APIs for In-Memory MapReduce over IGFS.
org.apache.ignite.igfs.mapreduce.records	Contains record resolvers for In-Memory MapReduce over IGFS.

Uses of IgfsInputStream in org.apache.ignite

Methods in org.apache.ignite that return IgfsInputStream

Modifier and Type	Method and Description
IgfsInputStream	IgniteFileSystem.open(IgfsPath path) Opens a file for reading.
IgfsInputStream	IgniteFileSystem.open(IgfsPath path, int bufSize) Opens a file for reading.
IgfsInputStream	IgniteFileSystem.open(IgfsPath path, int bufSize, int seqReadsBeforePrefetch) Opens a file for reading.

Uses of IgfsInputStream in org.apache.ignite.igfs.mapreduce

Subclasses of IgfsInputStream in org.apache.ignite.igfs.mapreduce

Modifier and Type	Class and Description
class	IgfsRangeInputStream Decorator for regular IgfsInputStream which streams only data within the given range.

Methods in org.apache.ignite.igfs.mapreduce with parameters of type IgfsInputStream

Modifier and Type	Method and Description
Object	IgfsJob.execute(IgniteFileSystem igfs, IgfsFileRange range, IgfsInputStream in) Executes this job.
Object	IgfsInputStreamJobAdapter.execute(IgniteFileSystem igfs, IgfsFileRange range, IgfsInputStream in) Executes this job.
@Nullable IgfsFileRange	IgfsRecordResolver.resolveRecords(IgniteFileSystem fs, IgfsInputStream stream, IgfsFileRange suggestedRecord) Adjusts record start offset and length.

Constructors in org.apache.ignite.igfs.mapreduce with parameters of type IgfsInputStream

Constructor and Description
IgfsRangeInputStream(IgfsInputStream is, IgfsFileRange range) Constructor.
IgfsRangeInputStream(IgfsInputStream is, long start, long maxLen) Constructor.

Uses of IgfsInputStream in org.apache.ignite.igfs.mapreduce.records

Methods in org.apache.ignite.igfs.mapreduce.records with parameters of type IgfsInputStream

Modifier and Type	Method and Description
IgfsFileRange	IgfsFixedLengthRecordResolver.resolveRecords(IgniteFileSystem fs, IgfsInputStream stream, IgfsFileRange suggestedRecord) Adjusts record start offset and length.
IgfsFileRange	IgfsByteDelimiterRecordResolver.resolveRecords(IgniteFileSystem fs, IgfsInputStream stream, IgfsFileRange suggestedRecord) Adjusts record start offset and length.