| Package | Description |
|---|---|
| io.druid.data.input.avro | |
| io.druid.data.input.schemarepo |
| Modifier and Type | Method and Description |
|---|---|
SubjectAndIdConverter<SUBJECT,ID> |
SchemaRepoBasedAvroBytesDecoder.getSubjectAndIdConverter() |
| Constructor and Description |
|---|
SchemaRepoBasedAvroBytesDecoder(SubjectAndIdConverter<SUBJECT,ID> subjectAndIdConverter,
org.schemarepo.Repository schemaRepository) |
| Modifier and Type | Class and Description |
|---|---|
class |
Avro1124SubjectAndIdConverter
This implementation using injected Kafka topic name as subject name, and an integer as schema id.
|
Copyright © 2011–2017. All rights reserved.