This project has retired. For details please refer to its Attic page.
Uses of Class org.apache.crunch.impl.dist.collect.PCollectionImpl (Apache Crunch 0.10.0 API)

Uses of Class
org.apache.crunch.impl.dist.collect.PCollectionImpl

Packages that use PCollectionImpl
org.apache.crunch.impl.dist.collect   
org.apache.crunch.impl.spark   
org.apache.crunch.impl.spark.collect   
 

Uses of PCollectionImpl in org.apache.crunch.impl.dist.collect
 

Subclasses of PCollectionImpl in org.apache.crunch.impl.dist.collect
 class BaseDoCollection<S>
           
 class BaseDoTable<K,V>
           
 class BaseGroupedTable<K,V>
           
 class BaseInputCollection<S>
           
 class BaseInputTable<K,V>
           
 class BaseUnionCollection<S>
           
 class BaseUnionTable<K,V>
           
 class EmptyPCollection<T>
           
 class EmptyPTable<K,V>
           
 class PTableBase<K,V>
           
 

Methods in org.apache.crunch.impl.dist.collect that return PCollectionImpl
 PCollectionImpl<?> PCollectionImpl.getOnlyParent()
           
 

Methods in org.apache.crunch.impl.dist.collect that return types with arguments of type PCollectionImpl
abstract  List<PCollectionImpl<?>> PCollectionImpl.getParents()
           
 List<PCollectionImpl<?>> EmptyPTable.getParents()
           
 List<PCollectionImpl<?>> EmptyPCollection.getParents()
           
 List<PCollectionImpl<?>> BaseUnionTable.getParents()
           
 List<PCollectionImpl<?>> BaseUnionCollection.getParents()
           
 List<PCollectionImpl<?>> BaseInputTable.getParents()
           
 List<PCollectionImpl<?>> BaseInputCollection.getParents()
           
 List<PCollectionImpl<?>> BaseGroupedTable.getParents()
           
 List<PCollectionImpl<?>> BaseDoTable.getParents()
           
 List<PCollectionImpl<?>> BaseDoCollection.getParents()
           
 

Methods in org.apache.crunch.impl.dist.collect with parameters of type PCollectionImpl
<S,T> BaseDoCollection<T>
PCollectionFactory.createDoCollection(String name, PCollectionImpl<S> chainingCollection, DoFn<S,T> fn, PType<T> type, ParallelDoOptions options)
           
<S,K,V> BaseDoTable<K,V>
PCollectionFactory.createDoTable(String name, PCollectionImpl<S> chainingCollection, CombineFn<K,V> combineFn, DoFn<S,Pair<K,V>> fn, PTableType<K,V> type)
           
<S,K,V> BaseDoTable<K,V>
PCollectionFactory.createDoTable(String name, PCollectionImpl<S> chainingCollection, DoFn<S,Pair<K,V>> fn, PTableType<K,V> type, ParallelDoOptions options)
           
 

Method parameters in org.apache.crunch.impl.dist.collect with type arguments of type PCollectionImpl
<S> BaseUnionCollection<S>
PCollectionFactory.createUnionCollection(List<? extends PCollectionImpl<S>> internal)
           
 

Uses of PCollectionImpl in org.apache.crunch.impl.spark
 

Constructor parameters in org.apache.crunch.impl.spark with type arguments of type PCollectionImpl
SparkRuntime(SparkPipeline pipeline, org.apache.spark.api.java.JavaSparkContext sparkContext, org.apache.hadoop.conf.Configuration conf, Map<PCollectionImpl<?>,Set<Target>> outputTargets, Map<PCollectionImpl<?>,org.apache.crunch.materialize.MaterializableIterable> toMaterialize, Map<PCollection<?>,org.apache.spark.storage.StorageLevel> toCache)
           
SparkRuntime(SparkPipeline pipeline, org.apache.spark.api.java.JavaSparkContext sparkContext, org.apache.hadoop.conf.Configuration conf, Map<PCollectionImpl<?>,Set<Target>> outputTargets, Map<PCollectionImpl<?>,org.apache.crunch.materialize.MaterializableIterable> toMaterialize, Map<PCollection<?>,org.apache.spark.storage.StorageLevel> toCache)
           
 

Uses of PCollectionImpl in org.apache.crunch.impl.spark.collect
 

Subclasses of PCollectionImpl in org.apache.crunch.impl.spark.collect
 class DoCollection<S>
           
 class DoTable<K,V>
           
 class InputCollection<S>
           
 class InputTable<K,V>
           
 class PGroupedTableImpl<K,V>
           
 class UnionCollection<S>
           
 class UnionTable<K,V>
           
 

Methods in org.apache.crunch.impl.spark.collect with parameters of type PCollectionImpl
<S,T> BaseDoCollection<T>
SparkCollectFactory.createDoCollection(String name, PCollectionImpl<S> parent, DoFn<S,T> fn, PType<T> type, ParallelDoOptions options)
           
<S,K,V> BaseDoTable<K,V>
SparkCollectFactory.createDoTable(String name, PCollectionImpl<S> parent, CombineFn<K,V> combineFn, DoFn<S,Pair<K,V>> fn, PTableType<K,V> type)
           
<S,K,V> BaseDoTable<K,V>
SparkCollectFactory.createDoTable(String name, PCollectionImpl<S> parent, DoFn<S,Pair<K,V>> fn, PTableType<K,V> type, ParallelDoOptions options)
           
 

Method parameters in org.apache.crunch.impl.spark.collect with type arguments of type PCollectionImpl
<S> BaseUnionCollection<S>
SparkCollectFactory.createUnionCollection(List<? extends PCollectionImpl<S>> internal)
           
 



Copyright © 2014 The Apache Software Foundation. All Rights Reserved.