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–2015. All rights reserved.