org.apache.beam.it.gcp.spanner.matchers

Class SpannerAsserts

java.lang.Object

org.apache.beam.it.gcp.spanner.matchers.SpannerAsserts

public class SpannerAsserts
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
SpannerAsserts()

Method Summary

Modifier and Type	Method and Description
static org.apache.beam.it.truthmatchers.RecordsSubject	assertThatMutations(java.util.List<com.google.cloud.spanner.Mutation> mutations) Creates a RecordsSubject to assert information within a list of records.
static org.apache.beam.it.truthmatchers.RecordsSubject	assertThatStructs(java.util.List<com.google.cloud.spanner.Struct> structs) Creates a RecordsSubject to assert information within a list of records.
static java.util.List<java.util.Map<java.lang.String,java.lang.Object>>	mutationsToRecords(java.util.List<com.google.cloud.spanner.Mutation> mutations) Convert Spanner Mutation list to a list of maps.
static java.util.List<java.util.Map<java.lang.String,java.lang.Object>>	mutationsToRecords(java.util.List<com.google.cloud.spanner.Mutation> mutations, java.util.List<java.lang.String> columns) Convert a list of Spanner Mutation objects into a list of maps, extracting specified columns.
static java.util.List<java.util.Map<java.lang.String,java.lang.Object>>	structsToRecords(java.util.List<com.google.cloud.spanner.Struct> structs) Convert Spanner Struct list to a list of maps.

Methods inherited from class java.lang.Object

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

Constructor Detail

SpannerAsserts

public SpannerAsserts()

Method Detail

structsToRecords

public static java.util.List<java.util.Map<java.lang.String,java.lang.Object>> structsToRecords(java.util.List<com.google.cloud.spanner.Struct> structs)

Convert Spanner Struct list to a list of maps.

Parameters:

structs - Structs to parse

Returns:

List of maps to use in RecordsSubject

mutationsToRecords

public static java.util.List<java.util.Map<java.lang.String,java.lang.Object>> mutationsToRecords(java.util.List<com.google.cloud.spanner.Mutation> mutations)

Convert Spanner Mutation list to a list of maps.

Parameters:

mutations - Mutations to parse

Returns:

List of maps to use in RecordsSubject

mutationsToRecords

public static java.util.List<java.util.Map<java.lang.String,java.lang.Object>> mutationsToRecords(java.util.List<com.google.cloud.spanner.Mutation> mutations,
                                                                                                  java.util.List<java.lang.String> columns)

Convert a list of Spanner Mutation objects into a list of maps, extracting specified columns.

Parameters:

mutations - The list of mutations to process.

columns - The columns to extract.

Returns:

List of maps to use in RecordsSubject

assertThatStructs

public static org.apache.beam.it.truthmatchers.RecordsSubject assertThatStructs(java.util.List<com.google.cloud.spanner.Struct> structs)

Creates a RecordsSubject to assert information within a list of records.

Parameters:

structs - Records in Spanner Struct format to use in the comparison.

Returns:

Truth Subject to chain assertions.

assertThatMutations

public static org.apache.beam.it.truthmatchers.RecordsSubject assertThatMutations(java.util.List<com.google.cloud.spanner.Mutation> mutations)

Creates a RecordsSubject to assert information within a list of records.

Parameters:

mutations - Mutations in Spanner Mutation format to use in the comparison.

Returns:

Truth Subject to chain assertions.