本文整理汇总了Java中org.apache.cassandra.db.compaction.CompactionInfo.Holder类的典型用法代码示例。如果您正苦于以下问题：Java Holder类的具体用法？Java Holder怎么用？Java Holder使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
Holder类属于org.apache.cassandra.db.compaction.CompactionInfo包，在下文中一共展示了Holder类的11个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: scrubOne
import org.apache.cassandra.db.compaction.CompactionInfo.Holder; //导入依赖的package包/类
private void scrubOne(ColumnFamilyStore cfs, SSTableReader sstable, boolean skipCorrupted) throws IOException
{
Scrubber scrubber = new Scrubber(cfs, sstable, skipCorrupted, false);
CompactionInfo.Holder scrubInfo = scrubber.getScrubInfo();
metrics.beginCompaction(scrubInfo);
try
{
scrubber.scrub();
}
finally
{
scrubber.close();
metrics.finishCompaction(scrubInfo);
}
}
开发者ID:vcostet，项目名称:cassandra-kmean，代码行数:17，代码来源:CompactionManager.java
示例2: scrubOne
import org.apache.cassandra.db.compaction.CompactionInfo.Holder; //导入依赖的package包/类
private void scrubOne(ColumnFamilyStore cfs, SSTableReader sstable) throws IOException
{
Scrubber scrubber = new Scrubber(cfs, sstable);
CompactionInfo.Holder scrubInfo = scrubber.getScrubInfo();
metrics.beginCompaction(scrubInfo);
try
{
scrubber.scrub();
}
finally
{
scrubber.close();
metrics.finishCompaction(scrubInfo);
}
if (scrubber.getNewInOrderSSTable() != null)
cfs.addSSTable(scrubber.getNewInOrderSSTable());
if (scrubber.getNewSSTable() == null)
cfs.markObsolete(Collections.singletonList(sstable), OperationType.SCRUB);
else
cfs.replaceCompactedSSTables(Collections.singletonList(sstable), Collections.singletonList(scrubber.getNewSSTable()), OperationType.SCRUB);
}
开发者ID:pgaref，项目名称:ACaZoo，代码行数:25，代码来源:CompactionManager.java
示例3: scrubOne
import org.apache.cassandra.db.compaction.CompactionInfo.Holder; //导入依赖的package包/类
private void scrubOne(ColumnFamilyStore cfs, LifecycleTransaction modifier, boolean skipCorrupted, boolean checkData) throws IOException
{
CompactionInfo.Holder scrubInfo = null;
try (Scrubber scrubber = new Scrubber(cfs, modifier, skipCorrupted, checkData))
{
scrubInfo = scrubber.getScrubInfo();
metrics.beginCompaction(scrubInfo);
scrubber.scrub();
}
finally
{
if (scrubInfo != null)
metrics.finishCompaction(scrubInfo);
}
}
开发者ID:scylladb，项目名称:scylla-tools-java，代码行数:17，代码来源:CompactionManager.java
示例4: verifyOne
import org.apache.cassandra.db.compaction.CompactionInfo.Holder; //导入依赖的package包/类
private void verifyOne(ColumnFamilyStore cfs, SSTableReader sstable, boolean extendedVerify) throws IOException
{
CompactionInfo.Holder verifyInfo = null;
try (Verifier verifier = new Verifier(cfs, sstable, false))
{
verifyInfo = verifier.getVerifyInfo();
metrics.beginCompaction(verifyInfo);
verifier.verify(extendedVerify);
}
finally
{
if (verifyInfo != null)
metrics.finishCompaction(verifyInfo);
}
}
开发者ID:scylladb，项目名称:scylla-tools-java，代码行数:17，代码来源:CompactionManager.java
示例5: scrubOne
import org.apache.cassandra.db.compaction.CompactionInfo.Holder; //导入依赖的package包/类
private void scrubOne(ColumnFamilyStore cfs, SSTableReader sstable) throws IOException
{
Scrubber scrubber = new Scrubber(cfs, sstable);
CompactionInfo.Holder scrubInfo = scrubber.getScrubInfo();
metrics.beginCompaction(scrubInfo);
try
{
scrubber.scrub();
}
finally
{
scrubber.close();
metrics.finishCompaction(scrubInfo);
}
if (scrubber.getNewInOrderSSTable() != null)
cfs.addSSTable(scrubber.getNewInOrderSSTable());
if (scrubber.getNewSSTable() == null)
cfs.markCompacted(Collections.singletonList(sstable), OperationType.SCRUB);
else
cfs.replaceCompactedSSTables(Collections.singletonList(sstable), Collections.singletonList(scrubber.getNewSSTable()), OperationType.SCRUB);
}
开发者ID:dprguiuc，项目名称:Cassandra-Wasef，代码行数:25，代码来源:CompactionManager.java
示例6: scrubOne
import org.apache.cassandra.db.compaction.CompactionInfo.Holder; //导入依赖的package包/类
private void scrubOne(ColumnFamilyStore cfs, SSTableReader sstable, boolean skipCorrupted) throws IOException
{
Scrubber scrubber = new Scrubber(cfs, sstable, skipCorrupted);
CompactionInfo.Holder scrubInfo = scrubber.getScrubInfo();
metrics.beginCompaction(scrubInfo);
try
{
scrubber.scrub();
}
finally
{
scrubber.close();
metrics.finishCompaction(scrubInfo);
}
if (scrubber.getNewInOrderSSTable() != null)
cfs.addSSTable(scrubber.getNewInOrderSSTable());
if (scrubber.getNewSSTable() == null)
cfs.markObsolete(Collections.singletonList(sstable), OperationType.SCRUB);
else
cfs.replaceCompactedSSTables(Collections.singletonList(sstable), Collections.singletonList(scrubber.getNewSSTable()), OperationType.SCRUB);
}
开发者ID:rajath26，项目名称:cassandra-trunk，代码行数:25，代码来源:CompactionManager.java
示例7: getCompactions
import org.apache.cassandra.db.compaction.CompactionInfo.Holder; //导入依赖的package包/类
public List<Map<String, String>> getCompactions()
{
List<Holder> compactionHolders = CompactionMetrics.getCompactions();
List<Map<String, String>> out = new ArrayList<Map<String, String>>(compactionHolders.size());
for (CompactionInfo.Holder ci : compactionHolders)
out.add(ci.getCompactionInfo().asMap());
return out;
}
开发者ID:vcostet，项目名称:cassandra-kmean，代码行数:9，代码来源:CompactionManager.java
示例8: getCompactionSummary
import org.apache.cassandra.db.compaction.CompactionInfo.Holder; //导入依赖的package包/类
public List<String> getCompactionSummary()
{
List<Holder> compactionHolders = CompactionMetrics.getCompactions();
List<String> out = new ArrayList<String>(compactionHolders.size());
for (CompactionInfo.Holder ci : compactionHolders)
out.add(ci.getCompactionInfo().toString());
return out;
}
开发者ID:vcostet，项目名称:cassandra-kmean，代码行数:9，代码来源:CompactionManager.java
示例9: stopCompaction
import org.apache.cassandra.db.compaction.CompactionInfo.Holder; //导入依赖的package包/类
public void stopCompaction(String type)
{
OperationType operation = OperationType.valueOf(type);
for (Holder holder : CompactionMetrics.getCompactions())
{
if (holder.getCompactionInfo().getTaskType() == operation)
holder.stop();
}
}
开发者ID:vcostet，项目名称:cassandra-kmean，代码行数:10，代码来源:CompactionManager.java
示例10: forceShutdown
import org.apache.cassandra.db.compaction.CompactionInfo.Holder; //导入依赖的package包/类
/**
* Shutdowns both compaction and validation executors, cancels running compaction / validation,
* and waits for tasks to complete if tasks were not cancelable.
*/
public void forceShutdown()
{
// shutdown executors to prevent further submission
executor.shutdown();
validationExecutor.shutdown();
// interrupt compactions and validations
for (Holder compactionHolder : CompactionMetrics.getCompactions())
{
compactionHolder.stop();
}
// wait for tasks to terminate
// compaction tasks are interrupted above, so it shuold be fairy quick
// until not interrupted tasks to complete.
for (ExecutorService exec : Arrays.asList(executor, validationExecutor))
{
try
{
exec.awaitTermination(1, TimeUnit.MINUTES);
}
catch (InterruptedException e)
{
logger.error("Interrupted while waiting for tasks to be terminated", e);
}
}
}
开发者ID:scylladb，项目名称:scylla-tools-java，代码行数:32，代码来源:CompactionManager.java
示例11: stopCompactionById
import org.apache.cassandra.db.compaction.CompactionInfo.Holder; //导入依赖的package包/类
public void stopCompactionById(String compactionId)
{
for (Holder holder : CompactionMetrics.getCompactions())
{
UUID holderId = holder.getCompactionInfo().compactionId();
if (holderId != null && holderId.equals(UUID.fromString(compactionId)))
holder.stop();
}
}
开发者ID:scylladb，项目名称:scylla-tools-java，代码行数:10，代码来源:CompactionManager.java
注：本文中的org.apache.cassandra.db.compaction.CompactionInfo.Holder类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。 |
客服电话
APP下载
官方微信
请发表评论