Skip to content

Conversation

@sanpwc
Copy link
Contributor

@sanpwc sanpwc commented Mar 21, 2022

No description provided.


private AtomicInteger scanCounter = new AtomicInteger(1);

private static final int INTERNAL_BATCH_SIZE = 10_000;
Copy link

Choose a reason for hiding this comment

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

Should we use configured parameter to define internal batch size?

Copy link
Contributor Author

Choose a reason for hiding this comment

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

naa, not now, and I'd rather use dynamic calculation here.

retrievedItems.add(item);

if (retrievedItems.size() % reqAmount == 0) {
if (reqAmount != Long.MAX_VALUE && retrievedItems.size() % reqAmount == 0) {
Copy link

Choose a reason for hiding this comment

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

What for additional condition reqAmount != Long.MAX_VALUE is added?
Is the condition retrievedItems.size() % reqAmount true in this case?

Copy link
Contributor Author

Choose a reason for hiding this comment

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

Yep, it's possible to remove given check here. Fixed.

Copy link

@tledkov tledkov left a comment

Choose a reason for hiding this comment

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

OK with me

…istributed/storage/InternalTableImpl.java

Co-authored-by: korlov42 <korlov@gridgain.com>
@sanpwc sanpwc merged commit 24918e1 into apache:main Mar 23, 2022
@sanpwc sanpwc deleted the ignite-16719 branch March 23, 2022 20:14
isapego pushed a commit to isapego/ignite-3 that referenced this pull request Dec 26, 2024
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.

3 participants