This project has retired. For details please refer to its Attic page.

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)