org.apache.beam.it.cassandra.matchers

Class CassandraAsserts

java.lang.Object

org.apache.beam.it.cassandra.matchers.CassandraAsserts

public class CassandraAsserts
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
CassandraAsserts()

Method Summary

Modifier and Type	Method and Description
static org.apache.beam.it.truthmatchers.RecordsSubject	assertThatCassandraRecords(java.lang.Iterable<com.datastax.oss.driver.api.core.cql.Row> rows) Creates a RecordsSubject to assert information within a list of records.
static java.util.List<java.util.Map<java.lang.String,java.lang.Object>>	cassandraRowsToRecords(java.lang.Iterable<com.datastax.oss.driver.api.core.cql.Row> rows) Convert Cassandra Row 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

CassandraAsserts

public CassandraAsserts()

Method Detail

cassandraRowsToRecords

public static java.util.List<java.util.Map<java.lang.String,java.lang.Object>> cassandraRowsToRecords(java.lang.Iterable<com.datastax.oss.driver.api.core.cql.Row> rows)

Convert Cassandra Row list to a list of maps.

Parameters:

rows - Rows to parse.

Returns:

List of maps to use in RecordsSubject.

assertThatCassandraRecords

public static org.apache.beam.it.truthmatchers.RecordsSubject assertThatCassandraRecords(java.lang.Iterable<com.datastax.oss.driver.api.core.cql.Row> rows)

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

Parameters:

rows - Records in Cassandra's Row format to use in the comparison.

Returns:

Truth subject to chain assertions on.