public class JacksonAvroParserImpl extends AvroParserImpl
AvroReadContext
implementations.AvroParser.Feature
Modifier and Type | Field and 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 int[] |
sUtf8UnitLengths
Additionally we can combine UTF-8 decoding info into similar
data table.
|
_branchIndex, _enumIndex, _numberFloat
_avroContext, _formatFeatures, _objectCodec, _rootSchema
_binaryValue, _byteArrayBuilder, _closed, _currInputProcessed, _currInputRow, _currInputRowStart, _expLength, _fractLength, _inputEnd, _inputPtr, _intLength, _ioContext, _nameCopied, _nameCopyBuffer, _nextToken, _numberBigDecimal, _numberBigInt, _numberDouble, _numberInt, _numberLong, _numberNegative, _numTypesValid, _parsingContext, _textBuffer, _tokenInputCol, _tokenInputRow, _tokenInputTotal
_currToken, _lastClearedToken, 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_SLASH, INT_SPACE, INT_TAB, MAX_ERROR_TOKEN_LENGTH, MAX_INT_D, MAX_INT_L, MAX_LONG_D, MIN_INT_D, MIN_INT_L, MIN_LONG_D, NO_BYTES, NO_INTS, NR_BIGDECIMAL, NR_BIGINT, NR_DOUBLE, NR_FLOAT, NR_INT, NR_LONG, NR_UNKNOWN
Constructor and Description |
---|
JacksonAvroParserImpl(com.fasterxml.jackson.core.io.IOContext ctxt,
int parserFeatures,
int avroFeatures,
com.fasterxml.jackson.core.ObjectCodec codec,
byte[] data,
int offset,
int len) |
JacksonAvroParserImpl(com.fasterxml.jackson.core.io.IOContext ctxt,
int parserFeatures,
int avroFeatures,
com.fasterxml.jackson.core.ObjectCodec codec,
InputStream in) |
Modifier and Type | Method and Description |
---|---|
protected void |
_closeInput() |
int |
_decodeIntSlow() |
long |
_decodeLongSlow() |
protected boolean |
_loadMore() |
protected void |
_loadMoreGuaranteed() |
protected 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() |
protected void |
_reportInvalidChar(int c) |
void |
_skipIntSlow() |
void |
_skipLongSlow() |
boolean |
checkInputEnd() |
long |
decodeArrayNext() |
long |
decodeArrayStart() |
com.fasterxml.jackson.core.JsonToken |
decodeBoolean() |
com.fasterxml.jackson.core.JsonToken |
decodeBytes() |
com.fasterxml.jackson.core.JsonToken |
decodeDouble() |
int |
decodeEnum() |
com.fasterxml.jackson.core.JsonToken |
decodeFixed(int size) |
com.fasterxml.jackson.core.JsonToken |
decodeFloat() |
int |
decodeIndex() |
int |
decodeInt() |
com.fasterxml.jackson.core.JsonToken |
decodeIntToken() |
long |
decodeLong() |
com.fasterxml.jackson.core.JsonToken |
decodeLongToken() |
String |
decodeMapKey() |
long |
decodeMapNext() |
long |
decodeMapStart() |
void |
decodeString() |
com.fasterxml.jackson.core.JsonToken |
decodeStringToken() |
Object |
getInputSource() |
String |
getText() |
int |
getText(Writer writer) |
boolean |
hasTextCharacters() |
String |
nextTextValue() |
int |
releaseBuffered(OutputStream out) |
protected com.fasterxml.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() |
_checkNumericValue, _initSchema, branchIndex, close, convertNumberToBigDecimal, convertNumberToBigInteger, convertNumberToDouble, convertNumberToFloat, convertNumberToInt, convertNumberToLong, enumIndex, getFloatValue, getNumberType, getNumberValue, getRemainingElements, isNaN, isRecord, nextFieldName, nextFieldName, nextToken, overrideFormatFeatures, setAvroContext, setBytes, setNumber, setNumber, setNumber, setNumber, skipValue
_finishString, canReadTypeId, canUseSchema, configure, disable, enable, getBinaryValue, getCodec, getCurrentLocation, getCurrentName, getEmbeddedObject, getSchema, getTextCharacters, getTextLength, getTextOffset, getTokenLocation, getTypeId, isEnabled, overrideCurrentName, setCodec, setSchema, version
_checkStdFeatureChanges, _decodeBase64Escape, _decodeBase64Escape, _decodeEscaped, _eofAsNextChar, _getByteArrayBuilder, _getSourceReference, _handleBase64MissingPadding, _handleEOF, _handleUnrecognizedCharacterEscape, _parseIntValue, _parseNumericValue, _reportMismatchedEndMarker, _reportTooLongIntegral, _throwUnquotedSpace, _validJsonTokenList, _validJsonValueList, disable, enable, getBigIntegerValue, getCurrentValue, getDecimalValue, getDoubleValue, getIntValue, getLongValue, getParsingContext, getTokenCharacterOffset, getTokenColumnNr, getTokenLineNr, growArrayBy, isClosed, loadMore, loadMoreGuaranteed, overrideStdFeatures, reportInvalidBase64Char, reportInvalidBase64Char, reset, resetAsNaN, resetFloat, resetInt, setCurrentValue, setFeatureMask
_ascii, _asciiBytes, _constructError, _decodeBase64, _getCharDesc, _hasTextualNull, _longIntegerDesc, _longNumberDesc, _reportError, _reportError, _reportError, _reportInputCoercion, _reportInvalidEOF, _reportInvalidEOF, _reportInvalidEOF, _reportInvalidEOFInValue, _reportInvalidEOFInValue, _reportMissingRootWS, _reportUnexpectedChar, _throwInternal, _throwInvalidSpace, _wrapError, clearCurrentToken, currentToken, currentTokenId, getCurrentToken, getCurrentTokenId, getLastClearedToken, getValueAsBoolean, getValueAsDouble, getValueAsInt, getValueAsInt, getValueAsLong, getValueAsLong, getValueAsString, getValueAsString, hasCurrentToken, hasToken, hasTokenId, isExpectedStartArrayToken, isExpectedStartObjectToken, nextValue, reportInvalidNumber, reportOverflowInt, reportOverflowInt, reportOverflowInt, reportOverflowLong, reportOverflowLong, reportOverflowLong, reportUnexpectedNumberChar, skipChildren
_codec, _constructError, _reportUnsupportedOperation, canParseAsync, canReadObjectId, configure, currentName, finishToken, getBinaryValue, getBooleanValue, getByteValue, getFeatureMask, getFormatFeatures, getNonBlockingInputFeeder, getObjectId, getShortValue, getValueAsBoolean, getValueAsDouble, isEnabled, isEnabled, nextBooleanValue, nextIntValue, nextLongValue, readBinaryValue, readBinaryValue, readValueAs, readValueAs, readValueAsTree, readValuesAs, readValuesAs, releaseBuffered, requiresCustomCodec, setRequestPayloadOnError, setRequestPayloadOnError, setRequestPayloadOnError
public static final int[] sUtf8UnitLengths
protected InputStream _inputStream
protected byte[] _inputBuffer
protected boolean _bufferRecyclable
If it is not, it also means that parser can NOT modify underlying buffer.
public JacksonAvroParserImpl(com.fasterxml.jackson.core.io.IOContext ctxt, int parserFeatures, int avroFeatures, com.fasterxml.jackson.core.ObjectCodec codec, InputStream in)
public JacksonAvroParserImpl(com.fasterxml.jackson.core.io.IOContext ctxt, int parserFeatures, int avroFeatures, com.fasterxml.jackson.core.ObjectCodec codec, byte[] data, int offset, int len)
protected void _releaseBuffers() throws IOException
_releaseBuffers
in class com.fasterxml.jackson.core.base.ParserBase
IOException
public Object getInputSource()
getInputSource
in class AvroParser
protected void _closeInput() throws IOException
_closeInput
in class AvroParser
IOException
public int releaseBuffered(OutputStream out) throws IOException
releaseBuffered
in class com.fasterxml.jackson.core.JsonParser
IOException
public String nextTextValue() throws IOException
nextTextValue
in class AvroParserImpl
IOException
public boolean hasTextCharacters()
hasTextCharacters
in class AvroParser
public String getText() throws IOException
getText
in class AvroParser
IOException
public int getText(Writer writer) throws IOException
getText
in class AvroParser
IOException
public com.fasterxml.jackson.core.JsonToken decodeIntToken() throws IOException
decodeIntToken
in class AvroParserImpl
IOException
public final int decodeInt() throws IOException
decodeInt
in class AvroParserImpl
IOException
public int _decodeIntSlow() throws IOException
IOException
public void skipInt() throws IOException
skipInt
in class AvroParserImpl
IOException
public void _skipIntSlow() throws IOException
IOException
public com.fasterxml.jackson.core.JsonToken decodeLongToken() throws IOException
decodeLongToken
in class AvroParserImpl
IOException
public long decodeLong() throws IOException
decodeLong
in class AvroParserImpl
IOException
public long _decodeLongSlow() throws IOException
IOException
public void skipLong() throws IOException
skipLong
in class AvroParserImpl
IOException
public void _skipLongSlow() throws IOException
IOException
public com.fasterxml.jackson.core.JsonToken decodeFloat() throws IOException
decodeFloat
in class AvroParserImpl
IOException
public void skipFloat() throws IOException
skipFloat
in class AvroParserImpl
IOException
public com.fasterxml.jackson.core.JsonToken decodeDouble() throws IOException
decodeDouble
in class AvroParserImpl
IOException
public void skipDouble() throws IOException
skipDouble
in class AvroParserImpl
IOException
public com.fasterxml.jackson.core.JsonToken decodeStringToken() throws IOException
decodeStringToken
in class AvroParserImpl
IOException
public void decodeString() throws IOException
decodeString
in class AvroParserImpl
IOException
public void skipString() throws IOException
skipString
in class AvroParserImpl
IOException
protected void _reportInvalidChar(int c) throws com.fasterxml.jackson.core.JsonParseException
com.fasterxml.jackson.core.JsonParseException
public com.fasterxml.jackson.core.JsonToken decodeBytes() throws IOException
decodeBytes
in class AvroParserImpl
IOException
public void skipBytes() throws IOException
skipBytes
in class AvroParserImpl
IOException
public com.fasterxml.jackson.core.JsonToken decodeFixed(int size) throws IOException
decodeFixed
in class AvroParserImpl
IOException
public void skipFixed(int size) throws IOException
skipFixed
in class AvroParserImpl
IOException
public long decodeArrayStart() throws IOException
decodeArrayStart
in class AvroParserImpl
IOException
public long decodeArrayNext() throws IOException
decodeArrayNext
in class AvroParserImpl
IOException
public long skipArray() throws IOException
skipArray
in class AvroParserImpl
IOException
public String decodeMapKey() throws IOException
decodeMapKey
in class AvroParserImpl
IOException
public long decodeMapStart() throws IOException
decodeMapStart
in class AvroParserImpl
IOException
public long decodeMapNext() throws IOException
decodeMapNext
in class AvroParserImpl
IOException
public long skipMap() throws IOException
skipMap
in class AvroParserImpl
IOException
public com.fasterxml.jackson.core.JsonToken decodeBoolean() throws IOException
decodeBoolean
in class AvroParserImpl
IOException
public void skipBoolean() throws IOException
skipBoolean
in class AvroParserImpl
IOException
public int decodeIndex() throws IOException
decodeIndex
in class AvroParserImpl
IOException
public int decodeEnum() throws IOException
decodeEnum
in class AvroParserImpl
IOException
public boolean checkInputEnd() throws IOException
checkInputEnd
in class AvroParserImpl
IOException
protected com.fasterxml.jackson.core.JsonToken setString(String str)
setString
in class AvroParserImpl
protected final void _loadMoreGuaranteed() throws IOException
IOException
protected final boolean _loadMore() throws IOException
IOException
protected final void _loadToHaveAtLeast(int minAvailable) throws IOException
IOException
Copyright © 2019 FasterXML. All rights reserved.