return get(createAsync(sink));
}
@Override
public Future<Sink> createAsync(SinkInfo sink) {
CreateSinkRequest request = CreateSinkRequest.newBuilder()
<BUG>.setParent(ConfigServiceV2Client.formatParentName(getOptions().getProjectId()))
.setSink(sink.toPb(getOptions().getProjectId()))</BUG>
.build();
return transform(rpc.create(request), Sink.fromPbFunction(this));
}

return get(createAsync(sink));
}
@Override
public Future<Sink> createAsync(SinkInfo sink) {
CreateSinkRequest request = CreateSinkRequest.newBuilder()
.setParent(ProjectName.create(getOptions().getProjectId()).toString())
.setSink(sink.toPb(getOptions().getProjectId()))
.build();
return transform(rpc.create(request), Sink.fromPbFunction(this));
}
