-
Notifications
You must be signed in to change notification settings - Fork 1.9k
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
[Feature][Connector][GoogleFirestore-Sink] Support GoogleFirestore Sink #4304
Conversation
Please provide a screenshot or e2e test to prove that it is available. |
@TaoZex |
LGTM. Thanks for your contribution. |
...ava/org/apache/seatunnel/connectors/seatunnel/google/firestore/sink/FirestoreSinkWriter.java
Outdated
Show resolved
Hide resolved
@TyrantLucifer PTAL. Thanks! |
you also should update release-note https://github.com/apache/incubator-seatunnel/blob/dev/release-note.md |
please add e2e test case. Refer to https://github.com/apache/incubator-seatunnel/blob/dev/docs/en/contribution/coding-guide.md |
refer |
...e/seatunnel/connectors/seatunnel/google/firestore/exception/FirestoreConnectorErrorCode.java
Show resolved
Hide resolved
...2e/connector-google-firestore-e2e/src/test/resources/firestore/fake_to_google_firestore.conf
Outdated
Show resolved
Hide resolved
I have no problem, @liugddx @TaoZex @TyrantLucifer PTAL again. |
...ava/org/apache/seatunnel/connectors/seatunnel/google/firestore/sink/FirestoreSinkWriter.java
Outdated
Show resolved
Hide resolved
…va/org/apache/seatunnel/connectors/seatunnel/google/firestore/sink/FirestoreSinkWriter.java Co-authored-by: TaoZex <[email protected]>
LGTM, thank you for your contribution. |
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.
LGTM
Assertions.assertTrue(documents.size() > 1); | ||
Assertions.assertEquals(15, documents.get(0).getData().size()); |
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.
Refer to src/test/java/org/apache/seatunnel/e2e/connector/starrocks/StarRocksCDCSinkIT.java, it is necessary to check the value of each field in each row
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.
@ic4y PTAL. Thanks
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.
LGTM, cc @hailin0 @EricJoy2048
@lvshaokang Suggest adding the new version documentation for GoogleFirestore Sink in subsequent PR.Or create a related issue |
@ic4y ok, i will supply new doc follow the rules. |
Purpose of this pull request
Support google firestore sink.
Check list
New License Guide
release-note
.