Skip to content

Commit 3db44c0

Browse files
committed
Fix rebase errors
1 parent 5671780 commit 3db44c0

File tree

5 files changed

+4
-5
lines changed

5 files changed

+4
-5
lines changed

benchmarks/src/main/java/org/apache/druid/benchmark/query/OakTopNBenchmark.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -141,7 +141,6 @@ public class OakTopNBenchmark
141141
JSON_MAPPER = new DefaultObjectMapper();
142142
INDEX_IO = new IndexIO(
143143
JSON_MAPPER,
144-
OffHeapMemorySegmentWriteOutMediumFactory.instance(),
145144
new ColumnConfig()
146145
{
147146
@Override

processing/src/main/java/org/apache/druid/segment/incremental/ExternalDataIncrementalIndex.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -165,7 +165,7 @@ public Iterator<Row> iterator()
165165
continue;
166166
}
167167
final DimensionIndexer indexer = dimensionDesc.getIndexer();
168-
Object rowVals = indexer.convertUnsortedEncodedKeyComponentToActualArrayOrList(dim, DimensionIndexer.LIST);
168+
Object rowVals = indexer.convertUnsortedEncodedKeyComponentToActualList(dim);
169169
theVals.put(dimensionName, rowVals);
170170
}
171171

processing/src/main/java/org/apache/druid/segment/incremental/OakIncrementalIndex.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -160,7 +160,7 @@ public Row apply(Map.Entry<ByteBuffer, ByteBuffer> entry)
160160
continue;
161161
}
162162
final DimensionIndexer indexer = dimensionDesc.getIndexer();
163-
Object rowVals = indexer.convertUnsortedEncodedKeyComponentToActualArrayOrList(dim, DimensionIndexer.LIST);
163+
Object rowVals = indexer.convertUnsortedEncodedKeyComponentToActualList(dim);
164164
theVals.put(dimensionName, rowVals);
165165
}
166166

processing/src/main/java/org/apache/druid/segment/incremental/OffheapAggsManager.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -83,7 +83,7 @@ protected BufferAggregator[] initAggs(
8383

8484
selectors.put(
8585
agg.getName(),
86-
new OnheapIncrementalIndex.ObjectCachingColumnSelectorFactory(columnSelectorFactory, concurrentEventAdd)
86+
new OnheapIncrementalIndex.CachingColumnSelectorFactory(columnSelectorFactory, concurrentEventAdd)
8787
);
8888

8989
if (i == 0) {

processing/src/main/java/org/apache/druid/segment/incremental/OnheapAggsManager.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -123,7 +123,7 @@ public Aggregator[] initAggs(
123123
for (AggregatorFactory agg : metrics) {
124124
selectors.put(
125125
agg.getName(),
126-
new OnheapIncrementalIndex.ObjectCachingColumnSelectorFactory(
126+
new OnheapIncrementalIndex.CachingColumnSelectorFactory(
127127
makeColumnSelectorFactory(agg, rowSupplier, deserializeComplexMetrics),
128128
concurrentEventAdd
129129
)

0 commit comments

Comments
 (0)