Skip to content

Conversation

@shivangi219
Copy link
Contributor

No description provided.

*/
public List<T> scatterGather(DetachedCriteria criteria) {
return daos.stream().map(dao -> {
List<T> results = new ArrayList<>();
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Why this change ?

Copy link
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

as it's scatter gather, need to pass shard id (i in this case) in the metric name.

bhaskarkr pushed a commit to bhaskarkr/dropwizard-db-sharding-bundle that referenced this pull request Dec 17, 2023
Adding infinite expiry for publishWithExpiry(), NPE bug fix for publish()
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants