Package | Description |
---|---|
io.druid.data.input | |
io.druid.data.input.impl | |
io.druid.data.input.protobuf | |
io.druid.firehose.kafka | |
io.druid.segment.transform |
Modifier and Type | Class and Description |
---|---|
class |
AvroStreamInputRowParser |
Modifier and Type | Method and Description |
---|---|
ByteBufferInputRowParser |
ByteBufferInputRowParser.withParseSpec(ParseSpec parseSpec) |
ByteBufferInputRowParser |
AvroStreamInputRowParser.withParseSpec(ParseSpec parseSpec) |
Modifier and Type | Class and Description |
---|---|
class |
StringInputRowParser |
Modifier and Type | Class and Description |
---|---|
class |
ProtobufInputRowParser |
Modifier and Type | Method and Description |
---|---|
FirehoseV2 |
KafkaEightSimpleConsumerFirehoseFactory.connect(ByteBufferInputRowParser firehoseParser,
Object lastCommit) |
Modifier and Type | Class and Description |
---|---|
class |
TransformingStringInputRowParser |
Copyright © 2011–2018. All rights reserved.