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

QueryableIndex.getColumnNames介绍

暂无

代码示例

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

@Override
public List<String> getMetricNames()
{
 final Set<String> columns = Sets.newLinkedHashSet(input.getColumnNames());
 final HashSet<String> dimensions = Sets.newHashSet(getDimensionNames());
 return ImmutableList.copyOf(Sets.difference(columns, dimensions));
}

代码示例来源：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

private List<String> getColumnsToInclude(final QueryableIndex index)
{
 final Set<String> columnNames = Sets.newLinkedHashSet(columnNamesFromCli);
 // Empty columnNames => include all columns.
 if (columnNames.isEmpty()) {
  columnNames.add(ColumnHolder.TIME_COLUMN_NAME);
  Iterables.addAll(columnNames, index.getColumnNames());
 } else {
  // Remove any provided columns that do not exist in this segment.
  for (String columnName : ImmutableList.copyOf(columnNames)) {
   if (index.getColumnHolder(columnName) == null) {
    columnNames.remove(columnName);
   }
  }
 }
 return ImmutableList.copyOf(columnNames);
}

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

);
List<String> expectedColumnNames = Arrays.asList("A", "d1");
List<String> actualColumnNames = Lists.newArrayList(index.getColumnNames());
Collections.sort(expectedColumnNames);
Collections.sort(actualColumnNames);

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

Assert.assertEquals(3, index.getColumnNames().size());
assertDimCompression(index, indexSpec.getDimensionCompression());

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

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

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

Assert.assertEquals(3, index.getColumnNames().size());
Assert.assertEquals(3, index.getColumnNames().size());
Assert.assertEquals(3, index.getColumnNames().size());

代码示例来源：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

Lists.newArrayList(index.getAvailableDimensions())
);
Assert.assertEquals(3, index.getColumnNames().size());

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

Assert.assertEquals(3, index1.getColumnNames().size());
Assert.assertEquals(3, merged.getColumnNames().size());

代码示例来源：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(3, index1.getColumnNames().size());
Assert.assertEquals(3, index2.getColumnNames().size());
Assert.assertEquals(3, merged.getColumnNames().size());
assertDimCompression(index2, indexSpec.getDimensionCompression());
assertDimCompression(index1, indexSpec.getDimensionCompression());

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

Assert.assertEquals(4, index1.getColumnNames().size());
Assert.assertEquals(4, converted.getColumnNames().size());

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

Assert.assertEquals(3, index1.getColumnNames().size());
Assert.assertEquals(3, merged.getColumnNames().size());

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

Assert.assertEquals(3, index1.getColumnNames().size());
Assert.assertEquals(3, merged.getColumnNames().size());

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

Assert.assertEquals(4, index1.getColumnNames().size());
Assert.assertEquals(4, converted.getColumnNames().size());

代码示例来源：origin: org.apache.druid/druid-processing

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

代码示例来源：origin: org.apache.druid/druid-processing

@Override
public List<String> getMetricNames()
{
 final Set<String> columns = Sets.newLinkedHashSet(input.getColumnNames());
 final HashSet<String> dimensions = Sets.newHashSet(getDimensionNames());
 return ImmutableList.copyOf(Sets.difference(columns, dimensions));
}

代码示例来源：origin: org.apache.druid/druid-services

private List<String> getColumnsToInclude(final QueryableIndex index)
{
 final Set<String> columnNames = Sets.newLinkedHashSet(columnNamesFromCli);
 // Empty columnNames => include all columns.
 if (columnNames.isEmpty()) {
  columnNames.add(ColumnHolder.TIME_COLUMN_NAME);
  Iterables.addAll(columnNames, index.getColumnNames());
 } else {
  // Remove any provided columns that do not exist in this segment.
  for (String columnName : ImmutableList.copyOf(columnNames)) {
   if (index.getColumnHolder(columnName) == null) {
    columnNames.remove(columnName);
   }
  }
 }
 return ImmutableList.copyOf(columnNames);
}