Jackson 3.0.1 · tools.jackson.dataformat.avro.deser.JacksonAvroParserImpl

Field Summary

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
public static final int[]	sUtf8UnitLengths Additionally we can combine UTF-8 decoding info into similar data table.

Inherited from tools.jackson.dataformat.avro.deser.AvroParserImpl:: _branchIndex _enumIndex

Constructor Summary

Access	Constructor and Description
public	JacksonAvroParserImpl(ObjectReadContext readCtxt, IOContext ioCtxt, int parserFeatures, int avroFeatures, AvroSchema schema, InputStream in)
public	JacksonAvroParserImpl(ObjectReadContext readCtxt, IOContext ioCtxt, int parserFeatures, int avroFeatures, AvroSchema schema, byte[] data, int offset, int len)

Method Summary

Modifier and Type	Method and Description
protected void	_closeInput() Implements abstract tools.jackson.dataformat.avro.AvroParser._closeInput. Abstract method for sub-classes to implement; to be called by `close()` implementation here.
private final long	_decodeChunkLength()
public int	_decodeIntSlow()
private long	_decodeLong2(int ptr, long lo)
public long	_decodeLongSlow()
private long	_decodeLongSlow2(long lo)
private final int	_decodeUTF8_3(int c1)
private final int	_decodeUTF8_4(int c)
private final void	_finishLongString(int len)
private final String	_finishShortString(int len)
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
private final byte	_nextByteGuaranteed()
private final byte	_nextByteGuaranteed2()
private final void	_read(byte[] target, int offset, int len)
protected void	_releaseBuffers() Overrides tools.jackson.core.base.ParserBase._releaseBuffers. Method called to release internal buffers owned by the base reader.
private void	_reportInvalidInitial(int mask)
private void	_reportInvalidNegative(int v)
private void	_reportInvalidOther(int mask)
private void	_reportInvalidOther(int mask, int ptr)
private final void	_skip(int len)
private final void	_skipByteGuaranteed()
private long	_skipChunkElements()
public void	_skipIntSlow()
private final void	_skipL(long len)
public void	_skipLongSlow()
public boolean	checkInputEnd() Implements abstract tools.jackson.dataformat.avro.deser.AvroParserImpl.checkInputEnd.
public long	decodeArrayNext() Implements abstract tools.jackson.dataformat.avro.deser.AvroParserImpl.decodeArrayNext.
public long	decodeArrayStart() Implements abstract tools.jackson.dataformat.avro.deser.AvroParserImpl.decodeArrayStart.
public JsonToken	decodeBoolean() Implements abstract tools.jackson.dataformat.avro.deser.AvroParserImpl.decodeBoolean.
public JsonToken	decodeBytes() Implements abstract tools.jackson.dataformat.avro.deser.AvroParserImpl.decodeBytes.
public JsonToken	decodeDouble() Implements abstract tools.jackson.dataformat.avro.deser.AvroParserImpl.decodeDouble.
public int	decodeEnum() Implements abstract tools.jackson.dataformat.avro.deser.AvroParserImpl.decodeEnum.
public JsonToken	decodeFixed(int size) Implements abstract tools.jackson.dataformat.avro.deser.AvroParserImpl.decodeFixed.
public JsonToken	decodeFloat() Implements abstract tools.jackson.dataformat.avro.deser.AvroParserImpl.decodeFloat.
public int	decodeIndex() Implements abstract tools.jackson.dataformat.avro.deser.AvroParserImpl.decodeIndex.
public final int	decodeInt() Implements abstract tools.jackson.dataformat.avro.deser.AvroParserImpl.decodeInt.
public JsonToken	decodeIntToken() Implements abstract tools.jackson.dataformat.avro.deser.AvroParserImpl.decodeIntToken.
public long	decodeLong() Implements abstract tools.jackson.dataformat.avro.deser.AvroParserImpl.decodeLong.
public JsonToken	decodeLongToken() Implements abstract tools.jackson.dataformat.avro.deser.AvroParserImpl.decodeLongToken.
public String	decodeMapKey() Implements abstract tools.jackson.dataformat.avro.deser.AvroParserImpl.decodeMapKey.
public long	decodeMapNext() Implements abstract tools.jackson.dataformat.avro.deser.AvroParserImpl.decodeMapNext.
public long	decodeMapStart() Implements abstract tools.jackson.dataformat.avro.deser.AvroParserImpl.decodeMapStart.
public void	decodeString() Implements abstract tools.jackson.dataformat.avro.deser.AvroParserImpl.decodeString.
public JsonToken	decodeStringToken() Implements abstract tools.jackson.dataformat.avro.deser.AvroParserImpl.decodeStringToken.
public String	getString() Implements abstract tools.jackson.dataformat.avro.AvroParser.getString. Method for accessing textual representation of the current token; if no current token (before first call to `nextToken`, or after encountering end-of-input), returns null.
public int	getString(Writer writer) Implements abstract tools.jackson.dataformat.avro.AvroParser.getString. Method to read the textual representation of the current token in chunks and pass it to the given Writer.
public boolean	hasStringCharacters() Implements abstract tools.jackson.dataformat.avro.AvroParser.hasStringCharacters. Method that can be used to determine whether calling of `getStringCharacters` would be the most efficient way to access String value for the event parser currently points to (compared to `getString()`).
public String	nextStringValue() Implements abstract tools.jackson.dataformat.avro.deser.AvroParserImpl.nextStringValue. Method that fetches next token (as if calling `nextToken`) and if it is `JsonToken#VALUE_STRING` returns contained String value; otherwise returns null.
public int	releaseBuffered(OutputStream out) Overrides tools.jackson.core.JsonParser.releaseBuffered. Method that can be called to push back any content that has been read but not consumed by the parser.
protected JsonToken	setString(String str) Implements abstract tools.jackson.dataformat.avro.deser.AvroParserImpl.setString.
public long	skipArray() Implements abstract tools.jackson.dataformat.avro.deser.AvroParserImpl.skipArray.
public void	skipBoolean() Implements abstract tools.jackson.dataformat.avro.deser.AvroParserImpl.skipBoolean.
public void	skipBytes() Implements abstract tools.jackson.dataformat.avro.deser.AvroParserImpl.skipBytes.
public void	skipDouble() Implements abstract tools.jackson.dataformat.avro.deser.AvroParserImpl.skipDouble.
public void	skipFixed(int size) Implements abstract tools.jackson.dataformat.avro.deser.AvroParserImpl.skipFixed.
public void	skipFloat() Implements abstract tools.jackson.dataformat.avro.deser.AvroParserImpl.skipFloat.
public void	skipInt() Implements abstract tools.jackson.dataformat.avro.deser.AvroParserImpl.skipInt.
public void	skipLong() Implements abstract tools.jackson.dataformat.avro.deser.AvroParserImpl.skipLong.
public long	skipMap() Implements abstract tools.jackson.dataformat.avro.deser.AvroParserImpl.skipMap.
public void	skipString() Implements abstract tools.jackson.dataformat.avro.deser.AvroParserImpl.skipString.
public Object	streamReadInputSource() Implements abstract tools.jackson.dataformat.avro.AvroParser.streamReadInputSource. Method that can be used to get access to object that is used to access input being parsed; this is usually either `InputStream` or `Reader`, depending on what parser was constructed with.

Field Detail

_bufferRecyclable	back to summary
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.

_bufferRecyclable

back to summary

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.

_inputBuffer	back to summary
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.

_inputStream	back to summary
protected InputStream _inputStream

sUtf8UnitLengths	back to summary
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.

Constructor Detail

JacksonAvroParserImpl	back to summary
public JacksonAvroParserImpl(ObjectReadContext readCtxt, IOContext ioCtxt, int parserFeatures, int avroFeatures, AvroSchema schema, InputStream in)

JacksonAvroParserImpl	back to summary
public JacksonAvroParserImpl(ObjectReadContext readCtxt, IOContext ioCtxt, int parserFeatures, int avroFeatures, AvroSchema schema, byte[] data, int offset, int len)

Method Detail

_closeInput back to summary

_closeInput	back to summary
protected void _closeInput() throws IOException Implements abstract tools.jackson.dataformat.avro.AvroParser._closeInput. Doc from tools.jackson.core.base.ParserMinimalBase._closeInput. Abstract method for sub-classes to implement; to be called by `close()` implementation here. Annotations @Override Exceptions IOException: from underlying input source if thrown

protected void _closeInput() throws IOException

Implements abstract tools.jackson.dataformat.avro.AvroParser._closeInput.

Doc from tools.jackson.core.base.ParserMinimalBase._closeInput.

Abstract method for sub-classes to implement; to be called by close() implementation here.

Annotations

@Override

Exceptions

IOException:: from underlying input source if thrown

_decodeChunkLength	back to summary
private final long _decodeChunkLength() throws IOException

_decodeIntSlow	back to summary
public int _decodeIntSlow() throws IOException

_decodeLong2	back to summary
private long _decodeLong2(int ptr, long lo) throws IOException

_decodeLongSlow	back to summary
public long _decodeLongSlow() throws IOException

_decodeLongSlow2	back to summary
private long _decodeLongSlow2(long lo) throws IOException

_decodeUTF8_3	back to summary
private final int _decodeUTF8_3(int c1) throws IOException

_decodeUTF8_4	back to summary
private final int _decodeUTF8_4(int c) throws IOException

_finishLongString	back to summary
private final void _finishLongString(int len) throws IOException

_finishShortString	back to summary
private final String _finishShortString(int len) throws IOException

_loadMore	back to summary
protected final boolean _loadMore() throws IOException

_loadMoreGuaranteed	back to summary
protected final void _loadMoreGuaranteed() throws IOException

_loadToHaveAtLeast	back to summary
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

_nextByteGuaranteed	back to summary
private final byte _nextByteGuaranteed() throws IOException

_nextByteGuaranteed2	back to summary
private final byte _nextByteGuaranteed2() throws IOException

_read	back to summary
private final void _read(byte[] target, int offset, int len) throws IOException

_releaseBuffers back to summary

_releaseBuffers	back to summary
protected void _releaseBuffers() Overrides tools.jackson.core.base.ParserBase._releaseBuffers. Doc from tools.jackson.core.base.ParserMinimalBase._releaseBuffers. Method called to release internal buffers owned by the base reader. This is expected to be called after `_closeInput` since the buffers are expected not to be needed any longer. Annotations @Override

protected void _releaseBuffers()

Overrides tools.jackson.core.base.ParserBase._releaseBuffers.

Doc from tools.jackson.core.base.ParserMinimalBase._releaseBuffers.

Method called to release internal buffers owned by the base reader. This is expected to be called after _closeInput since the buffers are expected not to be needed any longer.

Annotations

@Override

_reportInvalidInitial	back to summary
private void _reportInvalidInitial(int mask) throws JacksonException

_reportInvalidNegative	back to summary
private void _reportInvalidNegative(int v) throws JacksonException

_reportInvalidOther	back to summary
private void _reportInvalidOther(int mask) throws JacksonException

_reportInvalidOther	back to summary
private void _reportInvalidOther(int mask, int ptr) throws JacksonException

_skip	back to summary
private final void _skip(int len) throws IOException

_skipByteGuaranteed	back to summary
private final void _skipByteGuaranteed() throws IOException

_skipChunkElements	back to summary
private long _skipChunkElements() throws IOException

_skipIntSlow	back to summary
public void _skipIntSlow() throws IOException

_skipL	back to summary
private final void _skipL(long len) throws IOException

_skipLongSlow	back to summary
public void _skipLongSlow() throws IOException

checkInputEnd	back to summary
public boolean checkInputEnd() throws IOException Implements abstract tools.jackson.dataformat.avro.deser.AvroParserImpl.checkInputEnd. Annotations @Override

checkInputEnd

back to summary

public boolean checkInputEnd() throws IOException

Implements abstract tools.jackson.dataformat.avro.deser.AvroParserImpl.checkInputEnd.

Annotations

@Override

decodeArrayNext	back to summary
public long decodeArrayNext() throws IOException Implements abstract tools.jackson.dataformat.avro.deser.AvroParserImpl.decodeArrayNext. Annotations @Override

decodeArrayNext

back to summary

public long decodeArrayNext() throws IOException

Implements abstract tools.jackson.dataformat.avro.deser.AvroParserImpl.decodeArrayNext.

Annotations

@Override

decodeArrayStart	back to summary
public long decodeArrayStart() throws IOException Implements abstract tools.jackson.dataformat.avro.deser.AvroParserImpl.decodeArrayStart. Annotations @Override

decodeArrayStart

back to summary

public long decodeArrayStart() throws IOException

Implements abstract tools.jackson.dataformat.avro.deser.AvroParserImpl.decodeArrayStart.

Annotations

@Override

decodeBoolean	back to summary
public JsonToken decodeBoolean() throws IOException Implements abstract tools.jackson.dataformat.avro.deser.AvroParserImpl.decodeBoolean. Annotations @Override

decodeBoolean

back to summary

public JsonToken decodeBoolean() throws IOException

Implements abstract tools.jackson.dataformat.avro.deser.AvroParserImpl.decodeBoolean.

Annotations

@Override

decodeBytes	back to summary
public JsonToken decodeBytes() throws IOException Implements abstract tools.jackson.dataformat.avro.deser.AvroParserImpl.decodeBytes. Annotations @Override

decodeBytes

back to summary

public JsonToken decodeBytes() throws IOException

Implements abstract tools.jackson.dataformat.avro.deser.AvroParserImpl.decodeBytes.

Annotations

@Override

decodeDouble	back to summary
public JsonToken decodeDouble() throws IOException Implements abstract tools.jackson.dataformat.avro.deser.AvroParserImpl.decodeDouble. Annotations @Override

decodeDouble

back to summary

public JsonToken decodeDouble() throws IOException

Implements abstract tools.jackson.dataformat.avro.deser.AvroParserImpl.decodeDouble.

Annotations

@Override

decodeEnum	back to summary
public int decodeEnum() throws IOException Implements abstract tools.jackson.dataformat.avro.deser.AvroParserImpl.decodeEnum. Annotations @Override

decodeEnum

back to summary

public int decodeEnum() throws IOException

Implements abstract tools.jackson.dataformat.avro.deser.AvroParserImpl.decodeEnum.

Annotations

@Override

decodeFixed	back to summary
public JsonToken decodeFixed(int size) throws IOException Implements abstract tools.jackson.dataformat.avro.deser.AvroParserImpl.decodeFixed. Annotations @Override

decodeFixed

back to summary

public JsonToken decodeFixed(int size) throws IOException

Implements abstract tools.jackson.dataformat.avro.deser.AvroParserImpl.decodeFixed.

Annotations

@Override

decodeFloat	back to summary
public JsonToken decodeFloat() throws IOException Implements abstract tools.jackson.dataformat.avro.deser.AvroParserImpl.decodeFloat. Annotations @Override

decodeFloat

back to summary

public JsonToken decodeFloat() throws IOException

Implements abstract tools.jackson.dataformat.avro.deser.AvroParserImpl.decodeFloat.

Annotations

@Override

decodeIndex	back to summary
public int decodeIndex() throws IOException Implements abstract tools.jackson.dataformat.avro.deser.AvroParserImpl.decodeIndex. Annotations @Override

decodeIndex

back to summary

public int decodeIndex() throws IOException

Implements abstract tools.jackson.dataformat.avro.deser.AvroParserImpl.decodeIndex.

Annotations

@Override

decodeInt	back to summary
public final int decodeInt() throws IOException Implements abstract tools.jackson.dataformat.avro.deser.AvroParserImpl.decodeInt. Annotations @Override

decodeInt

back to summary

public final int decodeInt() throws IOException

Implements abstract tools.jackson.dataformat.avro.deser.AvroParserImpl.decodeInt.

Annotations

@Override

decodeIntToken	back to summary
public JsonToken decodeIntToken() throws IOException Implements abstract tools.jackson.dataformat.avro.deser.AvroParserImpl.decodeIntToken. Annotations @Override

decodeIntToken

back to summary

public JsonToken decodeIntToken() throws IOException

Implements abstract tools.jackson.dataformat.avro.deser.AvroParserImpl.decodeIntToken.

Annotations

@Override

decodeLong	back to summary
public long decodeLong() throws IOException Implements abstract tools.jackson.dataformat.avro.deser.AvroParserImpl.decodeLong. Annotations @Override

decodeLong

back to summary

public long decodeLong() throws IOException

Implements abstract tools.jackson.dataformat.avro.deser.AvroParserImpl.decodeLong.

Annotations

@Override

decodeLongToken	back to summary
public JsonToken decodeLongToken() throws IOException Implements abstract tools.jackson.dataformat.avro.deser.AvroParserImpl.decodeLongToken. Annotations @Override

decodeLongToken

back to summary

public JsonToken decodeLongToken() throws IOException

Implements abstract tools.jackson.dataformat.avro.deser.AvroParserImpl.decodeLongToken.

Annotations

@Override

decodeMapKey

back to summary

public String decodeMapKey() throws IOException

Implements abstract tools.jackson.dataformat.avro.deser.AvroParserImpl.decodeMapKey.

Annotations

@Override

decodeMapNext

back to summary

public long decodeMapNext() throws IOException

Implements abstract tools.jackson.dataformat.avro.deser.AvroParserImpl.decodeMapNext.

Annotations

@Override

decodeMapStart

back to summary

public long decodeMapStart() throws IOException

Implements abstract tools.jackson.dataformat.avro.deser.AvroParserImpl.decodeMapStart.

Annotations

@Override

decodeString

back to summary

public void decodeString() throws IOException

Implements abstract tools.jackson.dataformat.avro.deser.AvroParserImpl.decodeString.

Annotations

@Override

decodeStringToken

back to summary

public JsonToken decodeStringToken() throws IOException

Implements abstract tools.jackson.dataformat.avro.deser.AvroParserImpl.decodeStringToken.

Annotations

@Override

getString back to summary

public String getString() throws JacksonException

Implements abstract tools.jackson.dataformat.avro.AvroParser.getString.

Doc from tools.jackson.core.JsonParser.getString.

Method for accessing textual representation of the current token; if no current token (before first call to nextToken, or after encountering end-of-input), returns null. Method can be called for any token type.

Annotations

@Override

getString back to summary

public int getString(Writer writer) throws JacksonException

Implements abstract tools.jackson.dataformat.avro.AvroParser.getString.

Doc from tools.jackson.core.JsonParser.getString.

Method to read the textual representation of the current token in chunks and pass it to the given Writer. Functionally same as calling:

  writer.write(parser.getString());

but should typically be more efficient as longer content does need to be combined into a single String to return, and write can occur directly from intermediate buffers Jackson uses.

Note

String value will still be buffered (usually using TextBuffer) and will be accessible with other getString() calls (that is, it will not be consumed). So this accessor only avoids construction of java.lang.String compared to plain getString() method.

Note

In Jackson 2.x this method was called getString(Writer).

Annotations

@Override

hasStringCharacters back to summary

public boolean hasStringCharacters()

Implements abstract tools.jackson.dataformat.avro.AvroParser.hasStringCharacters.

Doc from tools.jackson.core.JsonParser.hasStringCharacters.

Method that can be used to determine whether calling of getStringCharacters would be the most efficient way to access String value for the event parser currently points to (compared to getString()).

Annotations

@Override

nextStringValue back to summary

public String nextStringValue() throws JacksonException

Implements abstract tools.jackson.dataformat.avro.deser.AvroParserImpl.nextStringValue.

Doc from tools.jackson.core.JsonParser.nextStringValue.

Method that fetches next token (as if calling nextToken) and if it is JsonToken#VALUE_STRING returns contained String value; otherwise returns null. It is functionally equivalent to:

  return (nextToken() == JsonToken.VALUE_STRING) ? getString() : null;

but may be faster for parser to process, and can therefore be used if caller expects to get a String value next from input.

Annotations

@Override

releaseBuffered

back to summary

public int releaseBuffered(OutputStream out)

Overrides tools.jackson.core.JsonParser.releaseBuffered.

Doc from tools.jackson.core.JsonParser.releaseBuffered.

Method that can be called to push back any content that has been read but not consumed by the parser. This is usually done after reading all content of interest using parser. Content is released by writing it to given stream if possible; if underlying input is byte-based it can released, if not (char-based) it cannot.

Annotations

@Override

setString

back to summary

protected JsonToken setString(String str) throws IOException

Implements abstract tools.jackson.dataformat.avro.deser.AvroParserImpl.setString.

Annotations

@Override

skipArray

back to summary

public long skipArray() throws IOException

Implements abstract tools.jackson.dataformat.avro.deser.AvroParserImpl.skipArray.

Annotations

@Override

skipBoolean

back to summary

public void skipBoolean() throws IOException

Implements abstract tools.jackson.dataformat.avro.deser.AvroParserImpl.skipBoolean.

Annotations

@Override

skipBytes

back to summary

public void skipBytes() throws IOException

Implements abstract tools.jackson.dataformat.avro.deser.AvroParserImpl.skipBytes.

Annotations

@Override

skipDouble

back to summary

public void skipDouble() throws IOException

Implements abstract tools.jackson.dataformat.avro.deser.AvroParserImpl.skipDouble.

Annotations

@Override

skipFixed

back to summary

public void skipFixed(int size) throws IOException

Implements abstract tools.jackson.dataformat.avro.deser.AvroParserImpl.skipFixed.

Annotations

@Override

skipFloat

back to summary

public void skipFloat() throws IOException

Implements abstract tools.jackson.dataformat.avro.deser.AvroParserImpl.skipFloat.

Annotations

@Override

skipInt

back to summary

public void skipInt() throws IOException

Implements abstract tools.jackson.dataformat.avro.deser.AvroParserImpl.skipInt.

Annotations

@Override

skipLong

back to summary

public void skipLong() throws IOException

Implements abstract tools.jackson.dataformat.avro.deser.AvroParserImpl.skipLong.

Annotations

@Override

skipMap

back to summary

public long skipMap() throws IOException

Implements abstract tools.jackson.dataformat.avro.deser.AvroParserImpl.skipMap.

Annotations

@Override

skipString

back to summary

public void skipString() throws IOException

Implements abstract tools.jackson.dataformat.avro.deser.AvroParserImpl.skipString.

Annotations

@Override

streamReadInputSource back to summary

public Object streamReadInputSource()

Implements abstract tools.jackson.dataformat.avro.AvroParser.streamReadInputSource.

Doc from tools.jackson.core.JsonParser.streamReadInputSource.

Method that can be used to get access to object that is used to access input being parsed; this is usually either InputStream or Reader, depending on what parser was constructed with. Note that returned value may be null in some cases; including case where parser implementation does not want to exposed raw source to caller. In cases where input has been decorated, object returned here is the decorated version; this allows some level of interaction between users of parser and decorator object.

In general use of this accessor should be considered as "last effort", i.e. only used if no other mechanism is applicable.

Note

was named getInputSource() in Jackson 2.x.

Annotations

@Override

public Class JacksonAvroParserImpl

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail