code: public Sink getSinkAsync(String sinkName) throws ExecutionException, InterruptedException {
      // [START getSinkAsync]
      Future<Sink> future = logging.getSinkAsync(sinkName);
      // ...
      Sink sink = future.get();
      if (sink == null) {
        // sink was not found
      }
      // [END getSinkAsync]
      return sink;
    }
docs: [VARIABLE "my_sink_name"]