FSDataOutputStream o = this.getFileSystem().create(p);
BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(o));
bw.write("twelve\t12\n");
bw.write("twelve\t1\n");
bw.write("eleven\t11\n");
bw.write("eleven\t10\n");
bw.close();

String jarFile;
jarFile = GenericUDAFCollect.class.getProtectionDomain().getCodeSource().getLocation().getFile();
client.execute("add jar " + jarFile);
client.execute("create temporary function collect as 'com.jointhegrid.udf.collect.GenericUDAFCollect'");
client.execute("create table  collecttest  (str string, countVal int) row format delimited fields terminated by '09' lines terminated by '10'");
client.execute("load data local inpath '" + p.toString() + "' into table collecttest");

client.execute("select collect(str) FROM collecttest");
List<String> expected = Arrays.asList("[\"twelve\",\"twelve\",\"eleven\",\"eleven\"]");
assertEquals(expected, client.fetchAll());

client.execute("SELECT concat_ws( ',' , collect(str)) FROM collecttest");
expected = Arrays.asList("twelve,twelve,eleven,eleven");
assertEquals(expected, client.fetchAll());