Module tools.jackson.dataformat.avro

Package tools.jackson.dataformat.avro.apacheimpl

Class ApacheAvroParserImpl

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.apacheimpl.ApacheAvroParserImpl

All Implemented Interfaces:

Closeable, AutoCloseable, tools.jackson.core.Versioned

public class ApacheAvroParserImpl
extends AvroParserImpl

Parser implementation that uses decoder from Apache Avro lib, instead of Jackson native 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 ApacheCodecRecycler	_apacheCodecRecycler
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 org.apache.avro.io.BinaryDecoder	_decoder	Actual decoder in use, possible same as _rootDecoder, but not necessarily, in case of different reader/writer schema in use.
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
protected String	_textValue	We need to keep track of text values.
protected static final org.apache.avro.io.DecoderFactory	DECODER_FACTORY

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
ApacheAvroParserImpl(tools.jackson.core.ObjectReadContext readCtxt, tools.jackson.core.io.IOContext ioCtxt, int parserFeatures, int avroFeatures, ApacheCodecRecycler apacheCodecRecycler, AvroSchema schema, byte[] buffer, int offset, int len)
ApacheAvroParserImpl(tools.jackson.core.ObjectReadContext readCtxt, tools.jackson.core.io.IOContext ioCtxt, int parserFeatures, int avroFeatures, ApacheCodecRecycler apacheCodecRecycler, AvroSchema schema, InputStream in)

Method Summary

Modifier and Type	Method	Description
protected void	_closeInput()
protected void	_releaseBuffers()
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()
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()
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, releaseBuffered

Methods inherited from class java.lang.Object

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

Field Details

DECODER_FACTORY

protected static final org.apache.avro.io.DecoderFactory DECODER_FACTORY

Since:

2.16

_apacheCodecRecycler

protected ApacheCodecRecycler _apacheCodecRecycler

Since:

2.16

_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.

_decoder

protected org.apache.avro.io.BinaryDecoder _decoder

Actual decoder in use, possible same as _rootDecoder, but not necessarily, in case of different reader/writer schema in use.

_textValue

protected String _textValue

We need to keep track of text values.

Constructor Details

ApacheAvroParserImpl

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

ApacheAvroParserImpl

public ApacheAvroParserImpl(tools.jackson.core.ObjectReadContext readCtxt,
 tools.jackson.core.io.IOContext ioCtxt,
 int parserFeatures,
 int avroFeatures,
 ApacheCodecRecycler apacheCodecRecycler,
 AvroSchema schema,
 byte[] buffer,
 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

hasStringCharacters

public boolean hasStringCharacters()

Specified by:

hasStringCharacters in class AvroParser

nextStringValue

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

Specified by:

nextStringValue in class AvroParserImpl

Throws:

tools.jackson.core.JacksonException

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

checkInputEnd

public boolean checkInputEnd()
                      throws IOException

Specified by:

checkInputEnd in class AvroParserImpl

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

decodeInt

public int decodeInt()
              throws IOException

Specified by:

decodeInt in class AvroParserImpl

Throws:

IOException

decodeIntToken

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

Specified by:

decodeIntToken in class AvroParserImpl

Throws:

IOException

skipInt

public void skipInt()
             throws IOException

Specified by:

skipInt in class AvroParserImpl

Throws:

IOException

decodeLong

public long decodeLong()
                throws IOException

Specified by:

decodeLong in class AvroParserImpl

Throws:

IOException

decodeLongToken

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

Specified by:

decodeLongToken in class AvroParserImpl

Throws:

IOException

skipLong

public void skipLong()
              throws IOException

Specified by:

skipLong in class AvroParserImpl

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

decodeString

public void decodeString()
                  throws IOException

Specified by:

decodeString in class AvroParserImpl

Throws:

IOException

decodeStringToken

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

Specified by:

decodeStringToken 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

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

setString

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

Specified by:

setString in class AvroParserImpl