Uses of Class org.apache.beam.runners.apex.ApexYarnLauncher.LaunchParams (Apache Beam SDK for Java, version 0.5.0)

Packages that use ApexYarnLauncher.LaunchParams
Package	Description
org.apache.beam.runners.apex	+ Implementation of the Beam runner for Apache Apex. +

Packages that use ApexYarnLauncher.LaunchParams

Package

Description

org.apache.beam.runners.apex

Implementation of the Beam runner for Apache Apex.

Methods in org.apache.beam.runners.apex with parameters of type ApexYarnLauncher.LaunchParams
Modifier and Type	Method and Description
`protected org.apache.apex.api.Launcher.AppHandle`	ApexYarnLauncher.`launchApp(ApexYarnLauncher.LaunchParams params)`

Methods in org.apache.beam.runners.apex with parameters of type ApexYarnLauncher.LaunchParams

Modifier and Type

Method and Description

protected org.apache.apex.api.Launcher.AppHandle

ApexYarnLauncher.launchApp(ApexYarnLauncher.LaunchParams params)

Packages that use TestApexRunner
Package	Description
org.apache.beam.runners.apex	+ Implementation of the Beam runner for Apache Apex. +

Packages that use TestApexRunner

Package

Description

org.apache.beam.runners.apex

Implementation of the Beam runner for Apache Apex.

Methods in org.apache.beam.runners.apex that return TestApexRunner
Modifier and Type	Method and Description
`static TestApexRunner`	TestApexRunner.`fromOptions(PipelineOptions options)`

Methods in org.apache.beam.runners.apex that return TestApexRunner

Modifier and Type

Method and Description

static TestApexRunner

TestApexRunner.fromOptions(PipelineOptions options)

+ + + + + + + + + + + + +
Interface Summary
Interface Description
ApexPipelineOptions +
Options that configure the Apex pipeline.
+
+

Interface Summary
Interface	Description
ApexPipelineOptions	+ Options that configure the Apex pipeline. +

+ + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + +

Class Summary
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	+ Contains the `PipelineRunnerRegistrar` and `PipelineOptionsRegistrar` for the + `ApexRunner`. +
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. +

+ + + +

Package org.apache.beam.runners.apex Description

Implementation of the Beam runner for Apache Apex.

Class Hierarchy

java.lang.Object +
- org.apache.beam.runners.apex.ApexRunnerRegistrar
- org.apache.beam.runners.apex.ApexRunnerRegistrar.Options (implements org.apache.beam.sdk.options.PipelineOptionsRegistrar)
- org.apache.beam.runners.apex.ApexRunnerRegistrar.Runner (implements org.apache.beam.sdk.runners.PipelineRunnerRegistrar)
- org.apache.beam.runners.apex.ApexRunnerResult (implements org.apache.beam.sdk.PipelineResult)
- org.apache.beam.runners.apex.ApexYarnLauncher
- org.apache.beam.runners.apex.ApexYarnLauncher.LaunchParams (implements java.io.Serializable)
- org.apache.beam.runners.apex.ApexYarnLauncher.ProcessWatcher (implements java.lang.Runnable)
- org.apache.beam.sdk.runners.PipelineRunner<ResultT> +
  - org.apache.beam.runners.apex.ApexRunner
  - org.apache.beam.runners.apex.TestApexRunner
  +
- org.apache.beam.sdk.transforms.PTransform<InputT,OutputT> (implements org.apache.beam.sdk.transforms.display.HasDisplayData, java.io.Serializable) +
  - org.apache.beam.runners.apex.ApexRunner.CreateApexPCollectionView<ElemT,ViewT>
  +
+

Interface Hierarchy

org.apache.beam.sdk.transforms.display.HasDisplayData +
- org.apache.beam.sdk.options.PipelineOptions +
  - org.apache.beam.runners.apex.ApexPipelineOptions (also extends java.io.Serializable)
  +
+
java.io.Serializable +
- org.apache.beam.runners.apex.ApexPipelineOptions (also extends org.apache.beam.sdk.options.PipelineOptions)
+

+ + + + + + + + + + + + +
Packages that use org.apache.beam.runners.apex
Package Description
org.apache.beam.runners.apex +
Implementation of the Beam runner for Apache Apex.
+
+

Packages that use org.apache.beam.runners.apex
Package	Description
org.apache.beam.runners.apex	+ Implementation of the Beam runner for Apache Apex. +

+ + + + + + + + + + + + + + + + + + + + + + + + + + + +

Classes in org.apache.beam.runners.apex used by org.apache.beam.runners.apex
Class and Description
ApexPipelineOptions + Options that configure the Apex pipeline. +
ApexRunner + A `PipelineRunner` that translates the + pipeline to an Apex DAG and executes it on an Apex cluster. +
ApexRunner.CreateApexPCollectionView + Creates a primitive `PCollectionView`. +
ApexRunnerResult + Result of executing a `Pipeline` with Apex in embedded mode. +
ApexYarnLauncher.LaunchParams + Launch parameters that will be serialized and passed to the child process. +
TestApexRunner + Apex `PipelineRunner` for testing. +

+
+
Enclosing interface:
+
ActiveWindowSet<W extends BoundedWindow>
+
+
+
+
```
public static interface ActiveWindowSet.MergeCallback<W extends BoundedWindow>
```
+
Callback for ActiveWindowSet.merge(org.apache.beam.runners.core.ActiveWindowSet.MergeCallback<W>).
+

+ +

+ + +

Method Summary

+ + + + + + + + + + + + + + +

All Methods Instance Methods Abstract Methods
Modifier and Type	Method and Description
`void`	`onMerge(Collection<W> toBeMerged, + W mergeResult)` + Called when windows are about to be merged, after all `prefetchOnMerge(java.util.Collection<W>, W)` calls + have been made, but before the active window set has been updated to reflect the merge. +
`void`	`prefetchOnMerge(Collection<W> toBeMerged, + W mergeResult)` + Called when windows are about to be merged, but before any `onMerge(java.util.Collection<W>, W)` callback + has been made. +

+ +
- + + +
  Method Detail
  + + + + + +
  - +
    prefetchOnMerge
    +
```
void prefetchOnMerge(Collection<W> toBeMerged,
+                     W mergeResult)
+              throws Exception
```
    +
    Called when windows are about to be merged, but before any onMerge(java.util.Collection<W>, W) callback + has been made.
    +
    +
    Parameters:
    +
    toBeMerged - the windows about to be merged.
    +
    mergeResult - the result window, either a member of toBeMerged or new.
    +
    Throws:
    +
    Exception
    +
    +
  + + + + + +
  - +
    onMerge
    +
```
void onMerge(Collection<W> toBeMerged,
+             W mergeResult)
+      throws Exception
```
    +
    Called when windows are about to be merged, after all prefetchOnMerge(java.util.Collection<W>, W) calls + have been made, but before the active window set has been updated to reflect the merge.
    +
    +
    Parameters:
    +
    toBeMerged - the windows about to be merged.
    +
    mergeResult - the result window, either a member of toBeMerged or new.
    +
    Throws:
    +
    Exception
    +
    +
  +
+