code: @SuppressWarnings("WeakerAccess")
    public ApiFuture<Cluster> createClusterAsync(CreateClusterRequest request) {
      return ApiFutures.transform(
          stub.createClusterOperationCallable().futureCall(request.toProto(projectId)),
          new ApiFunction<com.google.bigtable.admin.v2.Cluster, Cluster>() {
            @Override
            public Cluster apply(com.google.bigtable.admin.v2.Cluster proto) {
              return Cluster.fromProto(proto);
            }
          },
          MoreExecutors.directExecutor());
    }
docs: Asynchronously creates a new cluster in the specified instance.
  
  <p>Sample code:
  
  <pre>{@code
  ApiFuture<Cluster> clusterFuture = client.createClusterAsync(
  CreateClusterRequest.of("my-instance", "my-new-cluster")
  .setZone("us-east1-c")
  .setServeNodes(3)
  .setStorageType(StorageType.SSD)
  );
  
  Cluster cluster = clusterFuture.get();
  }</pre>