io.druid.segment.QueryableIndexIndexableAdapter.<init>()方法的使用及代码示例

x33g5p2x  于2022-01-29 转载在 其他  
字(2.1k)|赞(0)|评价(0)|浏览(49)

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

QueryableIndexIndexableAdapter.<init>介绍

暂无

代码示例

代码示例来源:origin: com.n3twork.druid/druid-processing

@Override
 public IndexableAdapter apply(final QueryableIndex input)
 {
  return new QueryableIndexIndexableAdapter(input);
 }
}

代码示例来源:origin: io.druid/druid-processing

public void validateTwoSegments(File dir1, File dir2) throws IOException
{
 try (QueryableIndex queryableIndex1 = loadIndex(dir1)) {
  try (QueryableIndex queryableIndex2 = loadIndex(dir2)) {
   validateTwoSegments(
     new QueryableIndexIndexableAdapter(queryableIndex1),
     new QueryableIndexIndexableAdapter(queryableIndex2)
   );
  }
 }
}

代码示例来源:origin: io.druid/druid-processing

final IndexableAdapter adapter = new QueryableIndexIndexableAdapter(index);
return makeIndexFiles(
  ImmutableList.of(adapter),

代码示例来源:origin: com.n3twork.druid/druid-indexing-service

adapters.add(
  new RowboatFilteringIndexAdapter(
    new QueryableIndexIndexableAdapter(
      IndexIO.loadIndex(holder.getFile())
    ),

代码示例来源:origin: io.druid/druid-indexing-service

adapters.add(
  new RowboatFilteringIndexAdapter(
    new QueryableIndexIndexableAdapter(
      toolbox.getIndexIO().loadIndex(holder.getFile())
    ),

代码示例来源:origin: com.n3twork.druid/druid-processing

public static boolean convertSegment(File toConvert, File converted) throws IOException
{
 final int version = SegmentUtils.getVersionFromDir(toConvert);
 switch (version) {
  case 1:
  case 2:
  case 3:
   log.makeAlert("Attempt to load segment of version <= 3.")
     .addData("version", version)
     .emit();
   return false;
  case 4:
  case 5:
  case 6:
  case 7:
   log.info("Old version, re-persisting.");
   IndexMerger.append(
     Arrays.<IndexableAdapter>asList(new QueryableIndexIndexableAdapter(loadIndex(toConvert))),
     converted
   );
   return true;
  case 8:
   DefaultIndexIOHandler.convertV8toV9(toConvert, converted);
   return true;
  default:
   log.info("Version[%s], skipping.", version);
   return false;
 }
}

相关文章

微信公众号

最新文章

更多

QueryableIndexIndexableAdapter类方法