@FunctionalInterface public interface ReactiveResultSetExtractor<T>
ReactiveCqlTemplate's query methods. Implementations of this interface perform the actual work of extracting results from a
ReactiveResultSet, but don't need to worry about exception handling.
DriverExceptions will be caught and handled by the calling
This interface is mainly used within the CQL framework itself. A
RowMapper is usually a simpler choice for
ReactiveResultSet processing, mapping one result object per row instead of one result object for the entire
ReactiveResultSetExtractor object is typically stateless and thus reusable, as long as it doesn't
access stateful resources or keep result state within the object.
org.reactivestreams.Publisher<T> extractData(ReactiveResultSet resultSet) throws com.datastax.driver.core.exceptions.DriverException, DataAccessException
ReactiveResultSetto extract data from, must not be null.
com.datastax.driver.core.exceptions.DriverException- if a
DriverExceptionis encountered getting column values or navigating (that is, there's no need to catch
DataAccessException- in case of custom exceptions.
Copyright © 2011–2020 Pivotal Software, Inc.. All rights reserved.