Skip to content

Commit 0102224

Browse files
committed
Skip deleted rows returned by ColumnFamilyRecordReader
1 parent de3f576 commit 0102224

File tree

1 file changed

+5
-0
lines changed

1 file changed

+5
-0
lines changed

cassandra-handler/src/main/java/org/apache/hadoop/hive/cassandra/input/CassandraHiveRecordReader.java

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -184,6 +184,11 @@ public boolean nextKeyValue() throws IOException {
184184
currentValue.clear();
185185

186186
if (next) {
187+
188+
// Skip deleted rows
189+
if(cfrr.getCurrentValue().size()==0)
190+
return nextKeyValue();
191+
187192
currentKey = convertByteBuffer(cfrr.getCurrentKey());
188193

189194
// rowKey

0 commit comments

Comments
 (0)