@Test
public void testAsDataStream() {

    VectorGeneratorsFamily family = new VectorGeneratorsFamily.Builder()
        .add(() -> VectorUtils.of(0.))
        .add(() -> VectorUtils.of(1.))
        .add(() -> VectorUtils.of(2.))
        .build(0L);
    family.asDataStream().labeled().limit(100).forEach(v -> {
        assertEquals(v.features().get(0), v.label(), 1e-7);
    });
}