Re: [PR] CASSANALYTICS-27: Support for Trie-based SSTables [cassandra-analytics]

2025-07-09 Thread via GitHub
lukasz-antoniak commented on code in PR #110: URL: https://github.com/apache/cassandra-analytics/pull/110#discussion_r2194760772 ## cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/data/FileSystemSource.java: ## @@ -48,12 +48,14 @@ public class FileSystemSour

Re: [PR] CASSANALYTICS-27: Support for Trie-based SSTables [cassandra-analytics]

2025-07-08 Thread via GitHub
lukasz-antoniak commented on code in PR #110: URL: https://github.com/apache/cassandra-analytics/pull/110#discussion_r2194142263 ## cassandra-five-zero-bridge/src/main/java/org/apache/cassandra/spark/reader/CompressionMetadata.java: ## @@ -0,0 +1,134 @@ +/* + * Licensed to the

Re: [PR] CASSANALYTICS-27: Support for Trie-based SSTables [cassandra-analytics]

2025-07-08 Thread via GitHub
lukasz-antoniak commented on code in PR #110: URL: https://github.com/apache/cassandra-analytics/pull/110#discussion_r2194158897 ## cassandra-five-zero-bridge/src/main/java/org/apache/cassandra/spark/reader/CompressionMetadata.java: ## @@ -0,0 +1,138 @@ +/* + * Licensed to the

Re: [PR] CASSANALYTICS-27: Support for Trie-based SSTables [cassandra-analytics]

2025-07-08 Thread via GitHub
yifan-c commented on code in PR #110: URL: https://github.com/apache/cassandra-analytics/pull/110#discussion_r2193550255 ## cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/data/FileSystemSource.java: ## @@ -48,12 +48,14 @@ public class FileSystemSource impl

Re: [PR] CASSANALYTICS-27: Support for Trie-based SSTables [cassandra-analytics]

2025-07-08 Thread via GitHub
yifan-c commented on code in PR #110: URL: https://github.com/apache/cassandra-analytics/pull/110#discussion_r2193534810 ## cassandra-five-zero-bridge/src/main/java/org/apache/cassandra/spark/reader/BtiIndexReader.java: ## @@ -0,0 +1,99 @@ +/* + * Licensed to the Apache Softwar

Re: [PR] CASSANALYTICS-27: Support for Trie-based SSTables [cassandra-analytics]

2025-07-04 Thread via GitHub
lukasz-antoniak commented on code in PR #110: URL: https://github.com/apache/cassandra-analytics/pull/110#discussion_r2184635200 ## cassandra-five-zero-bridge/src/main/java/org/apache/cassandra/spark/reader/BtiIndexReader.java: ## @@ -0,0 +1,99 @@ +/* + * Licensed to the Apache

Re: [PR] CASSANALYTICS-27: Support for Trie-based SSTables [cassandra-analytics]

2025-07-03 Thread via GitHub
lukasz-antoniak commented on code in PR #110: URL: https://github.com/apache/cassandra-analytics/pull/110#discussion_r2182639647 ## cassandra-five-zero-bridge/src/main/java/org/apache/cassandra/spark/reader/CompressionMetadata.java: ## @@ -0,0 +1,138 @@ +/* + * Licensed to the

Re: [PR] CASSANALYTICS-27: Support for Trie-based SSTables [cassandra-analytics]

2025-07-03 Thread via GitHub
lukasz-antoniak commented on code in PR #110: URL: https://github.com/apache/cassandra-analytics/pull/110#discussion_r2182215647 ## cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/data/SSTable.java: ## @@ -63,7 +63,13 @@ public InputStream openSummaryStream(

Re: [PR] CASSANALYTICS-27: Support for Trie-based SSTables [cassandra-analytics]

2025-07-03 Thread via GitHub
lukasz-antoniak commented on code in PR #110: URL: https://github.com/apache/cassandra-analytics/pull/110#discussion_r2182210935 ## cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/utils/streaming/BufferingInputStream.java: ## @@ -346,24 +361,28 @@ else if (c

Re: [PR] CASSANALYTICS-27: Support for Trie-based SSTables [cassandra-analytics]

2025-07-03 Thread via GitHub
lukasz-antoniak commented on code in PR #110: URL: https://github.com/apache/cassandra-analytics/pull/110#discussion_r2182193912 ## cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/utils/streaming/BufferingInputStream.java: ## @@ -237,8 +252,8 @@ public void

Re: [PR] CASSANALYTICS-27: Support for Trie-based SSTables [cassandra-analytics]

2025-07-03 Thread via GitHub
lukasz-antoniak commented on code in PR #110: URL: https://github.com/apache/cassandra-analytics/pull/110#discussion_r2182181168 ## cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/data/FileSystemSSTable.java: ## @@ -63,9 +61,11 @@ protected InputStream openI

Re: [PR] CASSANALYTICS-27: Support for Trie-based SSTables [cassandra-analytics]

2025-07-03 Thread via GitHub
lukasz-antoniak commented on code in PR #110: URL: https://github.com/apache/cassandra-analytics/pull/110#discussion_r2182178365 ## cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/data/FileSystemSource.java: ## @@ -90,28 +90,30 @@ public void request(long st

Re: [PR] CASSANALYTICS-27: Support for Trie-based SSTables [cassandra-analytics]

2025-07-02 Thread via GitHub
lukasz-antoniak commented on code in PR #110: URL: https://github.com/apache/cassandra-analytics/pull/110#discussion_r2180535929 ## cassandra-analytics-integration-framework/build.gradle: ## @@ -38,7 +38,9 @@ publishing { } } -ext.dtestJar = System.getenv("DTEST_JAR") ?

Re: [PR] CASSANALYTICS-27: Support for Trie-based SSTables [cassandra-analytics]

2025-07-02 Thread via GitHub
lukasz-antoniak commented on code in PR #110: URL: https://github.com/apache/cassandra-analytics/pull/110#discussion_r2180534333 ## cassandra-five-zero-bridge/src/main/java/org/apache/cassandra/spark/reader/BtiIndexReader.java: ## @@ -0,0 +1,99 @@ +/* + * Licensed to the Apache

Re: [PR] CASSANALYTICS-27: Support for Trie-based SSTables [cassandra-analytics]

2025-06-30 Thread via GitHub
lukasz-antoniak commented on code in PR #110: URL: https://github.com/apache/cassandra-analytics/pull/110#discussion_r2174559338 ## cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/utils/streaming/BufferingInputStream.java: ## @@ -346,24 +361,28 @@ else if (c

Re: [PR] CASSANALYTICS-27: Support for Trie-based SSTables [cassandra-analytics]

2025-06-11 Thread via GitHub
yifan-c commented on code in PR #110: URL: https://github.com/apache/cassandra-analytics/pull/110#discussion_r2141235828 ## cassandra-five-zero-types/src/main/java/org/apache/cassandra/spark/reader/ComplexTypeBuffer.java: ## @@ -0,0 +1,118 @@ +/* + * Licensed to the Apache Soft

Re: [PR] CASSANALYTICS-27: Support for Trie-based SSTables [cassandra-analytics]

2025-06-11 Thread via GitHub
yifan-c commented on code in PR #110: URL: https://github.com/apache/cassandra-analytics/pull/110#discussion_r2136874334 ## cassandra-analytics-common/src/main/java/org/apache/cassandra/cdc/api/CommitLog.java: ## @@ -54,7 +54,7 @@ static Optional> extractVersionAndSegmentId(@N

[PR] CASSANALYTICS-27: Support for Trie-based SSTables [cassandra-analytics]

2025-05-08 Thread via GitHub
lukasz-antoniak opened a new pull request, #110: URL: https://github.com/apache/cassandra-analytics/pull/110 Status: Work in progress. Contributions welcome! Although tests passes and users can read V5 SSTables, there are various things to fix on a code level: - [ ] `FileSystem