Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3748
---
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3748#discussion_r147517745
--- Diff:
flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraTableSink.java
---
@@ -0,0
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3748#discussion_r147442488
--- Diff:
flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraSink.java
---
@@ -205,12
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3748#discussion_r147507230
--- Diff:
flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraTableSink.java
---
@@ -0,0
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3748#discussion_r147456818
--- Diff:
flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraSink.java
---
@@ -375,6 +381,34
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3748#discussion_r147517530
--- Diff:
flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java
---
@@
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3748#discussion_r144854453
--- Diff:
flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java
---
@@
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3748#discussion_r144854466
--- Diff:
flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java
---
@@
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3748#discussion_r143966527
--- Diff:
flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraRowSink.java
---
@@ -0,0 +1,59
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3748#discussion_r143965663
--- Diff: flink-connectors/flink-connector-cassandra/pom.xml ---
@@ -187,5 +187,17 @@ under the License.
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3748#discussion_r143965738
--- Diff: flink-connectors/flink-connector-cassandra/pom.xml ---
@@ -187,5 +187,17 @@ under the License.
Github user PangZhi commented on a diff in the pull request:
https://github.com/apache/flink/pull/3748#discussion_r143098834
--- Diff:
flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java
---
@@
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3748#discussion_r116834041
--- Diff:
flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraRowSink.java
---
@@ -0,0 +1,59
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3748#discussion_r116833798
--- Diff:
flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java
---
@@
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3748#discussion_r116832836
--- Diff:
flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java
---
@@
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3748#discussion_r116833487
--- Diff:
flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java
---
@@
Github user haohui commented on a diff in the pull request:
https://github.com/apache/flink/pull/3748#discussion_r116092436
--- Diff:
flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java
---
@@
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3748#discussion_r115944431
--- Diff:
flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java
---
@@
Github user haohui commented on a diff in the pull request:
https://github.com/apache/flink/pull/3748#discussion_r115935549
--- Diff:
flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java
---
@@
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3748#discussion_r115934327
--- Diff: flink-connectors/flink-connector-cassandra/pom.xml ---
@@ -176,5 +176,23 @@ under the License.
Github user haohui commented on a diff in the pull request:
https://github.com/apache/flink/pull/3748#discussion_r115927398
--- Diff: flink-connectors/flink-connector-cassandra/pom.xml ---
@@ -176,5 +176,23 @@ under the License.
Github user haohui commented on a diff in the pull request:
https://github.com/apache/flink/pull/3748#discussion_r115861002
--- Diff: flink-connectors/flink-connector-cassandra/pom.xml ---
@@ -176,5 +176,23 @@ under the License.
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3748#discussion_r115859400
--- Diff: flink-connectors/flink-connector-cassandra/pom.xml ---
@@ -176,5 +176,23 @@ under the License.
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3748#discussion_r113781674
--- Diff:
flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraSink.java
---
@@ -190,10 +192,13
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3748#discussion_r113776064
--- Diff:
flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraSink.java
---
@@ -335,6 +340,30
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3748#discussion_r113745320
--- Diff: flink-connectors/flink-connector-cassandra/pom.xml ---
@@ -176,5 +176,10 @@ under the License.
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3748#discussion_r113747908
--- Diff:
flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraSink.java
---
@@ -190,10
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3748#discussion_r113779310
--- Diff:
flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java
---
@@
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3748#discussion_r113778001
--- Diff:
flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraTableSink.java
---
@@ -0,0
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3748#discussion_r113541703
--- Diff:
flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java
---
@@
Github user PangZhi commented on a diff in the pull request:
https://github.com/apache/flink/pull/3748#discussion_r113505564
--- Diff:
flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java
---
@@
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3748#discussion_r113410392
--- Diff:
flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java
---
@@
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3748#discussion_r113410244
--- Diff:
flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java
---
@@
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3748#discussion_r113410291
--- Diff:
flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java
---
@@
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3748#discussion_r113410371
--- Diff:
flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java
---
@@
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3748#discussion_r113410687
--- Diff:
flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java
---
@@
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3748#discussion_r113410023
--- Diff:
flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java
---
@@
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3748#discussion_r113408171
--- Diff: flink-connectors/flink-connector-cassandra/pom.xml ---
@@ -176,5 +176,10 @@ under the License.
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3748#discussion_r113409930
--- Diff:
flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraTableSink.java
---
@@ -0,0 +1,83
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3748#discussion_r113410447
--- Diff:
flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java
---
@@
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3748#discussion_r113410046
--- Diff:
flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java
---
@@
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3748#discussion_r113409179
--- Diff:
flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraTableSink.java
---
@@ -0,0 +1,83
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3748#discussion_r112616773
--- Diff:
flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraTableSink.java
---
@@ -0,0
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3748#discussion_r112616241
--- Diff:
flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraTableSink.java
---
@@ -0,0
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3748#discussion_r112615718
--- Diff:
flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java
---
@@
GitHub user PangZhi opened a pull request:
https://github.com/apache/flink/pull/3748
[FLINK-6225] [Cassandra Connector] add CassandraTableSink
This PR is to address https://issues.apache.org/jira/browse/FLINK-6225
- add Row type support for CassandraSink
- add
46 matches
Mail list logo
