org.apache.beam.it.gcp.artifacts.matchers

Class ArtifactsSubject

java.lang.Object

com.google.common.truth.Subject

org.apache.beam.it.gcp.artifacts.matchers.ArtifactsSubject

public final class ArtifactsSubject
extends com.google.common.truth.Subject

Subject that has assertion operations for artifact lists (GCS files), usually coming from the result of a template.

Nested Class Summary

Nested classes/interfaces inherited from class com.google.common.truth.Subject

com.google.common.truth.Subject.Factory<SubjectT extends com.google.common.truth.Subject,ActualT>

Method Summary

Modifier and Type	Method and Description
org.apache.beam.it.truthmatchers.RecordsSubject	asAvroRecords(Schema schema) Parse artifacts to Avro records to be used for assertions.
org.apache.beam.it.truthmatchers.RecordsSubject	asJsonRecords() Parse artifacts as Json records to be used for assertions.
org.apache.beam.it.truthmatchers.RecordsSubject	asParquetRecords() Parse artifacts to Parquet GenericRecord to be used for assertions.
static java.util.List<java.util.Map<java.lang.String,java.lang.Object>>	genericRecordToRecords(java.util.List<GenericRecord> avroRecords) Convert Avro GenericRecord to a list of maps.
void	hasContent(java.lang.String content) Check if any of the artifacts has a specific content.
void	hasFiles() Check if artifact list has files (is not empty).
void	hasFiles(int expectedFiles) Check if artifact list has a specific number of files.
void	hasHash(java.lang.String hash) Check if any of the artifacts have a specific content hash (using SHA-256).
static com.google.common.truth.Subject.Factory<ArtifactsSubject,java.util.List<Artifact>>	records()

Methods inherited from class com.google.common.truth.Subject

actualCustomStringRepresentation, check, equals, failWithActual, failWithActual, failWithoutActual, hashCode, ignoreCheck, isAnyOf, isEqualTo, isIn, isInstanceOf, isNoneOf, isNotEqualTo, isNotIn, isNotInstanceOf, isNotNull, isNotSameInstanceAs, isNull, isSameInstanceAs, toString

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Method Detail

records

public static com.google.common.truth.Subject.Factory<ArtifactsSubject,java.util.List<Artifact>> records()

hasFiles

public void hasFiles()

Check if artifact list has files (is not empty).

hasFiles

public void hasFiles(int expectedFiles)

Check if artifact list has a specific number of files.

Parameters:

expectedFiles - Expected files

hasContent

public void hasContent(java.lang.String content)

Check if any of the artifacts has a specific content.

Parameters:

content - Content to search for

hasHash

public void hasHash(java.lang.String hash)

Check if any of the artifacts have a specific content hash (using SHA-256).

Parameters:

hash - Content to search for

asAvroRecords

public org.apache.beam.it.truthmatchers.RecordsSubject asAvroRecords(Schema schema)

Parse artifacts to Avro records to be used for assertions.

Parameters:

schema - Avro Schema to use on the conversion.

asParquetRecords

public org.apache.beam.it.truthmatchers.RecordsSubject asParquetRecords()

Parse artifacts to Parquet GenericRecord to be used for assertions.

genericRecordToRecords

public static java.util.List<java.util.Map<java.lang.String,java.lang.Object>> genericRecordToRecords(java.util.List<GenericRecord> avroRecords)

Convert Avro GenericRecord to a list of maps.

Parameters:

avroRecords - Avro Records to parse

Returns:

List of maps to use in RecordsSubject

asJsonRecords

public org.apache.beam.it.truthmatchers.RecordsSubject asJsonRecords()

Parse artifacts as Json records to be used for assertions.