apache_beam.transforms.external_java module

Tests for the Java external transforms.

class apache_beam.transforms.external_java.JavaExternalTransformTest[source]

Bases: object

expansion_service_jar = None
expansion_service_port = None
static test_java_expansion_dataflow()[source]
static run_pipeline_with_expansion_service(pipeline_options)[source]
static run_pipeline(pipeline_options, expansion_service, wait_until_finish=True)[source]