Re: [PR] CASSANALYTICS-51 Support Tuples and Tuples with UDTs [cassandra-analytics]

skoppu22 commented on code in PR #116: URL: https://github.com/apache/cassandra-analytics/pull/116#discussion_r2207710180 ## cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/data/CqlTable.java: ## @@ -275,6 +275,37 @@ public boolean containsUdt(String fieldNa

Re: [PR] CASSANALYTICS-51 Support Tuples and Tuples with UDTs [cassandra-analytics]

skoppu22 closed pull request #116: CASSANALYTICS-51 Support Tuples and Tuples with UDTs URL: https://github.com/apache/cassandra-analytics/pull/116 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to th

Re: [PR] CASSANALYTICS-51 Support Tuples and Tuples with UDTs [cassandra-analytics]

yifan-c commented on code in PR #116: URL: https://github.com/apache/cassandra-analytics/pull/116#discussion_r2198434633 ## cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/RecordWriter.java: ## @@ -372,19 +372,33 @@ private void writeRow(Tuple2 key

Re: [PR] CASSANALYTICS-51 Support Tuples and Tuples with UDTs [cassandra-analytics]

yifan-c commented on code in PR #116: URL: https://github.com/apache/cassandra-analytics/pull/116#discussion_r2198415707 ## cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/data/CqlTable.java: ## @@ -275,6 +275,37 @@ public boolean containsUdt(String fieldNam

Re: [PR] CASSANALYTICS-51 Support Tuples and Tuples with UDTs [cassandra-analytics]

skoppu22 commented on code in PR #116: URL: https://github.com/apache/cassandra-analytics/pull/116#discussion_r2197889652 ## cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/SqlToCqlTypeConverter.java: ## @@ -172,6 +172,12 @@ public static Converter

Re: [PR] CASSANALYTICS-51 Support Tuples and Tuples with UDTs [cassandra-analytics]

skoppu22 commented on code in PR #116: URL: https://github.com/apache/cassandra-analytics/pull/116#discussion_r2197887450 ## cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/RecordWriter.java: ## @@ -372,19 +372,33 @@ private void writeRow(Tuple2 ke

Re: [PR] CASSANALYTICS-51 Support Tuples and Tuples with UDTs [cassandra-analytics]

skoppu22 commented on code in PR #116: URL: https://github.com/apache/cassandra-analytics/pull/116#discussion_r2197874162 ## cassandra-analytics-integration-tests/src/test/java/org/apache/cassandra/analytics/BulkWriteUdtTest.java: ## @@ -247,13 +251,14 @@ private int populateMa

Re: [PR] CASSANALYTICS-51 Support Tuples and Tuples with UDTs [cassandra-analytics]

skoppu22 commented on code in PR #116: URL: https://github.com/apache/cassandra-analytics/pull/116#discussion_r2197873179 ## cassandra-analytics-integration-tests/src/test/java/org/apache/cassandra/analytics/BulkWriteUdtTest.java: ## @@ -207,13 +210,14 @@ private int populateSe

Re: [PR] CASSANALYTICS-51 Support Tuples and Tuples with UDTs [cassandra-analytics]

skoppu22 commented on code in PR #116: URL: https://github.com/apache/cassandra-analytics/pull/116#discussion_r2197835886 ## cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/data/CqlTable.java: ## @@ -275,6 +275,37 @@ public boolean containsUdt(String fieldNa

Re: [PR] CASSANALYTICS-51 Support Tuples and Tuples with UDTs [cassandra-analytics]

skoppu22 commented on code in PR #116: URL: https://github.com/apache/cassandra-analytics/pull/116#discussion_r2197835886 ## cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/data/CqlTable.java: ## @@ -275,6 +275,37 @@ public boolean containsUdt(String fieldNa

Re: [PR] CASSANALYTICS-51 Support Tuples and Tuples with UDTs [cassandra-analytics]

skoppu22 commented on code in PR #116: URL: https://github.com/apache/cassandra-analytics/pull/116#discussion_r2197870934 ## cassandra-analytics-integration-tests/src/test/java/org/apache/cassandra/analytics/BulkWriteUdtTest.java: ## @@ -168,12 +168,15 @@ private int populateLi

Re: [PR] CASSANALYTICS-51 Support Tuples and Tuples with UDTs [cassandra-analytics]

skoppu22 commented on code in PR #116: URL: https://github.com/apache/cassandra-analytics/pull/116#discussion_r2197867670 ## cassandra-analytics-integration-tests/src/test/java/org/apache/cassandra/analytics/BulkWriteTupleTest.java: ## @@ -0,0 +1,181 @@ +/* + * Licensed to the

Re: [PR] CASSANALYTICS-51 Support Tuples and Tuples with UDTs [cassandra-analytics]

skoppu22 commented on code in PR #116: URL: https://github.com/apache/cassandra-analytics/pull/116#discussion_r2197835886 ## cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/data/CqlTable.java: ## @@ -275,6 +275,37 @@ public boolean containsUdt(String fieldNa

Re: [PR] CASSANALYTICS-51 Support Tuples and Tuples with UDTs [cassandra-analytics]

skoppu22 commented on code in PR #116: URL: https://github.com/apache/cassandra-analytics/pull/116#discussion_r2197839978 ## cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/RecordWriter.java: ## @@ -372,19 +372,33 @@ private void writeRow(Tuple2 ke

Re: [PR] CASSANALYTICS-51 Support Tuples and Tuples with UDTs [cassandra-analytics]

yifan-c commented on code in PR #116: URL: https://github.com/apache/cassandra-analytics/pull/116#discussion_r2180717481 ## cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/RecordWriter.java: ## @@ -372,19 +372,33 @@ private void writeRow(Tuple2 key

[PR] CASSANALYTICS-51 Support Tuples and Tuples with UDTs [cassandra-analytics]

skoppu22 opened a new pull request, #116: URL: https://github.com/apache/cassandra-analytics/pull/116 Currently Cassandra bulk writer unable to convert Tuples from sql to cql as No op converter is used. This needs to be handled. Also, need to support Tuples with UDTs nested inside them and