This project has retired. For details please refer to its Attic page.

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)