import org.apache.cassandra.transport.messages.StartupMessage; //导入依赖的package包/类
public void connect(boolean useCompression) throws IOException
{
    establishConnection();

    Map<String, String> options = new HashMap<String, String>();
    options.put(StartupMessage.CQL_VERSION, "3.0.0");
    if (useCompression)
    {
        options.put(StartupMessage.COMPRESSION, "snappy");
        connection.setCompressor(FrameCompressor.SnappyCompressor.instance);
    }
    execute(new StartupMessage(options));
}
 

import org.apache.cassandra.transport.messages.StartupMessage; //导入依赖的package包/类
public void connect(boolean useCompression) throws IOException
{
    establishConnection();

    Map<String, String> options = new HashMap<>();
    options.put(StartupMessage.CQL_VERSION, "3.0.0");
    if (useCompression)
    {
        options.put(StartupMessage.COMPRESSION, "snappy");
        connection.setCompressor(FrameCompressor.SnappyCompressor.instance);
    }
    execute(new StartupMessage(options));
}