Hierarchy For Package org.apache.beam.runners.spark.structuredstreaming.translation.batch.functions

Package Hierarchies:

• All Packages

Class Hierarchy

• java.lang.Object
  • org.apache.beam.runners.spark.structuredstreaming.translation.batch.functions.CachedSideInputReader (implements org.apache.beam.runners.core.SideInputReader)
  • org.apache.beam.runners.spark.structuredstreaming.translation.batch.functions.GroupAlsoByWindowViaOutputBufferFn<K,InputT,W> (implements org.apache.spark.api.java.function.FlatMapGroupsFunction<K,V,R>)
  • org.apache.beam.runners.spark.structuredstreaming.translation.batch.functions.NoOpStepContext (implements org.apache.beam.runners.core.StepContext)
  • org.apache.beam.runners.spark.structuredstreaming.translation.batch.functions.SideInputValues.BaseSideInputValues<BinaryT,ValuesT,T> (implements org.apache.beam.runners.spark.structuredstreaming.translation.batch.functions.SideInputValues<T>)
    • org.apache.beam.runners.spark.structuredstreaming.translation.batch.functions.SideInputValues.ByWindow<T>
    • org.apache.beam.runners.spark.structuredstreaming.translation.batch.functions.SideInputValues.Global<T>
  • org.apache.beam.runners.spark.structuredstreaming.translation.batch.functions.SparkSideInputReader (implements java.io.Serializable, org.apache.beam.runners.core.SideInputReader)

Interface Hierarchy

• java.util.function.Function<T,R>
  • org.apache.beam.runners.spark.structuredstreaming.translation.batch.functions.SideInputValues.Loader<T>
• com.esotericsoftware.kryo.KryoSerializable
  • org.apache.beam.runners.spark.structuredstreaming.translation.batch.functions.SideInputValues<T> (also extends java.io.Serializable)
• java.io.Serializable
  • org.apache.beam.runners.spark.structuredstreaming.translation.batch.functions.SideInputValues<T> (also extends com.esotericsoftware.kryo.KryoSerializable)