HVersionEnforcingClientFactory.java

package com.xxx.metadata.hector;

import me.prettyprint.cassandra.connection.client.HClient;
import me.prettyprint.cassandra.connection.factory.HThriftClientFactoryImpl;
import me.prettyprint.cassandra.service.CassandraHost;
import me.prettyprint.cassandra.service.CassandraHostConfigurator;

/**
 * Custom client factory for use in {@link CassandraHostConfigurator}.
 * Works by wrapping internally generated Thrift client with {@link HVersionEnforcingClient}.
 *
 * @author Max Alexejev
 * Mar 13, 2013
 */
public class HVersionEnforcingClientFactory extends HThriftClientFactoryImpl {

    public static final String CQL_VERSION = "3.0.0";

    @Override
    public HClient createClient(CassandraHost ch) {
        return new HVersionEnforcingClient(super.createClient(ch), CQL_VERSION);
    }

}