return get(getSinkAsync(sink));
}
@Override
public Future<Sink> getSinkAsync(String sink) {
GetSinkRequest request = GetSinkRequest.newBuilder()
<BUG>.setSinkName(ConfigServiceV2Client.formatSinkName(getOptions().getProjectId(), sink))
.build();</BUG>
return transform(rpc.get(request), Sink.fromPbFunction(this));
}
private static ListSinksRequest listSinksRequest(LoggingOptions serviceOptions,

return get(getSinkAsync(sink));
}
@Override
public Future<Sink> getSinkAsync(String sink) {
GetSinkRequest request = GetSinkRequest.newBuilder()
.setSinkName(SinkName.create(getOptions().getProjectId(), sink).toString())
.build();
return transform(rpc.get(request), Sink.fromPbFunction(this));
}
private static ListSinksRequest listSinksRequest(LoggingOptions serviceOptions,
