org.apache.druid.segment.QueryableIndex.getAvailableDimensions()方法的使用及代码示例

x33g5p2x  于2022-01-28 转载在 其他  
字(7.7k)|赞(0)|评价(0)|浏览(68)

本文整理了Java中org.apache.druid.segment.QueryableIndex.getAvailableDimensions方法的一些代码示例,展示了QueryableIndex.getAvailableDimensions的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。QueryableIndex.getAvailableDimensions方法的具体详情如下:
包路径:org.apache.druid.segment.QueryableIndex
类名称:QueryableIndex
方法名:getAvailableDimensions

QueryableIndex.getAvailableDimensions介绍

暂无

代码示例

代码示例来源:origin: apache/incubator-druid

@Override
public Indexed<String> getAvailableDimensions()
{
 return index.getAvailableDimensions();
}

代码示例来源:origin: apache/incubator-druid

@Override
public Iterable<String> getAvailableMetrics()
{
 HashSet<String> columnNames = Sets.newHashSet(index.getColumnNames());
 return Sets.difference(columnNames, Sets.newHashSet(index.getAvailableDimensions()));
}

代码示例来源:origin: apache/incubator-druid

public QueryableIndexIndexableAdapter(QueryableIndex input)
{
 this.input = input;
 numRows = input.getNumRows();
 availableDimensions = ImmutableList.copyOf(input.getAvailableDimensions());
 this.metadata = input.getMetadata();
}

代码示例来源:origin: apache/incubator-druid

final Map<String, DimensionHandler> dimensionHandlerMap = queryableIndex.getDimensionHandlers();
for (String dimension : queryableIndex.getAvailableDimensions()) {
 final ColumnHolder columnHolder = Preconditions.checkNotNull(
   queryableIndex.getColumnHolder(dimension),

代码示例来源:origin: apache/incubator-druid

.withDimensions(ImmutableList.copyOf(mappedSegment.getAvailableDimensions()))
.withBinaryVersion(SegmentUtils.getVersionFromDir(fileToUpload));

代码示例来源:origin: apache/incubator-druid

Assert.assertEquals(Arrays.asList("dim1", "dim2"), Lists.newArrayList(index.getAvailableDimensions()));
Assert.assertEquals(3, index.getColumnNames().size());
assertDimCompression(index, indexSpec.getDimensionCompression());

代码示例来源:origin: apache/incubator-druid

Assert.assertEquals("getDimensionNames", 0, Iterables.size(emptyQueryableIndex.getAvailableDimensions()));
Assert.assertEquals("getMetricNames", 0, emptyQueryableIndex.getColumnNames().size());
Assert.assertEquals("getDataInterval", Intervals.of("2012-08-01/P3D"), emptyQueryableIndex.getDataInterval());

代码示例来源:origin: apache/incubator-druid

try {
 QueryableIndex oldIndex = segment.asQueryableIndex();
 for (String dim : oldIndex.getAvailableDimensions()) {
  dimOrder.add(dim);
  oldCapabilities.put(dim, (ColumnCapabilitiesImpl) oldIndex.getColumnHolder(dim).getCapabilities());

代码示例来源:origin: apache/incubator-druid

@Test
public void testPersistWithSegmentMetadata() throws Exception
{
 final long timestamp = System.currentTimeMillis();
 IncrementalIndex toPersist = IncrementalIndexTest.createIndex(null);
 IncrementalIndexTest.populateIndex(timestamp, toPersist);
 Map<String, Object> metadataElems = ImmutableMap.of("key", "value");
 toPersist.getMetadata().putAll(metadataElems);
 final File tempDir = temporaryFolder.newFolder();
 QueryableIndex index = closer.closeLater(
   indexIO.loadIndex(indexMerger.persist(toPersist, tempDir, indexSpec, null))
 );
 Assert.assertEquals(2, index.getColumnHolder(ColumnHolder.TIME_COLUMN_NAME).getLength());
 Assert.assertEquals(Arrays.asList("dim1", "dim2"), Lists.newArrayList(index.getAvailableDimensions()));
 Assert.assertEquals(3, index.getColumnNames().size());
 assertDimCompression(index, indexSpec.getDimensionCompression());
 Assert.assertEquals(
   new Metadata(
     metadataElems,
     IncrementalIndexTest.getDefaultCombiningAggregatorFactories(),
     null,
     Granularities.NONE,
     Boolean.TRUE
   ),
   index.getMetadata()
 );
}

代码示例来源:origin: apache/incubator-druid

Assert.assertEquals(ImmutableList.of("dim2"), ImmutableList.copyOf(index1.getAvailableDimensions()));
Assert.assertEquals(ImmutableList.of("dim2"), ImmutableList.copyOf(index2.getAvailableDimensions()));
Assert.assertEquals(ImmutableList.of("dim2"), ImmutableList.copyOf(merged.getAvailableDimensions()));

代码示例来源:origin: apache/incubator-druid

@Test
public void testPersist() throws Exception
{
 final long timestamp = System.currentTimeMillis();
 IncrementalIndex toPersist = IncrementalIndexTest.createIndex(null);
 IncrementalIndexTest.populateIndex(timestamp, toPersist);
 final File tempDir = temporaryFolder.newFolder();
 QueryableIndex index = closer.closeLater(
   indexIO.loadIndex(indexMerger.persist(toPersist, tempDir, indexSpec, null))
 );
 Assert.assertEquals(2, index.getColumnHolder(ColumnHolder.TIME_COLUMN_NAME).getLength());
 Assert.assertEquals(Arrays.asList("dim1", "dim2"), Lists.newArrayList(index.getAvailableDimensions()));
 Assert.assertEquals(3, index.getColumnNames().size());
 assertDimCompression(index, indexSpec.getDimensionCompression());
 Assert.assertArrayEquals(
   IncrementalIndexTest.getDefaultCombiningAggregatorFactories(),
   index.getMetadata().getAggregators()
 );
 Assert.assertEquals(
   Granularities.NONE,
   index.getMetadata().getQueryGranularity()
 );
}

代码示例来源:origin: apache/incubator-druid

Assert.assertEquals(Arrays.asList("dim1", "dim2"), Lists.newArrayList(index1.getAvailableDimensions()));
Assert.assertEquals(3, index1.getColumnNames().size());
Assert.assertEquals(Arrays.asList("dim1", "dim2"), Lists.newArrayList(merged.getAvailableDimensions()));
Assert.assertEquals(3, merged.getColumnNames().size());

代码示例来源:origin: apache/incubator-druid

Assert.assertEquals(
  Arrays.asList("dim1", "dim2"),
  Lists.newArrayList(index.getAvailableDimensions())
);
Assert.assertEquals(3, index.getColumnNames().size());

代码示例来源:origin: apache/incubator-druid

Assert.assertEquals(Arrays.asList("dim1", "dim2"), Lists.newArrayList(index1.getAvailableDimensions()));
Assert.assertEquals(3, index1.getColumnNames().size());
Assert.assertEquals(Arrays.asList("dim1", "dim2"), Lists.newArrayList(index2.getAvailableDimensions()));
Assert.assertEquals(3, index2.getColumnNames().size());
Assert.assertEquals(Arrays.asList("dim1", "dim2"), Lists.newArrayList(merged.getAvailableDimensions()));
Assert.assertEquals(3, merged.getColumnNames().size());
assertDimCompression(index2, indexSpec.getDimensionCompression());

代码示例来源:origin: apache/incubator-druid

Assert.assertEquals(Arrays.asList("dim1", "dim2"), Lists.newArrayList(index1.getAvailableDimensions()));
Assert.assertEquals(3, index1.getColumnNames().size());
Assert.assertEquals(Arrays.asList("dim1", "dim2"), Lists.newArrayList(merged.getAvailableDimensions()));
Assert.assertEquals(3, merged.getColumnNames().size());

代码示例来源:origin: apache/incubator-druid

Assert.assertEquals(Arrays.asList("dim1", "dim2"), Lists.newArrayList(index1.getAvailableDimensions()));
Assert.assertEquals(4, index1.getColumnNames().size());
Assert.assertEquals(Arrays.asList("dim1", "dim2"), Lists.newArrayList(converted.getAvailableDimensions()));
Assert.assertEquals(4, converted.getColumnNames().size());

代码示例来源:origin: apache/incubator-druid

Assert.assertEquals(Arrays.asList("dim1", "dim2"), Lists.newArrayList(index1.getAvailableDimensions()));
Assert.assertEquals(3, index1.getColumnNames().size());
Assert.assertEquals(Arrays.asList("dim1", "dim2"), Lists.newArrayList(merged.getAvailableDimensions()));
Assert.assertEquals(3, merged.getColumnNames().size());

代码示例来源:origin: apache/incubator-druid

index.getAvailableDimensions(),
  query.getDimensions()
);

代码示例来源:origin: apache/incubator-druid

Assert.assertEquals(Arrays.asList("dim1", "dim2"), Lists.newArrayList(index1.getAvailableDimensions()));
Assert.assertEquals(4, index1.getColumnNames().size());
Assert.assertEquals(Arrays.asList("dim1", "dim2"), Lists.newArrayList(converted.getAvailableDimensions()));
Assert.assertEquals(4, converted.getColumnNames().size());

代码示例来源:origin: apache/incubator-druid

.buildMMappedIndex();
if (index4.getAvailableDimensions().size() != 0) {

相关文章