This is an automated email from the ASF dual-hosted git repository.

jwest pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/cassandra.git


The following commit(s) were added to refs/heads/trunk by this push:
     new c3bae31a52 Change SSTableSimpleScanner to use 
SSTableReader#openDataReaderForScan
c3bae31a52 is described below

commit c3bae31a528a1c751fb312ff9cc1343a9f12c500
Author: Jordan West <jor...@moonwest.dev>
AuthorDate: Wed Apr 9 12:12:34 2025 -0700

    Change SSTableSimpleScanner to use SSTableReader#openDataReaderForScan
    
    patch by Jordan West; Reviewed by Jon Haddad for CASSANDRA-20538
---
 CHANGES.txt                                                             | 1 +
 .../org/apache/cassandra/io/sstable/format/SSTableSimpleScanner.java    | 2 +-
 2 files changed, 2 insertions(+), 1 deletion(-)

diff --git a/CHANGES.txt b/CHANGES.txt
index a0b5da22c5..d37705c1e8 100644
--- a/CHANGES.txt
+++ b/CHANGES.txt
@@ -1,4 +1,5 @@
 5.1
+ * Change SSTableSimpleScanner to use SSTableReader#openDataReaderForScan 
(CASSANDRA-20538)
  * Automated Repair Inside Cassandra [CEP-37] (CASSANDRA-19918)
  * Grant permission on keyspaces system_views and system_virtual_schema not 
possible (CASSANDRA-20171)
  * General Purpose Transactions (Accord) [CEP-15] (CASSANDRA-17092)
diff --git 
a/src/java/org/apache/cassandra/io/sstable/format/SSTableSimpleScanner.java 
b/src/java/org/apache/cassandra/io/sstable/format/SSTableSimpleScanner.java
index 190ec42fa9..a649fbea4c 100644
--- a/src/java/org/apache/cassandra/io/sstable/format/SSTableSimpleScanner.java
+++ b/src/java/org/apache/cassandra/io/sstable/format/SSTableSimpleScanner.java
@@ -73,7 +73,7 @@ implements ISSTableScanner
     {
         assert sstable != null;
 
-        this.dfile = sstable.openDataReader();
+        this.dfile = sstable.openDataReaderForScan();
         this.sstable = sstable;
         this.sizeInBytes = boundsList.stream().mapToLong(ppb -> 
ppb.upperPosition - ppb.lowerPosition).sum();
         this.compressedSizeInBytes = sstable.compression ? 
sstable.onDiskSizeForPartitionPositions(boundsList) : sizeInBytes;


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@cassandra.apache.org
For additional commands, e-mail: commits-h...@cassandra.apache.org

Reply via email to