Hierarchy For Package org.apache.beam.runners.spark.translation

Package Hierarchies:

• All Packages

Class Hierarchy

• java.lang.Object
  • org.apache.beam.runners.spark.translation.BoundedDataset<T> (implements org.apache.beam.runners.spark.translation.Dataset)
  • org.apache.beam.runners.spark.translation.DoFnRunnerWithMetrics<InputT,OutputT> (implements org.apache.beam.runners.core.DoFnRunner<InputT,OutputT>)
  • org.apache.spark.streaming.dstream.DStream<T> (implements org.apache.spark.internal.Logging, scala.Serializable)
    • org.apache.spark.streaming.dstream.InputDStream<T>
      • org.apache.spark.streaming.dstream.ConstantInputDStream<T>
        • org.apache.beam.runners.spark.translation.SingleEmitInputDStream<T>
  • org.apache.beam.runners.spark.translation.EvaluationContext
  • org.apache.beam.runners.spark.translation.GroupCombineFunctions
  • org.apache.beam.runners.spark.translation.GroupNonMergingWindowsFunctions
  • org.apache.beam.runners.spark.translation.MultiDoFnFunction<InputT,OutputT> (implements org.apache.spark.api.java.function.PairFlatMapFunction<T,K,V>)
  • org.apache.beam.sdk.Pipeline.PipelineVisitor.Defaults (implements org.apache.beam.sdk.Pipeline.PipelineVisitor)
    • org.apache.beam.runners.spark.translation.GroupByKeyVisitor
  • org.apache.beam.runners.spark.translation.ReifyTimestampsAndWindowsFunction<K,V> (implements org.apache.spark.api.java.function.Function<T1,R>)
  • com.esotericsoftware.kryo.Serializer<T>
    • org.apache.beam.runners.spark.translation.ValueAndCoderKryoSerializer<T>
  • org.apache.beam.runners.spark.translation.SideInputMetadata (implements java.io.Serializable)
  • org.apache.beam.runners.spark.translation.SparkAssignWindowFn<T,W> (implements org.apache.spark.api.java.function.Function<T1,R>)
  • org.apache.beam.runners.spark.translation.SparkBatchPortablePipelineTranslator (implements org.apache.beam.runners.spark.translation.SparkPortablePipelineTranslator<T>)
  • org.apache.beam.runners.spark.translation.SparkBatchPortablePipelineTranslator.IsSparkNativeTransform (implements org.apache.beam.sdk.util.construction.NativeTransforms.IsNativeTransform)
  • org.apache.beam.runners.spark.translation.SparkCombineFn<InputT,ValueT,AccumT,OutputT> (implements java.io.Serializable)
  • org.apache.beam.runners.spark.translation.SparkContextFactory
  • org.apache.beam.runners.spark.translation.SparkExecutableStageContextFactory (implements org.apache.beam.runners.fnexecution.control.ExecutableStageContext.Factory)
  • org.apache.beam.runners.spark.translation.SparkPCollectionView (implements java.io.Serializable)
  • org.apache.beam.runners.spark.translation.SparkProcessContext<K,InputT,OutputT>
  • org.apache.beam.runners.spark.translation.SparkStreamingPortablePipelineTranslator (implements org.apache.beam.runners.spark.translation.SparkPortablePipelineTranslator<T>)
  • org.apache.beam.runners.spark.translation.SparkTranslationContext
    • org.apache.beam.runners.spark.translation.SparkStreamingTranslationContext
  • org.apache.beam.runners.spark.translation.TransformTranslator
  • org.apache.beam.runners.spark.translation.TransformTranslator.Translator (implements org.apache.beam.runners.spark.translation.SparkPipelineTranslator)
  • org.apache.beam.runners.spark.translation.TranslationUtils
  • org.apache.beam.runners.spark.translation.TranslationUtils.CombineGroupedValues<K,InputT,OutputT> (implements org.apache.spark.api.java.function.Function<T1,R>)
  • org.apache.beam.runners.spark.translation.TranslationUtils.TupleTagFilter<V> (implements org.apache.spark.api.java.function.Function<T1,R>)
  • org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.collect.UnmodifiableIterator<E> (implements java.util.Iterator<E>)
    • org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.collect.AbstractIterator<T>
      • org.apache.beam.runners.spark.translation.AbstractInOutIterator<K,InputT,OutputT>
  • org.apache.beam.runners.spark.translation.ValueAndCoderLazySerializable<T> (implements java.io.Serializable)

Interface Hierarchy

• java.io.Serializable
  • org.apache.beam.runners.spark.translation.Dataset
  • org.apache.beam.runners.spark.translation.TransformEvaluator<TransformT>
• org.apache.beam.runners.spark.translation.SparkCombineFn.WindowedAccumulator<InputT,ValueT,AccumT,ImplT>
• org.apache.beam.runners.spark.translation.SparkInputDataProcessor<FnInputT,FnOutputT,OutputT>
• org.apache.beam.runners.spark.translation.SparkPipelineTranslator
• org.apache.beam.runners.spark.translation.SparkPortablePipelineTranslator<T>

Enum Class Hierarchy

• java.lang.Object
  • java.lang.Enum<E> (implements java.lang.Comparable<T>, java.lang.constant.Constable, java.io.Serializable)
    • org.apache.beam.runners.spark.translation.SparkCombineFn.WindowedAccumulator.Type
    • org.apache.beam.runners.spark.translation.SparkPCollectionView.Type