public void testCsvLoaderComposite() {
StringBuilder sb = new StringBuilder().append("key, column, value\n")
.append("1, a:1, 1a1\n").append("1, b:1, 2b1\n")
.append("2, a:1, 3a1\n").append("3, a:1, 4a1\n");
CsvColumnReader reader = new CsvColumnReader(new StringReader(
sb.toString()));
RecordWriter writer = new ColumnarRecordWriter(keyspace,
CF_COMPOSITE_CSV.getName());
try {
reader.start();
writer.start();
List<Pair<String, String>> record = null;
while (null != (record = reader.next())) {
writer.write(record);
}
} catch (IOException e) {
LOG.error(e.getMessage(), e);
Assert.fail();
} catch (ConnectionException e) {
LOG.error(e.getMessage(), e);
Assert.fail();
} finally {
reader.shutdown();
writer.shutdown();
}
try {
Rows<ByteBuffer, ByteBuffer> rows = keyspace