docs: @Override
      public void init(DataGenerator dataGenerator) {
          this.dataGenerator = dataGenerator;
  
          this.ClusterName = configs.getCluster();
          logger.info("Cassandra  Cluster: " + ClusterName);
  
          this.ClusterContactPoint = configs.getHost();
          this.KeyspaceName = configs.getKeyspace();
          this.TableName = configs.getCfname();
          this.WriteConsistencyLevel = ConsistencyLevel.valueOf(configs.getWriteConsistencyLevel());
          this.ReadConsistencyLevel = ConsistencyLevel.valueOf(configs.getReadConsistencyLevel());
  
          cluster = Cluster.builder()
                  .withClusterName(ClusterName)
                  .addContactPoint(ClusterContactPoint)
                  .build();
          session = cluster.connect();
  
          upsertKeyspace(this.session);
          upsertCF(this.session);
  
          writePstmt = session.prepare("INSERT INTO "+ TableName +" (\"_id\", name) VALUES (?, ?)");
          readPstmt = session.prepare("SELECT * From "+ TableName +" Where \"_id\" = ?");
  
          logger.info("Initialized ElassandraCassJavaDriverPlugin");
      }