Hierarchy For Package org.apache.beam.runners.direct
Class Hierarchy
- java.lang.Object
- org.apache.beam.runners.direct.DirectOptions.AvailableParallelismFactory (implements org.apache.beam.sdk.options.DefaultValueFactory<T>)
- org.apache.beam.runners.direct.DirectRegistrar
- org.apache.beam.runners.direct.DirectRegistrar.Options (implements org.apache.beam.sdk.options.PipelineOptionsRegistrar)
- org.apache.beam.runners.direct.DirectRegistrar.Runner (implements org.apache.beam.sdk.runners.PipelineRunnerRegistrar)
- org.apache.beam.runners.direct.DirectRunner.DirectPipelineResult (implements org.apache.beam.sdk.PipelineResult)
- org.apache.beam.runners.direct.ParDoMultiOverrideFactory<InputT,
OutputT> (implements org.apache.beam.sdk.runners.PTransformOverrideFactory<InputT, OutputT, TransformT>) - org.apache.beam.sdk.PipelineRunner<ResultT>
- org.apache.beam.runners.direct.DirectRunner
Interface Hierarchy
- org.apache.beam.runners.direct.Clock
- org.apache.beam.runners.direct.ExecutableGraph<ExecutableT,
CollectionT> - org.apache.beam.sdk.transforms.display.HasDisplayData
- org.apache.beam.sdk.options.PipelineOptions
- org.apache.beam.sdk.options.ApplicationNameOptions
- org.apache.beam.runners.direct.DirectOptions (also extends org.apache.beam.sdk.options.PipelineOptions)
- org.apache.beam.runners.direct.DirectTestOptions (also extends org.apache.beam.sdk.options.PipelineOptions)
- org.apache.beam.runners.direct.DirectOptions (also extends org.apache.beam.sdk.options.ApplicationNameOptions)
- org.apache.beam.runners.direct.DirectTestOptions (also extends org.apache.beam.sdk.options.ApplicationNameOptions)
- org.apache.beam.sdk.options.ApplicationNameOptions
- org.apache.beam.sdk.options.PipelineOptions
- java.lang.Runnable
- org.apache.beam.runners.direct.TransformExecutor