Package | Description |
---|---|
io.druid.indexer |
Modifier and Type | Method and Description |
---|---|
static Pair<Bucket,byte[]> |
Bucket.fromGroupKey(byte[] keyBytes) |
com.google.common.base.Optional<Iterable<Bucket>> |
HadoopDruidIndexerConfig.getAllBuckets() |
com.google.common.base.Optional<Bucket> |
HadoopDruidIndexerConfig.getBucket(InputRow inputRow)
Get the proper bucket for some input row.
|
Modifier and Type | Method and Description |
---|---|
HadoopyShardSpec |
HadoopDruidIndexerConfig.getShardSpec(Bucket bucket) |
int |
HadoopDruidIndexerConfig.getShardSpecCount(Bucket bucket) |
Copyright © 2011–2017. All rights reserved.