|
|||||||||
PREV NEXT | FRAMES NO FRAMES |
Package org.apache.crunch |
---|
Class org.apache.crunch.CombineFn extends DoFn<Pair<S,Iterable<T>>,Pair<S,T>> implements Serializable |
---|
Class org.apache.crunch.CombineFn.AggregatorCombineFn extends CombineFn<K,V> implements Serializable |
---|
Serialized Fields |
---|
CombineFn.Aggregator<T> aggregator
Class org.apache.crunch.CombineFn.FirstNAggregator extends CombineFn.SimpleAggregator<V> implements Serializable |
---|
Serialized Fields |
---|
int arity
List<E> elements
Class org.apache.crunch.CombineFn.LastNAggregator extends CombineFn.SimpleAggregator<V> implements Serializable |
---|
Serialized Fields |
---|
int arity
LinkedList<E> elements
Class org.apache.crunch.CombineFn.MaxBigInts extends CombineFn.SimpleAggregator<BigInteger> implements Serializable |
---|
Serialized Fields |
---|
BigInteger max
Class org.apache.crunch.CombineFn.MaxDoubles extends CombineFn.SimpleAggregator<Double> implements Serializable |
---|
Serialized Fields |
---|
Double max
Class org.apache.crunch.CombineFn.MaxFloats extends CombineFn.SimpleAggregator<Float> implements Serializable |
---|
Serialized Fields |
---|
Float max
Class org.apache.crunch.CombineFn.MaxInts extends CombineFn.SimpleAggregator<Integer> implements Serializable |
---|
Serialized Fields |
---|
Integer max
Class org.apache.crunch.CombineFn.MaxLongs extends CombineFn.SimpleAggregator<Long> implements Serializable |
---|
Serialized Fields |
---|
Long max
Class org.apache.crunch.CombineFn.MaxNAggregator extends CombineFn.SimpleAggregator<V extends Comparable<V>> implements Serializable |
---|
Serialized Fields |
---|
int arity
Class org.apache.crunch.CombineFn.MinBigInts extends CombineFn.SimpleAggregator<BigInteger> implements Serializable |
---|
Serialized Fields |
---|
BigInteger min
Class org.apache.crunch.CombineFn.MinDoubles extends CombineFn.SimpleAggregator<Double> implements Serializable |
---|
Serialized Fields |
---|
Double min
Class org.apache.crunch.CombineFn.MinFloats extends CombineFn.SimpleAggregator<Float> implements Serializable |
---|
Serialized Fields |
---|
Float min
Class org.apache.crunch.CombineFn.MinInts extends CombineFn.SimpleAggregator<Integer> implements Serializable |
---|
Serialized Fields |
---|
Integer min
Class org.apache.crunch.CombineFn.MinLongs extends CombineFn.SimpleAggregator<Long> implements Serializable |
---|
Serialized Fields |
---|
Long min
Class org.apache.crunch.CombineFn.MinNAggregator extends CombineFn.SimpleAggregator<V extends Comparable<V>> implements Serializable |
---|
Serialized Fields |
---|
int arity
Class org.apache.crunch.CombineFn.PairAggregator extends org.apache.crunch.CombineFn.TupleAggregator<Pair<V1,V2>> implements Serializable |
---|
Class org.apache.crunch.CombineFn.QuadAggregator extends org.apache.crunch.CombineFn.TupleAggregator<Tuple4<A,B,C,D>> implements Serializable |
---|
Class org.apache.crunch.CombineFn.SimpleAggregator extends Object implements Serializable |
---|
Class org.apache.crunch.CombineFn.StringConcatAggregator extends CombineFn.SimpleAggregator<String> implements Serializable |
---|
Serialized Fields |
---|
String separator
boolean skipNulls
long maxOutputLength
long maxInputLength
long currentLength
LinkedList<E> list
Class org.apache.crunch.CombineFn.SumBigInts extends CombineFn.SimpleAggregator<BigInteger> implements Serializable |
---|
Serialized Fields |
---|
BigInteger sum
Class org.apache.crunch.CombineFn.SumDoubles extends CombineFn.SimpleAggregator<Double> implements Serializable |
---|
Serialized Fields |
---|
double sum
Class org.apache.crunch.CombineFn.SumFloats extends CombineFn.SimpleAggregator<Float> implements Serializable |
---|
Serialized Fields |
---|
float sum
Class org.apache.crunch.CombineFn.SumInts extends CombineFn.SimpleAggregator<Integer> implements Serializable |
---|
Serialized Fields |
---|
int sum
Class org.apache.crunch.CombineFn.SumLongs extends CombineFn.SimpleAggregator<Long> implements Serializable |
---|
Serialized Fields |
---|
long sum
Class org.apache.crunch.CombineFn.TripAggregator extends org.apache.crunch.CombineFn.TupleAggregator<Tuple3<A,B,C>> implements Serializable |
---|
Class org.apache.crunch.CombineFn.TupleNAggregator extends org.apache.crunch.CombineFn.TupleAggregator<TupleN> implements Serializable |
---|
Serialized Fields |
---|
int size
Class org.apache.crunch.CrunchRuntimeException extends RuntimeException implements Serializable |
---|
Serialized Fields |
---|
boolean logged
Class org.apache.crunch.DoFn extends Object implements Serializable |
---|
Class org.apache.crunch.FilterFn extends DoFn<T,T> implements Serializable |
---|
Class org.apache.crunch.FilterFn.AndFn extends FilterFn<S> implements Serializable |
---|
Serialized Fields |
---|
List<E> fns
Class org.apache.crunch.FilterFn.NotFn extends FilterFn<S> implements Serializable |
---|
Serialized Fields |
---|
FilterFn<T> base
Class org.apache.crunch.FilterFn.OrFn extends FilterFn<S> implements Serializable |
---|
Serialized Fields |
---|
List<E> fns
Class org.apache.crunch.MapFn extends DoFn<S,T> implements Serializable |
---|
Package org.apache.crunch.contrib.bloomfilter |
---|
Class org.apache.crunch.contrib.bloomfilter.BloomFilterFn extends DoFn<S,Pair<String,org.apache.hadoop.util.bloom.BloomFilter>> implements Serializable |
---|
Package org.apache.crunch.contrib.text |
---|
Class org.apache.crunch.contrib.text.AbstractCompositeExtractor extends Object implements Serializable |
---|
Serialized Fields |
---|
TokenizerFactory tokenizerFactory
int errors
boolean errorOnLast
List<E> extractors
Class org.apache.crunch.contrib.text.AbstractSimpleExtractor extends Object implements Serializable |
---|
Serialized Fields |
---|
int errors
boolean errorOnLast
Object defaultValue
TokenizerFactory scannerFactory
Class org.apache.crunch.contrib.text.TokenizerFactory extends Object implements Serializable |
---|
Serialized Fields |
---|
String delim
String skip
Locale locale
Set<E> indices
boolean keep
Package org.apache.crunch.examples |
---|
Class org.apache.crunch.examples.AverageBytesByIP extends org.apache.hadoop.conf.Configured implements Serializable |
---|
Serialized Fields |
---|
MapFn<S,T> calulateAverage
DoFn<S,T> extractResponseSize
Class org.apache.crunch.examples.SecondarySortExample extends org.apache.hadoop.conf.Configured implements Serializable |
---|
Class org.apache.crunch.examples.SortExample extends CrunchTool implements Serializable |
---|
Class org.apache.crunch.examples.TotalBytesByIP extends org.apache.hadoop.conf.Configured implements Serializable |
---|
Serialized Fields |
---|
DoFn<S,T> extractIPResponseSize
Class org.apache.crunch.examples.WordAggregationHBase extends org.apache.hadoop.conf.Configured implements Serializable |
---|
Serialized Fields |
---|
String TABLE_SOURCE
String TABLE_TARGET
byte[] COLUMN_FAMILY_SOURCE
byte[] COLUMN_QUALIFIER_SOURCE_PLAY
byte[] COLUMN_QUALIFIER_SOURCE_QUOTE
byte[] COLUMN_FAMILY_TARGET
byte[] COLUMN_QUALIFIER_TARGET_TEXT
Class org.apache.crunch.examples.WordCount extends org.apache.hadoop.conf.Configured implements Serializable |
---|
Package org.apache.crunch.fn |
---|
Class org.apache.crunch.fn.Aggregators.SimpleAggregator extends Object implements Serializable |
---|
Class org.apache.crunch.fn.CompositeMapFn extends MapFn<R,T> implements Serializable |
---|
Serialized Fields |
---|
MapFn<S,T> first
MapFn<S,T> second
Class org.apache.crunch.fn.ExtractKeyFn extends MapFn<V,Pair<K,V>> implements Serializable |
---|
Serialized Fields |
---|
MapFn<S,T> mapFn
Class org.apache.crunch.fn.IdentityFn extends MapFn<T,T> implements Serializable |
---|
Class org.apache.crunch.fn.MapKeysFn extends DoFn<Pair<K1,V>,Pair<K2,V>> implements Serializable |
---|
Class org.apache.crunch.fn.MapValuesFn extends DoFn<Pair<K,V1>,Pair<K,V2>> implements Serializable |
---|
Class org.apache.crunch.fn.PairMapFn extends MapFn<Pair<K,V>,Pair<S,T>> implements Serializable |
---|
Serialized Fields |
---|
MapFn<S,T> keys
MapFn<S,T> values
Package org.apache.crunch.io |
---|
Class org.apache.crunch.io.FormatBundle extends Object implements Serializable |
---|
Serialized Fields |
---|
Class<T> formatClass
Map<K,V> extraConf
org.apache.hadoop.conf.Configuration conf
Package org.apache.crunch.lib |
---|
Class org.apache.crunch.lib.Aggregate.TopKCombineFn extends CombineFn<Integer,Pair<K,V>> implements Serializable |
---|
Serialized Fields |
---|
int limit
boolean maximize
Class org.apache.crunch.lib.Aggregate.TopKFn extends DoFn<Pair<K,V>,Pair<Integer,Pair<K,V>>> implements Serializable |
---|
Serialized Fields |
---|
int limit
boolean maximize
Package org.apache.crunch.lib.join |
---|
Class org.apache.crunch.lib.join.BloomFilterJoinStrategy extends Object implements Serializable |
---|
Serialized Fields |
---|
int vectorSize
int nbHash
JoinStrategy<K,U,V> delegateJoinStrategy
Class org.apache.crunch.lib.join.DefaultJoinStrategy extends Object implements Serializable |
---|
Class org.apache.crunch.lib.join.FullOuterJoinFn extends JoinFn<K,U,V> implements Serializable |
---|
Class org.apache.crunch.lib.join.InnerJoinFn extends JoinFn<K,U,V> implements Serializable |
---|
Class org.apache.crunch.lib.join.JoinFn extends DoFn<Pair<Pair<K,Integer>,Iterable<Pair<U,V>>>,Pair<K,Pair<U,V>>> implements Serializable |
---|
Serialized Fields |
---|
PType<T> keyType
PType<T> leftValueType
Class org.apache.crunch.lib.join.LeftOuterJoinFn extends JoinFn<K,U,V> implements Serializable |
---|
Class org.apache.crunch.lib.join.MapsideJoinStrategy extends Object implements Serializable |
---|
Class org.apache.crunch.lib.join.RightOuterJoinFn extends JoinFn<K,U,V> implements Serializable |
---|
Class org.apache.crunch.lib.join.ShardedJoinStrategy extends Object implements Serializable |
---|
Serialized Fields |
---|
JoinStrategy<K,U,V> wrappedJoinStrategy
ShardedJoinStrategy.ShardingStrategy<K> shardingStrategy
Package org.apache.crunch.lib.sort |
---|
Class org.apache.crunch.lib.sort.SortFns.AvroGenericFn extends MapFn<V extends Tuple,org.apache.avro.generic.GenericRecord> implements Serializable |
---|
Serialized Fields |
---|
int[] indices
String schemaJson
Class org.apache.crunch.lib.sort.SortFns.SingleKeyFn extends MapFn<V extends Tuple,K> implements Serializable |
---|
Serialized Fields |
---|
int index
Class org.apache.crunch.lib.sort.SortFns.TupleKeyFn extends MapFn<V extends Tuple,K extends Tuple> implements Serializable |
---|
Serialized Fields |
---|
int[] indices
TupleFactory<T extends Tuple> tupleFactory
Package org.apache.crunch.types |
---|
Class org.apache.crunch.types.CollectionDeepCopier extends Object implements Serializable |
---|
Serialized Fields |
---|
PType<T> elementType
Class org.apache.crunch.types.DeepCopier.NoOpDeepCopier extends Object implements Serializable |
---|
Class org.apache.crunch.types.MapDeepCopier extends Object implements Serializable |
---|
Serialized Fields |
---|
PType<T> ptype
Class org.apache.crunch.types.PGroupedTableType extends Object implements Serializable |
---|
Serialized Fields |
---|
PTableType<K,V> tableType
Class org.apache.crunch.types.PGroupedTableType.PairIterableMapFn extends MapFn<Pair<Object,Iterable<Object>>,Pair<K,Iterable<V>>> implements Serializable |
---|
Serialized Fields |
---|
MapFn<S,T> keys
MapFn<S,T> values
Class org.apache.crunch.types.TupleDeepCopier extends Object implements Serializable |
---|
Serialized Fields |
---|
TupleFactory<T extends Tuple> tupleFactory
List<E> elementTypes
Class org.apache.crunch.types.TupleFactory extends Object implements Serializable |
---|
Package org.apache.crunch.types.avro |
---|
Class org.apache.crunch.types.avro.AvroDeepCopier.AvroGenericDeepCopier extends org.apache.crunch.types.avro.AvroDeepCopier<org.apache.avro.generic.GenericData.Record> implements Serializable |
---|
Class org.apache.crunch.types.avro.AvroDeepCopier.AvroReflectDeepCopier extends org.apache.crunch.types.avro.AvroDeepCopier<T> implements Serializable |
---|
Serialized Fields |
---|
Class<T> valueClass
Class org.apache.crunch.types.avro.AvroDeepCopier.AvroSpecificDeepCopier extends org.apache.crunch.types.avro.AvroDeepCopier<T> implements Serializable |
---|
Serialized Fields |
---|
Class<T> valueClass
Class org.apache.crunch.types.avro.AvroType extends Object implements Serializable |
---|
Serialized Fields |
---|
Class<T> typeClass
String schemaString
MapFn<S,T> baseInputMapFn
MapFn<S,T> baseOutputMapFn
List<E> subTypes
DeepCopier<T> deepCopier
boolean initialized
Package org.apache.crunch.types.writable |
---|
Class org.apache.crunch.types.writable.WritableDeepCopier extends Object implements Serializable |
---|
Serialized Fields |
---|
Class<T> writableClass
Class org.apache.crunch.types.writable.WritableType extends Object implements Serializable |
---|
Serialized Fields |
---|
Class<T> typeClass
Class<T> writableClass
Converter<K,V,S,T> converter
MapFn<S,T> inputFn
MapFn<S,T> outputFn
DeepCopier<T> deepCopier
List<E> subTypes
boolean initialized
Package org.apache.crunch.util |
---|
Class org.apache.crunch.util.CrunchTool extends org.apache.hadoop.conf.Configured implements Serializable |
---|
|
|||||||||
PREV NEXT | FRAMES NO FRAMES |