Skip to content

Commit a5dfb11

Browse files
committed
fixes
1 parent 97c8ce0 commit a5dfb11

File tree

3 files changed

+16
-9
lines changed

3 files changed

+16
-9
lines changed

astra-db-java/src/main/java/com/datastax/astra/client/collections/Collection.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -585,7 +585,6 @@ public CollectionInsertManyResult insertMany(List<? extends T> documents, Collec
585585
try {
586586
for (Future<CollectionInsertManyResult> future : futures) {
587587
CollectionInsertManyResult res = future.get();
588-
System.out.println("res = " + res.getInsertedIds());
589588
finalResult.getInsertedIds().addAll(res.getInsertedIds());
590589
finalResult.getDocumentResponses().addAll(res.getDocumentResponses());
591590
}

astra-db-java/src/main/java/com/datastax/astra/client/tables/Table.java

Lines changed: 8 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -784,10 +784,14 @@ public Page<T> findPage(Filter filter, TableFindOptions options) {
784784

785785
return new Page<>(
786786
apiResponse.getData().getNextPageState(),
787-
apiResponse.getData().getDocuments()
788-
.stream()
789-
.map(d -> d.map(getRowClass()))
790-
.collect(Collectors.toList()), sortVector);
787+
apiResponse.getData().getDocuments().stream()
788+
.map(doc -> {
789+
Row targetRow = new Row();
790+
targetRow.getColumnMap().putAll(doc.getDocumentMap());
791+
return targetRow;
792+
})
793+
.map(d -> RowMapper.mapFromRow(d, getSerializer(), getRowClass()))
794+
.collect(Collectors.toList()), sortVector);
791795
}
792796

793797
// -------------------------

astra-db-java/src/main/java/com/datastax/astra/client/tables/cursor/TableCursor.java

Lines changed: 8 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -325,17 +325,21 @@ public boolean hasNext() {
325325
* @throws NoSuchElementException if no more elements are available
326326
*/
327327
@Override
328+
@SuppressWarnings("unchecked")
328329
public R next() {
329330
if (!hasNext()) {
330331
throw new NoSuchElementException();
331332
}
333+
332334
T rawDoc = buffer.remove(0);
333335
consumedCount++;
334-
// Converted as Row Fist (pivot)
335-
Row row = RowMapper.mapAsRow(rawDoc);
336336

337-
// From Pivot to new class
338-
return RowMapper.mapFromRow(row, table.getOptions().getSerializer(), rowType);
337+
if (!rowType.isInstance(rawDoc)) {
338+
Row row = RowMapper.mapAsRow(rawDoc);
339+
return RowMapper.mapFromRow(row, table.getOptions().getSerializer(), rowType);
340+
} else {
341+
return (R) rawDoc;
342+
}
339343
}
340344
}
341345

0 commit comments

Comments
 (0)