Serialized Form (Apache Crunch 0.14.0 API)

Package org.apache.crunch
- Class org.apache.crunch.CombineFn extends DoFn<Pair<S,Iterable<T>>,Pair<S,T>> implements Serializable
- Class org.apache.crunch.CrunchRuntimeException extends RuntimeException implements Serializable
  - Serialized Fields
    - logged
```
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.GroupingOptions extends Object implements Serializable
  - Serialized Fields
    - partitionerClass
```
Class<T> partitionerClass
```
    - groupingComparatorClass
```
Class<T> groupingComparatorClass
```
    - sortComparatorClass
```
Class<T> sortComparatorClass
```
    - requireSortedKeys
```
boolean requireSortedKeys
```
    - numReducers
```
int numReducers
```
    - extraConf
```
Map<K,V> extraConf
```
- Class org.apache.crunch.MapFn extends DoFn<S,T> implements Serializable
- Class org.apache.crunch.Pair extends Object implements Serializable
  - Serialized Fields
    - first
```
Object first
```
    - second
```
Object second
```
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 tokenizerFactory
```
    - errors
```
int errors
```
    - errorOnLast
```
boolean errorOnLast
```
    - extractors
```
List<E> extractors
```
- Class org.apache.crunch.contrib.text.AbstractSimpleExtractor extends Object implements Serializable
  - Serialized Fields
    - errors
```
int errors
```
    - errorOnLast
```
boolean errorOnLast
```
    - defaultValue
```
Object defaultValue
```
    - scannerFactory
```
TokenizerFactory scannerFactory
```
- Class org.apache.crunch.contrib.text.TokenizerFactory extends Object implements Serializable
  - Serialized Fields
    - delim
```
String delim
```
    - skip
```
String skip
```
    - locale
```
Locale locale
```
    - indices
```
Set<E> indices
```
    - keep
```
boolean keep
```
Package org.apache.crunch.examples
- Class org.apache.crunch.examples.AverageBytesByIP extends org.apache.hadoop.conf.Configured implements Serializable
  - Serialized Fields
    - calulateAverage
```
MapFn<S,T> calulateAverage
```
    - extractResponseSize
```
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
    - extractIPResponseSize
```
DoFn<S,T> extractIPResponseSize
```
- Class org.apache.crunch.examples.TotalWordCount extends org.apache.hadoop.conf.Configured implements Serializable
- Class org.apache.crunch.examples.WordAggregationHBase extends org.apache.hadoop.conf.Configured implements Serializable
  - Serialized Fields
    - COLUMN_FAMILY_SOURCE
```
byte[] COLUMN_FAMILY_SOURCE
```
    - COLUMN_QUALIFIER_SOURCE_PLAY
```
byte[] COLUMN_QUALIFIER_SOURCE_PLAY
```
    - COLUMN_QUALIFIER_SOURCE_QUOTE
```
byte[] COLUMN_QUALIFIER_SOURCE_QUOTE
```
    - COLUMN_FAMILY_TARGET
```
byte[] COLUMN_FAMILY_TARGET
```
    - COLUMN_QUALIFIER_TARGET_TEXT
```
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
    - first
```
MapFn<S,T> first
```
    - second
```
MapFn<S,T> second
```
- Class org.apache.crunch.fn.ExtractKeyFn extends MapFn<V,Pair<K,V>> implements Serializable
  - Serialized Fields
    - mapFn
```
MapFn<S,T> mapFn
```
- Class org.apache.crunch.fn.IdentityFn extends MapFn<T,T> implements Serializable
- Class org.apache.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
```
- Class org.apache.crunch.fn.SDoubleFlatMapFunction extends org.apache.crunch.fn.SparkDoFn<T,Double> implements Serializable
- Class org.apache.crunch.fn.SDoubleFunction extends org.apache.crunch.fn.SparkMapFn<T,Double> implements Serializable
- Class org.apache.crunch.fn.SFlatMapFunction extends org.apache.crunch.fn.SparkDoFn<T,R> implements Serializable
- Class org.apache.crunch.fn.SFlatMapFunction2 extends DoFn<Pair<K,V>,R> implements Serializable
- Class org.apache.crunch.fn.SFunction extends org.apache.crunch.fn.SparkMapFn<T,R> implements Serializable
- Class org.apache.crunch.fn.SFunction2 extends org.apache.crunch.fn.SparkMapFn<Pair<K,V>,R> implements Serializable
- Class org.apache.crunch.fn.SPairFlatMapFunction extends org.apache.crunch.fn.SparkDoFn<T,Pair<K,V>> implements Serializable
- Class org.apache.crunch.fn.SPairFunction extends org.apache.crunch.fn.SparkMapFn<T,Pair<K,V>> implements Serializable
- Class org.apache.crunch.fn.SwapFn extends MapFn<Pair<V1,V2>,Pair<V2,V1>> implements Serializable
Package org.apache.crunch.impl.spark
- Class org.apache.crunch.impl.spark.ByteArray extends Object implements Serializable
  - Serialized Fields
    - value
```
byte[] value
```
    - helper
```
ByteArrayHelper helper
```
- Class org.apache.crunch.impl.spark.ByteArrayHelper extends Object implements Serializable
- Class org.apache.crunch.impl.spark.CounterAccumulatorParam extends Object implements Serializable
- Class org.apache.crunch.impl.spark.IntByteArray extends ByteArray implements Serializable
  - Serialized Fields
    - partition
```
int partition
```
- Class org.apache.crunch.impl.spark.SparkComparator extends Object implements Serializable
  - Serialized Fields
    - cmpClass
```
Class<T> cmpClass
```
    - options
```
GroupingOptions options
```
    - ptype
```
PGroupedTableType<K,V> ptype
```
    - ctxt
```
SparkRuntimeContext ctxt
```
- Class org.apache.crunch.impl.spark.SparkPartitioner extends org.apache.spark.Partitioner implements Serializable
  - Serialized Fields
    - numPartitions
```
int numPartitions
```
- Class org.apache.crunch.impl.spark.SparkRuntimeContext extends Object implements Serializable
  - Serialized Fields
    - jobName
```
String jobName
```
    - broadConf
```
org.apache.spark.broadcast.Broadcast<T> broadConf
```
    - counters
```
org.apache.spark.Accumulator<T> counters
```
Package org.apache.crunch.impl.spark.collect
- Class org.apache.crunch.impl.spark.collect.ToByteArrayFunction extends Object implements Serializable
Package org.apache.crunch.impl.spark.fn
- Class org.apache.crunch.impl.spark.fn.CombineMapsideFunction extends Object implements Serializable
  - Serialized Fields
    - combineFn
```
CombineFn<S,T> combineFn
```
    - ctxt
```
SparkRuntimeContext ctxt
```
- Class org.apache.crunch.impl.spark.fn.CrunchPairTuple2 extends Object implements Serializable
- Class org.apache.crunch.impl.spark.fn.FlatMapIndexFn extends Object implements Serializable
  - Serialized Fields
    - fn
```
DoFn<S,T> fn
```
    - convertInput
```
boolean convertInput
```
    - ctxt
```
SparkRuntimeContext ctxt
```
- Class org.apache.crunch.impl.spark.fn.FlatMapPairDoFn extends Object implements Serializable
  - Serialized Fields
    - fn
```
DoFn<S,T> fn
```
    - ctxt
```
SparkRuntimeContext ctxt
```
- Class org.apache.crunch.impl.spark.fn.InputConverterFunction extends Object implements Serializable
  - Serialized Fields
    - converter
```
Converter<K,V,S,T> converter
```
- Class org.apache.crunch.impl.spark.fn.MapFunction extends Object implements Serializable
  - Serialized Fields
    - fn
```
MapFn<S,T> fn
```
    - ctxt
```
SparkRuntimeContext ctxt
```
    - initialized
```
boolean initialized
```
- Class org.apache.crunch.impl.spark.fn.MapOutputFunction extends Object implements Serializable
  - Serialized Fields
    - keySerde
```
SerDe<T> keySerde
```
    - valueSerde
```
SerDe<T> valueSerde
```
- Class org.apache.crunch.impl.spark.fn.OutputConverterFunction extends Object implements Serializable
  - Serialized Fields
    - converter
```
Converter<K,V,S,T> converter
```
- Class org.apache.crunch.impl.spark.fn.PairFlatMapDoFn extends Object implements Serializable
  - Serialized Fields
    - fn
```
DoFn<S,T> fn
```
    - ctxt
```
SparkRuntimeContext ctxt
```
- Class org.apache.crunch.impl.spark.fn.PairMapFunction extends Object implements Serializable
  - Serialized Fields
    - fn
```
MapFn<S,T> fn
```
    - ctxt
```
SparkRuntimeContext ctxt
```
    - initialized
```
boolean initialized
```
- Class org.apache.crunch.impl.spark.fn.PairMapIterableFunction extends Object implements Serializable
  - Serialized Fields
    - fn
```
MapFn<S,T> fn
```
    - runtimeContext
```
SparkRuntimeContext runtimeContext
```
    - initialized
```
boolean initialized
```
- Class org.apache.crunch.impl.spark.fn.PartitionedMapOutputFunction extends Object implements Serializable
  - Serialized Fields
    - keySerde
```
SerDe<T> keySerde
```
    - valueSerde
```
SerDe<T> valueSerde
```
    - ptype
```
PGroupedTableType<K,V> ptype
```
    - numPartitions
```
int numPartitions
```
    - runtimeContext
```
SparkRuntimeContext runtimeContext
```
    - options
```
GroupingOptions options
```
- Class org.apache.crunch.impl.spark.fn.ReduceGroupingFunction extends Object implements Serializable
  - Serialized Fields
    - options
```
GroupingOptions options
```
    - ptype
```
PGroupedTableType<K,V> ptype
```
    - ctxt
```
SparkRuntimeContext ctxt
```
- Class org.apache.crunch.impl.spark.fn.ReduceInputFunction extends Object implements Serializable
  - Serialized Fields
    - keySerDe
```
SerDe<T> keySerDe
```
    - valueSerDe
```
SerDe<T> valueSerDe
```
- Class org.apache.crunch.impl.spark.fn.Tuple2MapFunction extends Object implements Serializable
  - Serialized Fields
    - fn
```
MapFn<S,T> fn
```
    - ctxt
```
SparkRuntimeContext ctxt
```
    - initialized
```
boolean initialized
```
Package org.apache.crunch.impl.spark.serde
- Class org.apache.crunch.impl.spark.serde.AvroSerDe extends Object implements Serializable
  - Serialized Fields
    - avroType
```
AvroType<T> avroType
```
    - modeProperties
```
Map<K,V> modeProperties
```
    - helper
```
ByteArrayHelper helper
```
- Class org.apache.crunch.impl.spark.serde.WritableSerDe extends Object implements Serializable
  - Serialized Fields
    - clazz
```
Class<T> clazz
```
Package org.apache.crunch.io
- Class org.apache.crunch.io.FormatBundle extends Object implements Serializable
  - Serialized Fields
    - formatClass
```
Class<T> formatClass
```
    - extraConf
```
Map<K,V> extraConf
```
    - conf
```
org.apache.hadoop.conf.Configuration conf
```
Package org.apache.crunch.lambda
- Class org.apache.crunch.lambda.LAggregator extends Aggregators.SimpleAggregator<V> implements Serializable
  - Serialized Fields
    - initialSupplier
```
SSupplier<T> initialSupplier
```
    - combineFn
```
SBiFunction<K,V,T> combineFn
```
    - outputFn
```
SFunction<S,T> outputFn
```
    - a
```
Object a
```
Package org.apache.crunch.lambda.fn
Package org.apache.crunch.lib
- Class org.apache.crunch.lib.Aggregate.TopKCombineFn extends CombineFn<Integer,Pair<K,V>> implements Serializable
  - Serialized Fields
    - limit
```
int limit
```
    - maximize
```
boolean maximize
```
    - pairType
```
PType<T> pairType
```
- Class org.apache.crunch.lib.Aggregate.TopKFn extends DoFn<Pair<K,V>,Pair<Integer,Pair<K,V>>> implements Serializable
  - Serialized Fields
    - limit
```
int limit
```
    - maximize
```
boolean maximize
```
    - pairType
```
PType<T> pairType
```
Package org.apache.crunch.lib.join
- Class org.apache.crunch.lib.join.BloomFilterJoinStrategy extends Object implements Serializable
  - Serialized Fields
    - vectorSize
```
int vectorSize
```
    - nbHash
```
int nbHash
```
    - delegateJoinStrategy
```
JoinStrategy<K,U,V> delegateJoinStrategy
```
- Class org.apache.crunch.lib.join.DefaultJoinStrategy extends Object implements Serializable
  - Serialized Fields
    - numReducers
```
int numReducers
```
- 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
    - keyType
```
PType<T> keyType
```
    - leftValueType
```
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
  - Serialized Fields
    - materialize
```
boolean materialize
```
- 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
    - wrappedJoinStrategy
```
JoinStrategy<K,U,V> wrappedJoinStrategy
```
    - shardingStrategy
```
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
    - indices
```
int[] indices
```
    - schemaJson
```
String schemaJson
```
- Class org.apache.crunch.lib.sort.SortFns.SingleKeyFn extends MapFn<V extends Tuple,K> implements Serializable
  - Serialized Fields
    - index
```
int index
```
- Class org.apache.crunch.lib.sort.SortFns.TupleKeyFn extends MapFn<V extends Tuple,K extends Tuple> implements Serializable
  - Serialized Fields
    - indices
```
int[] indices
```
    - tupleFactory
```
TupleFactory<T extends Tuple> tupleFactory
```
Package org.apache.crunch.types
- Class org.apache.crunch.types.CollectionDeepCopier extends Object implements Serializable
  - Serialized Fields
    - elementType
```
PType<T> elementType
```
- Class org.apache.crunch.types.MapDeepCopier extends Object implements Serializable
  - Serialized Fields
    - ptype
```
PType<T> ptype
```
- Class org.apache.crunch.types.NoOpDeepCopier extends Object implements Serializable
- Class org.apache.crunch.types.PGroupedTableType extends Object implements Serializable
  - Serialized Fields
    - tableType
```
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
    - keys
```
MapFn<S,T> keys
```
    - values
```
MapFn<S,T> values
```
- Class org.apache.crunch.types.TupleDeepCopier extends Object implements Serializable
  - Serialized Fields
    - tupleFactory
```
TupleFactory<T extends Tuple> tupleFactory
```
    - elementTypes
```
List<E> elementTypes
```
- Class org.apache.crunch.types.TupleFactory extends Object implements Serializable
- Class org.apache.crunch.types.UnionDeepCopier extends Object implements Serializable
  - Serialized Fields
    - elementTypes
```
List<E> elementTypes
```
Package org.apache.crunch.types.avro
- Class org.apache.crunch.types.avro.AvroDeepCopier.AvroByteBufferDeepCopier extends Object implements Serializable
- 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
- Class org.apache.crunch.types.avro.AvroDeepCopier.AvroSpecificDeepCopier extends org.apache.crunch.types.avro.AvroDeepCopier<T> implements Serializable
- Class org.apache.crunch.types.avro.AvroDerivedValueDeepCopier extends Object implements Serializable
  - Serialized Fields
    - derivedToAvroFn
```
MapFn<S,T> derivedToAvroFn
```
    - avroToDerivedFn
```
MapFn<S,T> avroToDerivedFn
```
    - avroBaseType
```
AvroType<T> avroBaseType
```
- Class org.apache.crunch.types.avro.AvroType extends Object implements Serializable
  - Serialized Fields
    - typeClass
```
Class<T> typeClass
```
    - schemaString
```
String schemaString
```
    - baseInputMapFn
```
MapFn<S,T> baseInputMapFn
```
    - baseOutputMapFn
```
MapFn<S,T> baseOutputMapFn
```
    - subTypes
```
List<E> subTypes
```
    - recordType
```
AvroType.AvroRecordType recordType
```
    - deepCopier
```
DeepCopier<T> deepCopier
```
Package org.apache.crunch.types.writable
- Class org.apache.crunch.types.writable.WritableDeepCopier extends Object implements Serializable
  - Serialized Fields
    - writableClass
```
Class<T> writableClass
```
- Class org.apache.crunch.types.writable.WritableType extends Object implements Serializable
  - Serialized Fields
    - typeClass
```
Class<T> typeClass
```
    - writableClass
```
Class<T> writableClass
```
    - converter
```
Converter<K,V,S,T> converter
```
    - inputFn
```
MapFn<S,T> inputFn
```
    - outputFn
```
MapFn<S,T> outputFn
```
    - deepCopier
```
DeepCopier<T> deepCopier
```
    - subTypes
```
List<E> subTypes
```
    - initialized
```
boolean initialized
```
Package org.apache.crunch.util
- Class org.apache.crunch.util.CrunchTool extends org.apache.hadoop.conf.Configured implements Serializable
- Class org.apache.crunch.util.DelegatingReadableData extends Object implements Serializable
  - Serialized Fields
    - delegate
```
ReadableData<T> delegate
```
    - fn
```
DoFn<S,T> fn
```
- Class org.apache.crunch.util.UnionReadableData extends Object implements Serializable
  - Serialized Fields
    - data
```
List<E> data
```
Package org.apache.hadoop.mapred
- Class org.apache.hadoop.mapred.Counters.CountersExceededException extends RuntimeException implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.hadoop.mapred.FileAlreadyExistsException extends IOException implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.hadoop.mapred.InvalidFileTypeException extends IOException implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.hadoop.mapred.InvalidInputException extends IOException implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - problems
```
List<E> problems
```
- Class org.apache.hadoop.mapred.InvalidJobConfException extends IOException implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.hadoop.mapred.NotificationTestCase.NotificationServlet extends javax.servlet.http.HttpServlet implements Serializable
  
  serialVersionUID:
  
  1L

Serialized Form

Package org.apache.crunch

Class org.apache.crunch.CombineFn extends DoFn<Pair<S,Iterable<T>>,Pair<S,T>> implements Serializable

Class org.apache.crunch.CrunchRuntimeException extends RuntimeException implements Serializable

Serialized Fields

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.GroupingOptions extends Object implements Serializable

Serialized Fields

partitionerClass

groupingComparatorClass

sortComparatorClass

requireSortedKeys

numReducers

extraConf

Class org.apache.crunch.MapFn extends DoFn<S,T> implements Serializable

Class org.apache.crunch.Pair extends Object implements Serializable

Serialized Fields

first

second

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

errors

errorOnLast

extractors

Class org.apache.crunch.contrib.text.AbstractSimpleExtractor extends Object implements Serializable

Serialized Fields

errors

errorOnLast

defaultValue

scannerFactory

Class org.apache.crunch.contrib.text.TokenizerFactory extends Object implements Serializable

Serialized Fields

delim

skip

locale

indices

keep

Package org.apache.crunch.examples

Class org.apache.crunch.examples.AverageBytesByIP extends org.apache.hadoop.conf.Configured implements Serializable

Serialized Fields

calulateAverage

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

extractIPResponseSize

Class org.apache.crunch.examples.TotalWordCount extends org.apache.hadoop.conf.Configured implements Serializable

Class org.apache.crunch.examples.WordAggregationHBase extends org.apache.hadoop.conf.Configured implements Serializable

Serialized Fields

COLUMN_FAMILY_SOURCE

COLUMN_QUALIFIER_SOURCE_PLAY

COLUMN_QUALIFIER_SOURCE_QUOTE

COLUMN_FAMILY_TARGET

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

first

second

Class org.apache.crunch.fn.ExtractKeyFn extends MapFn<V,Pair<K,V>> implements Serializable

Serialized Fields

mapFn

Class org.apache.crunch.fn.IdentityFn extends MapFn<T,T> implements Serializable

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

Serialized Fields

keys

values

Class org.apache.crunch.fn.SDoubleFlatMapFunction extends org.apache.crunch.fn.SparkDoFn<T,Double> implements Serializable

Class org.apache.crunch.fn.SDoubleFunction extends org.apache.crunch.fn.SparkMapFn<T,Double> implements Serializable

Class org.apache.crunch.fn.SFlatMapFunction extends org.apache.crunch.fn.SparkDoFn<T,R> implements Serializable

Class org.apache.crunch.fn.SFlatMapFunction2 extends DoFn<Pair<K,V>,R> implements Serializable