public class IgfsByteDelimiterRecordResolver extends Object implements IgfsRecordResolver, Externalizable
Note that you can use IgfsStringDelimiterRecordResolver
if your delimiter is a plain string.
Constructor and Description |
---|
IgfsByteDelimiterRecordResolver()
Empty constructor required for
Externalizable support. |
IgfsByteDelimiterRecordResolver(byte[]... delims)
Creates delimiter-based 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 IgfsByteDelimiterRecordResolver()
Externalizable
support.public IgfsByteDelimiterRecordResolver(byte[]... delims)
delims
- Delimiters.public IgfsFileRange resolveRecords(IgniteFileSystem fs, IgfsInputStream stream, IgfsFileRange suggestedRecord) throws IgniteException, IOException
resolveRecords
in interface IgfsRecordResolver
fs
- 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 Externalizable
IOException
public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException
readExternal
in interface Externalizable
IOException
ClassNotFoundException
Follow @ApacheIgnite
Ignite Database and Caching Platform : ver. 2.7.2 Release Date : February 6 2019