key = 0;
key = put(joinTable, key, "zebra");
key = put(joinTable, key, "donkey");
key = put(joinTable, key, "bird");
key = put(joinTable, key, "horse");
joinTable.flushCommits();
Scan joinScan = new Scan();
joinScan.addFamily(WORD_COLFAM);
PTable<ImmutableBytesWritable, Result> other = pipeline.read(FromHBase.table(joinTableName, joinScan));
PCollection<String> joined = words.join(other).parallelDo(new StringifyFn(), Writables.strings());