本文整理了Java中io.druid.segment.QueryableIndexIndexableAdapter.<init>
方法的一些代码示例,展示了QueryableIndexIndexableAdapter.<init>
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。QueryableIndexIndexableAdapter.<init>
方法的具体详情如下:
包路径:io.druid.segment.QueryableIndexIndexableAdapter
类名称: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;
}
}
内容来源于网络,如有侵权,请联系作者删除!