Module tools.jackson.dataformat.avro

Package tools.jackson.dataformat.avro.deser

Class JacksonAvroParserImpl

java.lang.Object

tools.jackson.core.JsonParser

tools.jackson.core.base.ParserMinimalBase

tools.jackson.core.base.ParserBase

tools.jackson.dataformat.avro.AvroParser

tools.jackson.dataformat.avro.deser.AvroParserImpl

tools.jackson.dataformat.avro.deser.JacksonAvroParserImpl

All Implemented Interfaces:

Closeable, AutoCloseable, tools.jackson.core.Versioned

public class JacksonAvroParserImpl
extends AvroParserImpl

Parser implementation that uses native Jackson avro decoder.

Nested Class Summary

Nested classes/interfaces inherited from class tools.jackson.core.JsonParser

tools.jackson.core.JsonParser.NumberType, tools.jackson.core.JsonParser.NumberTypeFP

Field Summary

Fields

Modifier and Type	Field	Description
protected boolean	_bufferRecyclable	Flag that indicates whether the input buffer is recycable (and needs to be returned to recycler once we are done) or not.
protected byte[]	_inputBuffer	Current buffer from which data is read; generally data is read into buffer from input source, but in some cases pre-loaded buffer is handed to the parser.
protected InputStream	_inputStream
static final int[]	sUtf8UnitLengths	Additionally we can combine UTF-8 decoding info into similar data table.

Fields inherited from class tools.jackson.dataformat.avro.deser.AvroParserImpl

_branchIndex, _enumIndex

Fields inherited from class tools.jackson.dataformat.avro.AvroParser

_avroContext, _formatFeatures, _rootSchema, _streamReadContext, AVRO_READ_CAPABILITIES

Fields inherited from class tools.jackson.core.base.ParserBase

_binaryValue, _byteArrayBuilder, _currInputProcessed, _currInputRow, _currInputRowStart, _expLength, _fractLength, _inputEnd, _inputPtr, _intLength, _numberBigDecimal, _numberBigInt, _numberDouble, _numberFloat, _numberInt, _numberIsNaN, _numberLong, _numberNegative, _numberString, _numTypesValid, _textBuffer, _tokenInputCol, _tokenInputRow, _tokenInputTotal

Fields inherited from class tools.jackson.core.base.ParserMinimalBase

_closed, _currToken, _ioContext, _lastClearedToken, _objectReadContext, _streamReadConstraints, _streamReadFeatures, _tokenCount, _trackMaxTokenCount, BD_MAX_INT, BD_MAX_LONG, BD_MIN_INT, BD_MIN_LONG, BI_MAX_INT, BI_MAX_LONG, BI_MIN_INT, BI_MIN_LONG, CHAR_NULL, INT_0, INT_9, INT_APOS, INT_ASTERISK, INT_BACKSLASH, INT_COLON, INT_COMMA, INT_CR, INT_e, INT_E, INT_HASH, INT_LBRACKET, INT_LCURLY, INT_LF, INT_MINUS, INT_PERIOD, INT_PLUS, INT_QUOTE, INT_RBRACKET, INT_RCURLY, INT_RS, INT_SLASH, INT_SPACE, INT_TAB, MAX_BYTE_I, MAX_INT_D, MAX_INT_L, MAX_LONG_D, MAX_SHORT_I, MIN_BYTE_I, MIN_INT_D, MIN_INT_L, MIN_LONG_D, MIN_SHORT_I, NO_BYTES, NO_INTS, NR_BIGDECIMAL, NR_BIGINT, NR_DOUBLE, NR_FLOAT, NR_INT, NR_LONG, NR_UNKNOWN, STREAM_READ_FEATURE_DEFAULTS

Fields inherited from class tools.jackson.core.JsonParser

DEFAULT_READ_CAPABILITIES

Constructor Summary

Constructors

Constructor	Description
JacksonAvroParserImpl(tools.jackson.core.ObjectReadContext readCtxt, tools.jackson.core.io.IOContext ioCtxt, int parserFeatures, int avroFeatures, AvroSchema schema, byte[] data, int offset, int len)
JacksonAvroParserImpl(tools.jackson.core.ObjectReadContext readCtxt, tools.jackson.core.io.IOContext ioCtxt, int parserFeatures, int avroFeatures, AvroSchema schema, InputStream in)

Method Summary

Modifier and Type	Method	Description
protected void	_closeInput()
int	_decodeIntSlow()
long	_decodeLongSlow()
protected final boolean	_loadMore()
protected final void	_loadMoreGuaranteed()
protected final void	_loadToHaveAtLeast(int minAvailable)	Helper method that will try to load at least specified number bytes in input buffer, possible moving existing data around if necessary
protected void	_releaseBuffers()
void	_skipIntSlow()
void	_skipLongSlow()
boolean	checkInputEnd()
long	decodeArrayNext()
long	decodeArrayStart()
tools.jackson.core.JsonToken	decodeBoolean()
tools.jackson.core.JsonToken	decodeBytes()
tools.jackson.core.JsonToken	decodeDouble()
int	decodeEnum()
tools.jackson.core.JsonToken	decodeFixed(int size)
tools.jackson.core.JsonToken	decodeFloat()
int	decodeIndex()
final int	decodeInt()
tools.jackson.core.JsonToken	decodeIntToken()
long	decodeLong()
tools.jackson.core.JsonToken	decodeLongToken()
String	decodeMapKey()
long	decodeMapNext()
long	decodeMapStart()
void	decodeString()
tools.jackson.core.JsonToken	decodeStringToken()
String	getString()
int	getString(Writer writer)
boolean	hasStringCharacters()
String	nextStringValue()
int	releaseBuffered(OutputStream out)
protected tools.jackson.core.JsonToken	setString(String str)
long	skipArray()
void	skipBoolean()
void	skipBytes()
void	skipDouble()
void	skipFixed(int size)
void	skipFloat()
void	skipInt()
void	skipLong()
long	skipMap()
void	skipString()
Object	streamReadInputSource()

Methods inherited from class tools.jackson.dataformat.avro.deser.AvroParserImpl

_checkNumericValue, _initSchema, branchIndex, close, convertNumberToBigDecimal, convertNumberToBigInteger, convertNumberToDouble, convertNumberToFloat, convertNumberToInt, convertNumberToLong, decodeBytesDecimal, decodeFixedDecimal, enumIndex, getFloatValue, getNumberType, getNumberTypeFP, getNumberValue, getNumberValueExact, getRemainingElements, isNaN, isRecord, nextName, nextName, nextNameMatch, nextToken, setAvroContext, setBytes, setNumber, setNumber, setNumber, setNumber, skipBytesDecimal, skipFixedDecimal, skipValue

Methods inherited from class tools.jackson.dataformat.avro.AvroParser

_parseIntValue, _parseNumericValue, assignCurrentValue, canReadTypeId, configure, currentLocation, currentName, currentTokenLocation, currentValue, disable, enable, getBinaryValue, getEmbeddedObject, getSchema, getStringCharacters, getStringLength, getStringOffset, getTypeId, isEnabled, setSchema, streamReadCapabilities, streamReadContext, version

Methods inherited from class tools.jackson.core.base.ParserBase

_contentReference, _contentReferenceRedacted, _convertBigDecimalToBigInteger, _decodeBase64Escape, _decodeBase64Escape, _decodeEscaped, _eofAsNextChar, _getBigDecimal, _getBigInteger, _getByteArrayBuilder, _getNumberDouble, _getNumberFloat, _growNameDecodeBuffer, _handleBase64MissingPadding, _handleEOF, _reportInvalidBase64Char, _reportInvalidBase64Char, getBigIntegerValue, getDecimalValue, getDoubleValue, getIntValue, getLongValue, getNumberValueDeferred, getTokenCharacterOffset, getTokenColumnNr, getTokenLineNr, growArrayBy, reset, resetAsNaN, resetFloat, resetInt

Methods inherited from class tools.jackson.core.base.ParserMinimalBase

_constructInputCoercion, _constructNotNumericType, _currentLocationMinusOne, _decodeBase64, _getCharDesc, _hasTextualNull, _longIntegerDesc, _longNumberDesc, _nullSafeUpdateToken, _reportBadInputStream, _reportBadReader, _reportError, _reportError, _reportError, _reportError, _reportInvalidEOF, _reportInvalidEOF, _reportInvalidEOFInValue, _reportInvalidNumber, _reportInvalidSpace, _reportInvalidUTF8Surrogate, _reportMissingRootWS, _reportOverflowByte, _reportOverflowInt, _reportOverflowInt, _reportOverflowInt, _reportOverflowLong, _reportOverflowLong, _reportOverflowLong, _reportOverflowShort, _reportUnexpectedChar, _reportUnexpectedNumberChar, _throwInternal, _updateToken, _updateTokenToNA, _updateTokenToNull, _wrapIOFailure, clearCurrentToken, currentNameMatch, currentToken, currentTokenCount, currentTokenId, finishToken, getBooleanValue, getByteValue, getLastClearedToken, getShortValue, getValueAsBoolean, getValueAsDouble, getValueAsInt, getValueAsInt, getValueAsLong, getValueAsLong, getValueAsString, getValueAsString, hasCurrentToken, hasToken, hasTokenId, isClosed, isEnabled, isExpectedNumberIntToken, isExpectedStartArrayToken, isExpectedStartObjectToken, nextValue, objectReadContext, readValueAs, readValueAs, readValueAs, readValueAsTree, skipChildren, streamReadConstraints, streamReadFeatures

Methods inherited from class tools.jackson.core.JsonParser

_constructReadException, _constructReadException, _constructReadException, _constructReadException, _constructReadException, _constructReadException, _reportUnsupportedOperation, canParseAsync, canReadObjectId, getBinaryValue, getObjectId, getText, getTextCharacters, getTextLength, getTextOffset, getValueAsBoolean, getValueAsDouble, nextBooleanValue, nextIntValue, nextLongValue, nonBlockingInputFeeder, readBinaryValue, readBinaryValue, readString, releaseBuffered

Methods inherited from class java.lang.Object

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

Field Details

sUtf8UnitLengths

public static final int[] sUtf8UnitLengths

Additionally we can combine UTF-8 decoding info into similar data table. Values indicate "byte length - 1"; meaning -1 is used for invalid bytes, 0 for single-byte codes, 1 for 2-byte codes and 2 for 3-byte codes.

_inputStream

protected InputStream _inputStream

_inputBuffer

protected byte[] _inputBuffer

Current buffer from which data is read; generally data is read into buffer from input source, but in some cases pre-loaded buffer is handed to the parser.

_bufferRecyclable

protected boolean _bufferRecyclable

Flag that indicates whether the input buffer is recycable (and needs to be returned to recycler once we are done) or not.

If it is not, it also means that parser can NOT modify underlying buffer.

Constructor Details

JacksonAvroParserImpl

public JacksonAvroParserImpl(tools.jackson.core.ObjectReadContext readCtxt,
 tools.jackson.core.io.IOContext ioCtxt,
 int parserFeatures,
 int avroFeatures,
 AvroSchema schema,
 InputStream in)

JacksonAvroParserImpl

public JacksonAvroParserImpl(tools.jackson.core.ObjectReadContext readCtxt,
 tools.jackson.core.io.IOContext ioCtxt,
 int parserFeatures,
 int avroFeatures,
 AvroSchema schema,
 byte[] data,
 int offset,
 int len)

Method Details

_releaseBuffers

protected void _releaseBuffers()

Overrides:

_releaseBuffers in class tools.jackson.core.base.ParserBase

streamReadInputSource

public Object streamReadInputSource()

Specified by:

streamReadInputSource in class AvroParser

_closeInput

protected void _closeInput()
                    throws IOException

Specified by:

_closeInput in class AvroParser

Throws:

IOException

releaseBuffered

public int releaseBuffered(OutputStream out)

Overrides:

releaseBuffered in class tools.jackson.core.JsonParser

nextStringValue

public String nextStringValue()
                       throws tools.jackson.core.JacksonException

Specified by:

nextStringValue in class AvroParserImpl

Throws:

tools.jackson.core.JacksonException

hasStringCharacters

public boolean hasStringCharacters()

Specified by:

hasStringCharacters in class AvroParser

getString

public String getString()
                 throws tools.jackson.core.JacksonException

Specified by:

getString in class AvroParser

Throws:

tools.jackson.core.JacksonException

getString

public int getString(Writer writer)
              throws tools.jackson.core.JacksonException

Specified by:

getString in class AvroParser

Throws:

tools.jackson.core.JacksonException

decodeIntToken

public tools.jackson.core.JsonToken decodeIntToken()
                                            throws IOException

Specified by:

decodeIntToken in class AvroParserImpl

Throws:

IOException

decodeInt

public final int decodeInt()
                    throws IOException

Specified by:

decodeInt in class AvroParserImpl

Throws:

IOException

_decodeIntSlow

public int _decodeIntSlow()
                   throws IOException

Throws:

IOException

skipInt

public void skipInt()
             throws IOException

Specified by:

skipInt in class AvroParserImpl

Throws:

IOException

_skipIntSlow

public void _skipIntSlow()
                  throws IOException

Throws:

IOException

decodeLongToken

public tools.jackson.core.JsonToken decodeLongToken()
                                             throws IOException

Specified by:

decodeLongToken in class AvroParserImpl

Throws:

IOException

decodeLong

public long decodeLong()
                throws IOException

Specified by:

decodeLong in class AvroParserImpl

Throws:

IOException

_decodeLongSlow

public long _decodeLongSlow()
                     throws IOException

Throws:

IOException

skipLong

public void skipLong()
              throws IOException

Specified by:

skipLong in class AvroParserImpl

Throws:

IOException

_skipLongSlow

public void _skipLongSlow()
                   throws IOException

Throws:

IOException

decodeFloat

public tools.jackson.core.JsonToken decodeFloat()
                                         throws IOException

Specified by:

decodeFloat in class AvroParserImpl

Throws:

IOException

skipFloat

public void skipFloat()
               throws IOException

Specified by:

skipFloat in class AvroParserImpl

Throws:

IOException

decodeDouble

public tools.jackson.core.JsonToken decodeDouble()
                                          throws IOException

Specified by:

decodeDouble in class AvroParserImpl

Throws:

IOException

skipDouble

public void skipDouble()
                throws IOException

Specified by:

skipDouble in class AvroParserImpl

Throws:

IOException

decodeStringToken

public tools.jackson.core.JsonToken decodeStringToken()
                                               throws IOException

Specified by:

decodeStringToken in class AvroParserImpl

Throws:

IOException

decodeString

public void decodeString()
                  throws IOException

Specified by:

decodeString in class AvroParserImpl

Throws:

IOException

skipString

public void skipString()
                throws IOException

Specified by:

skipString in class AvroParserImpl

Throws:

IOException

decodeBytes

public tools.jackson.core.JsonToken decodeBytes()
                                         throws IOException

Specified by:

decodeBytes in class AvroParserImpl

Throws:

IOException

skipBytes

public void skipBytes()
               throws IOException

Specified by:

skipBytes in class AvroParserImpl

Throws:

IOException

decodeFixed

public tools.jackson.core.JsonToken decodeFixed(int size)
                                         throws IOException

Specified by:

decodeFixed in class AvroParserImpl

Throws:

IOException

skipFixed

public void skipFixed(int size)
               throws IOException

Specified by:

skipFixed in class AvroParserImpl

Throws:

IOException

decodeArrayStart

public long decodeArrayStart()
                      throws IOException

Specified by:

decodeArrayStart in class AvroParserImpl

Throws:

IOException

decodeArrayNext

public long decodeArrayNext()
                     throws IOException

Specified by:

decodeArrayNext in class AvroParserImpl

Throws:

IOException

skipArray

public long skipArray()
               throws IOException

Specified by:

skipArray in class AvroParserImpl

Returns:

Either 0, in which case all entries have been successfully skipped; or positive non-zero number to indicate elements that caller has to skip

Throws:

IOException

decodeMapKey

public String decodeMapKey()
                    throws IOException

Specified by:

decodeMapKey in class AvroParserImpl

Throws:

IOException

decodeMapStart

public long decodeMapStart()
                    throws IOException

Specified by:

decodeMapStart in class AvroParserImpl

Throws:

IOException

decodeMapNext

public long decodeMapNext()
                   throws IOException

Specified by:

decodeMapNext in class AvroParserImpl

Throws:

IOException

skipMap

public long skipMap()
             throws IOException

Specified by:

skipMap in class AvroParserImpl

Returns:

Either 0, in which case all entries have been successfully skipped; or positive non-zero number to indicate map entries that caller has to skip

Throws:

IOException

decodeBoolean

public tools.jackson.core.JsonToken decodeBoolean()
                                           throws IOException

Specified by:

decodeBoolean in class AvroParserImpl

Throws:

IOException

skipBoolean

public void skipBoolean()
                 throws IOException

Specified by:

skipBoolean in class AvroParserImpl

Throws:

IOException

decodeIndex

public int decodeIndex()
                throws IOException

Specified by:

decodeIndex in class AvroParserImpl

Throws:

IOException

decodeEnum

public int decodeEnum()
               throws IOException

Specified by:

decodeEnum in class AvroParserImpl

Throws:

IOException

checkInputEnd

public boolean checkInputEnd()
                      throws IOException

Specified by:

checkInputEnd in class AvroParserImpl

Throws:

IOException

setString

protected tools.jackson.core.JsonToken setString(String str)
                                          throws IOException

Specified by:

setString in class AvroParserImpl

Throws:

IOException

_loadMoreGuaranteed

protected final void _loadMoreGuaranteed()
                                  throws IOException

Throws:

IOException

_loadMore

protected final boolean _loadMore()
                           throws IOException

Throws:

IOException

_loadToHaveAtLeast

protected final void _loadToHaveAtLeast(int minAvailable)
                                 throws IOException

Helper method that will try to load at least specified number bytes in input buffer, possible moving existing data around if necessary

Throws:

IOException