-
Notifications
You must be signed in to change notification settings - Fork 0
feat: expose serverStreamingCallable to save transformation #4
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
base: master
Are you sure you want to change the base?
Conversation
private <ReqT, RowT> ServerStreamingCallable<ReadRowsRequest, RowT> createReadRowsRawCallable( | ||
ServerStreamingCallSettings<ReqT, Row> readRowsSettings, RowAdapter<RowT> rowAdapter) { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Do you think is it acceptable for a private method to have two generic parameters but return the third class instead?
Because those generics classes would be only used for fetching the settings.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I don't see any problems with that
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Thanks a lot for your opinion!!!
* <li>Upon receiving the response stream, it will merge the {@link | ||
* com.google.bigtable.v2.ReadRowsResponse.CellChunk}s in logical rows. The actual row | ||
* implementation can be configured in by the {@code rowAdapter} parameter. | ||
* <li>Retry/resume on failure. |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
be configured in by
->
be configured by
(3 times)
86cbd43
to
8cb4be2
Compare
…leStub This commit would enable the user to target the table using absolute resource name on each read request. Currently we expose `ServerStreamingCallable<Query, RowT>`, which does not have an option to provide different `app-profile-id` on each request.
8cb4be2
to
fb025ae
Compare
With this commit, the public createReadRowsCallable() would refer to single createReadRowsBaseCallable.
In Progress