@Test @SuppressWarnings("unchecked") public void testComputeWithCtx3() { wrapper.computeWithCtx((ctx, data) -> { assertNotNull(ctx); assertNotNull(data); }); verify(dataset, times(1)).computeWithCtx(any(IgniteTriFunction.class), any(IgniteBinaryOperator.class), any()); }
@Override public <R> R computeWithCtx(IgniteTriFunction<C, D, LearningEnvironment, R> map, IgniteBinaryOperator<R> reduce, R identity) { return delegate.computeWithCtx(map, reduce, identity); }
DatasetWrapper implements Dataset<C, D> { @Override public <R> R computeWithCtx(IgniteTriFunction<C, D, LearningEnvironment, R> map, IgniteBinaryOperator<R> reduce, R identity) { return delegate.computeWithCtx(map, reduce, identity); } }
DatasetWrapper implements Dataset<C, D> { @Override public <R> R computeWithCtx(IgniteTriFunction<C, D, LearningEnvironment, R> map, IgniteBinaryOperator<R> reduce, R identity) { return delegate.computeWithCtx(map, reduce, identity); } DatasetWrapper(Dataset<C, D> delegate); }
DatasetWrapper implements Dataset<C, D> { @Override public <R> R computeWithCtx(IgniteTriFunction<C, D, LearningEnvironment, R> map, IgniteBinaryOperator<R> reduce, R identity) { return delegate.computeWithCtx(map, reduce, identity); } DatasetWrapper(Dataset<C, D> delegate); @Override R computeWithCtx(IgniteTriFunction<C, D, LearningEnvironment, R> map, IgniteBinaryOperator<R> reduce,
        R identity); @Override R compute(IgniteBiFunction<D, LearningEnvironment, R> map, IgniteBinaryOperator<R> reduce, R identity); @Override void close(); }
DatasetWrapper implements Dataset<C, D> { @Override public <R> R computeWithCtx(IgniteTriFunction<C, D, LearningEnvironment, R> map, IgniteBinaryOperator<R> reduce, R identity) { return delegate.computeWithCtx(map, reduce, identity); } DatasetWrapper(Dataset<C, D> delegate); @Override R computeWithCtx(IgniteTriFunction<C, D, LearningEnvironment, R> map, IgniteBinaryOperator<R> reduce,
        R identity); @Override R compute(IgniteBiFunction<D, LearningEnvironment, R> map, IgniteBinaryOperator<R> reduce, R identity); @Override void close();  }