com.spotify.flo.contrib.bigquery

Class BigQueryMocking

java.lang.Object

com.spotify.flo.contrib.bigquery.BigQueryMocking

public class BigQueryMocking
extends Object

Method Summary

Modifier and Type	Method and Description
void	dataset(com.google.cloud.bigquery.DatasetId datasetId)
void	dataset(String project, String dataset)
void	dataset(com.google.cloud.bigquery.TableId tableId)
static BigQueryMocking	mock() Get a BigQueryMocking instance to be used for mocking bigquery tables and checking tables outputed by a task output.
void	stagingTableId(com.google.cloud.bigquery.TableId finalTableId, com.google.cloud.bigquery.TableId stagingTableId)
void	table(String project, String dataset, String table)
void	table(com.google.cloud.bigquery.TableId tableId)
boolean	tableExists(String project, String dataset, String table)
boolean	tableExists(com.google.cloud.bigquery.TableId tableId)
boolean	tablePublished(String project, String dataset, String table)
boolean	tablePublished(com.google.cloud.bigquery.TableId tableId)

Methods inherited from class java.lang.Object

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

Method Detail

mock

public static BigQueryMocking mock()

Get a BigQueryMocking instance to be used for mocking bigquery tables and checking tables outputed by a task output. Must be called in a flo test scope.

tableExists

public boolean tableExists(com.google.cloud.bigquery.TableId tableId)

tableExists

public boolean tableExists(String project,
                           String dataset,
                           String table)

tablePublished

public boolean tablePublished(String project,
                              String dataset,
                              String table)

tablePublished

public boolean tablePublished(com.google.cloud.bigquery.TableId tableId)

dataset

public void dataset(String project,
                    String dataset)

dataset

public void dataset(com.google.cloud.bigquery.TableId tableId)

dataset

public void dataset(com.google.cloud.bigquery.DatasetId datasetId)

table

public void table(String project,
                  String dataset,
                  String table)

table

public void table(com.google.cloud.bigquery.TableId tableId)

stagingTableId

public void stagingTableId(com.google.cloud.bigquery.TableId finalTableId,
                           com.google.cloud.bigquery.TableId stagingTableId)