|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
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 | ||
---|---|---|
|
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 . |
|
|
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. |
|
|
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 . |
|
|
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 | ||
---|---|---|
|
MemCollection.parallelDo(DoFn<S,Pair<K,V>> doFn,
PTableType<K,V> type)
|
|
|
MemCollection.parallelDo(DoFn<S,T> doFn,
PType<T> type)
|
|
|
MemCollection.parallelDo(String name,
DoFn<S,Pair<K,V>> doFn,
PTableType<K,V> type)
|
|
|
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 | ||
---|---|---|
|
PCollectionImpl.parallelDo(DoFn<S,Pair<K,V>> fn,
PTableType<K,V> type)
|
|
|
PCollectionImpl.parallelDo(DoFn<S,T> fn,
PType<T> type)
|
|
|
PCollectionImpl.parallelDo(String name,
DoFn<S,Pair<K,V>> fn,
PTableType<K,V> type)
|
|
|
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>
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |