code: public Sink createSinkAsync(String sinkName, String datasetName)
        throws ExecutionException, InterruptedException {
      // [START createSinkAsync]
      SinkInfo sinkInfo = SinkInfo.of(sinkName, DatasetDestination.of(datasetName));
      Future<Sink> future = logging.createAsync(sinkInfo);
      // ...
      Sink sink = future.get();
      // [END createSinkAsync]
      return sink;
    }
docs: [VARIABLE "my_dataset"]