Skip to content
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

[Improve][Redis] Redis reader use scan cammnd instead of keys, single mode reader/writer support batch #7087

Merged
merged 6 commits into from
Jul 3, 2024

Conversation

FuYouJ
Copy link
Contributor

@FuYouJ FuYouJ commented Jun 30, 2024

Purpose of this pull request

Does this PR introduce any user-facing change?

  • reader use scan cammnd instead of keys to avoid blocking the database from reading data
  • In single mode, supports batch read and batch write

How was this patch tested?

Check list

@FuYouJ FuYouJ changed the title [improve][redis]issue#7030,issue#7085,redis reader using scan replace keys command, writer support batch [improve][redis]issue#7030,issue#7085,redis reader use scan cammnd instead of keys, single mode reader/writer support batch Jun 30, 2024
@Hisoka-X Hisoka-X changed the title [improve][redis]issue#7030,issue#7085,redis reader use scan cammnd instead of keys, single mode reader/writer support batch [Improve][Redis] Redis reader use scan cammnd instead of keys, single mode reader/writer support batch Jul 1, 2024
Comment on lines 87 to 91
>
> ### batch_size [int]
>
> Ensure the batch write size in single-machine mode; no guarantees in cluster mode.
>
Copy link
Member

Choose a reason for hiding this comment

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

Suggested change
>
> ### batch_size [int]
>
> Ensure the batch write size in single-machine mode; no guarantees in cluster mode.
>
### batch_size [int]
Ensure the batch write size in single-machine mode; no guarantees in cluster mode.

Copy link
Contributor Author

Choose a reason for hiding this comment

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

Thank you. I was careless here

@@ -113,6 +114,10 @@ each kv that in hash key it will be treated as a row and send it to upstream.

keys pattern

### batch_size [int]

indicates the number of keys to attempt to return per iteration.default 10
Copy link
Member

Choose a reason for hiding this comment

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

Suggested change
indicates the number of keys to attempt to return per iteration.default 10
indicates the number of keys to attempt to return per iteration, default 10

Copy link
Contributor Author

Choose a reason for hiding this comment

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

done

@FuYouJ FuYouJ requested a review from Hisoka-X July 1, 2024 14:57
Copy link
Member

@Hisoka-X Hisoka-X left a comment

Choose a reason for hiding this comment

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

Overall LGTM. Thanks @FuYouJ

@hailin0 hailin0 merged commit be37f05 into apache:dev Jul 3, 2024
8 checks passed
hawk9821 pushed a commit to hawk9821/seatunnel that referenced this pull request Jul 10, 2024
Thomas-HuWei pushed a commit to zilliztech/seatunnel that referenced this pull request Jul 10, 2024
hawk9821 pushed a commit to hawk9821/seatunnel that referenced this pull request Jul 13, 2024
chaorongzhi pushed a commit to chaorongzhi/seatunnel that referenced this pull request Aug 21, 2024
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Projects
None yet
3 participants