org.gridgain.grid.ggfs.mapreduce.records

Class GridGgfsByteDelimiterRecordResolver

java.lang.Object

org.gridgain.grid.ggfs.mapreduce.records.GridGgfsByteDelimiterRecordResolver

All Implemented Interfaces:

Externalizable, Serializable, GridGgfsRecordResolver

Direct Known Subclasses:

GridGgfsNewLineRecordResolver, GridGgfsStringDelimiterRecordResolver

public class GridGgfsByteDelimiterRecordResolver
extends Object
implements GridGgfsRecordResolver, Externalizable

Record resolver which adjusts records based on provided delimiters. Both start position and length are shifted to the right, based on delimiter positions.

Note that you can use GridGgfsStringDelimiterRecordResolver if your delimiter is a plain string.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
GridGgfsByteDelimiterRecordResolver() Empty constructor required for Externalizable support.
GridGgfsByteDelimiterRecordResolver(byte[]... delims) Creates delimiter-based record resolver.

Method Summary

Methods

Modifier and Type	Method and Description
void	readExternal(ObjectInput in)
GridGgfsFileRange	resolveRecords(GridGgfs ggfs, GridGgfsInputStream stream, GridGgfsFileRange suggestedRecord) Adjusts record start offset and length.
String	toString()
void	writeExternal(ObjectOutput out)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

GridGgfsByteDelimiterRecordResolver

public GridGgfsByteDelimiterRecordResolver()

Empty constructor required for Externalizable support.

GridGgfsByteDelimiterRecordResolver

public GridGgfsByteDelimiterRecordResolver(byte[]... delims)

Creates delimiter-based record resolver.

Parameters:

delims - Delimiters.

Method Detail

resolveRecords

public GridGgfsFileRange resolveRecords(GridGgfs ggfs,
                               GridGgfsInputStream stream,
                               GridGgfsFileRange suggestedRecord)
                                 throws GridException,
                                        IOException

Adjusts record start offset and length.

Specified by:

resolveRecords in interface GridGgfsRecordResolver

Parameters:

ggfs - GGFS instance to use.

stream - Input stream for split file.

suggestedRecord - Suggested file system record.

Returns:

New adjusted record. If this method returns null, original record is ignored.

Throws:

GridException - If resolve failed.

IOException - If resolve failed.

toString

public String toString()

Overrides:

toString in class Object

writeExternal

public void writeExternal(ObjectOutput out)
                   throws IOException

Specified by:

writeExternal in interface Externalizable

Throws:

IOException

readExternal

public void readExternal(ObjectInput in)
                  throws IOException,
                         ClassNotFoundException

Specified by:

readExternal in interface Externalizable

Throws:

IOException

ClassNotFoundException