HBaseUtils { public static byte[] rowKeySeparatorFor(Config config) { byte[] separator = DEFAULT_KEY_SEPARATOR.getBytes(); if (config.hasPath(KEY_SEPARATOR)) { separator = config.getString(KEY_SEPARATOR).getBytes(); } return separator; }  synchronized static Connection getConnection(Config config); static Configuration getHBaseConfiguration(Config config); static int batchSizeFor(Config config); static TableName tableInfoFor(Config config); static HBaseSerde getSerde(Config config); static byte[] rowKeySeparatorFor(Config config); static List<String> rowKeyFor(Config config); static Map<String, HBaseSerde.ColumnDef> columnsFor(Config config); static StructType buildSchema(Map<String, HBaseSerde.ColumnDef> columnDefinitions); static Scan mergeRangeScans(List<Scan> rangeScans); static byte[] exclusiveStopRow(byte[] startRow); static Validations getValidations(); static final String ZK_QUORUM_PROPERTY; static final String TABLE_NAME_PROPERTY; static final String ROWKEY_PROPERTY; static final String KEY_SEPARATOR; static final String COLUMNS_PROPERTY; static final String SERDE_PROPERTY; static final String HBASE_PASSTHRU_PREFIX; static final String HBASE_BATCH_SIZE; static final int DEFAULT_HBASE_BATCH_SIZE; static final String DEFAULT_SERDE_PROPERTY; static final String DEFAULT_KEY_SEPARATOR; }
@Test public void testRowKeySeparatorFor() { Config goodConfig = ConfigUtils.configFromResource("/hbase/hbase-output.conf").getConfig("output"); byte[] rowKeySeparatorFor = HBaseUtils.rowKeySeparatorFor(goodConfig); assertArrayEquals(":".getBytes(), rowKeySeparatorFor); }