Package net.corda.v5.ledger.utxo.query
Interface VaultNamedQueryCollector
-
- All Implemented Interfaces:
public interface VaultNamedQueryCollector<R, T>
A collector that is applied to the result set returned after executing the named query. Null values returned from the collection will be filtered out.
Example usage:
- Kotlin:
class MyVaultNamedQueryCollector : VaultNamedQueryCollector<MyPojo, Int> { override fun collect(resultSet: List<MyPojo>, parameters: Map<String, Any>): VaultNamedQueryCollector.Result<Int> { return VaultNamedQueryCollector.Result(listOf(resultSet.maxOf { it.value }), false) } }
- Java:
public class MyVaultNamedQueryCollector implements VaultNamedQueryCollector<Object, Integer> { public Result<Integer> collect(List<Object> resultSet, Map<String, Object> parameters) { return new VaultNamedQueryCollector.Result<>( List.of( resultSet.stream() .mapToInt(e -> Integer.parseInt(e.toString())) .max() .getAsInt() ), false); } }
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description public class
VaultNamedQueryCollector.Result
Representation of a "collected" result set that also contains a flag that shows whether the result set is finished or there are still elements in the original result set.
-