Modifier and Type | Class and Description |
---|---|
private static class | AvroReaderFactory.
Implementation used when no schema-resolution is needed, when we are using same schema for reading as was used for writing. |
private static class | AvroReaderFactory.
Implementation used when schema-resolution is needed, when we are using different schema for reading ("reader schema") than was used for writing encoded data ("writer schema") |
Modifier and Type | Field and Description |
---|---|
protected final TreeMap | _knownReaders
To resolve cyclic types, need to keep track of resolved named types. |
protected static final ScalarDecoder | |
protected static final ScalarDecoder | |
protected static final ScalarDecoder | |
protected static final ScalarDecoder | |
protected static final ScalarDecoder | |
protected static final ScalarDecoder | |
protected static final ScalarDecoder | |
protected static final ScalarDecoder |
Access | Constructor and Description |
---|---|
public |
Modifier and Type | Method and Description |
---|---|
protected AvroStructureReader | |
protected AvroFieldReader | |
public static AvroStructureReader | |
public static AvroStructureReader | |
protected AvroStructureReader | |
public AvroStructureReader | createReader(Schema schema)
Method for creating a reader instance for specified type, only using specific schema that was used to encoded data ("writer schema"). |
protected AvroStructureReader | |
public ScalarDecoder | |
protected AvroStructureReader |
_knownReaders | back to summary |
---|---|
protected final TreeMap<String, AvroStructureReader> _knownReaders To resolve cyclic types, need to keep track of resolved named types. |
READER_BOOLEAN | back to summary |
---|---|
protected static final ScalarDecoder READER_BOOLEAN |
READER_BYTES | back to summary |
---|---|
protected static final ScalarDecoder READER_BYTES |
READER_DOUBLE | back to summary |
---|---|
protected static final ScalarDecoder READER_DOUBLE |
READER_FLOAT | back to summary |
---|---|
protected static final ScalarDecoder READER_FLOAT |
READER_INT | back to summary |
---|---|
protected static final ScalarDecoder READER_INT |
READER_LONG | back to summary |
---|---|
protected static final ScalarDecoder READER_LONG |
READER_NULL | back to summary |
---|---|
protected static final ScalarDecoder READER_NULL |
READER_STRING | back to summary |
---|---|
protected static final ScalarDecoder READER_STRING |
AvroReaderFactory | back to summary |
---|---|
public AvroReaderFactory() |
createArrayReader | back to summary |
---|---|
protected AvroStructureReader createArrayReader(Schema schema) throws IOException |
createFieldReader | back to summary |
---|---|
protected AvroFieldReader createFieldReader(Schema. |
createFor | back to summary |
---|---|
public static AvroStructureReader createFor(Schema schema) throws IOException |
createFor | back to summary |
---|---|
public static AvroStructureReader createFor(Schema writerSchema, Schema readerSchema) throws IOException |
createMapReader | back to summary |
---|---|
protected AvroStructureReader createMapReader(Schema schema) throws IOException |
createReader | back to summary |
---|---|
public AvroStructureReader createReader(Schema schema) throws IOException Method for creating a reader instance for specified type, only using specific schema that was used to encoded data ("writer schema"). |
createRecordReader | back to summary |
---|---|
protected AvroStructureReader createRecordReader(Schema schema) throws IOException |
createScalarValueDecoder | back to summary |
---|---|
public ScalarDecoder createScalarValueDecoder(Schema type) |
createUnionReader | back to summary |
---|---|
protected AvroStructureReader createUnionReader(Schema schema) throws IOException |
Access | Constructor and Description |
---|---|
protected |
NonResolving | back to summary |
---|---|
protected NonResolving() |
Access | Constructor and Description |
---|---|
protected |
Modifier and Type | Method and Description |
---|---|
private Schema | Returns: Reader schema that matches expected writer schemaHelper method that verifies that the given reader schema is compatible with specified writer schema type: either directly (same type), or via latter being a union with compatible type. |
protected AvroStructureReader | |
protected AvroFieldReader | |
protected AvroFieldReader | |
protected AvroStructureReader | |
public AvroStructureReader | createReader(Schema writerSchema, Schema readerSchema)
Method for creating a reader instance for specified type. |
protected AvroStructureReader | |
protected AvroStructureReader |
Resolving | back to summary |
---|---|
protected Resolving() |
_verifyMatchingStructure | back to summary |
---|---|
private Schema _verifyMatchingStructure(Schema readerSchema, Schema writerSchema) Helper method that verifies that the given reader schema is compatible with specified writer schema type: either directly (same type), or via latter being a union with compatible type. In latter case, type (schema) within union that matches writer schema is returned instead of containing union
|
createArrayReader | back to summary |
---|---|
protected AvroStructureReader createArrayReader(Schema writerSchema, Schema readerSchema) throws IOException |
createFieldReader | back to summary |
---|---|
protected AvroFieldReader createFieldReader(String name, Schema writerSchema, Schema readerSchema) throws IOException |
createFieldSkipper | back to summary |
---|---|
protected AvroFieldReader createFieldSkipper(String name, Schema writerSchema) throws IOException |
createMapReader | back to summary |
---|---|
protected AvroStructureReader createMapReader(Schema writerSchema, Schema readerSchema) throws IOException |
createReader | back to summary |
---|---|
public AvroStructureReader createReader(Schema writerSchema, Schema readerSchema) throws IOException Method for creating a reader instance for specified type. |
createRecordReader | back to summary |
---|---|
protected AvroStructureReader createRecordReader(Schema writerSchema, Schema readerSchema) throws IOException |
createUnionReader | back to summary |
---|---|
protected AvroStructureReader createUnionReader(Schema writerSchema, Schema readerSchema) throws IOException |