@Test void testStreamDataPoints() { boolean found[] = new boolean[5]; Iterator<DataPoint> it = INSTANCE.stream().iterator(); while (it.hasNext()) { DataPoint dp = it.next(); for (int i = 0; i < 5; i++) if (new StringValue(STR_ID_VAL[i]).equals(dp.get(STR_ID)) && new IntegerValue(INT_ID_VAL[i]).equals(dp.get(INT_ID))) { ScalarValue<?, ?, ?> intVal = INT_ME_VAL[i] == null ? NullValue.instance(INTEGERDS) : new IntegerValue(INT_ME_VAL[i]); ScalarValue<?, ?, ?> bolVal = BOL_ME_VAL[i] == null ? NullValue.instance(BOOLEANDS) : BooleanValue.of(BOL_ME_VAL[i]); assertEquals(intVal, dp.get(INT_ME)); assertEquals(bolVal, dp.get(BOL_ME)); found[i] = true; } } for (int i = 1; i < 5; i++) assertTrue(found[i], "Datapoint " + i + " not found"); }
@Override protected Stream<DataPoint> streamDataPoints() { return Utils.getStream(nRows) .mapToObj(this::mapIndexToDataPoint); }
ColumnarDataSet extends AbstractDataSet { @Override protected Stream<DataPoint> streamDataPoints() { return Utils.getStream(nRows) .mapToObj(this::mapIndexToDataPoint); } }
ColumnarDataSet extends AbstractDataSet { @Override protected Stream<DataPoint> streamDataPoints() { return Utils.getStream(nRows) .mapToObj(this::mapIndexToDataPoint); } ColumnarDataSet(Map<? extends DataStructureComponent<?, ?, ?>, ScalarValue<?, ?, ?>[]> columns); }
ColumnarDataSet extends AbstractDataSet { @Override protected Stream<DataPoint> streamDataPoints() { return Utils.getStream(nRows) .mapToObj(this::mapIndexToDataPoint); } ColumnarDataSet(Map<? extends DataStructureComponent<?, ?, ?>, ScalarValue<?, ?, ?>[]> columns);  }
ColumnarDataSet extends AbstractDataSet { @Override protected Stream<DataPoint> streamDataPoints() { return Utils.getStream(nRows) .mapToObj(this::mapIndexToDataPoint); } ColumnarDataSet(Map<? extends DataStructureComponent<?, ?, ?>, ScalarValue<?, ?, ?>[]> columns);   }