本文整理了Java中com.datastax.driver.core.ResultSet.spliterator方法的一些代码示例，展示了ResultSet.spliterator的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。ResultSet.spliterator方法的具体详情如下：
包路径：com.datastax.driver.core.ResultSet
类名称：ResultSet
方法名：spliterator

ResultSet.spliterator介绍

暂无

代码示例

代码示例来源：origin: org.springframework.data/spring-data-cassandra

@Override
  @Nullable
  public Object extractData(ResultSet resultSet) {
    StreamSupport.stream(resultSet.spliterator(), false).forEach(rowCallbackHandler::processRow);
    return null;
  }
}

代码示例来源：origin: org.apache.james/apache-james-backends-cassandra

public Stream<Row> convertToStream(ResultSet resultSet) {
  return StreamSupport.stream(resultSet.spliterator(), true)
    .peek(row -> ensureFetchedNextPage(resultSet));
}

代码示例来源：origin: apache/james-project

public Stream<Row> convertToStream(ResultSet resultSet) {
  return StreamSupport.stream(resultSet.spliterator(), true)
    .peek(row -> ensureFetchedNextPage(resultSet));
}

代码示例来源：origin: org.springframework.data/spring-data-cassandra

@Override
public <T> Stream<T> stream(Statement statement, Class<T> entityClass) throws DataAccessException {
  Assert.notNull(statement, "Statement must not be null");
  Assert.notNull(entityClass, "Entity type must not be null");
  ResultSet resultSet = getCqlOperations().queryForResultSet(statement);
  return StreamSupport.stream(resultSet.spliterator(), false)
      .map(getMapper(entityClass, entityClass, QueryUtils.getTableName(statement)));
}

代码示例来源：origin: apache/attic-polygene-java

@Override
public Stream<EntityState> entityStates( ModuleDescriptor module )
{
  Session session = cluster.cassandraClientSession();
  String tableName = cluster.tableName();
  ResultSet resultSet = session.execute( "SELECT "
                      + IDENTITY_COLUMN + ", "
                      + VERSION_COLUMN + ", "
                      + TYPE_COLUMN + ", "
                      + APP_VERSION_COLUMN + ", "
                      + STORE_VERSION_COLUMN + ", "
                      + LASTMODIFIED_COLUMN + ", "
                      + USECASE_COLUMN + ", "
                      + PROPERTIES_COLUMN + ", "
                      + ASSOCIATIONS_COLUMN + ", "
                      + MANYASSOCIATIONS_COLUMN + ", "
                      + NAMEDASSOCIATIONS_COLUMN
                      + " FROM " + tableName );
  return stream( resultSet.spliterator(), false ).map( row -> deserialize( row, module ) );
}

代码示例来源：origin: org.springframework.data/spring-data-cassandra

<T> Stream<T> doStream(Query query, Class<?> entityClass, CqlIdentifier tableName, Class<T> returnType) {
  RegularStatement statement = getStatementFactory().select(query, getRequiredPersistentEntity(entityClass),
      tableName);
  ResultSet resultSet = getCqlOperations().queryForResultSet(statement);
  return StreamSupport.stream(resultSet.spliterator(), false).map(getMapper(entityClass, returnType, tableName));
}

代码示例来源：origin: tenmax/cqlkit

.stream(rs.spliterator(), false)
.map(this::map)
.forEach(out::println);

代码示例来源：origin: bazaarvoice/emodb

@Timed(name = "bv.emodb.databus.CqlSubscriptionDAO.getAllSubscriptions", absolute = true)
@Override
public Iterable<OwnedSubscription> getAllSubscriptions() {
  return () -> {
    ResultSet resultSet = _keyspace.getCqlSession().execute(
        select(subscriptionNameColumn(), subscriptionColumn())
            .from(CF_NAME)
            .where(eq(rowkeyColumn(), ROW_KEY))
            .setConsistencyLevel(ConsistencyLevel.LOCAL_QUORUM)
            .setFetchSize(200));
    return StreamSupport.stream(resultSet.spliterator(), false).map(this::rowToOwnedSubscription).iterator();
  };
}

代码示例来源：origin: com.bazaarvoice.emodb/emodb-databus

@Timed(name = "bv.emodb.databus.CqlSubscriptionDAO.getAllSubscriptions", absolute = true)
@Override
public Iterable<OwnedSubscription> getAllSubscriptions() {
  return () -> {
    ResultSet resultSet = _keyspace.getCqlSession().execute(
        select(subscriptionNameColumn(), subscriptionColumn())
            .from(CF_NAME)
            .where(eq(rowkeyColumn(), ROW_KEY))
            .setConsistencyLevel(ConsistencyLevel.LOCAL_QUORUM)
            .setFetchSize(200));
    return StreamSupport.stream(resultSet.spliterator(), false).map(this::rowToOwnedSubscription).iterator();
  };
}

代码示例来源：origin: com.bazaarvoice.emodb/emodb-databus

@Timed(name = "bv.emodb.databus.CqlSubscriptionDAO.getAllSubscriptionNames", absolute = true)
@Override
public Iterable<String> getAllSubscriptionNames() {
  return () -> {
    ResultSet resultSet = _keyspace.getCqlSession().execute(
        select(subscriptionNameColumn())
            .from(CF_NAME)
            .where(eq(rowkeyColumn(), ROW_KEY))
            .setConsistencyLevel(ConsistencyLevel.LOCAL_QUORUM)
            .setFetchSize(5000));
    return StreamSupport.stream(resultSet.spliterator(), false).map(row -> row.getString(0)).iterator();
  };
}

代码示例来源：origin: bazaarvoice/emodb

@Timed(name = "bv.emodb.databus.CqlSubscriptionDAO.getAllSubscriptionNames", absolute = true)
@Override
public Iterable<String> getAllSubscriptionNames() {
  return () -> {
    ResultSet resultSet = _keyspace.getCqlSession().execute(
        select(subscriptionNameColumn())
            .from(CF_NAME)
            .where(eq(rowkeyColumn(), ROW_KEY))
            .setConsistencyLevel(ConsistencyLevel.LOCAL_QUORUM)
            .setFetchSize(5000));
    return StreamSupport.stream(resultSet.spliterator(), false).map(row -> row.getString(0)).iterator();
  };
}