-
Notifications
You must be signed in to change notification settings - Fork 335
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
Add connector doris #31
Conversation
@@ -47,4 +52,8 @@ public interface FakeReaderOptions extends ReaderOptions.BaseReaderOptions { | |||
ConfigOption<Boolean> USE_BITSAIL_TYPE = | |||
key(READER_PREFIX + "use_bitsail_type") | |||
.defaultValue(true); | |||
|
|||
ConfigOption<List<Map<String, String>>> FIXED_COLUMNS = | |||
key(READER_PREFIX + "fixed_columns") |
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.
what is the meaning of fixed_columns
?
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.
Means the column(s) defined here has fixed value.
Format is:
[ { "name": "column_name", "fixed_value": "a value" } ]
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.
We need this option because we want some fixed value columns sometimes. For example in doris connector test, the FakeSource needs to produce records with the same partition value(s).
Already add comment to this option.
.defaultValue("root"); | ||
|
||
ConfigOption<String> PASSWORD = | ||
key(WRITER_PREFIX + "password") |
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.
is this field being printed anywhere in the log?
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.
No.
public class DorisSinkITCase { | ||
|
||
@Test | ||
public void test() throws Exception { |
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.
No doris container needed?
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.
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
Signed-off-by: Peng Liu [email protected]
Pre-Checklist
Note: Please complete ALL items in the following checklist.
Purpose
Add connectors for doris.
Approaches
Related Issues
N/A
New Behavior (screenshots if needed)
N/A