// ...
import com.google.cloud.bigtable.hbase.BigtableConfiguration;
import org.apache.hadoop.hbase.client.Admin;
import org.apache.hadoop.hbase.client.Connection;
// ...

    try (Connection connection = BigtableConfiguration.connect(projectId, instanceId)) {
      HTableDescriptor descriptor = new HTableDescriptor(TableName.valueOf(tableId));
      descriptor.addFamily(new HColumnDescriptor(columnFamilyName));
      try (Admin admin = connection.getAdmin()) {
        admin.createTable(descriptor);
        // Retrieve the table we just created so we can do some reads and writes
        try (Table table = connection.getTable(TableName.valueOf(tableId))) {

          String rowKey = "r1";

          Put put = new Put(Bytes.toBytes(rowKey));
          put.addColumn(Bytes.toBytes(columnFamilyName), Bytes.toBytes(columnName),
              Bytes.toBytes(data));
          table.put(put);
        }
      }
    }

    BigtableTableAdminSettings.Builder tableAdminSettings = BigtableTableAdminSettings.newBuilderForEmulator(bigtableEmulator.getPort());
    tableAdminClient = BigtableTableAdminClient.create(tableAdminSettings.build());

    BigtableDataSettings.Builder dataSettings = BigtableDataSettings.newBuilderForEmulator(bigtableEmulator.getPort());
    dataClient = BigtableDataClient.create(dataSettings.build());

    // Create a test table that can be used in tests
    tableAdminClient.createTable(
        CreateTableRequest.of("fake-table")
          .addFamily("cf")
    );