private static void cqlDataSetLoad(String host, String port, String file) {
Cluster cluster = new Cluster.Builder().addContactPoints(host).withPort(Integer.parseInt(port)).build();
Session session = cluster.connect();
CQLDataLoader dataLoader = new CQLDataLoader(session);
dataLoader.load(new FileCQLDataSet(file, false));
}
private static boolean containBadReplicationFactorArgumentValue() {
String replicationFactor = commandLine.getOptionValue("r");
if (replicationFactor != null && !replicationFactor.trim().isEmpty()) {