@Table(name = "employees", columnFamily = "info") public class Employee { @Row private String id; @ColumnFamily("personal") private String name; @ColumnFamily("personal") private int age; @ColumnFamily("address") @Column("city") private String city; } properties hbase.zookeeper.quorum=localhost hbase.zookeeper.property.clientPort=2181 Configuration config = HBaseConfiguration.create(); config.set("hbase.zookeeper.quorum", "localhost"); config.set("hbase.zookeeper.property.clientPort", "2181"); try (Connection connection = ConnectionFactory.createConnection(config)) { TableInterface table = connection.getTable(TableName.valueOf("employees")); Put put = new Put(Bytes.toBytes("1")); put.addColumn(Bytes.toBytes("info"), Bytes.toBytes("personal:name"), Bytes.toBytes("John Doe")); put.addColumn(Bytes.toBytes("info"), Bytes.toBytes("personal:age"), Bytes.toBytes("30")); table.put(put); } Configuration config = HBaseConfiguration.create(); config.set("hbase.zookeeper.quorum", "localhost"); config.set("hbase.zookeeper.property.clientPort", "2181"); try (Connection connection = ConnectionFactory.createConnection(config)) { TableInterface table = connection.getTable(TableName.valueOf("employees")); Get get = new Get(Bytes.toBytes("1")); get.addColumn(Bytes.toBytes("info"), Bytes.toBytes("personal:name")); get.addColumn(Bytes.toBytes("info"), Bytes.toBytes("personal:age")); Result result = table.get(get); byte[] name = result.getValue(Bytes.toBytes("info"), Bytes.toBytes("personal:name")); byte[] age = result.getValue(Bytes.toBytes("info"), Bytes.toBytes("personal:age")); System.out.println("Name: " + Bytes.toString(name)); System.out.println("Age: " + Bytes.toString(age)); }