Package org.apache.flink.types.parser
Class ShortParser
- java.lang.Object
-
- org.apache.flink.types.parser.FieldParser<Short>
-
- org.apache.flink.types.parser.ShortParser
-
@PublicEvolving public class ShortParser extends FieldParser<Short>
Parses a decimal text field into aShort
. Only characters '1' to '0' and '-' are allowed. The parser does not check for the maximum value.
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class org.apache.flink.types.parser.FieldParser
FieldParser.ParseErrorState
-
-
Constructor Summary
Constructors Constructor Description ShortParser()
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description Short
createValue()
Returns an instance of the parsed value type.Short
getLastResult()
Gets the parsed field.static short
parseField(byte[] bytes, int startPos, int length)
Static utility to parse a field of type short from a byte sequence that represents text characters (such as when read from a file stream).int
parseField(byte[] bytes, int startPos, int limit, byte[] delimiter, Short reusable)
Each parser's logic should be implemented inside this methodstatic short
parseField(byte[] bytes, int startPos, int length, char delimiter)
Static utility to parse a field of type short from a byte sequence that represents text characters (such as when read from a file stream).-
Methods inherited from class org.apache.flink.types.parser.FieldParser
delimiterNext, endsWithDelimiter, getCharset, getErrorState, getParserForType, nextStringEndPos, nextStringLength, resetErrorStateAndParse, resetParserState, setCharset, setErrorState
-
-
-
-
Method Detail
-
parseField
public int parseField(byte[] bytes, int startPos, int limit, byte[] delimiter, Short reusable)
Description copied from class:FieldParser
Each parser's logic should be implemented inside this method- Specified by:
parseField
in classFieldParser<Short>
-
createValue
public Short createValue()
Description copied from class:FieldParser
Returns an instance of the parsed value type.- Specified by:
createValue
in classFieldParser<Short>
- Returns:
- An instance of the parsed value type.
-
getLastResult
public Short getLastResult()
Description copied from class:FieldParser
Gets the parsed field. This method returns the value parsed by the last successful invocation ofFieldParser.parseField(byte[], int, int, byte[], Object)
. It objects are mutable and reused, it will return the object instance that was passed the parse function.- Specified by:
getLastResult
in classFieldParser<Short>
- Returns:
- The latest parsed field.
-
parseField
public static final short parseField(byte[] bytes, int startPos, int length)
Static utility to parse a field of type short from a byte sequence that represents text characters (such as when read from a file stream).- Parameters:
bytes
- The bytes containing the text data that should be parsed.startPos
- The offset to start the parsing.length
- The length of the byte sequence (counting from the offset).- Returns:
- The parsed value.
- Throws:
NumberFormatException
- Thrown when the value cannot be parsed because the text represents not a correct number.
-
parseField
public static final short parseField(byte[] bytes, int startPos, int length, char delimiter)
Static utility to parse a field of type short from a byte sequence that represents text characters (such as when read from a file stream).- Parameters:
bytes
- The bytes containing the text data that should be parsed.startPos
- The offset to start the parsing.length
- The length of the byte sequence (counting from the offset).delimiter
- The delimiter that terminates the field.- Returns:
- The parsed value.
- Throws:
NumberFormatException
- Thrown when the value cannot be parsed because the text represents not a correct number.
-
-