[
https://issues.apache.org/jira/browse/FLINK-6225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15984499#comment-15984499
]
ASF GitHub Bot commented on FLINK-6225:
---------------------------------------
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
---
@@ -108,10 +109,16 @@ protected Cluster buildCluster(Cluster.Builder
builder) {
private static final String SELECT_DATA_QUERY = "SELECT * FROM
flink.test;";
private static final ArrayList<Tuple3<String, Integer, Integer>>
collection = new ArrayList<>(20);
+ private static final ArrayList<org.apache.flink.types.Row>
rowCollection = new ArrayList<>(20);
+
+ private static final String[] FIELD_NAMES = new String[] {"id",
"counter", "batch_id"};
+ private static final TypeInformation[] FIELD_TYPES = new
TypeInformation[] {BasicTypeInfo.STRING_TYPE_INFO,
+ BasicTypeInfo.INT_TYPE_INFO, BasicTypeInfo.INT_TYPE_INFO};
static {
for (int i = 0; i < 20; i++) {
collection.add(new
Tuple3<>(UUID.randomUUID().toString(), i, 0));
+
rowCollection.add(org.apache.flink.types.Row.of(UUID.randomUUID().toString(),
i, 0));
--- End diff --
same as above regarding the import
> Support Row Stream for CassandraSink
> ------------------------------------
>
> Key: FLINK-6225
> URL: https://issues.apache.org/jira/browse/FLINK-6225
> Project: Flink
> Issue Type: New Feature
> Components: Cassandra Connector
> Affects Versions: 1.3.0
> Reporter: Jing Fan
> Assignee: Haohui Mai
> Fix For: 1.3.0
>
>
> Currently in CassandraSink, specifying query is not supported for row-stream.
> The solution should be similar to CassandraTupleSink.
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
