[jira] [Commented] (FLINK-25965) Add a Couchbase sink
[ https://issues.apache.org/jira/browse/FLINK-25965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17488104#comment-17488104 ] Nir Tsruya commented on FLINK-25965: I see, thank you very much for the heads up [~MartijnVisser] . I guess development an be initiated and then moved accordingly > Add a Couchbase sink > > > Key: FLINK-25965 > URL: https://issues.apache.org/jira/browse/FLINK-25965 > Project: Flink > Issue Type: New Feature > Components: Connectors / Common >Reporter: Nir Tsruya >Priority: Minor > > h2. Motivation > *User stories:* > As a Flink user, I’d like to use CouchBase as sink for my data pipeline. > *Scope:* > * Implement an asynchronous sink for CouchBase inheriting the AsyncSinkBase > class. The implementation can for now reside in its own module in > flink-connectors. > * Implement an asynchornous sink writer for CouchBase by extending the > AsyncSinkWriter. The implemented Sink Writer will be used by the Sink class > that will be created as part of this story. > * Java / code-level docs. > * End to end testing -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Commented] (FLINK-25965) Add a Couchbase sink
[ https://issues.apache.org/jira/browse/FLINK-25965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17488054#comment-17488054 ] Martijn Visser commented on FLINK-25965: [~nir.tsruya] It depends on preference. Some contributors are waiting, others are opening a PR against Flink master to already get some insights but accept that there will be refactoring needed when its actually going to be send to its own repository. > Add a Couchbase sink > > > Key: FLINK-25965 > URL: https://issues.apache.org/jira/browse/FLINK-25965 > Project: Flink > Issue Type: New Feature > Components: Connectors / Common >Reporter: Nir Tsruya >Priority: Minor > > h2. Motivation > *User stories:* > As a Flink user, I’d like to use CouchBase as sink for my data pipeline. > *Scope:* > * Implement an asynchronous sink for CouchBase inheriting the AsyncSinkBase > class. The implementation can for now reside in its own module in > flink-connectors. > * Implement an asynchornous sink writer for CouchBase by extending the > AsyncSinkWriter. The implemented Sink Writer will be used by the Sink class > that will be created as part of this story. > * Java / code-level docs. > * End to end testing -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Commented] (FLINK-25965) Add a Couchbase sink
[ https://issues.apache.org/jira/browse/FLINK-25965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17488045#comment-17488045 ] Nir Tsruya commented on FLINK-25965: Thanks [~MartijnVisser] , I see. Does it mean that in order to create new connectors, we need to wait for these repositories to be created? and there will be a new Jira project for these? > Add a Couchbase sink > > > Key: FLINK-25965 > URL: https://issues.apache.org/jira/browse/FLINK-25965 > Project: Flink > Issue Type: New Feature > Components: Connectors / Common >Reporter: Nir Tsruya >Priority: Minor > > h2. Motivation > *User stories:* > As a Flink user, I’d like to use CouchBase as sink for my data pipeline. > *Scope:* > * Implement an asynchronous sink for CouchBase inheriting the AsyncSinkBase > class. The implementation can for now reside in its own module in > flink-connectors. > * Implement an asynchornous sink writer for CouchBase by extending the > AsyncSinkWriter. The implemented Sink Writer will be used by the Sink class > that will be created as part of this story. > * Java / code-level docs. > * End to end testing -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Commented] (FLINK-25965) Add a Couchbase sink
[ https://issues.apache.org/jira/browse/FLINK-25965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17487957#comment-17487957 ] Martijn Visser commented on FLINK-25965: [~nir.tsruya] Please keep in mind that we don't want to add new connectors to the Flink repository itself after the 1.15 branch is cut (this week), given the discussion we've had on externalizing connectors. See https://cwiki.apache.org/confluence/display/FLINK/Connectors > Add a Couchbase sink > > > Key: FLINK-25965 > URL: https://issues.apache.org/jira/browse/FLINK-25965 > Project: Flink > Issue Type: New Feature > Components: Connectors / Common >Reporter: Nir Tsruya >Priority: Minor > > h2. Motivation > *User stories:* > As a Flink user, I’d like to use CouchBase as sink for my data pipeline. > *Scope:* > * Implement an asynchronous sink for CouchBase inheriting the AsyncSinkBase > class. The implementation can for now reside in its own module in > flink-connectors. > * Implement an asynchornous sink writer for CouchBase by extending the > AsyncSinkWriter. The implemented Sink Writer will be used by the Sink class > that will be created as part of this story. > * Java / code-level docs. > * End to end testing -- This message was sent by Atlassian Jira (v8.20.1#820001)
