Package primitives contains integration tests for primitives in beam.

Package synthetic contains pipelines for testing synthetic steps and sources.

Package wordcount contains transforms for wordcount.

Package xlang contains integration tests for cross-language transforms.

CheckFilters checks if an integration test is filtered to be skipped, either because the intended runner does not support it, or the test is sickbayed.

GetExpansionAddrs gets all the addresses given to --expansion_addr as a map of label to address.

GetExpansionJars gets all the jars given to --expansion_jar as a map of label to jar location.

NewExpansionServices creates and initializes an ExpansionServices instance.

BigQueryDataset is the name of the dataset to create tables in for BigQuery integration tests.

BigtableInstance is the name of the Bigtable instance to create tables in for Bigtable integration tests.

BootstrapServers is the address of the bootstrap servers for a Kafka cluster, used for Kafka IO tests.

ExpansionAddrs contains elements in the form "label:address" describing endpoints for expansion services to use in integration tests, and the corresponding labels.

ExpansionJars contains elements in the form "label:jar" describing jar filepaths for expansion services to use in integration tests, and the corresponding labels.

ExpansionTimeout attempts to apply an auto-shutdown timeout to any expansion services started by integration tests.

KafkaJar is a filepath to a jar for starting a Kafka cluster, used for Kafka IO tests.

KafkaJarTimeout attempts to apply an auto-shutdown timeout to the Kafka cluster jar.

ExpansionServices is a struct used for getting addresses and starting expansion services, based on the --expansion_jar and --expansion_addr flags in this package.