| Package | Description |
|---|---|
| org.apache.storm.druid.bolt |
| Modifier and Type | Method and Description |
|---|---|
DruidConfig.Builder |
DruidConfig.Builder.blockOnFull(boolean blockOnFull) |
DruidConfig.Builder |
DruidConfig.Builder.discardStreamId(String discardStreamId) |
DruidConfig.Builder |
DruidConfig.Builder.lingerMillis(int lingerMillis) |
DruidConfig.Builder |
DruidConfig.Builder.maxBatchSize(int maxBatchSize) |
DruidConfig.Builder |
DruidConfig.Builder.maxPendingBatches(int maxPendingBatches) |
static DruidConfig.Builder |
DruidConfig.newBuilder()
Deprecated.
|
| Constructor and Description |
|---|
DruidBeamBolt(DruidBeamFactory<E> beamFactory,
ITupleDruidEventMapper<E> druidEventMapper,
DruidConfig.Builder druidConfigBuilder)
Deprecated.
|
Copyright © 2019 The Apache Software Foundation. All Rights Reserved.