public class AsyncRowMapperResultSetExtractor<T> extends Object implements AsyncResultSetExtractor<List<T>>
ResultSetExtractor
interface that delegates to a RowMapper
which is
supposed to create an object for each row. Each object is added to the results List of this
ResultSetExtractor
.
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.
RowMapper
,
AsyncCqlTemplate
Constructor and Description |
---|
AsyncRowMapperResultSetExtractor(RowMapper<T> rowMapper)
Create a new
AsyncRowMapperResultSetExtractor . |
Modifier and Type | Method and Description |
---|---|
ListenableFuture<List<T>> |
extractData(com.datastax.oss.driver.api.core.cql.AsyncResultSet resultSet)
Implementations must implement this method to process the entire
AsyncResultSet . |
public AsyncRowMapperResultSetExtractor(RowMapper<T> rowMapper)
AsyncRowMapperResultSetExtractor
.rowMapper
- the RowMapper
which creates an object for each row, must not be null.public ListenableFuture<List<T>> extractData(com.datastax.oss.driver.api.core.cql.AsyncResultSet resultSet) throws com.datastax.oss.driver.api.core.DriverException, DataAccessException
AsyncResultSetExtractor
AsyncResultSet
.extractData
in interface AsyncResultSetExtractor<List<T>>
resultSet
- AsyncResultSet
to extract data from.com.datastax.oss.driver.api.core.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 exceptionsCopyright © 2011–2021 Pivotal Software, Inc.. All rights reserved.