apache_beam.transforms.external_java module

Tests for the Java external transforms.

class apache_beam.transforms.external_java.JavaExternalTransformTest

Bases: object

expansion_service_jar = None

expansion_service_port = None

static test_java_expansion_dataflow()

static run_pipeline_with_expansion_service(pipeline_options)

static run_pipeline(pipeline_options, expansion_service, wait_until_finish=True)