Uses of Class
com.cloudera.crunch.DoFn

Packages that use DoFn
com.cloudera.crunch   
com.cloudera.crunch.fn   
com.cloudera.crunch.impl.mem.collect   
com.cloudera.crunch.impl.mr.collect   
com.cloudera.crunch.impl.mr.plan   
com.cloudera.crunch.impl.mr.run   
com.cloudera.crunch.lib   
com.cloudera.crunch.type   
com.cloudera.crunch.util   
 

Uses of DoFn in com.cloudera.crunch
 

Subclasses of DoFn in com.cloudera.crunch
 class CombineFn<S,T>
          A special DoFn implementation that converts an Iterable of values into a single value.
static class CombineFn.AggregatorCombineFn<K,V>
          A CombineFn that delegates all of the actual work to an Aggregator instance.
 class FilterFn<T>
          A DoFn for the common case of filtering the members of a PCollection based on a boolean condition.
static class FilterFn.AndFn<S>
           
static class FilterFn.NotFn<S>
           
static class FilterFn.OrFn<S>
           
 class MapFn<S,T>
          A DoFn for the common case of emitting exactly one value for each input record.
 

Methods in com.cloudera.crunch with parameters of type DoFn
<K,V> PTable<K,V>
PCollection.parallelDo(DoFn<S,Pair<K,V>> doFn, PTableType<K,V> type)
          Similar to the other parallelDo instance, but returns a PTable instance instead of a PCollection.
<T> PCollection<T>
PCollection.parallelDo(DoFn<S,T> doFn, PType<T> type)
          Applies the given doFn to the elements of this PCollection and returns a new PCollection that is the output of this processing.
<K,V> PTable<K,V>
PCollection.parallelDo(String name, DoFn<S,Pair<K,V>> doFn, PTableType<K,V> type)
          Similar to the other parallelDo instance, but returns a PTable instance instead of a PCollection.
<T> PCollection<T>
PCollection.parallelDo(String name, DoFn<S,T> doFn, PType<T> type)
          Applies the given doFn to the elements of this PCollection and returns a new PCollection that is the output of this processing.
 

Uses of DoFn in com.cloudera.crunch.fn
 

Subclasses of DoFn in com.cloudera.crunch.fn
 class CompositeMapFn<R,S,T>
           
 class IdentityFn<T>
           
 class MapKeysFn<K1,K2,V>
           
 class MapValuesFn<K,V1,V2>
           
 class PairMapFn<K,V,S,T>
           
 

Uses of DoFn in com.cloudera.crunch.impl.mem.collect
 

Methods in com.cloudera.crunch.impl.mem.collect with parameters of type DoFn
<K,V> PTable<K,V>
MemCollection.parallelDo(DoFn<S,Pair<K,V>> doFn, PTableType<K,V> type)
           
<T> PCollection<T>
MemCollection.parallelDo(DoFn<S,T> doFn, PType<T> type)
           
<K,V> PTable<K,V>
MemCollection.parallelDo(String name, DoFn<S,Pair<K,V>> doFn, PTableType<K,V> type)
           
<T> PCollection<T>
MemCollection.parallelDo(String name, DoFn<S,T> doFn, PType<T> type)
           
 

Uses of DoFn in com.cloudera.crunch.impl.mr.collect
 

Methods in com.cloudera.crunch.impl.mr.collect with parameters of type DoFn
<K,V> PTable<K,V>
PCollectionImpl.parallelDo(DoFn<S,Pair<K,V>> fn, PTableType<K,V> type)
           
<T> PCollection<T>
PCollectionImpl.parallelDo(DoFn<S,T> fn, PType<T> type)
           
<K,V> PTable<K,V>
PCollectionImpl.parallelDo(String name, DoFn<S,Pair<K,V>> fn, PTableType<K,V> type)
           
<T> PCollection<T>
PCollectionImpl.parallelDo(String name, DoFn<S,T> fn, PType<T> type)
           
 

Uses of DoFn in com.cloudera.crunch.impl.mr.plan
 

Methods in com.cloudera.crunch.impl.mr.plan with parameters of type DoFn
static DoNode DoNode.createFnNode(String name, DoFn<?,?> function, PType<?> ptype)
           
 

Uses of DoFn in com.cloudera.crunch.impl.mr.run
 

Constructors in com.cloudera.crunch.impl.mr.run with parameters of type DoFn
RTNode(DoFn<Object,Object> fn, String name, List<RTNode> children, Converter inputConverter, Converter outputConverter, String outputName)
           
 

Uses of DoFn in com.cloudera.crunch.lib
 

Subclasses of DoFn in com.cloudera.crunch.lib
static class Aggregate.TopKCombineFn<K,V>
           
static class Aggregate.TopKFn<K,V>
           
static class Sample.SamplerFn<S>
           
 

Uses of DoFn in com.cloudera.crunch.type
 

Subclasses of DoFn in com.cloudera.crunch.type
static class PGroupedTableType.PairIterableMapFn<K,V>
           
 

Uses of DoFn in com.cloudera.crunch.util
 

Subclasses of DoFn in com.cloudera.crunch.util
static class PTypes.JacksonInputMapFn<T>
           
static class PTypes.JacksonOutputMapFn<T>
           
static class PTypes.ProtoInputMapFn<T extends Message>
           
static class PTypes.ProtoOutputMapFn<T extends Message>
           
static class PTypes.SmileInputMapFn<T>
           
static class PTypes.SmileOutputMapFn<T>
           
static class PTypes.ThriftInputMapFn<T extends TBase>
           
static class PTypes.ThriftOutputMapFn<T extends TBase>
           
 



Copyright © 2012. All Rights Reserved.