org.apache.beam.sdk.io.gcp.testing

Class BigqueryMatcher

java.lang.Object

org.hamcrest.BaseMatcher<T>

org.hamcrest.TypeSafeMatcher<PipelineResult>

org.apache.beam.sdk.io.gcp.testing.BigqueryMatcher

All Implemented Interfaces:

java.io.Serializable, SerializableMatcher<PipelineResult>, Matcher<PipelineResult>, SelfDescribing

@NotThreadSafe
 @Experimental
public class BigqueryMatcher
extends TypeSafeMatcher<PipelineResult>
implements SerializableMatcher<PipelineResult>

A matcher to verify data in BigQuery by processing given query and comparing with content's checksum.

Example:

 [
   assertThat(job, new BigqueryMatcher(appName, projectId, queryString, expectedChecksum));
 ]

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
BigqueryMatcher(java.lang.String applicationName, java.lang.String projectId, java.lang.String query, java.lang.String expectedChecksum)

Method Summary

Modifier and Type	Method and Description
static BigqueryMatcher	createUsingStandardSql(java.lang.String applicationName, java.lang.String projectId, java.lang.String query, java.lang.String expectedChecksum)
void	describeMismatchSafely(PipelineResult pResult, Description description)
void	describeTo(Description description)
protected boolean	matchesSafely(PipelineResult pipelineResult)

Methods inherited from class org.hamcrest.TypeSafeMatcher

describeMismatch, matches

Methods inherited from class org.hamcrest.BaseMatcher

_dont_implement_Matcher___instead_extend_BaseMatcher_, isNotNull, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.hamcrest.Matcher

_dont_implement_Matcher___instead_extend_BaseMatcher_, describeMismatch, matches

Constructor Detail

BigqueryMatcher

public BigqueryMatcher(java.lang.String applicationName,
                       java.lang.String projectId,
                       java.lang.String query,
                       java.lang.String expectedChecksum)

Method Detail

createUsingStandardSql

public static BigqueryMatcher createUsingStandardSql(java.lang.String applicationName,
                                                     java.lang.String projectId,
                                                     java.lang.String query,
                                                     java.lang.String expectedChecksum)

matchesSafely

protected boolean matchesSafely(PipelineResult pipelineResult)

Specified by:

matchesSafely in class TypeSafeMatcher<PipelineResult>

describeTo

public void describeTo(Description description)

Specified by:

describeTo in interface SelfDescribing

describeMismatchSafely

public void describeMismatchSafely(PipelineResult pResult,
                                   Description description)

Overrides:

describeMismatchSafely in class TypeSafeMatcher<PipelineResult>