Package org.apache.beam.sdk.testing

Class CombineFnTester

java.lang.Object

org.apache.beam.sdk.testing.CombineFnTester

public class CombineFnTester
extends Object

Utilities for testing CombineFns. Ensures that the Combine.CombineFn gives correct results across various permutations and shardings of the input.

Constructor Summary

Constructors

Constructor	Description
CombineFnTester()

Method Summary

Modifier and Type	Method	Description
static <InputT, AccumT, OutputT> void	testCombineFn(Combine.CombineFn<InputT,AccumT,OutputT> fn, List<InputT> input, Matcher<? super OutputT> matcher)
static <InputT, AccumT, OutputT> void	testCombineFn(Combine.CombineFn<InputT,AccumT,OutputT> fn, List<InputT> input, OutputT expected)	Tests that the Combine.CombineFn, when applied to the provided input, produces the provided output.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

CombineFnTester

public CombineFnTester()

Method Details

testCombineFn

public static <InputT,
AccumT,
OutputT> void testCombineFn(Combine.CombineFn<InputT,AccumT,OutputT> fn,
 List<InputT> input,
 OutputT expected)

Tests that the Combine.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,
 List<InputT> input,
 Matcher<? super OutputT> matcher)