tkalkirill commented on code in PR #1652:
URL: https://github.com/apache/ignite-3/pull/1652#discussion_r1105678848
##########
modules/page-memory/src/integrationTest/java/org/apache/ignite/internal/pagememory/tree/AbstractBplusTreePageMemoryTest.java:
##########
@@ -2367,6 +2371,157 @@ void testFindNext() throws Exception {
assertEquals(0L, tree.findNext(-1L, true));
}
+ @Test
+ void testFindOneWithMapper() throws Exception {
+ TestTree tree = createTestTree(true);
+
+ tree.put(0L);
+
+ TreeRowClosure<Long, Long> treeRowClosure = new TreeRowClosure<>() {
+ @Override
+ public boolean apply(BplusTree<Long, Long> tree, BplusIo<Long> io,
long pageAddr, int idx) {
+ return true;
+ }
+
+ @Override
+ public String map(Long treeRow) {
Review Comment:
Tried to fix it.
##########
modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/tree/BplusTree.java:
##########
@@ -1270,12 +1270,14 @@ public Cursor<T> find(
* @param upper Upper bound or {@code null} if unbounded.
* @param lowIncl {@code true} if lower bound is inclusive.
* @param upIncl {@code true} if upper bound is inclusive.
- * @param c Filter closure.
+ * @param c Tree row closure.
* @param x Implementation specific argument, {@code null} always means
that we need to return full detached data row.
* @return Cursor.
- * @throws IgniteInternalCheckedException If failed.
+ * @throws CorruptedDataStructureException If the data structure is broken.
+ * @throws CorruptedTreeException If there were {@link RuntimeException}
or {@link AssertionError}.
+ * @throws IgniteInternalCheckedException If other errors occurred.
*/
- public Cursor<T> find(
+ public <R> Cursor<R> find(
Review Comment:
Tried to fix it.
--
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 the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
