See: Description
| Interface | Description |
|---|---|
| ApexPipelineOptions |
Options that configure the Apex pipeline.
|
| Class | Description |
|---|---|
| ApexRunner |
A
PipelineRunner that translates the pipeline to an Apex DAG and executes it on an Apex
cluster. |
| ApexRunner.CreateApexPCollectionView<ElemT,ViewT> |
Creates a primitive
PCollectionView. |
| ApexRunnerRegistrar | |
| ApexRunnerRegistrar.Options |
Registers the
ApexPipelineOptions. |
| ApexRunnerRegistrar.Runner |
Registers the
ApexRunner. |
| ApexRunnerResult |
Result of executing a
Pipeline with Apex in embedded mode. |
| ApexYarnLauncher |
Proxy to launch the YARN application through the hadoop script to run in the pre-configured
environment (class path, configuration, native libraries etc.).
|
| ApexYarnLauncher.LaunchParams |
Launch parameters that will be serialized and passed to the child process.
|
| ApexYarnLauncher.ProcessWatcher |
Starts a command and waits for it to complete.
|
| TestApexRunner |
Apex
PipelineRunner for testing. |