public class IgfsFixedLengthRecordResolver extends Object implements IgfsRecordResolver, Externalizable
newStart % length == 0.| Constructor and Description |
|---|
IgfsFixedLengthRecordResolver()
Empty constructor required for
Externalizable support. |
IgfsFixedLengthRecordResolver(long recLen)
Creates fixed-length record resolver.
|
| Modifier and Type | Method and Description |
|---|---|
void |
readExternal(ObjectInput in) |
IgfsFileRange |
resolveRecords(IgniteFileSystem fs,
IgfsInputStream stream,
IgfsFileRange suggestedRecord)
Adjusts record start offset and length.
|
String |
toString() |
void |
writeExternal(ObjectOutput out) |
public IgfsFixedLengthRecordResolver()
Externalizable support.public IgfsFixedLengthRecordResolver(long recLen)
recLen - Record length.public IgfsFileRange resolveRecords(IgniteFileSystem fs, IgfsInputStream stream, IgfsFileRange suggestedRecord) throws IgniteException, IOException
resolveRecords in interface IgfsRecordResolverfs - IGFS instance to use.stream - Input stream for split file.suggestedRecord - Suggested file system record.null, original record is ignored.IgniteException - If resolve failed.IOException - If resolve failed.public void writeExternal(ObjectOutput out) throws IOException
writeExternal in interface ExternalizableIOExceptionpublic void readExternal(ObjectInput in) throws IOException, ClassNotFoundException
readExternal in interface ExternalizableIOExceptionClassNotFoundException
Follow @ApacheIgnite
Ignite Fabric : ver. 1.5.11 Release Date : April 8 2016