@Test
public void flatMap() throws Exception {

	AnyToTripleFlatMapper transKvToTriple = new AnyToTripleFlatMapper(
		CsvUtil.schemaStr2Schema("row_id long, kv string"),
		new Params()
			.set(FormatTransParams.FROM_FORMAT, FormatType.KV)
			.set(FromKvParams.KV_COL, "kv")
			.set(FromKvParams.KV_COL_DELIMITER, ",")
			.set(FromKvParams.KV_VAL_DELIMITER, ":")
			.set(ToTripleParams.TRIPLE_COL_VAL_SCHEMA_STR, "col_id int, val double")
			.set(ToTripleParams.RESERVED_COLS, new String[] {"row_id"})
	);
	transKvToTriple.open();
	RowCollector collector = new RowCollector();
	transKvToTriple.flatMap(Row.of(3L, "1:1.0,4:1.0"), collector);
	Assert.assertEquals(collector.getRows().size(), 2);
/		for (Row row : collector.getRows()) {
/			System.out.println(row);
/		}
}