import org.apache.cassandra.io.compress.LZ4Compressor; //导入依赖的package包/类
@Test
public void testSerializerNormal() throws IOException
{
    UUID hostId = UUID.randomUUID();
    int version = HintsDescriptor.CURRENT_VERSION;
    long timestamp = System.currentTimeMillis();
    ImmutableMap<String, Object> parameters =
            ImmutableMap.of("compression", (Object) ImmutableMap.of("class_name", LZ4Compressor.class.getName()));
    HintsDescriptor descriptor = new HintsDescriptor(hostId, version, timestamp, parameters);

    testSerializeDeserializeLoop(descriptor);
}
 

import org.apache.cassandra.io.compress.LZ4Compressor; //导入依赖的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()) } });
}
 

import org.apache.cassandra.io.compress.LZ4Compressor; //导入依赖的package包/类
@Test
public void lz4Compressor() throws Exception
{
    multiFlushAndDeserializeTest(LZ4Compressor.class);
}