本文整理汇总了Java中skadistats.clarity.processor.runner.ControllableRunner.seek方法的典型用法代码示例。如果您正苦于以下问题：Java ControllableRunner.seek方法的具体用法？Java ControllableRunner.seek怎么用？Java ControllableRunner.seek使用的例子？那么恭喜您, 这里精选的方法代码示例或许可以为您提供帮助。您也可以进一步了解该方法所在类skadistats.clarity.processor.runner.ControllableRunner的用法示例。
在下文中一共展示了ControllableRunner.seek方法的3个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于系统推荐出更棒的Java代码示例。
示例1: runSeek
import skadistats.clarity.processor.runner.ControllableRunner; //导入方法依赖的package包/类
public void runSeek(String[] args) throws Exception {
ControllableRunner runner = new ControllableRunner(new MappedFileSource(args[0])).runWith(this);
int lastTick = runner.getLastTick();
Random r = new Random();
int i = N_SEEKS;
try {
long tStart = System.nanoTime();
while (i-- > 0) {
int nextTick = r.nextInt(lastTick);
log.warn("seeking to {}", nextTick);
runner.seek(nextTick);
}
long tTick = System.nanoTime() - tStart;
double tMs = tTick / 1000000.0d;
log.warn("{} seek operations took {}ms, {}ms/seek", N_SEEKS, tMs, tMs / N_SEEKS);
} finally {
runner.halt();
}
}
示例2: runSeek
import skadistats.clarity.processor.runner.ControllableRunner; //导入方法依赖的package包/类
public void runSeek(String[] args) throws Exception {
ControllableRunner runner = new ControllableRunner(new MappedFileSource(args[0])).runWith(this);
runner.seek(30000);
System.out.println("at 30000\n\n");
runner.seek(0);
System.out.println("at 0\n\n");
runner.halt();
}
示例3: run
import skadistats.clarity.processor.runner.ControllableRunner; //导入方法依赖的package包/类
public void run(String[] args) throws Exception {
long tStart = System.currentTimeMillis();
int tick = Integer.valueOf(args[0]);
String demoName = args[1];
ControllableRunner r = new ControllableRunner(new MappedFileSource(demoName)).runWith(this);
r.seek(tick);
r.halt();
Context ctx = r.getContext();
File dir = new File(String.format("baselines%s%s", File.separator, ctx.getBuildNumber() == -1 ? "latest" : ctx.getBuildNumber()));
if (!dir.exists()) {
dir.mkdirs();
}
FieldReader fieldReader = ctx.getEngineType().getNewFieldReader();
StringTables stringTables = ctx.getProcessor(StringTables.class);
DTClasses dtClasses = ctx.getProcessor(DTClasses.class);
StringTable baselines = stringTables.forName("instancebaseline");
for (int i = 0; i < baselines.getEntryCount(); i++) {
DTClass dtClass = dtClasses.forClassId(Integer.valueOf(baselines.getNameByIndex(i)));
String fileName = String.format("%s%s%s.txt", dir.getPath(), File.separator, dtClass.getDtName());
log.info("writing {}", fileName);
fieldReader.DEBUG_STREAM = new PrintStream(new FileOutputStream(fileName), true, "UTF-8");
BitStream bs = BitStream.createBitStream(baselines.getValueByIndex(i));
try {
fieldReader.readFields(bs, dtClass, dtClass.getEmptyStateArray(), true);
if (bs.remaining() < 0 || bs.remaining() > 7) {
log.info("-- OFF: {} remaining", bs.remaining());
}
} catch (Exception e) {
log.info("-- FAIL: {}", e.getMessage());
e.printStackTrace(fieldReader.DEBUG_STREAM);
} finally {
}
}
long tMatch = System.currentTimeMillis() - tStart;
log.info("total time taken: {}s", (tMatch) / 1000.0);
}