Uses of Class
org.apache.crunch.MapFn

Packages that use MapFn

org.apache.crunch
org.apache.crunch.fn
org.apache.crunch.impl.mem.collect
org.apache.crunch.impl.mr.collect
org.apache.crunch.types
org.apache.crunch.types.avro
org.apache.crunch.types.writable
org.apache.crunch.util

Uses of MapFn in org.apache.crunch

Methods in org.apache.crunch with parameters of type MapFn

<K> PTable<K,S>	PCollection.by(MapFn<S,K> extractKeyFn, PType<K> keyType) Apply the given map function to each element of this instance in order to create a PTable.
<K> PTable<K,S>	PCollection.by(String name, MapFn<S,K> extractKeyFn, PType<K> keyType) Apply the given map function to each element of this instance in order to create a PTable.

Uses of MapFn in org.apache.crunch.fn

Subclasses of MapFn in org.apache.crunch.fn

class	CompositeMapFn<R,S,T>
class	ExtractKeyFn<K,V> Wrapper function for converting a MapFn into a key-value pair that is used to convert from a PCollection<V> to a PTable<K, V>.
class	IdentityFn<T>
class	PairMapFn<K,V,S,T>

Methods in org.apache.crunch.fn that return MapFn

MapFn<R,S>	CompositeMapFn.getFirst()
MapFn<S,T>	CompositeMapFn.getSecond()

Constructors in org.apache.crunch.fn with parameters of type MapFn

CompositeMapFn(MapFn<R,S> first, MapFn<S,T> second)

CompositeMapFn(MapFn<R,S> first, MapFn<S,T> second)

ExtractKeyFn(MapFn<V,K> mapFn)

PairMapFn(MapFn<K,S> keys, MapFn<V,T> values)

PairMapFn(MapFn<K,S> keys, MapFn<V,T> values)

Uses of MapFn in org.apache.crunch.impl.mem.collect

Methods in org.apache.crunch.impl.mem.collect with parameters of type MapFn

<K> PTable<K,S>	MemCollection.by(MapFn<S,K> mapFn, PType<K> keyType)
<K> PTable<K,S>	MemCollection.by(String name, MapFn<S,K> mapFn, PType<K> keyType)

Uses of MapFn in org.apache.crunch.impl.mr.collect

Methods in org.apache.crunch.impl.mr.collect with parameters of type MapFn

<K> PTable<K,S>	PCollectionImpl.by(MapFn<S,K> mapFn, PType<K> keyType)
<K> PTable<K,S>	PCollectionImpl.by(String name, MapFn<S,K> mapFn, PType<K> keyType)

Uses of MapFn in org.apache.crunch.types

Subclasses of MapFn in org.apache.crunch.types

static class

PGroupedTableType.PairIterableMapFn<K,V>

Methods in org.apache.crunch.types that return MapFn

MapFn<Object,T>	PType.getInputMapFn()
MapFn<T,Object>	PType.getOutputMapFn()

Methods in org.apache.crunch.types with parameters of type MapFn

<S,T> PType<T>	PTypeFamily.derived(Class<T> clazz, MapFn<S,T> inputFn, MapFn<T,S> outputFn, PType<S> base)
<S,T> PType<T>	PTypeFamily.derived(Class<T> clazz, MapFn<S,T> inputFn, MapFn<T,S> outputFn, PType<S> base)

Constructors in org.apache.crunch.types with parameters of type MapFn

PGroupedTableType.PairIterableMapFn(MapFn<Object,K> keys, MapFn<Object,V> values)

PGroupedTableType.PairIterableMapFn(MapFn<Object,K> keys, MapFn<Object,V> values)

Uses of MapFn in org.apache.crunch.types.avro

Fields in org.apache.crunch.types.avro declared as MapFn

static MapFn<Object,ByteBuffer>	Avros.BYTES_IN
static MapFn<String,org.apache.avro.util.Utf8>	Avros.STRING_TO_UTF8
static MapFn<CharSequence,String>	Avros.UTF8_TO_STRING

Methods in org.apache.crunch.types.avro that return MapFn

MapFn<Object,T>	AvroType.getInputMapFn()
MapFn	AvroGroupedTableType.getInputMapFn()
MapFn<T,Object>	AvroType.getOutputMapFn()
MapFn	AvroGroupedTableType.getOutputMapFn()

Methods in org.apache.crunch.types.avro with parameters of type MapFn

static <S,T> AvroType<T>	Avros.derived(Class<T> clazz, MapFn<S,T> inputFn, MapFn<T,S> outputFn, PType<S> base)
static <S,T> AvroType<T>	Avros.derived(Class<T> clazz, MapFn<S,T> inputFn, MapFn<T,S> outputFn, PType<S> base)
<S,T> PType<T>	AvroTypeFamily.derived(Class<T> clazz, MapFn<S,T> inputFn, MapFn<T,S> outputFn, PType<S> base)
<S,T> PType<T>	AvroTypeFamily.derived(Class<T> clazz, MapFn<S,T> inputFn, MapFn<T,S> outputFn, PType<S> base)

Constructors in org.apache.crunch.types.avro with parameters of type MapFn

AvroType(Class<T> typeClass, org.apache.avro.Schema schema, MapFn inputMapFn, MapFn outputMapFn, DeepCopier<T> deepCopier, PType... ptypes)

AvroType(Class<T> typeClass, org.apache.avro.Schema schema, MapFn inputMapFn, MapFn outputMapFn, DeepCopier<T> deepCopier, PType... ptypes)

Uses of MapFn in org.apache.crunch.types.writable

Methods in org.apache.crunch.types.writable that return MapFn

MapFn	WritableType.getInputMapFn()
MapFn	WritableGroupedTableType.getInputMapFn()
MapFn	WritableType.getOutputMapFn()
MapFn	WritableGroupedTableType.getOutputMapFn()

Methods in org.apache.crunch.types.writable with parameters of type MapFn

static <S,T> PType<T>	Writables.derived(Class<T> clazz, MapFn<S,T> inputFn, MapFn<T,S> outputFn, PType<S> base)
static <S,T> PType<T>	Writables.derived(Class<T> clazz, MapFn<S,T> inputFn, MapFn<T,S> outputFn, PType<S> base)
<S,T> PType<T>	WritableTypeFamily.derived(Class<T> clazz, MapFn<S,T> inputFn, MapFn<T,S> outputFn, PType<S> base)
<S,T> PType<T>	WritableTypeFamily.derived(Class<T> clazz, MapFn<S,T> inputFn, MapFn<T,S> outputFn, PType<S> base)

Uses of MapFn in org.apache.crunch.util

Subclasses of MapFn in org.apache.crunch.util

static class	Protos.ExtractKeyFn<M extends Message,K>
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.ThriftInputMapFn<T extends TBase>
static class	PTypes.ThriftOutputMapFn<T extends TBase>

Fields in org.apache.crunch.util declared as MapFn

static MapFn<BigInteger,ByteBuffer>	PTypes.BIGINT_TO_BYTE
static MapFn<ByteBuffer,BigInteger>	PTypes.BYTE_TO_BIGINT

Methods in org.apache.crunch.util that return MapFn

static <M extends com.google.protobuf.Message,K> MapFn<M,K>

Protos.extractKey(String fieldName)