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

QueryableIndex.getNumRows介绍

暂无

代码示例

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

@Override
public int getNumRows()
{
 return index.getNumRows();
}

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

.mapToLong(queryableIndexAndDataSegment -> queryableIndexAndDataSegment.lhs.getNumRows())
  .sum();
final long totalSizeBytes = queryableIndexAndSegments

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

@Override
 public WindowedStorageAdapter apply(WindowedDataSegment segment)
 {
  try {
   logger.info("Getting storage path for segment [%s]", segment.getSegment().getId());
   Path path = new Path(JobHelper.getURIFromSegment(segment.getSegment()));
   logger.info("Fetch segment files from [%s]", path);
   File dir = Files.createTempDir();
   tmpSegmentDirs.add(dir);
   logger.info("Locally storing fetched segment at [%s]", dir);
   JobHelper.unzipNoGuava(path, context.getConfiguration(), dir, context, null);
   logger.info("finished fetching segment files");
   QueryableIndex index = HadoopDruidIndexerConfig.INDEX_IO.loadIndex(dir);
   indexes.add(index);
   numRows += index.getNumRows();
   return new WindowedStorageAdapter(
     new QueryableIndexStorageAdapter(index),
     segment.getInterval()
   );
  }
  catch (IOException ex) {
   throw Throwables.propagate(ex);
  }
 }
}

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

ReferenceCountingSegment segment = hydrant.getIncrementedSegment();
try {
 numRowsExcludingCurrIndex.addAndGet(segment.asQueryableIndex().getNumRows());

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

);
final int totalRows = index.getNumRows();

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

),
  ImmutableMultiset.copyOf(
    IntStream.range(0, index.getNumRows())
         .mapToObj(rowNumber -> getRow(dictionaryColumn, rowNumber))
for (int i = 0; i < index.getNumRows(); i++) {
 final List<String> row = getRow(dictionaryColumn, i);
 if (row.isEmpty() || row.stream().anyMatch(NullHandling::isNullOrEquivalent)) {

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

@Override
public int getNumRows()
{
 return index.getNumRows();
}

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

.mapToLong(queryableIndexAndDataSegment -> queryableIndexAndDataSegment.lhs.getNumRows())
  .sum();
final long totalSizeBytes = queryableIndexAndSegments

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

@Override
 public WindowedStorageAdapter apply(WindowedDataSegment segment)
 {
  try {
   logger.info("Getting storage path for segment [%s]", segment.getSegment().getIdentifier());
   Path path = new Path(JobHelper.getURIFromSegment(segment.getSegment()));
   logger.info("Fetch segment files from [%s]", path);
   File dir = Files.createTempDir();
   tmpSegmentDirs.add(dir);
   logger.info("Locally storing fetched segment at [%s]", dir);
   JobHelper.unzipNoGuava(path, context.getConfiguration(), dir, context, null);
   logger.info("finished fetching segment files");
   QueryableIndex index = HadoopDruidIndexerConfig.INDEX_IO.loadIndex(dir);
   indexes.add(index);
   numRows += index.getNumRows();
   return new WindowedStorageAdapter(
     new QueryableIndexStorageAdapter(index),
     segment.getInterval()
   );
  }
  catch (IOException ex) {
   throw Throwables.propagate(ex);
  }
 }
}

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

ReferenceCountingSegment segment = hydrant.getIncrementedSegment();
try {
 numRowsExcludingCurrIndex.addAndGet(segment.asQueryableIndex().getNumRows());

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

);
final int totalRows = index.getNumRows();