LOG.info("Transaction {} STARTED", tx);

            Put row1 = new Put(exampleRow1);
            row1.addColumn(family, qualifier, dataValue1);
            txTable.put(tx, row1);
            LOG.info("Transaction {} trying to write a new value in [TABLE:ROW/CF/Q] => {}:{}/{}/{} = {} ",
                     tx, userTableName, Bytes.toString(exampleRow1), Bytes.toString(family),
                     Bytes.toString(qualifier), Bytes.toString(dataValue1));

            Put row2 = new Put(exampleRow2);
            row2.addColumn(family, qualifier, dataValue2);
            txTable.put(tx, row2);
            LOG.info("Transaction {} trying to write a new value in [TABLE:ROW/CF/Q] => {}:{}/{}/{} = {} ",
                     tx, userTableName, Bytes.toString(exampleRow2), Bytes.toString(family),
                     Bytes.toString(qualifier), Bytes.toString(dataValue2));

            tm.commit(tx);
            LOG.info("Transaction {} COMMITTED", tx);

    private static final Logger LOG = LoggerFactory.getLogger(BasicExample.class);

    public static void main(String[] args) throws Exception {

        LOG.info("Parsing command line arguments");
        String userTableName = "MY_TX_TABLE";
        if (args != null && args.length > 0 && StringUtils.isNotEmpty(args[0])) {
            userTableName = args[0];
        }
        byte[] family = Bytes.toBytes("MY_CF");
        if (args != null && args.length > 1 && StringUtils.isNotEmpty(args[1])) {
            family = Bytes.toBytes(args[1]);
        }
        LOG.info("Table '{}', column family '{}'", userTableName, Bytes.toString(family));

            long startTimestamp = ((long) key[0] & 0xFF) << 56
                    | ((long) key[1] & 0xFF) << 48
                    | ((long) key[2] & 0xFF) << 40
                    | ((long) key[3] & 0xFF) << 32
                    | ((long) key[4] & 0xFF) << 24
                    | ((long) key[5] & 0xFF) << 16
                    | ((long) key[6] & 0xFF) << 8
                    | ((long) key[7] & 0xFF);