|
|||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use MaterializableIterable | |
---|---|
org.apache.crunch.impl.dist | |
org.apache.crunch.impl.mr.exec | |
org.apache.crunch.impl.mr.plan | |
org.apache.crunch.impl.spark |
Uses of MaterializableIterable in org.apache.crunch.impl.dist |
---|
Fields in org.apache.crunch.impl.dist with type parameters of type MaterializableIterable | |
---|---|
protected Map<PCollectionImpl<?>,MaterializableIterable<?>> |
DistributedPipeline.outputTargetsToMaterialize
|
Uses of MaterializableIterable in org.apache.crunch.impl.mr.exec |
---|
Constructor parameters in org.apache.crunch.impl.mr.exec with type arguments of type MaterializableIterable | |
---|---|
MRExecutor(org.apache.hadoop.conf.Configuration conf,
Class<?> jarClass,
Map<PCollectionImpl<?>,Set<Target>> outputTargets,
Map<PCollectionImpl<?>,MaterializableIterable> toMaterialize)
|
Uses of MaterializableIterable in org.apache.crunch.impl.mr.plan |
---|
Constructor parameters in org.apache.crunch.impl.mr.plan with type arguments of type MaterializableIterable | |
---|---|
MSCRPlanner(MRPipeline pipeline,
Map<PCollectionImpl<?>,Set<Target>> outputs,
Map<PCollectionImpl<?>,MaterializableIterable> toMaterialize)
|
Uses of MaterializableIterable in org.apache.crunch.impl.spark |
---|
Constructor parameters in org.apache.crunch.impl.spark with type arguments of type MaterializableIterable | |
---|---|
SparkRuntime(SparkPipeline pipeline,
org.apache.spark.api.java.JavaSparkContext sparkContext,
org.apache.hadoop.conf.Configuration conf,
Map<PCollectionImpl<?>,Set<Target>> outputTargets,
Map<PCollectionImpl<?>,MaterializableIterable> toMaterialize,
Map<PCollection<?>,org.apache.spark.storage.StorageLevel> toCache)
|
|
|||||||||
PREV NEXT | FRAMES NO FRAMES |