flink-connector-aws icon indicating copy to clipboard operation
flink-connector-aws copied to clipboard

[FLINK-31987] Implement Table API support

Open darenwkt opened this issue 1 year ago • 0 comments

Purpose of the change

Implements the Table API for the Kinesis Source.

Verifying this change

This change added tests and can be verified as follows:

  • Added unit tests
  • Manually verified by running the Kinesis connector on a local Flink cluster.

Significant changes

(Please check any boxes [x] if the answer is "yes". You can first publish the PR and check them afterwards, for convenience.)

  • [x ] Dependencies have been added or upgraded
  • [ ] Public API has been changed (Public API is any class annotated with @Public(Evolving))
  • [ ] Serializers have been changed
  • [x ] New feature has been introduced
    • If yes, how is this documented? (not applicable / docs / JavaDocs / not documented)

darenwkt avatar Jun 20 '23 09:06 darenwkt