This project has retired. For details please refer to its Attic page.

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)