queryByPath method

  1. @override
Stream<KeyEntry<String, AtData, AtMetaData?>> queryByPath({
  1. required KeyPattern keyPattern,
  2. required Predicate predicate,
  3. OrderByKey? orderBy,
  4. int? limit,
  5. int? skip,
})
override

Stream every (key, value, metadata) entry matching keyPattern AND predicate. The predicate is evaluated against the value's JSON-shaped fields.

Backends MUST throw UnsupportedError when called and supportsPathQueries is false. Consumers should gate on the flag before calling.

Implementation

@override
Stream<KeyEntry<String, AtData, AtMetaData?>> queryByPath({
  required KeyPattern keyPattern,
  required Predicate predicate,
  OrderByKey? orderBy,
  int? limit,
  int? skip,
}) {
  throw UnsupportedError(
    'HiveAtKeyValueStore does not support push-down path queries. '
    'Check `supportsPathQueries` before calling; on Hive, fall back '
    'to `scanKeys + getMany + in-memory filter`. A future SQL '
    'backend flips the flag to true and executes the predicate via '
    'indexed `WHERE` clauses.',
  );
}