Skip to content

[3.0][cdc-common] Add ConText for Source/Sink initialization.#2672

Merged
GOODBOY008 merged 1 commit intoapache:masterfrom
joyCurry30:2666_add_context
Nov 17, 2023
Merged

[3.0][cdc-common] Add ConText for Source/Sink initialization.#2672
GOODBOY008 merged 1 commit intoapache:masterfrom
joyCurry30:2666_add_context

Conversation

@joyCurry30
Copy link
Copy Markdown
Contributor

Refer to #2666
We should add 'ConText' with options for Source/Sink initialization.

@joyCurry30
Copy link
Copy Markdown
Contributor Author

@lvyanquan @GOODBOY008 @PatrickRen PTAL.

@lvyanquan
Copy link
Copy Markdown
Contributor

Pass Context to DataSinkFactory/DataSourceFactory, like DynamicTableSourceFactory.


/** A helper for working with {@link Factory}. */
@PublicEvolving
public class FactoryHelper {
Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Not sure this class is necessary, @GOODBOY008 What do you think?

@lvyanquan
Copy link
Copy Markdown
Contributor

lvyanquan commented Nov 9, 2023

getConfiguration method is also necessary to get ConfigOption, so you may need to wait #2668 to be done.

@joyCurry30 joyCurry30 force-pushed the 2666_add_context branch 2 times, most recently from d4803d3 to 547ad88 Compare November 17, 2023 02:52
Copy link
Copy Markdown
Contributor

@lvyanquan lvyanquan left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

LGTM.

Comment thread flink-cdc-connect/flink-cdc-source-connectors/pom.xml Outdated
Copy link
Copy Markdown
Member

@GOODBOY008 GOODBOY008 left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

@GOODBOY008 GOODBOY008 merged commit a1b67a7 into apache:master Nov 17, 2023
e-mhui pushed a commit to e-mhui/flink-cdc-connectors that referenced this pull request Dec 2, 2023
ChaomingZhangCN pushed a commit to ChaomingZhangCN/flink-cdc that referenced this pull request Jan 13, 2025
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

Successfully merging this pull request may close these issues.

4 participants