| Package | Description |
|---|---|
| io.druid.indexer |
| Modifier and Type | Method and Description |
|---|---|
static SortableBytes |
SortableBytes.fromBytes(byte[] bytes) |
static SortableBytes |
SortableBytes.fromBytes(byte[] bytes,
int offset,
int length) |
static SortableBytes |
SortableBytes.fromBytesWritable(org.apache.hadoop.io.BytesWritable bytes) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
DeterminePartitionsJob.DeterminePartitionsDimSelectionCombiner.innerReduce(org.apache.hadoop.mapreduce.Reducer.Context context,
SortableBytes keyBytes,
Iterable<io.druid.indexer.DeterminePartitionsJob.DimValueCount> combinedIterable) |
protected void |
DeterminePartitionsJob.DeterminePartitionsDimSelectionReducer.innerReduce(org.apache.hadoop.mapreduce.Reducer.Context context,
SortableBytes keyBytes,
Iterable<io.druid.indexer.DeterminePartitionsJob.DimValueCount> combinedIterable) |
Copyright © 2011–2017. All rights reserved.