org.apache.crunch.types

Class PTypes

java.lang.Object

org.apache.crunch.types.PTypes

public class PTypes
extends Object

Utility functions for creating common types of derived PTypes, e.g., for JSON data, protocol buffers, and Thrift records.

Field Summary

Fields

Modifier and Type	Field and Description
static MapFn<BigInteger,ByteBuffer>	BIGINT_TO_BYTE
static MapFn<ByteBuffer,BigInteger>	BYTE_TO_BIGINT

Constructor Summary

Constructors

Constructor and Description
PTypes()

Method Summary

Methods

Modifier and Type	Method and Description
static PType<BigInteger>	bigInt(PTypeFamily typeFamily)
static <T extends Enum> PType<T>	enums(Class<T> type, PTypeFamily typeFamily)
static <T> PType<T>	jsonString(Class<T> clazz, PTypeFamily typeFamily)
static <T extends com.google.protobuf.Message> PType<T>	protos(Class<T> clazz, PTypeFamily typeFamily)
static <T extends org.apache.thrift.TBase> PType<T>	thrifts(Class<T> clazz, PTypeFamily typeFamily)

Methods inherited from class java.lang.Object

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

Field Detail

BYTE_TO_BIGINT

public static MapFn<ByteBuffer,BigInteger> BYTE_TO_BIGINT

BIGINT_TO_BYTE

public static MapFn<BigInteger,ByteBuffer> BIGINT_TO_BYTE

Constructor Detail

PTypes

public PTypes()

Method Detail

bigInt

public static PType<BigInteger> bigInt(PTypeFamily typeFamily)

jsonString

public static <T> PType<T> jsonString(Class<T> clazz,
                      PTypeFamily typeFamily)

protos

public static <T extends com.google.protobuf.Message> PType<T> protos(Class<T> clazz,
                                                      PTypeFamily typeFamily)

thrifts

public static <T extends org.apache.thrift.TBase> PType<T> thrifts(Class<T> clazz,
                                                   PTypeFamily typeFamily)

enums

public static final <T extends Enum> PType<T> enums(Class<T> type,
                              PTypeFamily typeFamily)