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

QueryableIndex.getMetadata介绍

暂无

代码示例

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

@Override
 public Metadata getMetadata()
 {
  return index.getMetadata();
 }
}

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

private static AggregatorFactory[] createMetricsSpec(
  List<Pair<QueryableIndex, DataSegment>> queryableIndexAndSegments
)
{
 final List<AggregatorFactory[]> aggregatorFactories = queryableIndexAndSegments
   .stream()
   .map(pair -> pair.lhs.getMetadata().getAggregators()) // We have already done null check on index.getMetadata()
   .collect(Collectors.toList());
 final AggregatorFactory[] mergedAggregators = AggregatorFactory.mergeAggregators(aggregatorFactories);
 if (mergedAggregators == null) {
  throw new ISE("Failed to merge aggregators[%s]", aggregatorFactories);
 }
 return mergedAggregators;
}

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

if (index.getMetadata() == null) {
  throw new RE("Index metadata doesn't exist for segment[%s]", pair.rhs.getId());
 final Boolean isRollup = pair.lhs.getMetadata().isRollup();
 return isRollup != null && isRollup;
});

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

Metadata segmentMetadata = queryableIndex.getMetadata();
if (segmentMetadata != null) {
 Object timestampObj = segmentMetadata.get(COMMIT_METADATA_TIMESTAMP_KEY);
   log.info(
     "Found metaData [%s] with latestCommitTime [%s] greater than previous recorded [%s]",
     queryableIndex.getMetadata(), timestamp, latestCommitTime
   );
   latestCommitTime = timestamp;
   metadata = queryableIndex.getMetadata().get(COMMIT_METADATA_KEY);

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

@Test
public void testPersistWithSegmentMetadata() throws IOException
{
 File outDir = Files.createTempDir();
 QueryableIndex index = null;
 try {
  outDir = Files.createTempDir();
  index = indexIO.loadIndex(indexMerger.persist(toPersist, outDir, INDEX_SPEC, null));
  Assert.assertEquals("value", index.getMetadata().get("key"));
 }
 finally {
  if (index != null) {
   index.close();
  }
  if (outDir != null) {
   FileUtils.deleteDirectory(outDir);
  }
 }
}

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

index.getMetadata().getAggregators()
);
  index.getMetadata().getQueryGranularity()
);

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

@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

index1.getMetadata().getAggregators()
);
  merged.getMetadata().getAggregators()
);

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

merged.getMetadata().getAggregators()
);

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

converted.getMetadata().getAggregators()
);

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

converted.getMetadata().getAggregators()
);

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

@Override
 public Metadata getMetadata()
 {
  return index.getMetadata();
 }
}

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

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

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

if (index.getMetadata() == null) {
  throw new RE("Index metadata doesn't exist for segment[%s]", pair.rhs.getIdentifier());
  .map(pair -> pair.lhs.getMetadata().getAggregators()) // We have already done null check on index.getMetadata()
  .collect(Collectors.toList());
final AggregatorFactory[] mergedAggregators = AggregatorFactory.mergeAggregators(aggregatorFactories);
 final Boolean isRollup = pair.lhs.getMetadata().isRollup();
 return isRollup != null && isRollup;
});

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

Metadata segmentMetadata = queryableIndex.getMetadata();
if (segmentMetadata != null) {
 Object timestampObj = segmentMetadata.get(COMMIT_METADATA_TIMESTAMP_KEY);
   log.info(
     "Found metaData [%s] with latestCommitTime [%s] greater than previous recorded [%s]",
     queryableIndex.getMetadata(), timestamp, latestCommitTime
   );
   latestCommitTime = timestamp;
   metadata = queryableIndex.getMetadata().get(COMMIT_METADATA_KEY);