本文整理汇总了Java中org.apache.cassandra.utils.obs.OpenBitSet类的典型用法代码示例。如果您正苦于以下问题：Java OpenBitSet类的具体用法？Java OpenBitSet怎么用？Java OpenBitSet使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
OpenBitSet类属于org.apache.cassandra.utils.obs包，在下文中一共展示了OpenBitSet类的11个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: deserialize
import org.apache.cassandra.utils.obs.OpenBitSet; //导入依赖的package包/类
@SuppressWarnings("resource")
public static BloomFilter deserialize(DataInput in, boolean offheap, boolean oldBfHashOrder) throws IOException
{
int hashes = in.readInt();
IBitSet bs = offheap ? OffHeapBitSet.deserialize(in) : OpenBitSet.deserialize(in);
return new BloomFilter(hashes, bs, oldBfHashOrder);
}
开发者ID:Netflix，项目名称:sstable-adaptor，代码行数:9，代码来源:BloomFilterSerializer.java
示例2: createFilter
import org.apache.cassandra.utils.obs.OpenBitSet; //导入依赖的package包/类
@SuppressWarnings("resource")
private static IFilter createFilter(int hash, long numElements, int bucketsPer, boolean offheap, boolean oldBfHashOrder)
{
long numBits = (numElements * bucketsPer) + BITSET_EXCESS;
IBitSet bitset = offheap ? new OffHeapBitSet(numBits) : new OpenBitSet(numBits);
return new BloomFilter(hash, bitset, oldBfHashOrder);
}
开发者ID:Netflix，项目名称:sstable-adaptor，代码行数:8，代码来源:FilterFactory.java
示例3: populateRandom
import org.apache.cassandra.utils.obs.OpenBitSet; //导入依赖的package包/类
public void populateRandom(OffHeapBitSet offbs, OpenBitSet obs, long index)
{
if (random.nextBoolean())
{
offbs.set(index);
obs.set(index);
}
}
开发者ID:vcostet，项目名称:cassandra-kmean，代码行数:9，代码来源:LongBitSetTest.java
示例4: testBitSetOperations
import org.apache.cassandra.utils.obs.OpenBitSet; //导入依赖的package包/类
@Test
public void testBitSetOperations()
{
long size_to_test = Integer.MAX_VALUE / 40;
long size_and_excess = size_to_test + 20;
OffHeapBitSet offbs = new OffHeapBitSet(size_and_excess);
OpenBitSet obs = new OpenBitSet(size_and_excess);
for (long i = 0; i < size_to_test; i++)
populateRandom(offbs, obs, i);
for (long i = 0; i < size_to_test; i++)
compare(offbs, obs, i);
}
开发者ID:vcostet，项目名称:cassandra-kmean，代码行数:14，代码来源:LongBitSetTest.java
示例5: timeit
import org.apache.cassandra.utils.obs.OpenBitSet; //导入依赖的package包/类
@Test
public void timeit()
{
long size_to_test = Integer.MAX_VALUE / 10; // about 214 million
long size_and_excess = size_to_test + 20;
OpenBitSet obs = new OpenBitSet(size_and_excess);
OffHeapBitSet offbs = new OffHeapBitSet(size_and_excess);
logger.info("||Open BS set's|Open BS get's|Open BS clear's|Offheap BS set's|Offheap BS get's|Offheap BS clear's|");
// System.out.println("||Open BS set's|Open BS get's|Open BS clear's|Offheap BS set's|Offheap BS get's|Offheap BS clear's|");
loopOnce(obs, offbs, size_to_test);
}
开发者ID:vcostet，项目名称:cassandra-kmean，代码行数:13，代码来源:LongBitSetTest.java
示例6: loopOnce
import org.apache.cassandra.utils.obs.OpenBitSet; //导入依赖的package包/类
public void loopOnce(OpenBitSet obs, OffHeapBitSet offbs, long size_to_test)
{
StringBuffer buffer = new StringBuffer();
// start off fresh.
System.gc();
long start = System.nanoTime();
for (long i = 0; i < size_to_test; i++)
obs.set(i);
buffer.append("||").append(TimeUnit.NANOSECONDS.toMillis(System.nanoTime() - start));
start = System.nanoTime();
for (long i = 0; i < size_to_test; i++)
obs.get(i);
buffer.append("|").append(TimeUnit.NANOSECONDS.toMillis(System.nanoTime() - start));
start = System.nanoTime();
for (long i = 0; i < size_to_test; i++)
obs.clear(i);
buffer.append("|").append(TimeUnit.NANOSECONDS.toMillis(System.nanoTime() - start));
System.gc();
start = System.nanoTime();
for (long i = 0; i < size_to_test; i++)
offbs.set(i);
buffer.append("|").append(TimeUnit.NANOSECONDS.toMillis(System.nanoTime() - start));
start = System.nanoTime();
for (long i = 0; i < size_to_test; i++)
offbs.get(i);
buffer.append("|").append(TimeUnit.NANOSECONDS.toMillis(System.nanoTime() - start));
start = System.nanoTime();
for (long i = 0; i < size_to_test; i++)
offbs.clear(i);
buffer.append("|").append(TimeUnit.NANOSECONDS.toMillis(System.nanoTime() - start)).append("|");
logger.info(buffer.toString());
// System.out.println(buffer.toString());
}
开发者ID:vcostet，项目名称:cassandra-kmean，代码行数:39，代码来源:LongBitSetTest.java
示例7: loopIt
import org.apache.cassandra.utils.obs.OpenBitSet; //导入依赖的package包/类
/**
* Just to make sure JIT doesn't come on our way
*/
@Test
// @Ignore
public void loopIt()
{
long size_to_test = Integer.MAX_VALUE / 10; // about 214 million
long size_and_excess = size_to_test + 20;
OpenBitSet obs = new OpenBitSet(size_and_excess);
OffHeapBitSet offbs = new OffHeapBitSet(size_and_excess);
for (int i = 0; i < 10; i++)
// 10 times to do approx 2B keys each.
loopOnce(obs, offbs, size_to_test);
}
开发者ID:vcostet，项目名称:cassandra-kmean，代码行数:17，代码来源:LongBitSetTest.java
示例8: testOffHeapCompatibility
import org.apache.cassandra.utils.obs.OpenBitSet; //导入依赖的package包/类
@Test
public void testOffHeapCompatibility() throws IOException
{
try (OpenBitSet bs = new OpenBitSet(100000))
{
populateAndReserialize(bs);
}
}
开发者ID:scylladb，项目名称:scylla-tools-java，代码行数:9，代码来源:BitSetTest.java
示例9: createFilter
import org.apache.cassandra.utils.obs.OpenBitSet; //导入依赖的package包/类
private static IFilter createFilter(int hash, long numElements, int bucketsPer, Type type, boolean offheap)
{
long numBits = (numElements * bucketsPer) + BITSET_EXCESS;
IBitSet bitset = offheap ? new OffHeapBitSet(numBits) : new OpenBitSet(numBits);
switch (type)
{
case MURMUR2:
return new Murmur2BloomFilter(hash, bitset);
default:
return new Murmur3BloomFilter(hash, bitset);
}
}
开发者ID:dprguiuc，项目名称:Cassandra-Wasef，代码行数:13，代码来源:FilterFactory.java
示例10: loopOnce
import org.apache.cassandra.utils.obs.OpenBitSet; //导入依赖的package包/类
public void loopOnce(OpenBitSet obs, OffHeapBitSet offbs, long size_to_test)
{
StringBuffer buffer = new StringBuffer();
// start off fresh.
System.gc();
long start = System.currentTimeMillis();
for (long i = 0; i < size_to_test; i++)
obs.set(i);
buffer.append("||").append(System.currentTimeMillis() - start);
start = System.currentTimeMillis();
for (long i = 0; i < size_to_test; i++)
obs.get(i);
buffer.append("|").append(System.currentTimeMillis() - start);
start = System.currentTimeMillis();
for (long i = 0; i < size_to_test; i++)
obs.clear(i);
buffer.append("|").append(System.currentTimeMillis() - start);
System.gc();
start = System.currentTimeMillis();
for (long i = 0; i < size_to_test; i++)
offbs.set(i);
buffer.append("|").append(System.currentTimeMillis() - start);
start = System.currentTimeMillis();
for (long i = 0; i < size_to_test; i++)
offbs.get(i);
buffer.append("|").append(System.currentTimeMillis() - start);
start = System.currentTimeMillis();
for (long i = 0; i < size_to_test; i++)
offbs.clear(i);
buffer.append("|").append(System.currentTimeMillis() - start).append("|");
logger.info(buffer.toString());
// System.out.println(buffer.toString());
}
开发者ID:dprguiuc，项目名称:Cassandra-Wasef，代码行数:39，代码来源:LongBitSetTest.java
示例11: testExpectedCompatablity
import org.apache.cassandra.utils.obs.OpenBitSet; //导入依赖的package包/类
/**
* Test compatibility with a 1.1-version data file
*/
@Test
public void testExpectedCompatablity() throws IOException
{
DataInputStream dis = new DataInputStream(new FileInputStream(new File(LEGACY_SST_FILE)));
dis.readInt(); // bloom filter hash count
OpenBitSet bs = OpenBitSet.deserialize(dis);
dis = new DataInputStream(new FileInputStream(new File(LEGACY_SST_FILE)));
dis.readInt(); // bloom filter hash count
OffHeapBitSet obs = OffHeapBitSet.deserialize(dis);
compare(obs, bs);
}
开发者ID:dprguiuc，项目名称:Cassandra-Wasef，代码行数:17，代码来源:BitSetTest.java
注：本文中的org.apache.cassandra.utils.obs.OpenBitSet类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。 |
客服电话
APP下载
官方微信
请发表评论