-
Notifications
You must be signed in to change notification settings - Fork 1.7k
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][Connector-V2] Pulsar support user-defined schema #2436
Conversation
f92415a
to
69dcea1
Compare
@@ -222,7 +225,9 @@ private void setPartitionDiscoverer(Config config) { | |||
|
|||
private void setDeserialization(Config config) { | |||
String format = config.getString("format"); | |||
// TODO: json format | |||
// TODO: format SPI | |||
SeaTunnelRowType rowType = SeatunnelSchema.buildWithConfig(config.getConfig(SeatunnelSchema.SCHEMA)).getSeaTunnelRowType(); |
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.
Use fields
as config key? reference #2469
example:
SeaTunnelRowType rowType = SeatunnelSchema.buildWithConfig(config).getSeaTunnelRowType();
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.
SeatunnelSchema
does not support your notation yet;
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.
You can merge from dev again. Then you can use this feature.
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
* [Improve][Connector-V2] Pulsar support user-defined schema * import the constant
* [Improve][Connector-V2] Pulsar support user-defined schema * import the constant
* [Improve][Connector-V2] Pulsar support user-defined schema * import the constant
* [Improve][Connector-V2] Pulsar support user-defined schema * import the constant
* [Improve][Connector-V2] Pulsar support user-defined schema * import the constant
Purpose of this pull request
Check list
New License Guide