This project has retired. For details please refer to its Attic page.
Writables (Apache Crunch 0.8.0 API)

org.apache.crunch.types.writable
Class Writables

java.lang.Object
  extended by org.apache.crunch.types.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>,org.apache.crunch.types.writable.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,W extends org.apache.hadoop.io.Writable>
WritableType<T,W>
records(Class<T> clazz)
           
static
<T> void
register(Class<T> clazz, WritableType<T,? extends org.apache.hadoop.io.Writable> ptype)
           
static WritableType<String,org.apache.hadoop.io.Text> strings()
           
static
<K,V> org.apache.crunch.types.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
equals, 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,? extends org.apache.hadoop.io.Writable> 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,W extends org.apache.hadoop.io.Writable> WritableType<T,W> 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> org.apache.crunch.types.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>,org.apache.crunch.types.writable.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)


Copyright © 2013 The Apache Software Foundation. All Rights Reserved.