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

ResultSet.forEach介绍

暂无

代码示例

代码示例来源：origin: scalar-labs/scalardb

@Override
@Nonnull
public List<Result> all() {
 List<Result> results = new ArrayList<>();
 resultSet.forEach(r -> results.add(new ResultImpl(r, metadata)));
 return results;
}

代码示例来源：origin: com.github.ddth/ddth-mappings-core

/**
 * {@inheritDoc}
 */
@Override
protected Collection<MappingBo<O, T>> storageGetMappingsTargetObjs(String namespace, T target) {
  Collection<MappingBo<O, T>> result = new HashSet<>();
  ResultSet rs = cqlDelegator.select(pstmSeleteDataMultiple, namespace, DATA_TYPE_TARGET_OBJ,
      serializeTarget(target));
  rs.forEach(row -> result.add(createMappingBo(row)));
  return result;
}

代码示例来源：origin: com.github.ddth/ddth-mappings-core

/**
 * {@inheritDoc}
 */
@Override
protected Collection<MappingBo<O, T>> storageGetMappingsObjTargets(String namespace, O obj) {
  Collection<MappingBo<O, T>> result = new HashSet<>();
  ResultSet rs = cqlDelegator.select(pstmSeleteDataMultiple, namespace, DATA_TYPE_OBJ_TARGET,
      serializeObject(obj));
  rs.forEach(row -> result.add(createMappingBo(row)));
  return result;
}

代码示例来源：origin: com.github.ddth/ddth-mappings-core

/**
 * {@inheritDoc}
 */
@Override
protected Collection<MappingBo<O, T>> storageGetMappingsTargetObjs(String namespace, T target) {
  Collection<MappingBo<O, T>> result = new HashSet<>();
  ResultSet rs = cqlDelegator.select(pstmSeleteTOMulti, namespace, serializeTarget(target));
  rs.forEach(row -> result.add(createMappingBo(row, DATA_TYPE_TARGET_OBJ)));
  return result;
}

代码示例来源：origin: com.github.ddth/ddth-mappings-core

/**
 * Get all stats of a mapping namespace.
 *
 * @param mapping
 * @param namespace
 * @return
 */
public Map<String, Long> getAllStats(String mapping, String namespace) {
  Session session = getSession();
  if (pstmGetAllStats == null) {
    pstmGetAllStats = prepareStatement(session,
        MessageFormat.format(CQL_SELECT_ALL_STATS, tableStats));
  }
  Map<String, Long> result = new HashMap<>();
  ResultSet rs = select(session, pstmGetAllStats, mapping, namespace);
  rs.forEach(row -> result.put(row.getString(COL_KEY), row.getLong(COL_VALUE)));
  return result;
}

代码示例来源：origin: com.github.ddth/ddth-dao-core

/**
 * {@inheritDoc}
 */
@Override
public Map<String, Object> get(String table, String key) {
  String CQL = MessageFormat.format(CQL_SELECT, calcTableName(table));
  ResultSet rs = getSessionManager().execute(CQL, getConsistencyLevelGet(), key);
  if (rs != null) {
    Map<String, byte[]> data = new HashMap<>();
    rs.forEach(row -> {
      String field = row.getString(columnField);
      ByteBuffer value = row.getBytes(columnValue);
      if (value != null) {
        data.put(field, value.array());
      }
    });
    return bytesMapToDocument(data);
  }
  return null;
}

代码示例来源：origin: hawkular/hawkular-metrics

private Map<String,String> getMappingTable() {
  // You only want to prepare the query once. Best to do it when you initialize the session.
  PreparedStatement findMappings = session.prepare(
      "SELECT project_id, project_name " +
          "FROM openshift_metrics.metrics_mappings " +
          "WHERE token(project_id) > ? AND token(project_id) <= ?");
  Map<String,String> mappings = new HashMap<>();
  if (hasMappingTable()) {
    for (TokenRange tokenRange : getTokenRanges()) {
      BoundStatement boundStatement = findMappings.bind().setToken(0, tokenRange.getStart())
          .setToken(1, tokenRange.getEnd());
      ResultSet resultSet = session.execute(boundStatement);
      resultSet.forEach(row -> mappings.put(row.getString(0), row.getString(1)));
    }
  }
  mappings.remove("%succeeded");
  return mappings;
}

代码示例来源：origin: locationtech/geowave

final ResultSet results = getSession().execute(statement);
final Map<ByteArray, GeoWaveRow> resultsMap = new HashMap<>();
results.forEach(r -> {
 final byte[] d = r.getBytes(CassandraField.GW_PARTITION_ID_KEY.getFieldName()).array();
 final byte[] v = r.getBytes(CassandraField.GW_VALUE_KEY.getFieldName()).array();