Package org.apache.ignite.table.criteria
Interface CriteriaQuerySource<T>
- Type Parameters:
T
- The type of elements returned by iterator.
- All Known Subinterfaces:
KeyValueView<K,
,V> RecordView<R>
public interface CriteriaQuerySource<T>
Represents an entity that can be used to execute predicate-based criteria queries.
-
Method Summary
Modifier and TypeMethodDescriptionquery
(@Nullable Transaction tx, @Nullable Criteria criteria) Executes predicate-based criteria query.query
(@Nullable Transaction tx, @Nullable Criteria criteria, @Nullable String indexName) Executes predicate-based criteria query.query
(@Nullable Transaction tx, @Nullable Criteria criteria, @Nullable String indexName, @Nullable CriteriaQueryOptions opts) Executes a predicate-based criteria query.default CompletableFuture<AsyncCursor<T>>
queryAsync
(@Nullable Transaction tx, @Nullable Criteria criteria) Executes a predicate-based criteria query in an asynchronous way.default CompletableFuture<AsyncCursor<T>>
queryAsync
(@Nullable Transaction tx, @Nullable Criteria criteria, @Nullable String indexName) Executes a predicate-based criteria query in an asynchronous way.queryAsync
(@Nullable Transaction tx, @Nullable Criteria criteria, @Nullable String indexName, @Nullable CriteriaQueryOptions opts) Executes a predicate-based criteria query in an asynchronous way.
-
Method Details
-
query
Executes predicate-based criteria query.- Parameters:
tx
- Transaction to execute the query within ornull
to run within implicit transaction.criteria
- The predicate to filter entries ornull
to return all entries from the underlying table.- Returns:
- Iterator with query results.
- Throws:
CriteriaException
- If failed.
-
query
default Cursor<T> query(@Nullable @Nullable Transaction tx, @Nullable @Nullable Criteria criteria, @Nullable @Nullable String indexName) Executes predicate-based criteria query.- Parameters:
tx
- Transaction to execute the query within ornull
to run within implicit transaction.criteria
- The predicate to filter entries ornull
to return all entries from the underlying table.indexName
- The name of the index to force usage in the query ornull
to use the default.- Returns:
- Iterator with query results.
- Throws:
CriteriaException
- If failed.
-
query
Cursor<T> query(@Nullable @Nullable Transaction tx, @Nullable @Nullable Criteria criteria, @Nullable @Nullable String indexName, @Nullable @Nullable CriteriaQueryOptions opts) Executes a predicate-based criteria query.- Parameters:
tx
- Transaction to execute the query within ornull
to run within implicit transaction.criteria
- The predicate to filter entries ornull
to return all entries from the underlying table.indexName
- The name of the index to force usage in the query ornull
to use the default.opts
- Criteria query options ornull
to use default.- Returns:
- Iterator with query results.
- Throws:
CriteriaException
- If failed.
-
queryAsync
default CompletableFuture<AsyncCursor<T>> queryAsync(@Nullable @Nullable Transaction tx, @Nullable @Nullable Criteria criteria) Executes a predicate-based criteria query in an asynchronous way.- Parameters:
tx
- Transaction to execute the query within ornull
to run within implicit transaction.criteria
- The predicate to filter entries ornull
to return all entries from the underlying table.- Returns:
- Future that represents the pending completion of the operation.
- Throws:
CriteriaException
- If failed.
-
queryAsync
default CompletableFuture<AsyncCursor<T>> queryAsync(@Nullable @Nullable Transaction tx, @Nullable @Nullable Criteria criteria, @Nullable @Nullable String indexName) Executes a predicate-based criteria query in an asynchronous way.- Parameters:
tx
- Transaction to execute the query within ornull
to run within implicit transaction.criteria
- The predicate to filter entries ornull
to return all entries from the underlying table.indexName
- The name of the index to force usage in the query ornull
to use the default.- Returns:
- Future that represents the pending completion of the operation.
- Throws:
CriteriaException
- If failed.
-
queryAsync
CompletableFuture<AsyncCursor<T>> queryAsync(@Nullable @Nullable Transaction tx, @Nullable @Nullable Criteria criteria, @Nullable @Nullable String indexName, @Nullable @Nullable CriteriaQueryOptions opts) Executes a predicate-based criteria query in an asynchronous way.- Parameters:
tx
- Transaction to execute the query within ornull
to run within implicit transaction.criteria
- The predicate to filter entries ornull
to return all entries from the underlying table.indexName
- The name of the index to force usage in the query ornull
to use the default.opts
- Criteria query options ornull
to use default.- Returns:
- Future that represents the pending completion of the operation.
- Throws:
CriteriaException
- If failed.
-