com.cloudera.crunch.type.writable
Class Writables

java.lang.Object
  com.cloudera.crunch.type.writable.Writables

public class Writables
extends Object

Defines static methods that are analogous to the methods defined in WritableTypeFamily for convenient static importing.

Method Summary

static WritableType<Boolean,org.apache.hadoop.io.BooleanWritable>	booleans()
static WritableType<ByteBuffer,org.apache.hadoop.io.BytesWritable>	bytes()
static <T> WritableType<Collection<T>,GenericArrayWritable<T>>	collections(PType<T> ptype)
static <S,T> PType<T>	derived(Class<T> clazz, MapFn<S,T> inputFn, MapFn<T,S> outputFn, PType<S> base)
static WritableType<Double,org.apache.hadoop.io.DoubleWritable>	doubles()
static WritableType<Float,org.apache.hadoop.io.FloatWritable>	floats()
static <T> PType<T>	getPrimitiveType(Class<T> clazz)
static WritableType<Integer,org.apache.hadoop.io.IntWritable>	ints()
static <T> PType<T>	jsons(Class<T> clazz)
static WritableType<Long,org.apache.hadoop.io.LongWritable>	longs()
static <T> WritableType<Map<String,T>,org.apache.hadoop.io.MapWritable>	maps(PType<T> ptype)
static WritableType<Void,org.apache.hadoop.io.NullWritable>	nulls()
static <V1,V2> WritableType<Pair<V1,V2>,TupleWritable>	pairs(PType<V1> p1, PType<V2> p2)
static <V1,V2,V3,V4> WritableType<Tuple4<V1,V2,V3,V4>,TupleWritable>	quads(PType<V1> p1, PType<V2> p2, PType<V3> p3, PType<V4> p4)
static <T> WritableType<T,T>	records(Class<T> clazz)
static <T> void	register(Class<T> clazz, WritableType<T,?> ptype)
static WritableType<String,org.apache.hadoop.io.Text>	strings()
static <K,V> com.cloudera.crunch.type.writable.WritableTableType<K,V>	tableOf(PType<K> key, PType<V> value)
static <V1,V2,V3> WritableType<Tuple3<V1,V2,V3>,TupleWritable>	triples(PType<V1> p1, PType<V2> p2, PType<V3> p3)
static <T extends Tuple> PType<T>	tuples(Class<T> clazz, PType... ptypes)
static WritableType<TupleN,TupleWritable>	tuples(PType... ptypes)
static <W extends org.apache.hadoop.io.Writable> WritableType<W,W>	writables(Class<W> clazz)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

getPrimitiveType

public static <T> PType<T> getPrimitiveType(Class<T> clazz)

register

public static <T> void register(Class<T> clazz,
                                WritableType<T,?> ptype)

nulls

public static final WritableType<Void,org.apache.hadoop.io.NullWritable> nulls()

strings

public static final WritableType<String,org.apache.hadoop.io.Text> strings()

longs

public static final WritableType<Long,org.apache.hadoop.io.LongWritable> longs()

ints

public static final WritableType<Integer,org.apache.hadoop.io.IntWritable> ints()

floats

public static final WritableType<Float,org.apache.hadoop.io.FloatWritable> floats()

doubles

public static final WritableType<Double,org.apache.hadoop.io.DoubleWritable> doubles()

booleans

public static final WritableType<Boolean,org.apache.hadoop.io.BooleanWritable> booleans()

bytes

public static final WritableType<ByteBuffer,org.apache.hadoop.io.BytesWritable> bytes()

records

public static final <T> WritableType<T,T> records(Class<T> clazz)

writables

public static <W extends org.apache.hadoop.io.Writable> WritableType<W,W> writables(Class<W> clazz)

tableOf

public static <K,V> com.cloudera.crunch.type.writable.WritableTableType<K,V> tableOf(PType<K> key,
                                                                                     PType<V> value)

pairs

public static <V1,V2> WritableType<Pair<V1,V2>,TupleWritable> pairs(PType<V1> p1,
                                                                    PType<V2> p2)

triples

public static <V1,V2,V3> WritableType<Tuple3<V1,V2,V3>,TupleWritable> triples(PType<V1> p1,
                                                                              PType<V2> p2,
                                                                              PType<V3> p3)

quads

public static <V1,V2,V3,V4> WritableType<Tuple4<V1,V2,V3,V4>,TupleWritable> quads(PType<V1> p1,
                                                                                  PType<V2> p2,
                                                                                  PType<V3> p3,
                                                                                  PType<V4> p4)

tuples

public static WritableType<TupleN,TupleWritable> tuples(PType... ptypes)

tuples

public static <T extends Tuple> PType<T> tuples(Class<T> clazz,
                                                PType... ptypes)

derived

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

collections

public static <T> WritableType<Collection<T>,GenericArrayWritable<T>> collections(PType<T> ptype)

maps

public static <T> WritableType<Map<String,T>,org.apache.hadoop.io.MapWritable> maps(PType<T> ptype)

jsons

public static <T> PType<T> jsons(Class<T> clazz)