Package org.apache.beam.sdk.testing

Class SerializableMatchers

java.lang.Object

org.apache.beam.sdk.testing.SerializableMatchers

All Implemented Interfaces:

Serializable

public class SerializableMatchers
extends Object
implements Serializable

Static class for building and using SerializableMatcher instances.

Most matchers are wrappers for hamcrest's Matchers. Please be familiar with the documentation there. Values retained by a SerializableMatcher are required to be serializable, either via Java serialization or via a provided Coder.

The following matchers are novel to Apache Beam:

• kvWithKey(K) for matching just the key of a KV.
• kvWithValue(V) for matching just the value of a KV.
• kv(org.apache.beam.sdk.testing.SerializableMatcher<? super K>, org.apache.beam.sdk.testing.SerializableMatcher<? super V>) for matching the key and value of a KV.

For example, to match a group from GroupByKey, which has type KV<K, Iterable<V>> for some K and V and where the order of the iterable is undefined, use a matcher like kv(equalTo("some key"), containsInAnyOrder(1, 2, 3)).

See Also:

• Serialized Form

Method Summary

Modifier and Type	Method	Description
static <T> SerializableMatcher<T>	allOf(Iterable<SerializableMatcher<? super T>> serializableMatchers)	A SerializableMatcher with identical criteria to Matchers.allOf(Iterable).
static <T> SerializableMatcher<T>	allOf(SerializableMatcher<T>... matchers)	A SerializableMatcher with identical criteria to Matchers.allOf(Matcher[]).
static <T> SerializableMatcher<T>	anyOf(Iterable<SerializableMatcher<? super T>> serializableMatchers)	A SerializableMatcher with identical criteria to Matchers.anyOf(Iterable).
static <T> SerializableMatcher<T>	anyOf(SerializableMatcher<T>... matchers)	A SerializableMatcher with identical criteria to Matchers.anyOf(Matcher[]).
static SerializableMatcher<Object>	anything()	A SerializableMatcher with identical criteria to Matchers.anything().
static <T> SerializableMatcher<T[]>	arrayContaining(List<SerializableMatcher<? super T>> serializableMatchers)	A SerializableMatcher with identical criteria to Matchers.arrayContaining(List).
static <T> SerializableMatcher<T[]>	arrayContaining(Coder<T> coder, T... items)	A SerializableMatcher with identical criteria to Matchers.arrayContaining(Object[]).
static <T> SerializableMatcher<T[]>	arrayContaining(SerializableMatcher<? super T>... matchers)	A SerializableMatcher with identical criteria to Matchers.arrayContaining(Matcher[]).
static <T extends Serializable> SerializableMatcher<T[]>	arrayContaining(T... items)	A SerializableMatcher with identical criteria to Matchers.arrayContaining(Object[]).
static <T> SerializableMatcher<T[]>	arrayContainingInAnyOrder(Collection<SerializableMatcher<? super T>> serializableMatchers)	A SerializableMatcher with identical criteria to Matchers.arrayContainingInAnyOrder(Collection).
static <T> SerializableMatcher<T[]>	arrayContainingInAnyOrder(Coder<T> coder, T... items)	A SerializableMatcher with identical criteria to Matchers.arrayContainingInAnyOrder(Object[]).
static <T> SerializableMatcher<T[]>	arrayContainingInAnyOrder(SerializableMatcher<? super T>... matchers)	A SerializableMatcher with identical criteria to Matchers.arrayContainingInAnyOrder(Matcher[]).
static <T extends Serializable> SerializableMatcher<T[]>	arrayContainingInAnyOrder(T... items)	A SerializableMatcher with identical criteria to Matchers.arrayContainingInAnyOrder(Object[]).
static <T> SerializableMatcher<T[]>	arrayWithSize(int size)	A SerializableMatcher with identical criteria to Matchers.arrayWithSize(int).
static <T> SerializableMatcher<T[]>	arrayWithSize(SerializableMatcher<? super Integer> sizeMatcher)	A SerializableMatcher with identical criteria to Matchers.arrayWithSize(Matcher).
static SerializableMatcher<Double>	closeTo(double target, double error)	A SerializableMatcher with identical criteria to Matchers.closeTo(double,double).
static <T extends Serializable> SerializableMatcher<Iterable<? extends T>>	contains(List<SerializableMatcher<? super T>> serializableMatchers)	A SerializableMatcher with identical criteria to Matchers.contains(List).
static <T> SerializableMatcher<Iterable<? extends T>>	contains(Coder<T> coder, T... items)	A SerializableMatcher with identical criteria to Matchers.contains(Object[]).
static <T> SerializableMatcher<Iterable<? extends T>>	contains(SerializableMatcher<? super T>... matchers)	A SerializableMatcher with identical criteria to Matchers.contains(Matcher[]).
static <T extends Serializable> SerializableMatcher<Iterable<? extends T>>	contains(T... items)	A SerializableMatcher with identical criteria to Matchers.contains(Object[]).
static <T> SerializableMatcher<Iterable<? extends T>>	containsInAnyOrder(Collection<SerializableMatcher<? super T>> serializableMatchers)	A SerializableMatcher with identical criteria to Matchers.containsInAnyOrder(Collection).
static <T> SerializableMatcher<Iterable<? extends T>>	containsInAnyOrder(Coder<T> coder, T... items)	A SerializableMatcher with identical criteria to Matchers.containsInAnyOrder(Object[]).
static <T> SerializableMatcher<Iterable<? extends T>>	containsInAnyOrder(SerializableMatcher<? super T>... matchers)	A SerializableMatcher with identical criteria to Matchers.containsInAnyOrder(Matcher[]).
static <T extends Serializable> SerializableMatcher<Iterable<? extends T>>	containsInAnyOrder(T... items)	A SerializableMatcher with identical criteria to Matchers.containsInAnyOrder(Object[]).
static SerializableMatcher<String>	containsString(String substring)	A SerializableMatcher with identical criteria to Matchers.containsString(java.lang.String).
static <T> SerializableMatcher<Collection<? extends T>>	empty()	A SerializableMatcher with identical criteria to Matchers.empty().
static <T> SerializableMatcher<T[]>	emptyArray()	A SerializableMatcher with identical criteria to Matchers.emptyArray().
static <T> SerializableMatcher<Iterable<? extends T>>	emptyIterable()	A SerializableMatcher with identical criteria to Matchers.emptyIterable().
static SerializableMatcher<String>	endsWith(String substring)	A SerializableMatcher with identical criteria to Matchers.endsWith(java.lang.String).
static <T> SerializableMatcher<T>	equalTo(Coder<T> coder, T expected)	A SerializableMatcher with identical criteria to Matchers.equalTo(Object).
static <T extends Serializable> SerializableMatcher<T>	equalTo(T expected)	A SerializableMatcher with identical criteria to Matchers.equalTo(Object).
static <T> SerializableMatcher<T>	fromSupplier(org.apache.beam.sdk.util.SerializableSupplier<Matcher<T>> supplier)	Constructs a SerializableMatcher from a non-serializable Matcher via indirection through SerializableSupplier.
static <T extends Comparable<T> & Serializable> SerializableMatcher<T>	greaterThan(Coder<T> coder, T target)	A SerializableMatcher with identical criteria to Matchers.greaterThan(Comparable).
static <T extends Comparable<T> & Serializable> SerializableMatcher<T>	greaterThan(T target)	A SerializableMatcher with identical criteria to Matchers.greaterThan(Comparable).
static <T extends Comparable<T> & Serializable> SerializableMatcher<T>	greaterThanOrEqualTo(Coder<T> coder, T target)	A SerializableMatcher with identical criteria to Matchers.greaterThanOrEqualTo(Comparable).
static <T extends Comparable<T>> SerializableMatcher<T>	greaterThanOrEqualTo(T target)	A SerializableMatcher with identical criteria to Matchers.greaterThanOrEqualTo(Comparable).
static <T> SerializableMatcher<Iterable<? super T>>	hasItem(Coder<T> coder, T target)	A SerializableMatcher with identical criteria to Matchers.hasItem(Object).
static <T> SerializableMatcher<Iterable<? super T>>	hasItem(SerializableMatcher<? super T> matcher)	A SerializableMatcher with identical criteria to Matchers.hasItem(Matcher).
static <T extends Serializable> SerializableMatcher<Iterable<? super T>>	hasItem(T target)	A SerializableMatcher with identical criteria to Matchers.hasItem(Object).
static <T> SerializableMatcher<Collection<? extends T>>	hasSize(int size)	A SerializableMatcher with identical criteria to Matchers.hasSize(int).
static <T> SerializableMatcher<Collection<? extends T>>	hasSize(SerializableMatcher<? super Integer> sizeMatcher)	A SerializableMatcher with identical criteria to Matchers.hasSize(Matcher).
static <T extends Serializable> SerializableMatcher<T>	isIn(Collection<T> collection)	A SerializableMatcher with identical criteria to Matchers.isIn(Collection).
static <T> SerializableMatcher<T>	isIn(Coder<T> coder, Collection<T> collection)	A SerializableMatcher with identical criteria to Matchers.isIn(Collection).
static <T> SerializableMatcher<T>	isIn(Coder<T> coder, T[] items)	A SerializableMatcher with identical criteria to Matchers.isIn(Object[]).
static <T extends Serializable> SerializableMatcher<T>	isIn(T[] items)	A SerializableMatcher with identical criteria to Matchers.isIn(Object[]).
static <T> SerializableMatcher<T>	isOneOf(Coder<T> coder, T... items)	A SerializableMatcher with identical criteria to Matchers.isOneOf(T...).
static <T extends Serializable> SerializableMatcher<T>	isOneOf(T... elems)	A SerializableMatcher with identical criteria to Matchers.isOneOf(T...).
static <T> SerializableMatcher<Iterable<T>>	iterableWithSize(int size)	A SerializableMatcher with identical criteria to Matchers.iterableWithSize(int).
static <T> SerializableMatcher<Iterable<T>>	iterableWithSize(SerializableMatcher<? super Integer> sizeMatcher)	A SerializableMatcher with identical criteria to Matchers.iterableWithSize(Matcher).
static <K, V> SerializableMatcher<KV<? extends K,? extends V>>	kv(SerializableMatcher<? super K> keyMatcher, SerializableMatcher<? super V> valueMatcher)	A SerializableMatcher that matches any KV with matching key and value.
static <K extends Serializable, V> SerializableMatcher<KV<? extends K,? extends V>>	kvWithKey(K key)	A SerializableMatcher that matches any KV with the specified key.
static <K, V> SerializableMatcher<KV<? extends K,? extends V>>	kvWithKey(Coder<K> coder, K key)	A SerializableMatcher that matches any KV with the specified key.
static <K, V> SerializableMatcher<KV<? extends K,? extends V>>	kvWithKey(SerializableMatcher<? super K> keyMatcher)	A SerializableMatcher that matches any KV with matching key.
static <K, V> SerializableMatcher<KV<? extends K,? extends V>>	kvWithValue(Coder<V> coder, V value)	A SerializableMatcher that matches any KV with the specified value.
static <K, V> SerializableMatcher<KV<? extends K,? extends V>>	kvWithValue(SerializableMatcher<? super V> valueMatcher)	A SerializableMatcher that matches any KV with matching value.
static <K, V extends Serializable> SerializableMatcher<KV<? extends K,? extends V>>	kvWithValue(V value)	A SerializableMatcher that matches any KV with the specified value.
static <T extends Comparable<T>> SerializableMatcher<T>	lessThan(Coder<T> coder, T target)	A SerializableMatcher with identical criteria to Matchers.lessThan(Comparable).
static <T extends Comparable<T> & Serializable> SerializableMatcher<T>	lessThan(T target)	A SerializableMatcher with identical criteria to Matchers.lessThan(Comparable).
static <T extends Comparable<T>> SerializableMatcher<T>	lessThanOrEqualTo(Coder<T> coder, T target)	A SerializableMatcher with identical criteria to Matchers.lessThanOrEqualTo(Comparable).
static <T extends Comparable<T> & Serializable> SerializableMatcher<T>	lessThanOrEqualTo(T target)	A SerializableMatcher with identical criteria to Matchers.lessThanOrEqualTo(Comparable).
static <T> SerializableMatcher<T>	not(SerializableMatcher<T> matcher)	A SerializableMatcher with identical criteria to Matchers.not(org.hamcrest.Matcher<T>).
static SerializableMatcher<Object>	nullValue()	A SerializableMatcher with identical criteria to Matchers.nullValue().
static SerializableMatcher<String>	startsWith(String substring)	A SerializableMatcher with identical criteria to Matchers.startsWith(java.lang.String).

Methods inherited from class java.lang.Object

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

Method Details

allOf

public static <T> SerializableMatcher<T> allOf(Iterable<SerializableMatcher<? super T>> serializableMatchers)

A SerializableMatcher with identical criteria to Matchers.allOf(Iterable).

allOf

@SafeVarargs
public static <T> SerializableMatcher<T> allOf(SerializableMatcher<T>... matchers)

A SerializableMatcher with identical criteria to Matchers.allOf(Matcher[]).

anyOf

public static <T> SerializableMatcher<T> anyOf(Iterable<SerializableMatcher<? super T>> serializableMatchers)

A SerializableMatcher with identical criteria to Matchers.anyOf(Iterable).

anyOf

@SafeVarargs
public static <T> SerializableMatcher<T> anyOf(SerializableMatcher<T>... matchers)

A SerializableMatcher with identical criteria to Matchers.anyOf(Matcher[]).

anything

public static SerializableMatcher<Object> anything()

A SerializableMatcher with identical criteria to Matchers.anything().

arrayContaining

@SafeVarargs
public static <T extends Serializable>
SerializableMatcher<T[]> arrayContaining(T... items)

A SerializableMatcher with identical criteria to Matchers.arrayContaining(Object[]).

arrayContaining

@SafeVarargs
public static <T> SerializableMatcher<T[]> arrayContaining(Coder<T> coder,
 T... items)

A SerializableMatcher with identical criteria to Matchers.arrayContaining(Object[]).

The items of type T will be serialized using the provided Coder. They are explicitly not required or expected to be serializable via Java serialization.

arrayContaining

@SafeVarargs
public static <T> SerializableMatcher<T[]> arrayContaining(SerializableMatcher<? super T>... matchers)

A SerializableMatcher with identical criteria to Matchers.arrayContaining(Matcher[]).

arrayContaining

public static <T> SerializableMatcher<T[]> arrayContaining(List<SerializableMatcher<? super T>> serializableMatchers)

A SerializableMatcher with identical criteria to Matchers.arrayContaining(List).

arrayContainingInAnyOrder

@SafeVarargs
public static <T extends Serializable>
SerializableMatcher<T[]> arrayContainingInAnyOrder(T... items)

A SerializableMatcher with identical criteria to Matchers.arrayContainingInAnyOrder(Object[]).

arrayContainingInAnyOrder

@SafeVarargs
public static <T> SerializableMatcher<T[]> arrayContainingInAnyOrder(Coder<T> coder,
 T... items)

A SerializableMatcher with identical criteria to Matchers.arrayContainingInAnyOrder(Object[]).

The items of type T will be serialized using the provided Coder. They are explicitly not required or expected to be serializable via Java serialization.

arrayContainingInAnyOrder

@SafeVarargs
public static <T> SerializableMatcher<T[]> arrayContainingInAnyOrder(SerializableMatcher<? super T>... matchers)

A SerializableMatcher with identical criteria to Matchers.arrayContainingInAnyOrder(Matcher[]).

arrayContainingInAnyOrder

public static <T> SerializableMatcher<T[]> arrayContainingInAnyOrder(Collection<SerializableMatcher<? super T>> serializableMatchers)

A SerializableMatcher with identical criteria to Matchers.arrayContainingInAnyOrder(Collection).

arrayWithSize

public static <T> SerializableMatcher<T[]> arrayWithSize(int size)

A SerializableMatcher with identical criteria to Matchers.arrayWithSize(int).

arrayWithSize

public static <T> SerializableMatcher<T[]> arrayWithSize(SerializableMatcher<? super Integer> sizeMatcher)

A SerializableMatcher with identical criteria to Matchers.arrayWithSize(Matcher).

closeTo

public static SerializableMatcher<Double> closeTo(double target,
 double error)

A SerializableMatcher with identical criteria to Matchers.closeTo(double,double).

contains

@SafeVarargs
public static <T extends Serializable>
SerializableMatcher<Iterable<? extends T>> contains(T... items)

A SerializableMatcher with identical criteria to Matchers.contains(Object[]).

contains

@SafeVarargs
public static <T>
SerializableMatcher<Iterable<? extends T>> contains(Coder<T> coder,
 T... items)

A SerializableMatcher with identical criteria to Matchers.contains(Object[]).

The items of type T will be serialized using the provided Coder. They are explicitly not required or expected to be serializable via Java serialization.

contains

@SafeVarargs
public static <T>
SerializableMatcher<Iterable<? extends T>> contains(SerializableMatcher<? super T>... matchers)

A SerializableMatcher with identical criteria to Matchers.contains(Matcher[]).

contains

public static <T extends Serializable>
SerializableMatcher<Iterable<? extends T>> contains(List<SerializableMatcher<? super T>> serializableMatchers)

A SerializableMatcher with identical criteria to Matchers.contains(List).

containsInAnyOrder

@SafeVarargs
public static <T extends Serializable>
SerializableMatcher<Iterable<? extends T>> containsInAnyOrder(T... items)

A SerializableMatcher with identical criteria to Matchers.containsInAnyOrder(Object[]).

containsInAnyOrder

@SafeVarargs
public static <T>
SerializableMatcher<Iterable<? extends T>> containsInAnyOrder(Coder<T> coder,
 T... items)

A SerializableMatcher with identical criteria to Matchers.containsInAnyOrder(Object[]).

The items of type T will be serialized using the provided Coder. It is explicitly not required or expected to be serializable via Java serialization.

containsInAnyOrder

@SafeVarargs
public static <T>
SerializableMatcher<Iterable<? extends T>> containsInAnyOrder(SerializableMatcher<? super T>... matchers)

A SerializableMatcher with identical criteria to Matchers.containsInAnyOrder(Matcher[]).

containsInAnyOrder

public static <T>
SerializableMatcher<Iterable<? extends T>> containsInAnyOrder(Collection<SerializableMatcher<? super T>> serializableMatchers)

A SerializableMatcher with identical criteria to Matchers.containsInAnyOrder(Collection).

containsString

public static SerializableMatcher<String> containsString(String substring)

A SerializableMatcher with identical criteria to Matchers.containsString(java.lang.String).

empty

public static <T>
SerializableMatcher<Collection<? extends T>> empty()

A SerializableMatcher with identical criteria to Matchers.empty().

emptyArray

public static <T> SerializableMatcher<T[]> emptyArray()

A SerializableMatcher with identical criteria to Matchers.emptyArray().

emptyIterable

public static <T>
SerializableMatcher<Iterable<? extends T>> emptyIterable()

A SerializableMatcher with identical criteria to Matchers.emptyIterable().

endsWith

public static SerializableMatcher<String> endsWith(String substring)

A SerializableMatcher with identical criteria to Matchers.endsWith(java.lang.String).

equalTo

public static <T extends Serializable>
SerializableMatcher<T> equalTo(T expected)

A SerializableMatcher with identical criteria to Matchers.equalTo(Object).

equalTo

public static <T> SerializableMatcher<T> equalTo(Coder<T> coder,
 T expected)

A SerializableMatcher with identical criteria to Matchers.equalTo(Object).

The expected value of type T will be serialized using the provided Coder. It is explicitly not required or expected to be serializable via Java serialization.

greaterThan

public static <T extends Comparable<T> & Serializable>
SerializableMatcher<T> greaterThan(T target)

A SerializableMatcher with identical criteria to Matchers.greaterThan(Comparable).

greaterThan

public static <T extends Comparable<T> & Serializable>
SerializableMatcher<T> greaterThan(Coder<T> coder,
 T target)

A SerializableMatcher with identical criteria to Matchers.greaterThan(Comparable).

The target value of type T will be serialized using the provided Coder. It is explicitly not required or expected to be serializable via Java serialization.

greaterThanOrEqualTo

public static <T extends Comparable<T>>
SerializableMatcher<T> greaterThanOrEqualTo(T target)

A SerializableMatcher with identical criteria to Matchers.greaterThanOrEqualTo(Comparable).

greaterThanOrEqualTo

public static <T extends Comparable<T> & Serializable>
SerializableMatcher<T> greaterThanOrEqualTo(Coder<T> coder,
 T target)

A SerializableMatcher with identical criteria to Matchers.greaterThanOrEqualTo(Comparable).

The target value of type T will be serialized using the provided Coder. It is explicitly not required or expected to be serializable via Java serialization.

hasItem

public static <T extends Serializable>
SerializableMatcher<Iterable<? super T>> hasItem(T target)

A SerializableMatcher with identical criteria to Matchers.hasItem(Object).

hasItem

public static <T>
SerializableMatcher<Iterable<? super T>> hasItem(Coder<T> coder,
 T target)

A SerializableMatcher with identical criteria to Matchers.hasItem(Object).

The item of type T will be serialized using the provided Coder. It is explicitly not required or expected to be serializable via Java serialization.

hasItem

public static <T>
SerializableMatcher<Iterable<? super T>> hasItem(SerializableMatcher<? super T> matcher)

A SerializableMatcher with identical criteria to Matchers.hasItem(Matcher).

hasSize

public static <T>
SerializableMatcher<Collection<? extends T>> hasSize(int size)

A SerializableMatcher with identical criteria to Matchers.hasSize(int).

hasSize

public static <T>
SerializableMatcher<Collection<? extends T>> hasSize(SerializableMatcher<? super Integer> sizeMatcher)

A SerializableMatcher with identical criteria to Matchers.hasSize(Matcher).

iterableWithSize

public static <T> SerializableMatcher<Iterable<T>> iterableWithSize(int size)

A SerializableMatcher with identical criteria to Matchers.iterableWithSize(int).

iterableWithSize

public static <T> SerializableMatcher<Iterable<T>> iterableWithSize(SerializableMatcher<? super Integer> sizeMatcher)

A SerializableMatcher with identical criteria to Matchers.iterableWithSize(Matcher).

isIn

public static <T extends Serializable>
SerializableMatcher<T> isIn(Collection<T> collection)

A SerializableMatcher with identical criteria to Matchers.isIn(Collection).

isIn

public static <T> SerializableMatcher<T> isIn(Coder<T> coder,
 Collection<T> collection)

A SerializableMatcher with identical criteria to Matchers.isIn(Collection).

The items of type T will be serialized using the provided Coder. They are explicitly not required or expected to be serializable via Java serialization.

isIn

public static <T extends Serializable>
SerializableMatcher<T> isIn(T[] items)

A SerializableMatcher with identical criteria to Matchers.isIn(Object[]).

isIn

public static <T> SerializableMatcher<T> isIn(Coder<T> coder,
 T[] items)

A SerializableMatcher with identical criteria to Matchers.isIn(Object[]).

The items of type T will be serialized using the provided Coder. They are explicitly not required or expected to be serializable via Java serialization.

isOneOf

@SafeVarargs
public static <T extends Serializable>
SerializableMatcher<T> isOneOf(T... elems)

A SerializableMatcher with identical criteria to Matchers.isOneOf(T...).

isOneOf

@SafeVarargs
public static <T> SerializableMatcher<T> isOneOf(Coder<T> coder,
 T... items)

A SerializableMatcher with identical criteria to Matchers.isOneOf(T...).

The items of type T will be serialized using the provided Coder. They are explicitly not required or expected to be serializable via Java serialization.

kvWithKey

public static <K extends Serializable,
V>
SerializableMatcher<KV<? extends K,? extends V>> kvWithKey(K key)

A SerializableMatcher that matches any KV with the specified key.

kvWithKey

public static <K,
V>
SerializableMatcher<KV<? extends K,? extends V>> kvWithKey(Coder<K> coder,
 K key)

A SerializableMatcher that matches any KV with the specified key.

The key of type K will be serialized using the provided Coder. It is explicitly not required or expected to be serializable via Java serialization.

kvWithKey

public static <K,
V>
SerializableMatcher<KV<? extends K,? extends V>> kvWithKey(SerializableMatcher<? super K> keyMatcher)

A SerializableMatcher that matches any KV with matching key.

kvWithValue

public static <K,
V extends Serializable>
SerializableMatcher<KV<? extends K,? extends V>> kvWithValue(V value)

A SerializableMatcher that matches any KV with the specified value.

kvWithValue

public static <K,
V>
SerializableMatcher<KV<? extends K,? extends V>> kvWithValue(Coder<V> coder,
 V value)

A SerializableMatcher that matches any KV with the specified value.

The value of type V will be serialized using the provided Coder. It is explicitly not required or expected to be serializable via Java serialization.

kvWithValue

public static <K,
V>
SerializableMatcher<KV<? extends K,? extends V>> kvWithValue(SerializableMatcher<? super V> valueMatcher)

A SerializableMatcher that matches any KV with matching value.

kv

public static <K,
V>
SerializableMatcher<KV<? extends K,? extends V>> kv(SerializableMatcher<? super K> keyMatcher,
 SerializableMatcher<? super V> valueMatcher)

A SerializableMatcher that matches any KV with matching key and value.

lessThan

public static <T extends Comparable<T> & Serializable>
SerializableMatcher<T> lessThan(T target)

A SerializableMatcher with identical criteria to Matchers.lessThan(Comparable).

lessThan

public static <T extends Comparable<T>>
SerializableMatcher<T> lessThan(Coder<T> coder,
 T target)

A SerializableMatcher with identical criteria to Matchers.lessThan(Comparable).

The target value of type T will be serialized using the provided Coder. It is explicitly not required or expected to be serializable via Java serialization.

lessThanOrEqualTo

public static <T extends Comparable<T> & Serializable>
SerializableMatcher<T> lessThanOrEqualTo(T target)

A SerializableMatcher with identical criteria to Matchers.lessThanOrEqualTo(Comparable).

lessThanOrEqualTo

public static <T extends Comparable<T>>
SerializableMatcher<T> lessThanOrEqualTo(Coder<T> coder,
 T target)

A SerializableMatcher with identical criteria to Matchers.lessThanOrEqualTo(Comparable).

The target value of type T will be serialized using the provided Coder. It is explicitly not required or expected to be serializable via Java serialization.

not

public static <T> SerializableMatcher<T> not(SerializableMatcher<T> matcher)

A SerializableMatcher with identical criteria to Matchers.not(org.hamcrest.Matcher<T>).

nullValue

public static SerializableMatcher<Object> nullValue()

A SerializableMatcher with identical criteria to Matchers.nullValue().

startsWith

public static SerializableMatcher<String> startsWith(String substring)

A SerializableMatcher with identical criteria to Matchers.startsWith(java.lang.String).

fromSupplier

public static <T> SerializableMatcher<T> fromSupplier(org.apache.beam.sdk.util.SerializableSupplier<Matcher<T>> supplier)

Constructs a SerializableMatcher from a non-serializable Matcher via indirection through SerializableSupplier.

To wrap a Matcher which is not serializable, provide a SerializableSupplier with a Supplier.get() method that returns a fresh instance of the Matcher desired. The resulting SerializableMatcher will behave according to the Matcher returned by get() when it is invoked during matching (which may occur on another machine).

 return fromSupplier(new SerializableSupplier<Matcher<T>>() {
   *     @Override
     public Matcher<T> get() {
       return new MyMatcherForT();
     }
 });