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

HStore.createFlushContext介绍

暂无

代码示例

代码示例来源：origin: apache/hbase

private MemStoreSize doDropStoreMemStoreContentsForSeqId(HStore s, long currentSeqId)
  throws IOException {
 MemStoreSize flushableSize = s.getFlushableSize();
 this.decrMemStoreSize(flushableSize);
 StoreFlushContext ctx = s.createFlushContext(currentSeqId, FlushLifeCycleTracker.DUMMY);
 ctx.prepare();
 ctx.abort();
 return flushableSize;
}

代码示例来源：origin: apache/hbase

private static void flushStore(HStore store, long id) throws IOException {
 StoreFlushContext storeFlushCtx = store.createFlushContext(id, FlushLifeCycleTracker.DUMMY);
 storeFlushCtx.prepare();
 storeFlushCtx.flushCache(Mockito.mock(MonitoredTask.class));
 storeFlushCtx.commit(Mockito.mock(MonitoredTask.class));
}

代码示例来源：origin: apache/hbase

long startTime = EnvironmentEdgeManager.currentTime();
if (prepareFlushResult == null || prepareFlushResult.storeFlushCtxs == null) {
 ctx = store.createFlushContext(flush.getFlushSequenceNumber(), FlushLifeCycleTracker.DUMMY);
} else {
 ctx = prepareFlushResult.storeFlushCtxs.get(family);

代码示例来源：origin: apache/hbase

StoreFlushContext storeFlushCtx = store.createFlushContext(id++, FlushLifeCycleTracker.DUMMY);
storeFlushCtx.prepare();
inputCellsAfterSnapshot.forEach(c -> store.add(c, null));

代码示例来源：origin: apache/hbase

store.createFlushContext(12345, FlushLifeCycleTracker.DUMMY);
storeFlushCtx.prepare();

代码示例来源：origin: apache/hbase

s.createFlushContext(flushOpSeqId, tracker));

代码示例来源：origin: apache/hbase

quals.add(qf2);
quals.add(qf3);
StoreFlushContext storeFlushCtx = store.createFlushContext(id++, FlushLifeCycleTracker.DUMMY);
MyCompactingMemStore.START_TEST.set(true);
Runnable flush = () -> {

代码示例来源：origin: apache/hbase

faultyLog.setStoreFlushCtx(store.createFlushContext(12345, FlushLifeCycleTracker.DUMMY));

代码示例来源：origin: apache/hbase

StoreFlushContext storeFlushCtx = store.createFlushContext(12345, FlushLifeCycleTracker.DUMMY);
storeFlushCtx.prepare();

代码示例来源：origin: apache/hbase

store.add(createCell(qf3, ts, seqId, value), memStoreSizing);
assertEquals(1, MyCompactingMemStoreWithCustomCompactor.RUNNER_COUNT.get());
StoreFlushContext storeFlushCtx = store.createFlushContext(id++, FlushLifeCycleTracker.DUMMY);
storeFlushCtx.prepare();

代码示例来源：origin: apache/hbase

long snapshotId = id++;
StoreFlushContext storeFlushCtx = store.createFlushContext(snapshotId, FlushLifeCycleTracker
  .DUMMY);
storeFlushCtx.prepare();

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

private static void flushStore(HStore store, long id) throws IOException {
 StoreFlushContext storeFlushCtx = store.createFlushContext(id, FlushLifeCycleTracker.DUMMY);
 storeFlushCtx.prepare();
 storeFlushCtx.flushCache(Mockito.mock(MonitoredTask.class));
 storeFlushCtx.commit(Mockito.mock(MonitoredTask.class));
}

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

StoreFlushContext storeFlushCtx = store.createFlushContext(id++, FlushLifeCycleTracker.DUMMY);
storeFlushCtx.prepare();
inputCellsAfterSnapshot.forEach(c -> store.add(c, null));

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

store.createFlushContext(12345, FlushLifeCycleTracker.DUMMY);
storeFlushCtx.prepare();

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

quals.add(qf2);
quals.add(qf3);
StoreFlushContext storeFlushCtx = store.createFlushContext(id++, FlushLifeCycleTracker.DUMMY);
MyCompactingMemStore.START_TEST.set(true);
Runnable flush = () -> {

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

faultyLog.setStoreFlushCtx(store.createFlushContext(12345, FlushLifeCycleTracker.DUMMY));

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

store.add(createCell(qf3, ts, seqId, value), memStoreSizing);
assertEquals(1, MyCompactingMemStoreWithCustomCompactor.RUNNER_COUNT.get());
StoreFlushContext storeFlushCtx = store.createFlushContext(id++, FlushLifeCycleTracker.DUMMY);
storeFlushCtx.prepare();

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

StoreFlushContext storeFlushCtx = store.createFlushContext(12345, FlushLifeCycleTracker.DUMMY);
storeFlushCtx.prepare();

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

long snapshotId = id++;
StoreFlushContext storeFlushCtx = store.createFlushContext(snapshotId, FlushLifeCycleTracker
  .DUMMY);
storeFlushCtx.prepare();