docs: @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");
      }