本文整理汇总了Java中org.apache.cassandra.io.compress.SnappyCompressor类的典型用法代码示例。如果您正苦于以下问题:Java SnappyCompressor类的具体用法?Java SnappyCompressor怎么用?Java SnappyCompressor使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
SnappyCompressor类属于org.apache.cassandra.io.compress包,在下文中一共展示了SnappyCompressor类的4个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: useCompression
import org.apache.cassandra.io.compress.SnappyCompressor; //导入依赖的package包/类
private static void useCompression(List<KSMetaData> schema)
{
for (KSMetaData ksm : schema)
{
for (CFMetaData cfm : ksm.cfMetaData().values())
{
cfm.compressionParameters(new CompressionParameters(SnappyCompressor.instance));
}
}
}
开发者ID:vcostet,项目名称:cassandra-kmean,代码行数:11,代码来源:SchemaLoader.java
示例2: generateData
import org.apache.cassandra.io.compress.SnappyCompressor; //导入依赖的package包/类
@Parameters()
public static Collection<Object[]> generateData()
{
return Arrays.asList(new Object[][] {
{ null }, // No compression
{ new ParameterizedClass(LZ4Compressor.class.getName(), Collections.emptyMap()) },
{ new ParameterizedClass(SnappyCompressor.class.getName(), Collections.emptyMap()) },
{ new ParameterizedClass(DeflateCompressor.class.getName(), Collections.emptyMap()) } });
}
开发者ID:scylladb,项目名称:scylla-tools-java,代码行数:10,代码来源:CommitLogTest.java
示例3: snappyCompressor
import org.apache.cassandra.io.compress.SnappyCompressor; //导入依赖的package包/类
@Test
public void snappyCompressor() throws Exception
{
multiFlushAndDeserializeTest(SnappyCompressor.class);
}
开发者ID:scylladb,项目名称:scylla-tools-java,代码行数:6,代码来源:HintsCompressionTest.java
示例4: testDataCorruptionDetection
import org.apache.cassandra.io.compress.SnappyCompressor; //导入依赖的package包/类
@Test
public void testDataCorruptionDetection() throws IOException {
String CONTENT = "Lorem ipsum dolor sit amet, consectetur adipiscing elit. Etiam vitae.";
File file = new File("testDataCorruptionDetection");
file.deleteOnExit();
File metadata = new File(file.getPath() + ".meta");
metadata.deleteOnExit();
SSTableMetadata.Collector sstableMetadataCollector = SSTableMetadata.createCollector().replayPosition(null);
SequentialWriter writer = new CompressedSequentialWriter(file, metadata.getPath(), false, new CompressionParameters(SnappyCompressor.instance), sstableMetadataCollector);
writer.write(CONTENT.getBytes());
writer.close();
// open compression metadata and get chunk information
CompressionMetadata meta = new CompressionMetadata(metadata.getPath(), file.length(), fs);
CompressionMetadata.Chunk chunk = meta.chunkFor(0);
RandomAccessReader reader = CompressedRandomAccessReader.open(new Path(file.getPath()), meta, false, fs);
// read and verify compressed data
assertEquals(CONTENT, reader.readLine());
// close reader
reader.close();
Random random = new Random();
RandomAccessFile checksumModifier = null;
try {
checksumModifier = new RandomAccessFile(file, "rw");
byte[] checksum = new byte[4];
// seek to the end of the compressed chunk
checksumModifier.seek(chunk.length);
// read checksum bytes
checksumModifier.read(checksum);
// seek back to the chunk end
checksumModifier.seek(chunk.length);
// lets modify one byte of the checksum on each iteration
for (int i = 0; i < checksum.length; i++) {
checksumModifier.write(random.nextInt());
checksumModifier.getFD().sync(); // making sure that change was synced with disk
final RandomAccessReader r = CompressedRandomAccessReader.open(new Path(file.getPath()), meta, false, fs);
Throwable exception = null;
try {
r.readLine();
} catch (Throwable t) {
exception = t;
}
assertNotNull(exception);
assertEquals(exception.getClass(), CorruptSSTableException.class);
assertEquals(exception.getCause().getClass(), CorruptBlockException.class);
r.close();
}
// lets write original checksum and check if we can read data
updateChecksum(checksumModifier, chunk.length, checksum);
reader = CompressedRandomAccessReader.open(new Path(file.getPath()), meta, false, fs);
// read and verify compressed data
assertEquals(CONTENT, reader.readLine());
// close reader
reader.close();
} finally {
if (checksumModifier != null)
checksumModifier.close();
}
}
开发者ID:fullcontact,项目名称:hadoop-sstable,代码行数:74,代码来源:CompressedRandomAccessReaderTest.java
注:本文中的org.apache.cassandra.io.compress.SnappyCompressor类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论