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