This is an automated email from the ASF dual-hosted git repository. ptupitsyn pushed a commit to branch ignite-14972 in repository https://gitbox.apache.org/repos/asf/ignite-3.git
commit 4eeff5d53c264b9c8353d32cbb27a988ca640a57 Author: Pavel Tupitsyn <[email protected]> AuthorDate: Mon May 30 14:49:39 2022 +0300 Add AsyncResultSetImpl.currentPageSize --- .../org/apache/ignite/internal/sql/api/AsyncResultSetImpl.java | 10 ++++++++++ 1 file changed, 10 insertions(+) diff --git a/modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/api/AsyncResultSetImpl.java b/modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/api/AsyncResultSetImpl.java index 2c363696f..726a865fb 100644 --- a/modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/api/AsyncResultSetImpl.java +++ b/modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/api/AsyncResultSetImpl.java @@ -126,6 +126,16 @@ public class AsyncResultSetImpl implements AsyncResultSet { return () -> new TransformingIterator<>(batchPage.items().iterator(), SqlRowImpl::new); } + /** {@inheritDoc} */ + @Override + public int currentPageSize() { + if (!hasRowSet()) { + throw new NoRowSetExpectedException("Query hasn't result set: [type=" + cur.queryType() + ']'); + } + + return batchPage.items().size(); + } + /** {@inheritDoc} */ @Override public CompletionStage<? extends AsyncResultSet> fetchNextPage() {
