org.apache.flink.types.parser

Class FieldParser<T>

java.lang.Object

org.apache.flink.types.parser.FieldParser<T>

Type Parameters:

T - The type that is parsed.

Direct Known Subclasses:

BooleanParser, BooleanValueParser, ByteParser, ByteValueParser, DoubleParser, DoubleValueParser, FloatParser, FloatValueParser, IntParser, IntValueParser, LongParser, LongValueParser, ShortParser, ShortValueParser, StringParser, StringValueParser

@PublicEvolving
public abstract class FieldParser<T>
extends Object

A FieldParser is used parse a field from a sequence of bytes. Fields occur in a byte sequence and are terminated by the end of the byte sequence or a delimiter.

The parsers do not throw exceptions in general, but set an error state. That way, they can be used in functions that ignore invalid lines, rather than failing on them.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	FieldParser.ParseErrorState An enumeration of different types of errors that may occur.

Constructor Summary

Constructors

Constructor and Description
FieldParser()

Method Summary

Modifier and Type	Method and Description
abstract T	createValue() Returns an instance of the parsed value type.
static boolean	delimiterNext(byte[] bytes, int startPos, byte[] delim) Checks if the delimiter starts at the given start position of the byte array.
FieldParser.ParseErrorState	getErrorState() Gets the error state of the parser, as a value of the enumeration FieldParser.ParseErrorState.
abstract T	getLastResult() Gets the parsed field.
static <T> Class<FieldParser<T>>	getParserForType(Class<T> type) Gets the parser for the type specified by the given class.
abstract int	parseField(byte[] bytes, int startPos, int limit, byte[] delim, T reuse) Parses the value of a field from the byte array.
protected void	setErrorState(FieldParser.ParseErrorState error) Sets the error state of the parser.

Methods inherited from class java.lang.Object

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

Constructor Detail

FieldParser

public FieldParser()

Method Detail

parseField

public abstract int parseField(byte[] bytes,
                               int startPos,
                               int limit,
                               byte[] delim,
                               T reuse)

Parses the value of a field from the byte array. The start position within the byte array and the array's valid length is given. The content of the value is delimited by a field delimiter.

Parameters:

bytes - The byte array that holds the value.

startPos - The index where the field starts

limit - The limit unto which the byte contents is valid for the parser. The limit is the position one after the last valid byte.

delim - The field delimiter character

reuse - An optional reusable field to hold the value

Returns:

The index of the next delimiter, if the field was parsed correctly. A value less than 0 otherwise.

getLastResult

public abstract T getLastResult()

Gets the parsed field. This method returns the value parsed by the last successful invocation of parseField(byte[], int, int, byte[], Object). It objects are mutable and reused, it will return the object instance that was passed the parse function.

Returns:

The latest parsed field.

createValue

public abstract T createValue()

Returns an instance of the parsed value type.

Returns:

An instance of the parsed value type.

delimiterNext

public static final boolean delimiterNext(byte[] bytes,
                                          int startPos,
                                          byte[] delim)

Checks if the delimiter starts at the given start position of the byte array. Attention: This method assumes that enough characters follow the start position for the delimiter check!

Parameters:

bytes - The byte array that holds the value.

startPos - The index of the byte array where the check for the delimiter starts.

delim - The delimiter to check for.

Returns:

true if a delimiter starts at the given start position, false otherwise.

setErrorState

protected void setErrorState(FieldParser.ParseErrorState error)

Sets the error state of the parser. Called by subclasses of the parser to set the type of error when failing a parse.

Parameters:

error - The error state to set.

getErrorState

public FieldParser.ParseErrorState getErrorState()

Gets the error state of the parser, as a value of the enumeration FieldParser.ParseErrorState. If no error occurred, the error state will be FieldParser.ParseErrorState.NONE.

Returns:

The current error state of the parser.

getParserForType

public static <T> Class<FieldParser<T>> getParserForType(Class<T> type)

Gets the parser for the type specified by the given class. Returns null, if no parser for that class is known.

Parameters:

type - The class of the type to get the parser for.

Returns:

The parser for the given type, or null, if no such parser exists.