Package org.apache.beam.sdk.testing
Class CombineFnTester
- java.lang.Object
-
- org.apache.beam.sdk.testing.CombineFnTester
-
public class CombineFnTester extends java.lang.Object
Utilities for testingCombineFns
. Ensures that theCombine.CombineFn
gives correct results across various permutations and shardings of the input.
-
-
Constructor Summary
Constructors Constructor Description CombineFnTester()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static <InputT,AccumT,OutputT>
voidtestCombineFn(Combine.CombineFn<InputT,AccumT,OutputT> fn, java.util.List<InputT> input, org.hamcrest.Matcher<? super OutputT> matcher)
static <InputT,AccumT,OutputT>
voidtestCombineFn(Combine.CombineFn<InputT,AccumT,OutputT> fn, java.util.List<InputT> input, OutputT expected)
Tests that theCombine.CombineFn
, when applied to the provided input, produces the provided output.
-
-
-
Method Detail
-
testCombineFn
public static <InputT,AccumT,OutputT> void testCombineFn(Combine.CombineFn<InputT,AccumT,OutputT> fn, java.util.List<InputT> input, OutputT expected)
Tests that theCombine.CombineFn
, when applied to the provided input, produces the provided output. Tests a variety of permutations of the input.
-
testCombineFn
public static <InputT,AccumT,OutputT> void testCombineFn(Combine.CombineFn<InputT,AccumT,OutputT> fn, java.util.List<InputT> input, org.hamcrest.Matcher<? super OutputT> matcher)
-
-