@Override
    public void init(DataGenerator dataGenerator) throws Exception
    {
        try
        {
            this.dataGenerator = dataGenerator;
            this.cluster = cassA6XManager.registerCluster(config.getCluster(), config.getHost(), config.getHostPort());
            this.keyspace = cassA6XManager.registerKeyspace(config.getCluster(), config.getKeyspace(), config.getHost(), config.getHostPort());

            AstyanaxConfigurationImpl aci = (AstyanaxConfigurationImpl) this.keyspace.getConfig();
            aci.setDefaultReadConsistencyLevel(ConsistencyLevel.valueOf(config.getReadConsistencyLevel()))
               .setDefaultWriteConsistencyLevel(ConsistencyLevel.valueOf(config.getWriteConsistencyLevel()));

            CF = new ColumnFamily<>(config.getCfname(), StringSerializer.get(), IntegerSerializer.get(), StringSerializer.get());

            if (config.getCreateSchema())
            {
                logger.info("Trying to upsert schema");
                preInit();
            }
        }
        catch (ConnectionException e)
        {
            logger.error("Failed to initialize Astyanax driver");
            throw e;
        }

        logger.info("Registered keyspace : " + this.keyspace.getKeyspaceName());
        logger.info("Initialized CassAstyanaxPlugin");
    }
@ Override public void init ( DataGenerator dataGenerator ) throws Exception { try { this . dataGenerator = dataGenerator ; this . cluster = cassA6XManager . registerCluster ( config . getCluster ( ) , config . getHost ( ) , config . getHostPort ( ) ) ; this . keyspace = cassA6XManager . registerKeyspace ( config . getCluster ( ) , config . getKeyspace ( ) , config . getHost ( ) , config . getHostPort ( ) ) ; AstyanaxConfigurationImpl aci = ( AstyanaxConfigurationImpl ) this . keyspace . getConfig ( ) ; aci . setDefaultReadConsistencyLevel ( ConsistencyLevel . valueOf ( config . getReadConsistencyLevel ( ) ) ) . setDefaultWriteConsistencyLevel ( ConsistencyLevel . valueOf ( config . getWriteConsistencyLevel ( ) ) ) ; CF = new ColumnFamily < > ( config . getCfname ( ) , StringSerializer . get ( ) , IntegerSerializer . get ( ) , StringSerializer . get ( ) ) ; if ( config . getCreateSchema ( ) ) { logger . info ( "Trying to upsert schema" ) ; preInit ( ) ; } } catch ( ConnectionException e ) { logger . error ( "Failed to initialize Astyanax driver" ) ; throw e ; } logger . info ( "Registered keyspace : " + this . keyspace . getKeyspaceName ( ) ) ; logger . info ( "Initialized CassAstyanaxPlugin" ) ; }
Initialize the client