|
|||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use CachingOptions | |
---|---|
org.apache.crunch | Client-facing API and core abstractions. |
org.apache.crunch.impl.dist.collect | |
org.apache.crunch.impl.mem | In-memory Pipeline implementation for rapid prototyping and testing. |
org.apache.crunch.impl.mr | A Pipeline implementation that runs on Hadoop MapReduce. |
org.apache.crunch.impl.spark |
Uses of CachingOptions in org.apache.crunch |
---|
Fields in org.apache.crunch declared as CachingOptions | |
---|---|
static CachingOptions |
CachingOptions.DEFAULT
An instance of CachingOptions with the default caching settings. |
Methods in org.apache.crunch that return CachingOptions | |
---|---|
CachingOptions |
CachingOptions.Builder.build()
|
Methods in org.apache.crunch with parameters of type CachingOptions | ||
---|---|---|
PTable<K,V> |
PTable.cache(CachingOptions options)
|
|
PCollection<S> |
PCollection.cache(CachingOptions options)
Marks this data as cached using the given CachingOptions . |
|
|
Pipeline.cache(PCollection<T> pcollection,
CachingOptions options)
Caches the given PCollection so that it will be processed at most once during pipeline execution. |
Uses of CachingOptions in org.apache.crunch.impl.dist.collect |
---|
Methods in org.apache.crunch.impl.dist.collect with parameters of type CachingOptions | |
---|---|
PTable<K,V> |
PTableBase.cache(CachingOptions options)
|
PCollection<S> |
PCollectionImpl.cache(CachingOptions options)
|
Uses of CachingOptions in org.apache.crunch.impl.mem |
---|
Methods in org.apache.crunch.impl.mem with parameters of type CachingOptions | ||
---|---|---|
|
MemPipeline.cache(PCollection<T> pcollection,
CachingOptions options)
|
Uses of CachingOptions in org.apache.crunch.impl.mr |
---|
Methods in org.apache.crunch.impl.mr with parameters of type CachingOptions | ||
---|---|---|
|
MRPipeline.cache(PCollection<T> pcollection,
CachingOptions options)
|
Uses of CachingOptions in org.apache.crunch.impl.spark |
---|
Methods in org.apache.crunch.impl.spark with parameters of type CachingOptions | ||
---|---|---|
|
SparkPipeline.cache(PCollection<T> pcollection,
CachingOptions options)
|
|
|||||||||
PREV NEXT | FRAMES NO FRAMES |