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