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 © 2022 The Apache Software Foundation. All Rights Reserved.