@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.
DriverException
s will be caught and handled by the calling ReactiveCqlTemplate
.
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
ReactiveResultSet
.
Note: ReactiveResultSetExtractor
object is typically stateless and thus reusable, as long as it doesn't
access stateful resources or keep result state within the object.
ReactiveCqlTemplate
,
RowCallbackHandler
,
RowMapper
Modifier and Type | Method and Description |
---|---|
org.reactivestreams.Publisher<T> |
extractData(ReactiveResultSet resultSet)
Implementations must implement this method to process the entire
ReactiveResultSet . |
org.reactivestreams.Publisher<T> extractData(ReactiveResultSet resultSet) throws com.datastax.driver.core.exceptions.DriverException, DataAccessException
ReactiveResultSet
.resultSet
- ReactiveResultSet
to extract data from, must not be null.Publisher
.com.datastax.driver.core.exceptions.DriverException
- if a DriverException
is encountered getting column values or navigating (that is,
there's no need to catch DriverException
).DataAccessException
- in case of custom exceptions.Copyright © 2011–2019 Pivotal Software, Inc.. All rights reserved.