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.