Skip to content
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

Optimize transform api #45

Closed
sunxiaojian opened this issue Jun 9, 2022 · 1 comment
Closed

Optimize transform api #45

sunxiaojian opened this issue Jun 9, 2022 · 1 comment

Comments

@sunxiaojian
Copy link
Contributor

No description provided.

sunxiaojian added a commit to sunxiaojian/openconnect that referenced this issue Jun 9, 2022
odbozhou pushed a commit that referenced this issue Jun 21, 2022
* SinkTask and SourceTask implement the validate method apache/rocketmq-connect#85

* Adjust the init and start methods of the component interface

* Set pause and resume to deprecated methods. It feels like they can be removed

* Add struct object and optimize schema and schema builder API #41

* add offset storage writer #41

* add getter and setter method #41

* add SchemaAndValue #41

* add logical type #41

* Schemabuilder add required method

* schema add  hashCode and equals method

* fixed doc method

* Field add equals and hashcode method

* optimize api #85

* Optimize transform api #45

* Optimize transform api and add RecordConverter
@odbozhou
Copy link
Contributor

merged

odbozhou pushed a commit that referenced this issue Jul 14, 2022
* SinkTask and SourceTask implement the validate method apache/rocketmq-connect#85

* Adjust the init and start methods of the component interface

* Set pause and resume to deprecated methods. It feels like they can be removed

* Add struct object and optimize schema and schema builder API #41

* add offset storage writer #41

* add getter and setter method #41

* add SchemaAndValue #41

* add logical type #41

* Schemabuilder add required method

* schema add  hashCode and equals method

* fixed doc method

* Field add equals and hashcode method

* optimize api #85

* Optimize transform api #45

* Optimize transform api and add RecordConverter

* Optimize the source task commit method #51

* add batch commit #51
odbozhou pushed a commit that referenced this issue Jul 20, 2022
…54)

* SinkTask and SourceTask implement the validate method apache/rocketmq-connect#85

* Adjust the init and start methods of the component interface

* Set pause and resume to deprecated methods. It feels like they can be removed

* Add struct object and optimize schema and schema builder API #41

* add offset storage writer #41

* add getter and setter method #41

* add SchemaAndValue #41

* add logical type #41

* Schemabuilder add required method

* schema add  hashCode and equals method

* fixed doc method

* Field add equals and hashcode method

* optimize api #85

* Optimize transform api #45

* Optimize transform api and add RecordConverter

* Connectrecord add a key field to identify the unique data #53
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

2 participants