Hierarchy For Package org.apache.crunch.impl.spark.collect

Package Hierarchies:

All Packages

Class Hierarchy

• java.lang.Object
  • scala.runtime.AbstractFunction1<T1,R> (implements scala.Function1<T1,R>)
    • org.apache.spark.api.java.function.WrappedFunction1<T,R>
      • org.apache.spark.api.java.function.PairFunction<T,K,V> (implements java.io.Serializable)
        • org.apache.crunch.impl.spark.collect.ToByteArrayFunction
  • org.apache.crunch.impl.dist.collect.PCollectionImpl<S> (implements org.apache.crunch.PCollection<S>)
    • org.apache.crunch.impl.dist.collect.BaseDoCollection<S>
      • org.apache.crunch.impl.spark.collect.DoCollection<S> (implements org.apache.crunch.impl.spark.SparkCollection)
    • org.apache.crunch.impl.dist.collect.BaseGroupedTable<K,V> (implements org.apache.crunch.PGroupedTable<K,V>)
      • org.apache.crunch.impl.spark.collect.PGroupedTableImpl<K,V> (implements org.apache.crunch.impl.spark.SparkCollection)
    • org.apache.crunch.impl.dist.collect.BaseInputCollection<S>
      • org.apache.crunch.impl.spark.collect.InputCollection<S> (implements org.apache.crunch.impl.spark.SparkCollection)
    • org.apache.crunch.impl.dist.collect.BaseUnionCollection<S>
      • org.apache.crunch.impl.spark.collect.UnionCollection<S> (implements org.apache.crunch.impl.spark.SparkCollection)
    • org.apache.crunch.impl.dist.collect.EmptyPCollection<T>
      • org.apache.crunch.impl.spark.collect.EmptyPCollection<T> (implements org.apache.crunch.impl.spark.SparkCollection)
    • org.apache.crunch.impl.dist.collect.PTableBase<K,V> (implements org.apache.crunch.PTable<K,V>)
      • org.apache.crunch.impl.dist.collect.BaseDoTable<K,V> (implements org.apache.crunch.PTable<K,V>)
        • org.apache.crunch.impl.spark.collect.DoTable<K,V> (implements org.apache.crunch.impl.spark.SparkCollection)
      • org.apache.crunch.impl.dist.collect.BaseInputTable<K,V>
        • org.apache.crunch.impl.spark.collect.InputTable<K,V> (implements org.apache.crunch.impl.spark.SparkCollection)
      • org.apache.crunch.impl.dist.collect.BaseUnionTable<K,V>
        • org.apache.crunch.impl.spark.collect.UnionTable<K,V> (implements org.apache.crunch.impl.spark.SparkCollection)
      • org.apache.crunch.impl.dist.collect.EmptyPTable<K,V>
        • org.apache.crunch.impl.spark.collect.EmptyPTable<K,V> (implements org.apache.crunch.impl.spark.SparkCollection)
  • org.apache.crunch.impl.spark.collect.SparkCollectFactory (implements org.apache.crunch.impl.dist.collect.PCollectionFactory)