org.apache.crunch.util
Class Protos

java.lang.Object
  org.apache.crunch.util.Protos

public class Protos
extends Object

Utility functions for working with protocol buffers in Crunch.

Nested Class Summary

static class	Protos.ExtractKeyFn<M extends com.google.protobuf.Message,K>
static class	Protos.TextToProtoFn<M extends com.google.protobuf.Message>

Constructor Summary

Protos()

Method Summary

static <M extends com.google.protobuf.Message,K> MapFn<M,K>	extractKey(String fieldName)
static <M extends com.google.protobuf.Message> DoFn<String,M>	lineParser(String sep, Class<M> msgClass)

Methods inherited from class java.lang.Object

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

Constructor Detail

Protos

public Protos()

Method Detail

extractKey

public static <M extends com.google.protobuf.Message,K> MapFn<M,K> extractKey(String fieldName)

lineParser

public static <M extends com.google.protobuf.Message> DoFn<String,M> lineParser(String sep,
                                                                                Class<M> msgClass)