本文整理汇总了Java中org.apache.cassandra.db.DataTracker类的典型用法代码示例。如果您正苦于以下问题:Java DataTracker类的具体用法?Java DataTracker怎么用?Java DataTracker使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
DataTracker类属于org.apache.cassandra.db包,在下文中一共展示了DataTracker类的8个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: getCompactingAndNonCompactingSSTables
import org.apache.cassandra.db.DataTracker; //导入依赖的package包/类
/**
* Returns a Pair of all compacting and non-compacting sstables. Non-compacting sstables will be marked as
* compacting.
*/
private Pair<List<SSTableReader>, Multimap<DataTracker, SSTableReader>> getCompactingAndNonCompactingSSTables()
{
List<SSTableReader> allCompacting = new ArrayList<>();
Multimap<DataTracker, SSTableReader> allNonCompacting = HashMultimap.create();
for (Keyspace ks : Keyspace.all())
{
for (ColumnFamilyStore cfStore: ks.getColumnFamilyStores())
{
Set<SSTableReader> nonCompacting, allSSTables;
do
{
allSSTables = cfStore.getDataTracker().getSSTables();
nonCompacting = Sets.newHashSet(cfStore.getDataTracker().getUncompactingSSTables(allSSTables));
}
while (!(nonCompacting.isEmpty() || cfStore.getDataTracker().markCompacting(nonCompacting)));
allNonCompacting.putAll(cfStore.getDataTracker(), nonCompacting);
allCompacting.addAll(Sets.difference(allSSTables, nonCompacting));
}
}
return Pair.create(allCompacting, allNonCompacting);
}
开发者ID:vcostet,项目名称:cassandra-kmean,代码行数:26,代码来源:IndexSummaryManager.java
示例2: refreshOverlaps
import org.apache.cassandra.db.DataTracker; //导入依赖的package包/类
private void refreshOverlaps()
{
if (this.overlappingSSTables != null)
overlappingSSTables.release();
if (compacting == null)
overlappingSSTables = Refs.tryRef(Collections.<SSTableReader>emptyList());
else
overlappingSSTables = cfs.getAndReferenceOverlappingSSTables(compacting);
this.overlappingTree = DataTracker.buildIntervalTree(overlappingSSTables);
}
开发者ID:vcostet,项目名称:cassandra-kmean,代码行数:12,代码来源:CompactionController.java
示例3: setTracker
import org.apache.cassandra.db.DataTracker; //导入依赖的package包/类
public void setTracker(DataTracker tracker)
{
// the tracker is used only to notify listeners of deletion of the sstable;
// since deletion of a non-final file is not really deletion of the sstable,
// we don't want to notify the listeners in this event
if (desc.type == Descriptor.Type.FINAL)
this.tracker = tracker;
}
开发者ID:vcostet,项目名称:cassandra-kmean,代码行数:9,代码来源:SSTableDeletingTask.java
示例4: setTrackedBy
import org.apache.cassandra.db.DataTracker; //导入依赖的package包/类
public void setTrackedBy(DataTracker tracker)
{
tidy.type.deletingTask.setTracker(tracker);
// under normal operation we can do this at any time, but SSTR is also used outside C* proper,
// e.g. by BulkLoader, which does not initialize the cache. As a kludge, we set up the cache
// here when we know we're being wired into the rest of the server infrastructure.
keyCache = CacheService.instance.keyCache;
}
开发者ID:vcostet,项目名称:cassandra-kmean,代码行数:9,代码来源:SSTableReader.java
示例5: redistributeSummaries
import org.apache.cassandra.db.DataTracker; //导入依赖的package包/类
public void redistributeSummaries() throws IOException
{
Pair<List<SSTableReader>, Multimap<DataTracker, SSTableReader>> compactingAndNonCompacting = getCompactingAndNonCompactingSSTables();
try
{
redistributeSummaries(compactingAndNonCompacting.left, Lists.newArrayList(compactingAndNonCompacting.right.values()), this.memoryPoolBytes);
}
finally
{
for(DataTracker tracker : compactingAndNonCompacting.right.keySet())
tracker.unmarkCompacting(compactingAndNonCompacting.right.get(tracker));
}
}
开发者ID:vcostet,项目名称:cassandra-kmean,代码行数:14,代码来源:IndexSummaryManager.java
示例6: setTrackedBy
import org.apache.cassandra.db.DataTracker; //导入依赖的package包/类
public void setTrackedBy(DataTracker tracker)
{
deletingTask.setTracker(tracker);
// under normal operation we can do this at any time, but SSTR is also used outside C* proper,
// e.g. by BulkLoader, which does not initialize the cache. As a kludge, we set up the cache
// here when we know we're being wired into the rest of the server infrastructure.
keyCache = CacheService.instance.keyCache;
}
开发者ID:daidong,项目名称:GraphTrek,代码行数:9,代码来源:SSTableReader.java
示例7: SSTableDeletingReference
import org.apache.cassandra.db.DataTracker; //导入依赖的package包/类
SSTableDeletingReference(DataTracker tracker, SSTableReader referent, ReferenceQueue<? super SSTableReader> q)
{
super(referent, q);
this.tracker = tracker;
this.desc = referent.descriptor;
this.components = referent.components;
this.size = referent.bytesOnDisk();
}
开发者ID:devdattakulkarni,项目名称:Cassandra-KVPM,代码行数:9,代码来源:SSTableDeletingReference.java
示例8: setTracker
import org.apache.cassandra.db.DataTracker; //导入依赖的package包/类
public void setTracker(DataTracker tracker)
{
this.tracker = tracker;
}
开发者ID:pgaref,项目名称:ACaZoo,代码行数:5,代码来源:SSTableDeletingTask.java
注:本文中的org.apache.cassandra.db.DataTracker类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论