liangyepianzhou commented on issue #5133: URL: https://github.com/apache/inlong/issues/5133#issuecomment-1227236577
# Motivation Sort module supports InfluxDB. InfluxDs is a scalable datastore for metrics, events, and real-time analytics. We should support InfluxDB in sort module. # Design The design will follow following the document [Sort Plugin](https://inlong.apache.org/docs/design_and_concept/how_to_extend_data_node_for_sort) and [Manager Plugin](https://inlong.apache.org/zh-CN/docs/design_and_concept/how_to_extend_data_node_for_manager) 1. Extend a new Extract Node for InfluxDB 2. Extend a new Load Node for InfluxDB 3. Implement the corresponding flink connectors for InfluxDB 4. Extend Extract Node and Load Node in manager module for InfluxDB # Modification ## Load Node 1. add the new class InfluxDBLoadNode, which inherits the LoadNode class 2. add the Load for InfluxDB to JsonSubTypes in LoadNode and Node ## Extract Node 1. add the new class InfluxDBExtractNode, which inherits the ExtractNode class 2. add the Extract for InfluxDB to JsonSubTypes in ExtractNode and Node ## Flink Connector Creating new file called InfluxDB in inlong-sort/sort-connectors, Adding new classes into the file: * InfluxDBTableSink * InfluxDBTableSource * InfluxDBTableFactory * ConfigOptions * InfluxDBCatalog * InfluxDBCatalogFactory # Manager plugin Follow the document [Manager Plugin](https://inlong.apache.org/zh-CN/docs/design_and_concept/how_to_extend_data_node_for_manager) to extend the extract node and load node -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
