Uses of Class
org.apache.crunch.impl.spark.SparkPipeline

Packages that use SparkPipeline

Package	Description
org.apache.crunch.impl.spark
org.apache.crunch.impl.spark.collect

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

Constructors in org.apache.crunch.impl.spark with parameters of type SparkPipeline

Constructor and Description

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, Map<PipelineCallable<?>,Set<Target>> allPipelineCallables)

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

Constructors in org.apache.crunch.impl.spark.collect with parameters of type SparkPipeline

Constructor and Description
CreatedCollection(SparkPipeline p, Iterable<T> contents, PType<T> ptype, CreateOptions options)
CreatedTable(SparkPipeline pipeline, Iterable<Pair<K,V>> contents, PTableType<K,V> ptype, CreateOptions options)