|
|||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use SparkPipeline | |
---|---|
org.apache.crunch.impl.spark |
Uses of SparkPipeline in org.apache.crunch.impl.spark |
---|
Constructors in org.apache.crunch.impl.spark with parameters of type SparkPipeline | |
---|---|
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)
|
|
|||||||||
PREV NEXT | FRAMES NO FRAMES |