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 testing CombineFns. Ensures that the Combine.CombineFn gives correct results across various permutations and shardings of the input.

Constructor Summary

Constructors

Constructor and Description
CombineFnTester()

Method Summary

Modifier and Type	Method and Description
static <InputT,AccumT,OutputT> void	testCombineFn(Combine.CombineFn<InputT,AccumT,OutputT> fn, java.util.List<InputT> input, Matcher<? super OutputT> matcher)
static <InputT,AccumT,OutputT> void	testCombineFn(Combine.CombineFn<InputT,AccumT,OutputT> fn, java.util.List<InputT> input, OutputT expected) Tests that the 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 Detail

CombineFnTester

public CombineFnTester()

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