org.apache.beam.it.gcp.bigquery.conditions

Class BigQueryRowsCheck

java.lang.Object

org.apache.beam.it.conditions.ConditionCheck

org.apache.beam.it.gcp.bigquery.conditions.BigQueryRowsCheck

All Implemented Interfaces:

java.util.function.Supplier<java.lang.Boolean>

public abstract class BigQueryRowsCheck
extends ConditionCheck

ConditionCheck to validate if BigQuery has received a certain number of rows.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	BigQueryRowsCheck.Builder Builder for BigQueryRowsCheck.

Nested classes/interfaces inherited from class org.apache.beam.it.conditions.ConditionCheck

ConditionCheck.CheckResult

Constructor Summary

Constructors

Constructor and Description
BigQueryRowsCheck()

Method Summary

Modifier and Type	Method and Description
static BigQueryRowsCheck.Builder	builder(BigQueryResourceManager resourceManager, com.google.cloud.bigquery.TableId tableId)
ConditionCheck.CheckResult	check()
java.lang.String	getDescription()
java.lang.Long	getRowCount()

Methods inherited from class org.apache.beam.it.conditions.ConditionCheck

and, get

Methods inherited from class java.lang.Object

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

Constructor Detail

BigQueryRowsCheck

public BigQueryRowsCheck()

Method Detail

getDescription

public java.lang.String getDescription()

Specified by:

getDescription in class ConditionCheck

check

public ConditionCheck.CheckResult check()

Specified by:

check in class ConditionCheck

builder

public static BigQueryRowsCheck.Builder builder(BigQueryResourceManager resourceManager,
                                                com.google.cloud.bigquery.TableId tableId)

getRowCount

public java.lang.Long getRowCount()