-
Notifications
You must be signed in to change notification settings - Fork 1.6k
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
[Connectors-V2]Support IoTDB Source #2431
Conversation
e2e sink already done. i will add it after sink merged |
...iotdb/src/main/java/org/apache/seatunnel/connectors/seatunnel/iotdb/config/SourceConfig.java
Outdated
Show resolved
Hide resolved
...-iotdb/src/main/java/org/apache/seatunnel/connectors/seatunnel/iotdb/source/IoTDBSource.java
Outdated
Show resolved
Hide resolved
.../src/main/java/org/apache/seatunnel/connectors/seatunnel/iotdb/source/IoTDBSourceReader.java
Outdated
Show resolved
Hide resolved
.../java/org/apache/seatunnel/connectors/seatunnel/iotdb/source/IoTDBSourceSplitEnumerator.java
Show resolved
Hide resolved
# Conflicts: # plugin-mapping.properties # seatunnel-connectors-v2/connector-iotdb/pom.xml
# Conflicts: # plugin-mapping.properties # seatunnel-connectors-v2/connector-iotdb/pom.xml
@hailin0 hi, PTAL again.thx |
throw new PrepareFailException(getPluginName(), PluginType.SOURCE, "host and port and node urls are both empty"); | ||
} | ||
} | ||
SeatunnelSchema seatunnelSchema = SeatunnelSchema.buildWithConfig(pluginConfig); |
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.
Define like this?
schema { fields { code = int data = string success = boolean } }
Using a unified format will facilitate future merged schema into connector api
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.
hi, as it stands, it probably doesn't make much sense to use an extra level of nesting. What is the meaning of schema and field?
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.
yes, I agree
LGTM |
* [Connectors-V2]Support IoTDB Source * fix license header * fix java doc * fix check style * improve read method * used by SeatunelSchema get source field type * fetch upstream * reformat docs
No description provided.