• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    迪恩网络公众号
登陆 注册
描述文字

Java CacheService类代码示例

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

本文整理汇总了Java中org.apache.cassandra.service.CacheService类的典型用法代码示例。如果您正苦于以下问题：Java CacheService类的具体用法？Java CacheService怎么用？Java CacheService使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。



CacheService类属于org.apache.cassandra.service包，在下文中一共展示了CacheService类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: getCurrentValues

import org.apache.cassandra.service.CacheService; //导入依赖的package包/类
private ClockAndCount[] getCurrentValues(List<CounterUpdateCell> counterUpdateCells, ColumnFamilyStore cfs)
{
    ClockAndCount[] currentValues = new ClockAndCount[counterUpdateCells.size()];
    int remaining = counterUpdateCells.size();

    if (CacheService.instance.counterCache.getCapacity() != 0)
    {
        Tracing.trace("Fetching {} counter values from cache", counterUpdateCells.size());
        remaining = getCurrentValuesFromCache(counterUpdateCells, cfs, currentValues);
        if (remaining == 0)
            return currentValues;
    }

    Tracing.trace("Reading {} counter values from the CF", remaining);
    getCurrentValuesFromCFS(counterUpdateCells, cfs, currentValues);

    return currentValues;
}
开发者ID:vcostet，项目名称:cassandra-kmean，代码行数:19，代码来源:CounterMutation.java


示例2: Writer

import org.apache.cassandra.service.CacheService; //导入依赖的package包/类
protected Writer(int keysToSave)
{
    if (keysToSave >= getKeySet().size())
        keys = getKeySet();
    else
        keys = hotKeySet(keysToSave);

    OperationType type;
    if (cacheType == CacheService.CacheType.KEY_CACHE)
        type = OperationType.KEY_CACHE_SAVE;
    else if (cacheType == CacheService.CacheType.ROW_CACHE)
        type = OperationType.ROW_CACHE_SAVE;
    else if (cacheType == CacheService.CacheType.COUNTER_CACHE)
        type = OperationType.COUNTER_CACHE_SAVE;
    else
        type = OperationType.UNKNOWN;

    info = new CompactionInfo(CFMetaData.denseCFMetaData(Keyspace.SYSTEM_KS, cacheType.toString(), BytesType.instance),
                              type,
                              0,
                              keys.size(),
                              "keys");
}
开发者ID:vcostet，项目名称:cassandra-kmean，代码行数:24，代码来源:AutoSavingCache.java


示例3: testRowCacheCleanup

import org.apache.cassandra.service.CacheService; //导入依赖的package包/类
@Test
public void testRowCacheCleanup() throws Exception
{
    StorageService.instance.initServer(0);
    CacheService.instance.setRowCacheCapacityInMB(1);
    rowCacheLoad(100, Integer.MAX_VALUE, 1000);

    ColumnFamilyStore store = Keyspace.open(KEYSPACE).getColumnFamilyStore(COLUMN_FAMILY);
    assertEquals(CacheService.instance.rowCache.getKeySet().size(), 100);
    store.cleanupCache();
    assertEquals(CacheService.instance.rowCache.getKeySet().size(), 100);
    TokenMetadata tmd = StorageService.instance.getTokenMetadata();
    byte[] tk1, tk2;
    tk1 = "key1000".getBytes();
    tk2 = "key1050".getBytes();
    tmd.updateNormalToken(new BytesToken(tk1), InetAddress.getByName("127.0.0.1"));
    tmd.updateNormalToken(new BytesToken(tk2), InetAddress.getByName("127.0.0.2"));
    store.cleanupCache();
    assertEquals(CacheService.instance.rowCache.getKeySet().size(), 50);
    CacheService.instance.setRowCacheCapacityInMB(0);
}
开发者ID:vcostet，项目名称:cassandra-kmean，代码行数:22，代码来源:RowCacheTest.java


示例4: testReadWrite

import org.apache.cassandra.service.CacheService; //导入依赖的package包/类
@Test
public void testReadWrite()
{
    ColumnFamilyStore cfs = Keyspace.open(KS).getColumnFamilyStore(CF);
    CacheService.instance.invalidateCounterCache();

    assertEquals(0, CacheService.instance.counterCache.size());
    assertNull(cfs.getCachedCounter(bytes(1), cellname(1)));
    assertNull(cfs.getCachedCounter(bytes(1), cellname(2)));
    assertNull(cfs.getCachedCounter(bytes(2), cellname(1)));
    assertNull(cfs.getCachedCounter(bytes(2), cellname(2)));

    cfs.putCachedCounter(bytes(1), cellname(1), ClockAndCount.create(1L, 1L));
    cfs.putCachedCounter(bytes(1), cellname(2), ClockAndCount.create(1L, 2L));
    cfs.putCachedCounter(bytes(2), cellname(1), ClockAndCount.create(2L, 1L));
    cfs.putCachedCounter(bytes(2), cellname(2), ClockAndCount.create(2L, 2L));

    assertEquals(4, CacheService.instance.counterCache.size());
    assertEquals(ClockAndCount.create(1L, 1L), cfs.getCachedCounter(bytes(1), cellname(1)));
    assertEquals(ClockAndCount.create(1L, 2L), cfs.getCachedCounter(bytes(1), cellname(2)));
    assertEquals(ClockAndCount.create(2L, 1L), cfs.getCachedCounter(bytes(2), cellname(1)));
    assertEquals(ClockAndCount.create(2L, 2L), cfs.getCachedCounter(bytes(2), cellname(2)));
}
开发者ID:vcostet，项目名称:cassandra-kmean，代码行数:24，代码来源:CounterCacheTest.java


示例5: testSaveLoad

import org.apache.cassandra.service.CacheService; //导入依赖的package包/类
@Test
public void testSaveLoad() throws ExecutionException, InterruptedException, WriteTimeoutException
{
    ColumnFamilyStore cfs = Keyspace.open(KS).getColumnFamilyStore(CF);
    CacheService.instance.invalidateCounterCache();

    ColumnFamily cells = ArrayBackedSortedColumns.factory.create(cfs.metadata);
    cells.addColumn(new BufferCounterUpdateCell(cellname(1), 1L, FBUtilities.timestampMicros()));
    cells.addColumn(new BufferCounterUpdateCell(cellname(2), 2L, FBUtilities.timestampMicros()));
    new CounterMutation(new Mutation(KS, bytes(1), cells), ConsistencyLevel.ONE).apply();
    new CounterMutation(new Mutation(KS, bytes(2), cells), ConsistencyLevel.ONE).apply();

    // flush the counter cache and invalidate
    CacheService.instance.counterCache.submitWrite(Integer.MAX_VALUE).get();
    CacheService.instance.invalidateCounterCache();
    assertEquals(0, CacheService.instance.counterCache.size());

    // load from cache and validate
    CacheService.instance.counterCache.loadSaved(cfs);
    assertEquals(4, CacheService.instance.counterCache.size());
    assertEquals(ClockAndCount.create(1L, 1L), cfs.getCachedCounter(bytes(1), cellname(1)));
    assertEquals(ClockAndCount.create(1L, 2L), cfs.getCachedCounter(bytes(1), cellname(2)));
    assertEquals(ClockAndCount.create(1L, 1L), cfs.getCachedCounter(bytes(2), cellname(1)));
    assertEquals(ClockAndCount.create(1L, 2L), cfs.getCachedCounter(bytes(2), cellname(2)));
}
开发者ID:vcostet，项目名称:cassandra-kmean，代码行数:26，代码来源:CounterCacheTest.java


示例6: Writer

import org.apache.cassandra.service.CacheService; //导入依赖的package包/类
protected Writer(int keysToSave)
{
    if (keysToSave >= getKeySet().size())
        keys = getKeySet();
    else
        keys = hotKeySet(keysToSave);

    OperationType type;
    if (cacheType == CacheService.CacheType.KEY_CACHE)
        type = OperationType.KEY_CACHE_SAVE;
    else if (cacheType == CacheService.CacheType.ROW_CACHE)
        type = OperationType.ROW_CACHE_SAVE;
    else
        type = OperationType.UNKNOWN;

    info = new CompactionInfo(new CFMetaData(Keyspace.SYSTEM_KS, cacheType.toString(), ColumnFamilyType.Standard, BytesType.instance, null),
                              type,
                              0,
                              keys.size(),
                              "keys");
}
开发者ID:pgaref，项目名称:ACaZoo，代码行数:22，代码来源:AutoSavingCache.java


示例7: processModifications

import org.apache.cassandra.service.CacheService; //导入依赖的package包/类
private PartitionUpdate processModifications(PartitionUpdate changes)
{
    ColumnFamilyStore cfs = Keyspace.open(getKeyspaceName()).getColumnFamilyStore(changes.metadata().cfId);

    List<PartitionUpdate.CounterMark> marks = changes.collectCounterMarks();

    if (CacheService.instance.counterCache.getCapacity() != 0)
    {
        Tracing.trace("Fetching {} counter values from cache", marks.size());
        updateWithCurrentValuesFromCache(marks, cfs);
        if (marks.isEmpty())
            return changes;
    }

    Tracing.trace("Reading {} counter values from the CF", marks.size());
    updateWithCurrentValuesFromCFS(marks, cfs);

    // What's remain is new counters
    for (PartitionUpdate.CounterMark mark : marks)
        updateWithCurrentValue(mark, ClockAndCount.BLANK, cfs);

    return changes;
}
开发者ID:scylladb，项目名称:scylla-tools-java，代码行数:24，代码来源:CounterMutation.java


示例8: invalidateRowCache

import org.apache.cassandra.service.CacheService; //导入依赖的package包/类
public int invalidateRowCache(Collection<Bounds<Token>> boundsToInvalidate)
{
    int invalidatedKeys = 0;
    for (Iterator<RowCacheKey> keyIter = CacheService.instance.rowCache.keyIterator();
         keyIter.hasNext(); )
    {
        RowCacheKey key = keyIter.next();
        DecoratedKey dk = decorateKey(ByteBuffer.wrap(key.key));
        if (key.ksAndCFName.equals(metadata.ksAndCFName) && Bounds.isInBounds(dk.getToken(), boundsToInvalidate))
        {
            invalidateCachedPartition(dk);
            invalidatedKeys++;
        }
    }
    return invalidatedKeys;
}
开发者ID:scylladb，项目名称:scylla-tools-java，代码行数:17，代码来源:ColumnFamilyStore.java


示例9: invalidateCounterCache

import org.apache.cassandra.service.CacheService; //导入依赖的package包/类
public int invalidateCounterCache(Collection<Bounds<Token>> boundsToInvalidate)
{
    int invalidatedKeys = 0;
    for (Iterator<CounterCacheKey> keyIter = CacheService.instance.counterCache.keyIterator();
         keyIter.hasNext(); )
    {
        CounterCacheKey key = keyIter.next();
        DecoratedKey dk = decorateKey(ByteBuffer.wrap(key.partitionKey));
        if (key.ksAndCFName.equals(metadata.ksAndCFName) && Bounds.isInBounds(dk.getToken(), boundsToInvalidate))
        {
            CacheService.instance.counterCache.remove(key);
            invalidatedKeys++;
        }
    }
    return invalidatedKeys;
}
开发者ID:scylladb，项目名称:scylla-tools-java，代码行数:17，代码来源:ColumnFamilyStore.java


示例10: testRowCacheCleanup

import org.apache.cassandra.service.CacheService; //导入依赖的package包/类
@Test
public void testRowCacheCleanup() throws Exception
{
    StorageService.instance.initServer(0);
    CacheService.instance.setRowCacheCapacityInMB(1);
    rowCacheLoad(100, Integer.MAX_VALUE, 1000);

    ColumnFamilyStore store = Keyspace.open(KEYSPACE_CACHED).getColumnFamilyStore(CF_CACHED);
    assertEquals(CacheService.instance.rowCache.size(), 100);
    store.cleanupCache();
    assertEquals(CacheService.instance.rowCache.size(), 100);
    TokenMetadata tmd = StorageService.instance.getTokenMetadata();
    byte[] tk1, tk2;
    tk1 = "key1000".getBytes();
    tk2 = "key1050".getBytes();
    tmd.updateNormalToken(new BytesToken(tk1), InetAddress.getByName("127.0.0.1"));
    tmd.updateNormalToken(new BytesToken(tk2), InetAddress.getByName("127.0.0.2"));
    store.cleanupCache();
    assertEquals(50, CacheService.instance.rowCache.size());
    CacheService.instance.setRowCacheCapacityInMB(0);
}
开发者ID:scylladb，项目名称:scylla-tools-java，代码行数:22，代码来源:RowCacheTest.java


示例11: testInvalidateRowCache

import org.apache.cassandra.service.CacheService; //导入依赖的package包/类
@Test
public void testInvalidateRowCache() throws Exception
{
    StorageService.instance.initServer(0);
    CacheService.instance.setRowCacheCapacityInMB(1);
    rowCacheLoad(100, Integer.MAX_VALUE, 1000);

    ColumnFamilyStore store = Keyspace.open(KEYSPACE_CACHED).getColumnFamilyStore(CF_CACHED);
    assertEquals(CacheService.instance.rowCache.size(), 100);

    //construct 5 bounds of 20 elements each
    ArrayList<Bounds<Token>> subranges = getBounds(20);

    //invalidate 3 of the 5 bounds
    ArrayList<Bounds<Token>> boundsToInvalidate = Lists.newArrayList(subranges.get(0), subranges.get(2), subranges.get(4));
    int invalidatedKeys = store.invalidateRowCache(boundsToInvalidate);
    assertEquals(60, invalidatedKeys);

    //now there should be only 40 cached entries left
    assertEquals(CacheService.instance.rowCache.size(), 40);
    CacheService.instance.setRowCacheCapacityInMB(0);
}
开发者ID:scylladb，项目名称:scylla-tools-java，代码行数:23，代码来源:RowCacheTest.java


示例12: getBounds

import org.apache.cassandra.service.CacheService; //导入依赖的package包/类
private ArrayList<Bounds<Token>> getBounds(int nElements)
{
    ColumnFamilyStore store = Keyspace.open(KEYSPACE_CACHED).getColumnFamilyStore(CF_CACHED);
    TreeSet<DecoratedKey> orderedKeys = new TreeSet<>();

    for(Iterator<RowCacheKey> it = CacheService.instance.rowCache.keyIterator();it.hasNext();)
        orderedKeys.add(store.decorateKey(ByteBuffer.wrap(it.next().key)));

    ArrayList<Bounds<Token>> boundsToInvalidate = new ArrayList<>();
    Iterator<DecoratedKey> iterator = orderedKeys.iterator();

    while (iterator.hasNext())
    {
        Token startRange = iterator.next().getToken();
        for (int i = 0; i < nElements-2; i++)
            iterator.next();
        Token endRange = iterator.next().getToken();
        boundsToInvalidate.add(new Bounds<>(startRange, endRange));
    }
    return boundsToInvalidate;
}
开发者ID:scylladb，项目名称:scylla-tools-java，代码行数:22，代码来源:RowCacheTest.java


示例13: rowCacheLoad

import org.apache.cassandra.service.CacheService; //导入依赖的package包/类
public void rowCacheLoad(int totalKeys, int keysToSave, int offset) throws Exception
{
    CompactionManager.instance.disableAutoCompaction();

    ColumnFamilyStore store = Keyspace.open(KEYSPACE_CACHED).getColumnFamilyStore(CF_CACHED);

    // empty the cache
    CacheService.instance.invalidateRowCache();
    assertEquals(0, CacheService.instance.rowCache.size());

    // insert data and fill the cache
    SchemaLoader.insertData(KEYSPACE_CACHED, CF_CACHED, offset, totalKeys);
    readData(KEYSPACE_CACHED, CF_CACHED, offset, totalKeys);
    assertEquals(totalKeys, CacheService.instance.rowCache.size());

    // force the cache to disk
    CacheService.instance.rowCache.submitWrite(keysToSave).get();

    // empty the cache again to make sure values came from disk
    CacheService.instance.invalidateRowCache();
    assertEquals(0, CacheService.instance.rowCache.size());
    assertEquals(keysToSave == Integer.MAX_VALUE ? totalKeys : keysToSave, CacheService.instance.rowCache.loadSaved());
}
开发者ID:scylladb，项目名称:scylla-tools-java，代码行数:24，代码来源:RowCacheTest.java


示例14: verifyCache

import org.apache.cassandra.service.CacheService; //导入依赖的package包/类
private static void verifyCache(String legacyVersion, long startCount) throws InterruptedException, java.util.concurrent.ExecutionException
{
    //For https://issues.apache.org/jira/browse/CASSANDRA-10778
    //Validate whether the key cache successfully saves in the presence of old keys as
    //well as loads the correct number of keys
    long endCount = CacheService.instance.keyCache.size();
    Assert.assertTrue(endCount > startCount);
    CacheService.instance.keyCache.submitWrite(Integer.MAX_VALUE).get();
    CacheService.instance.invalidateKeyCache();
    Assert.assertEquals(startCount, CacheService.instance.keyCache.size());
    CacheService.instance.keyCache.loadSaved();
    if (BigFormat.instance.getVersion(legacyVersion).storeRows())
        Assert.assertEquals(endCount, CacheService.instance.keyCache.size());
    else
        Assert.assertEquals(startCount, CacheService.instance.keyCache.size());
}
开发者ID:scylladb，项目名称:scylla-tools-java，代码行数:17，代码来源:LegacySSTableTest.java


示例15: testRowCacheCleanup

import org.apache.cassandra.service.CacheService; //导入依赖的package包/类
@Test
public void testRowCacheCleanup() throws Exception
{
    StorageService.instance.initServer(0);
    CacheService.instance.setRowCacheCapacityInMB(1);
    rowCacheLoad(100, Integer.MAX_VALUE, 1000);

    ColumnFamilyStore store = Keyspace.open(KEYSPACE_CACHED).getColumnFamilyStore(CF_CACHED);
    assertEquals(CacheService.instance.rowCache.getKeySet().size(), 100);
    store.cleanupCache();
    assertEquals(CacheService.instance.rowCache.getKeySet().size(), 100);
    TokenMetadata tmd = StorageService.instance.getTokenMetadata();
    byte[] tk1, tk2;
    tk1 = "key1000".getBytes();
    tk2 = "key1050".getBytes();
    tmd.updateNormalToken(new BytesToken(tk1), InetAddress.getByName("127.0.0.1"));
    tmd.updateNormalToken(new BytesToken(tk2), InetAddress.getByName("127.0.0.2"));
    store.cleanupCache();
    assertEquals(CacheService.instance.rowCache.getKeySet().size(), 50);
    CacheService.instance.setRowCacheCapacityInMB(0);
}
开发者ID:daidong，项目名称:GraphTrek，代码行数:22，代码来源:RowCacheTest.java


示例16: testReadWrite

import org.apache.cassandra.service.CacheService; //导入依赖的package包/类
@Test
public void testReadWrite()
{
    ColumnFamilyStore cfs = Keyspace.open(KEYSPACE1).getColumnFamilyStore(CF);
    CacheService.instance.invalidateCounterCache();

    assertEquals(0, CacheService.instance.counterCache.size());
    assertNull(cfs.getCachedCounter(bytes(1), cellname(1)));
    assertNull(cfs.getCachedCounter(bytes(1), cellname(2)));
    assertNull(cfs.getCachedCounter(bytes(2), cellname(1)));
    assertNull(cfs.getCachedCounter(bytes(2), cellname(2)));

    cfs.putCachedCounter(bytes(1), cellname(1), ClockAndCount.create(1L, 1L));
    cfs.putCachedCounter(bytes(1), cellname(2), ClockAndCount.create(1L, 2L));
    cfs.putCachedCounter(bytes(2), cellname(1), ClockAndCount.create(2L, 1L));
    cfs.putCachedCounter(bytes(2), cellname(2), ClockAndCount.create(2L, 2L));

    assertEquals(4, CacheService.instance.counterCache.size());
    assertEquals(ClockAndCount.create(1L, 1L), cfs.getCachedCounter(bytes(1), cellname(1)));
    assertEquals(ClockAndCount.create(1L, 2L), cfs.getCachedCounter(bytes(1), cellname(2)));
    assertEquals(ClockAndCount.create(2L, 1L), cfs.getCachedCounter(bytes(2), cellname(1)));
    assertEquals(ClockAndCount.create(2L, 2L), cfs.getCachedCounter(bytes(2), cellname(2)));
}
开发者ID:daidong，项目名称:GraphTrek，代码行数:24，代码来源:CounterCacheTest.java


示例17: testSaveLoad

import org.apache.cassandra.service.CacheService; //导入依赖的package包/类
@Test
public void testSaveLoad() throws ExecutionException, InterruptedException, WriteTimeoutException
{
    ColumnFamilyStore cfs = Keyspace.open(KEYSPACE1).getColumnFamilyStore(CF);
    CacheService.instance.invalidateCounterCache();

    ColumnFamily cells = ArrayBackedSortedColumns.factory.create(cfs.metadata);
    cells.addColumn(new BufferCounterUpdateCell(cellname(1), 1L, FBUtilities.timestampMicros()));
    cells.addColumn(new BufferCounterUpdateCell(cellname(2), 2L, FBUtilities.timestampMicros()));
    new CounterMutation(new Mutation(KEYSPACE1, bytes(1), cells), ConsistencyLevel.ONE).apply();
    new CounterMutation(new Mutation(KEYSPACE1, bytes(2), cells), ConsistencyLevel.ONE).apply();

    // flush the counter cache and invalidate
    CacheService.instance.counterCache.submitWrite(Integer.MAX_VALUE).get();
    CacheService.instance.invalidateCounterCache();
    assertEquals(0, CacheService.instance.counterCache.size());

    // load from cache and validate
    CacheService.instance.counterCache.loadSaved(cfs);
    assertEquals(4, CacheService.instance.counterCache.size());
    assertEquals(ClockAndCount.create(1L, 1L), cfs.getCachedCounter(bytes(1), cellname(1)));
    assertEquals(ClockAndCount.create(1L, 2L), cfs.getCachedCounter(bytes(1), cellname(2)));
    assertEquals(ClockAndCount.create(1L, 1L), cfs.getCachedCounter(bytes(2), cellname(1)));
    assertEquals(ClockAndCount.create(1L, 2L), cfs.getCachedCounter(bytes(2), cellname(2)));
}
开发者ID:daidong，项目名称:GraphTrek，代码行数:26，代码来源:CounterCacheTest.java


示例18: invalidate

import org.apache.cassandra.service.CacheService; //导入依赖的package包/类
/** call when dropping or renaming a CF. Performs mbean housekeeping and invalidates CFS to other operations */
public void invalidate()
{
    valid = false;

    try
    {
        unregisterMBean();
    }
    catch (Exception e)
    {
        // this shouldn't block anything.
        logger.warn("Failed unregistering mbean: " + mbeanName, e);
    }

    compactionStrategy.shutdown();

    SystemTable.removeTruncationRecord(metadata.cfId);
    data.unreferenceSSTables();
    indexManager.invalidate();

    for (RowCacheKey key : CacheService.instance.rowCache.getKeySet())
        if (key.cfId == metadata.cfId)
            invalidateCachedRow(key);
}
开发者ID:jackliu8722，项目名称:cassandra-1.2.16，代码行数:26，代码来源:ColumnFamilyStore.java


示例19: Writer

import org.apache.cassandra.service.CacheService; //导入依赖的package包/类
protected Writer(int keysToSave)
{
    if (keysToSave >= getKeySet().size())
        keys = getKeySet();
    else
        keys = hotKeySet(keysToSave);

    OperationType type;
    if (cacheType == CacheService.CacheType.KEY_CACHE)
        type = OperationType.KEY_CACHE_SAVE;
    else if (cacheType == CacheService.CacheType.ROW_CACHE)
        type = OperationType.ROW_CACHE_SAVE;
    else
        type = OperationType.UNKNOWN;

    info = new CompactionInfo(CFMetaData.denseCFMetaData(Keyspace.SYSTEM_KS, cacheType.toString(), BytesType.instance),
                              type,
                              0,
                              keys.size(),
                              "keys");
}
开发者ID:mafernandez-stratio，项目名称:cassandra-cqlMod，代码行数:22，代码来源:AutoSavingCache.java


示例20: Writer

import org.apache.cassandra.service.CacheService; //导入依赖的package包/类
protected Writer(int keysToSave)
{
    if (keysToSave >= getKeySet().size())
        keys = getKeySet();
    else
        keys = hotKeySet(keysToSave);

    OperationType type;
    if (cacheType == CacheService.CacheType.KEY_CACHE)
        type = OperationType.KEY_CACHE_SAVE;
    else if (cacheType == CacheService.CacheType.ROW_CACHE)
        type = OperationType.ROW_CACHE_SAVE;
    else
        type = OperationType.UNKNOWN;

    info = new CompactionInfo(new CFMetaData(Table.SYSTEM_KS, cacheType.toString(), null, null, null),
                              type,
                              0,
                              keys.size(),
                              "keys");
}
开发者ID:wso2，项目名称:wso2-cassandra，代码行数:22，代码来源:AutoSavingCache.java



注：本文中的org.apache.cassandra.service.CacheService类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。

鲜花
握手
雷人
路过
鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
More+
上一篇：
Java BigIntegers类代码示例发布时间：2022-05-22
下一篇：
Java State类代码示例发布时间：2022-05-22
热门推荐
More+
热门话题
More+
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服（服务时间 9:00～18:00）

在线QQ客服
地址：深圳市南山区西丽大学城创智工业园
电邮：jeky_zhao#qq.com
移动电话：139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap