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	Client-facing API and core abstractions.
org.apache.crunch.fn	Commonly used functions for manipulating collections.
org.apache.crunch.types	Common functionality for business object serialization.
org.apache.crunch.types.avro	Business object serialization using Apache Avro.
org.apache.crunch.types.writable	Business object serialization using Hadoop's Writables framework.

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.types

Subclasses of MapFn in org.apache.crunch.types

static class	PGroupedTableType.PairIterableMapFn<K,V>
static class	Protos.ExtractKeyFn<M extends Message,K>
static class	PTypes.EnumInputMapper<T extends Enum>
static class	PTypes.EnumOutputMapper<T extends Enum>
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.types declared as MapFn

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

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

static <M extends com.google.protobuf.Message,K> MapFn<M,K>	Protos.extractKey(String fieldName)
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)