Serialized Form

Package com.cloudera.crunch

Class com.cloudera.crunch.CombineFn extends DoFn<Pair<S,Iterable<T>>,Pair<S,T>> implements Serializable

Class com.cloudera.crunch.CombineFn.AggregatorCombineFn extends CombineFn<K,V> implements Serializable

Serialized Fields

aggregator

CombineFn.Aggregator<T> aggregator

Class com.cloudera.crunch.CombineFn.FirstNAggregator extends Object implements Serializable

Serialized Fields

arity

int arity

elements

List<E> elements

Class com.cloudera.crunch.CombineFn.LastNAggregator extends Object implements Serializable

Serialized Fields

arity

int arity

elements

LinkedList<E> elements

Class com.cloudera.crunch.CombineFn.MaxBigInts extends Object implements Serializable

Serialized Fields

max

BigInteger max

Class com.cloudera.crunch.CombineFn.MaxDoubles extends Object implements Serializable

Serialized Fields

max

Double max

Class com.cloudera.crunch.CombineFn.MaxFloats extends Object implements Serializable

Serialized Fields

max

Float max

Class com.cloudera.crunch.CombineFn.MaxInts extends Object implements Serializable

Serialized Fields

max

Integer max

Class com.cloudera.crunch.CombineFn.MaxLongs extends Object implements Serializable

Serialized Fields

max

Long max

Class com.cloudera.crunch.CombineFn.MaxNAggregator extends Object implements Serializable

Serialized Fields

arity

int arity

Class com.cloudera.crunch.CombineFn.MinBigInts extends Object implements Serializable

Serialized Fields

min

BigInteger min

Class com.cloudera.crunch.CombineFn.MinDoubles extends Object implements Serializable

Serialized Fields

min

Double min

Class com.cloudera.crunch.CombineFn.MinFloats extends Object implements Serializable

Serialized Fields

min

Float min

Class com.cloudera.crunch.CombineFn.MinInts extends Object implements Serializable

Serialized Fields

min

Integer min

Class com.cloudera.crunch.CombineFn.MinLongs extends Object implements Serializable

Serialized Fields

min

Long min

Class com.cloudera.crunch.CombineFn.MinNAggregator extends Object implements Serializable

Serialized Fields

arity

int arity

Class com.cloudera.crunch.CombineFn.PairAggregator extends com.cloudera.crunch.CombineFn.TupleAggregator<Pair<V1,V2>> implements Serializable

Class com.cloudera.crunch.CombineFn.QuadAggregator extends com.cloudera.crunch.CombineFn.TupleAggregator<Tuple4<A,B,C,D>> implements Serializable

Class com.cloudera.crunch.CombineFn.SumBigInts extends Object implements Serializable

Serialized Fields

sum

BigInteger sum

Class com.cloudera.crunch.CombineFn.SumDoubles extends Object implements Serializable

Serialized Fields

sum

double sum

Class com.cloudera.crunch.CombineFn.SumFloats extends Object implements Serializable

Serialized Fields

sum

float sum

Class com.cloudera.crunch.CombineFn.SumInts extends Object implements Serializable

Serialized Fields

sum

int sum

Class com.cloudera.crunch.CombineFn.SumLongs extends Object implements Serializable

Serialized Fields

sum

long sum

Class com.cloudera.crunch.CombineFn.TripAggregator extends com.cloudera.crunch.CombineFn.TupleAggregator<Tuple3<A,B,C>> implements Serializable

Class com.cloudera.crunch.CombineFn.TupleNAggregator extends com.cloudera.crunch.CombineFn.TupleAggregator<TupleN> implements Serializable

Serialized Fields

size

int size

Class com.cloudera.crunch.DoFn extends Object implements Serializable

Class com.cloudera.crunch.FilterFn extends DoFn<T,T> implements Serializable

Class com.cloudera.crunch.FilterFn.AndFn extends FilterFn<S> implements Serializable

Serialized Fields

fns

List<E> fns

Class com.cloudera.crunch.FilterFn.NotFn extends FilterFn<S> implements Serializable

Serialized Fields

base

FilterFn<T> base

Class com.cloudera.crunch.FilterFn.OrFn extends FilterFn<S> implements Serializable

Serialized Fields

fns

List<E> fns

Class com.cloudera.crunch.MapFn extends DoFn<S,T> implements Serializable

Package com.cloudera.crunch.fn

Class com.cloudera.crunch.fn.CompositeMapFn extends MapFn<R,T> implements Serializable

Serialized Fields

first

MapFn<S,T> first

second

MapFn<S,T> second

Class com.cloudera.crunch.fn.IdentityFn extends MapFn<T,T> implements Serializable

Class com.cloudera.crunch.fn.MapKeysFn extends DoFn<Pair<K1,V>,Pair<K2,V>> implements Serializable

Class com.cloudera.crunch.fn.MapValuesFn extends DoFn<Pair<K,V1>,Pair<K,V2>> implements Serializable

Class com.cloudera.crunch.fn.PairMapFn extends MapFn<Pair<K,V>,Pair<S,T>> implements Serializable

Serialized Fields

keys

MapFn<S,T> keys

values

MapFn<S,T> values

Package com.cloudera.crunch.impl.mr.run

Class com.cloudera.crunch.impl.mr.run.CrunchRuntimeException extends RuntimeException implements Serializable

Serialized Fields

logged

boolean logged

Class com.cloudera.crunch.impl.mr.run.RTNode extends Object implements Serializable

Serialized Fields

nodeName

String nodeName

fn

DoFn<S,T> fn

children

List<E> children

inputConverter

Converter<K,V,S,T> inputConverter

outputConverter

Converter<K,V,S,T> outputConverter

outputName

String outputName

Package com.cloudera.crunch.lib

Class com.cloudera.crunch.lib.Aggregate.TopKCombineFn extends CombineFn<Boolean,Pair<K,V>> implements Serializable

Serialized Fields

limit

int limit

maximize

boolean maximize

Class com.cloudera.crunch.lib.Aggregate.TopKFn extends DoFn<Pair<K,V>,Pair<Boolean,Pair<K,V>>> implements Serializable

Serialized Fields

limit

int limit

maximize

boolean maximize

Class com.cloudera.crunch.lib.Sample.SamplerFn extends DoFn<S,S> implements Serializable

Serialized Fields

seed

long seed

acceptanceProbability

double acceptanceProbability

Package com.cloudera.crunch.type

Class com.cloudera.crunch.type.PGroupedTableType.PairIterableMapFn extends MapFn<Pair<Object,Iterable<Object>>,Pair<K,Iterable<V>>> implements Serializable

Serialized Fields

keys

MapFn<S,T> keys

values

MapFn<S,T> values

Class com.cloudera.crunch.type.TupleFactory extends Object implements Serializable

Package com.cloudera.crunch.type.avro

Class com.cloudera.crunch.type.avro.AvroKeyConverter extends Object implements Serializable

Class com.cloudera.crunch.type.avro.AvroPairConverter extends Object implements Serializable

Package com.cloudera.crunch.type.writable

Class com.cloudera.crunch.type.writable.WritablePairConverter extends Object implements Serializable

Serialized Fields

keyClass

Class<T> keyClass

valueClass

Class<T> valueClass

Package com.cloudera.crunch.util

Class com.cloudera.crunch.util.PTypes.JacksonInputMapFn extends MapFn<String,T> implements Serializable

Serialized Fields

clazz

Class<T> clazz

Class com.cloudera.crunch.util.PTypes.JacksonOutputMapFn extends MapFn<T,String> implements Serializable

Class com.cloudera.crunch.util.PTypes.ProtoInputMapFn extends MapFn<ByteBuffer,T extends com.google.protobuf.Message> implements Serializable

Serialized Fields

clazz

Class<T> clazz

Class com.cloudera.crunch.util.PTypes.ProtoOutputMapFn extends MapFn<T extends com.google.protobuf.Message,ByteBuffer> implements Serializable

Class com.cloudera.crunch.util.PTypes.SmileInputMapFn extends MapFn<ByteBuffer,T> implements Serializable

Serialized Fields

clazz

Class<T> clazz

Class com.cloudera.crunch.util.PTypes.SmileOutputMapFn extends MapFn<T,ByteBuffer> implements Serializable

Class com.cloudera.crunch.util.PTypes.ThriftInputMapFn extends MapFn<ByteBuffer,T extends org.apache.thrift.TBase> implements Serializable

Serialized Fields

clazz

Class<T> clazz

Class com.cloudera.crunch.util.PTypes.ThriftOutputMapFn extends MapFn<T extends org.apache.thrift.TBase,ByteBuffer> implements Serializable