public class BigtableAsserts
extends java.lang.Object
Constructor and Description |
---|
BigtableAsserts() |
Modifier and Type | Method and Description |
---|---|
static org.apache.beam.it.truthmatchers.RecordsSubject |
assertThatBigtableRecords(java.lang.Iterable<com.google.cloud.bigtable.data.v2.models.Row> rows,
java.lang.String family)
Creates a
RecordsSubject to assert information within a list of records. |
static java.util.List<java.util.Map<java.lang.String,java.lang.Object>> |
bigtableRowsToRecords(java.lang.Iterable<com.google.cloud.bigtable.data.v2.models.Row> rows,
java.lang.String family)
Convert Bigtable
Row to a list of maps. |
public static java.util.List<java.util.Map<java.lang.String,java.lang.Object>> bigtableRowsToRecords(java.lang.Iterable<com.google.cloud.bigtable.data.v2.models.Row> rows, java.lang.String family)
Row
to a list of maps.rows
- Bigtable rows to parse.family
- Bigtable column family to parse from.RecordsSubject
public static org.apache.beam.it.truthmatchers.RecordsSubject assertThatBigtableRecords(java.lang.Iterable<com.google.cloud.bigtable.data.v2.models.Row> rows, java.lang.String family)
RecordsSubject
to assert information within a list of records.rows
- Records in Bigtable's Row
format to use in the comparison.family
- The column family to read records from.