Package | Description |
---|---|
io.druid.segment | |
io.druid.segment.incremental |
Modifier and Type | Method and Description |
---|---|
Rowboat |
IndexMerger.RowboatMergeFunction.apply(Rowboat lhs,
Rowboat rhs) |
Modifier and Type | Method and Description |
---|---|
Iterable<Rowboat> |
IndexMerger.MMappedIndexRowIterable.getIndex() |
Iterable<Rowboat> |
RowboatFilteringIndexAdapter.getRows() |
Iterable<Rowboat> |
QueryableIndexIndexableAdapter.getRows() |
Iterable<Rowboat> |
IndexableAdapter.getRows() |
Iterator<Rowboat> |
IndexMerger.MMappedIndexRowIterable.iterator() |
protected Iterable<Rowboat> |
IndexMerger.makeRowIterable(List<IndexableAdapter> indexes,
List<String> mergedDimensions,
List<String> mergedMetrics,
com.google.common.base.Function<ArrayList<Iterable<Rowboat>>,Iterable<Rowboat>> rowMergerFn,
List<ColumnCapabilitiesImpl> dimCapabilities,
DimensionHandler[] handlers,
List<DimensionMerger> mergers) |
Modifier and Type | Method and Description |
---|---|
Rowboat |
IndexMerger.RowboatMergeFunction.apply(Rowboat lhs,
Rowboat rhs) |
int |
Rowboat.compareTo(Rowboat rhs) |
static void |
IndexIO.validateRowValues(Map<String,DimensionHandler> dimHandlers,
Rowboat rb1,
IndexableAdapter adapter1,
Rowboat rb2,
IndexableAdapter adapter2) |
Modifier and Type | Method and Description |
---|---|
protected File |
IndexMergerV9.makeIndexFiles(List<IndexableAdapter> adapters,
AggregatorFactory[] metricAggs,
File outDir,
ProgressIndicator progress,
List<String> mergedDimensions,
List<String> mergedMetrics,
com.google.common.base.Function<ArrayList<Iterable<Rowboat>>,Iterable<Rowboat>> rowMergerFn,
IndexSpec indexSpec) |
protected File |
IndexMergerV9.makeIndexFiles(List<IndexableAdapter> adapters,
AggregatorFactory[] metricAggs,
File outDir,
ProgressIndicator progress,
List<String> mergedDimensions,
List<String> mergedMetrics,
com.google.common.base.Function<ArrayList<Iterable<Rowboat>>,Iterable<Rowboat>> rowMergerFn,
IndexSpec indexSpec) |
protected File |
IndexMerger.makeIndexFiles(List<IndexableAdapter> indexes,
AggregatorFactory[] metricAggs,
File outDir,
ProgressIndicator progress,
List<String> mergedDimensions,
List<String> mergedMetrics,
com.google.common.base.Function<ArrayList<Iterable<Rowboat>>,Iterable<Rowboat>> rowMergerFn,
IndexSpec indexSpec) |
protected File |
IndexMerger.makeIndexFiles(List<IndexableAdapter> indexes,
AggregatorFactory[] metricAggs,
File outDir,
ProgressIndicator progress,
List<String> mergedDimensions,
List<String> mergedMetrics,
com.google.common.base.Function<ArrayList<Iterable<Rowboat>>,Iterable<Rowboat>> rowMergerFn,
IndexSpec indexSpec) |
protected Iterable<Rowboat> |
IndexMerger.makeRowIterable(List<IndexableAdapter> indexes,
List<String> mergedDimensions,
List<String> mergedMetrics,
com.google.common.base.Function<ArrayList<Iterable<Rowboat>>,Iterable<Rowboat>> rowMergerFn,
List<ColumnCapabilitiesImpl> dimCapabilities,
DimensionHandler[] handlers,
List<DimensionMerger> mergers) |
protected Iterable<Rowboat> |
IndexMerger.makeRowIterable(List<IndexableAdapter> indexes,
List<String> mergedDimensions,
List<String> mergedMetrics,
com.google.common.base.Function<ArrayList<Iterable<Rowboat>>,Iterable<Rowboat>> rowMergerFn,
List<ColumnCapabilitiesImpl> dimCapabilities,
DimensionHandler[] handlers,
List<DimensionMerger> mergers) |
Constructor and Description |
---|
RowboatFilteringIndexAdapter(IndexableAdapter baseAdapter,
com.google.common.base.Predicate<Rowboat> filter) |
Modifier and Type | Method and Description |
---|---|
Iterable<Rowboat> |
IncrementalIndexAdapter.getRows() |
Copyright © 2011–2017. All rights reserved.