public class ReactiveRowMapperResultSetExtractor<T> extends Object implements ReactiveResultSetExtractor<T>
ReactiveResultSetExtractorinterface that delegates to a
RowMapperwhich is supposed to create an object for each row. Each object is emitted through the
Useful for the typical case of one object per row in the database table. The number of entries in the results will match the number of rows.
Note that a
RowMapper object is typically stateless and thus reusable.
|Constructor and Description|
Create a new
|Modifier and Type||Method and Description|
Implementations must implement this method to process the entire
public org.reactivestreams.Publisher<T> extractData(ReactiveResultSet resultSet) throws com.datastax.oss.driver.api.core.DriverException, DataAccessException
ReactiveResultSetto extract data from, must not be null.
com.datastax.oss.driver.api.core.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–2021 Pivotal Software, Inc.. All rights reserved.