A C D G L O P R S

A

accept(Class<?>) - Method in class com.twitter.elephantbird.cascading2.io.protobuf.ProtobufSerialization

C

close() - Method in class com.twitter.elephantbird.cascading2.io.protobuf.ProtobufDeserializer

close() - Method in class com.twitter.elephantbird.cascading2.io.protobuf.ProtobufSerializer

com.twitter.elephantbird.cascading2.io.protobuf - package com.twitter.elephantbird.cascading2.io.protobuf

com.twitter.elephantbird.cascading2.scheme - package com.twitter.elephantbird.cascading2.scheme

CombinedSequenceFile - Class in com.twitter.elephantbird.cascading2.scheme

This scheme allows SequenceFile splits to be combined via the DelegateCombineFileInputFormat before it is read.

CombinedSequenceFile() - Constructor for class com.twitter.elephantbird.cascading2.scheme.CombinedSequenceFile

CombinedSequenceFile(Fields) - Constructor for class com.twitter.elephantbird.cascading2.scheme.CombinedSequenceFile

compare(BufferedInputStream, BufferedInputStream) - Method in class com.twitter.elephantbird.cascading2.io.protobuf.ProtobufComparator

compare(Message, Message) - Method in class com.twitter.elephantbird.cascading2.io.protobuf.ProtobufComparator

D

deserialize(Message) - Method in class com.twitter.elephantbird.cascading2.io.protobuf.ProtobufDeserializer

G

getComparator(Class<Message>) - Method in class com.twitter.elephantbird.cascading2.io.protobuf.ProtobufSerialization

getDeserializer(Class<Message>) - Method in class com.twitter.elephantbird.cascading2.io.protobuf.ProtobufSerialization

getSerializer(Class<Message>) - Method in class com.twitter.elephantbird.cascading2.io.protobuf.ProtobufSerialization

L

LzoBinaryScheme<M,T extends BinaryWritable<M>> - Class in com.twitter.elephantbird.cascading2.scheme

Scheme for lzo binary encoded files.

LzoBinaryScheme() - Constructor for class com.twitter.elephantbird.cascading2.scheme.LzoBinaryScheme

LzoByteArrayScheme - Class in com.twitter.elephantbird.cascading2.scheme

Scheme for lzo compressed files with binary records.

LzoByteArrayScheme() - Constructor for class com.twitter.elephantbird.cascading2.scheme.LzoByteArrayScheme

LzoProtobufB64LineScheme<M extends com.google.protobuf.Message> - Class in com.twitter.elephantbird.cascading2.scheme

Deprecated. please use LzoProtobufScheme

LzoProtobufB64LineScheme(Class) - Constructor for class com.twitter.elephantbird.cascading2.scheme.LzoProtobufB64LineScheme

Deprecated.

LzoProtobufBlockScheme<M extends com.google.protobuf.Message> - Class in com.twitter.elephantbird.cascading2.scheme

Deprecated. please use LzoProtobufScheme

LzoProtobufBlockScheme(Class) - Constructor for class com.twitter.elephantbird.cascading2.scheme.LzoProtobufBlockScheme

Deprecated.

LzoProtobufScheme<M extends com.google.protobuf.Message> - Class in com.twitter.elephantbird.cascading2.scheme

Scheme for Protobuf lzo compressed files.

LzoProtobufScheme(Class) - Constructor for class com.twitter.elephantbird.cascading2.scheme.LzoProtobufScheme

LzoTextDelimited - Class in com.twitter.elephantbird.cascading2.scheme

Scheme for LZO encoded TSV files.

LzoTextDelimited(Fields, String) - Constructor for class com.twitter.elephantbird.cascading2.scheme.LzoTextDelimited

LzoTextDelimited(Fields, boolean, String) - Constructor for class com.twitter.elephantbird.cascading2.scheme.LzoTextDelimited

LzoTextDelimited(Fields, String, Class[]) - Constructor for class com.twitter.elephantbird.cascading2.scheme.LzoTextDelimited

LzoTextDelimited(Fields, boolean, String, Class[]) - Constructor for class com.twitter.elephantbird.cascading2.scheme.LzoTextDelimited

LzoTextDelimited(Fields, String, String, Class[]) - Constructor for class com.twitter.elephantbird.cascading2.scheme.LzoTextDelimited

LzoTextDelimited(Fields, boolean, String, String, Class[]) - Constructor for class com.twitter.elephantbird.cascading2.scheme.LzoTextDelimited

LzoTextDelimited(Fields, String, String, Class[], boolean) - Constructor for class com.twitter.elephantbird.cascading2.scheme.LzoTextDelimited

LzoTextDelimited(Fields, boolean, boolean, String, boolean, String, Class[], boolean) - Constructor for class com.twitter.elephantbird.cascading2.scheme.LzoTextDelimited

LzoTextDelimited(Fields, boolean, String, String, Class[], boolean) - Constructor for class com.twitter.elephantbird.cascading2.scheme.LzoTextDelimited

LzoTextDelimited(Fields, String, String) - Constructor for class com.twitter.elephantbird.cascading2.scheme.LzoTextDelimited

LzoTextDelimited(Fields, boolean, String, String) - Constructor for class com.twitter.elephantbird.cascading2.scheme.LzoTextDelimited

LzoTextLine - Class in com.twitter.elephantbird.cascading2.scheme

Scheme for LZO encoded text files.

LzoTextLine() - Constructor for class com.twitter.elephantbird.cascading2.scheme.LzoTextLine

LzoTextLine(int) - Constructor for class com.twitter.elephantbird.cascading2.scheme.LzoTextLine

LzoTextLine(Fields, Fields) - Constructor for class com.twitter.elephantbird.cascading2.scheme.LzoTextLine

LzoTextLine(Fields, Fields, int) - Constructor for class com.twitter.elephantbird.cascading2.scheme.LzoTextLine

LzoTextLine(Fields) - Constructor for class com.twitter.elephantbird.cascading2.scheme.LzoTextLine

LzoTextLine(Fields, int) - Constructor for class com.twitter.elephantbird.cascading2.scheme.LzoTextLine

LzoThriftB64LineScheme<M extends org.apache.thrift.TBase<?,?>> - Class in com.twitter.elephantbird.cascading2.scheme

Deprecated. please use LzoThriftScheme

LzoThriftB64LineScheme(Class) - Constructor for class com.twitter.elephantbird.cascading2.scheme.LzoThriftB64LineScheme

Deprecated.

LzoThriftScheme<M extends org.apache.thrift.TBase<?,?>> - Class in com.twitter.elephantbird.cascading2.scheme

Scheme for Thrift lzo compressed files.

LzoThriftScheme(Class) - Constructor for class com.twitter.elephantbird.cascading2.scheme.LzoThriftScheme

O

open(InputStream) - Method in class com.twitter.elephantbird.cascading2.io.protobuf.ProtobufDeserializer

open(OutputStream) - Method in class com.twitter.elephantbird.cascading2.io.protobuf.ProtobufSerializer

P

parseMessage(Method, InputStream) - Static method in class com.twitter.elephantbird.cascading2.io.protobuf.ProtobufReflectionUtil

Parse the message in a given InputStream using scpecified Method

parseMessage(Class<Message>, InputStream) - Static method in class com.twitter.elephantbird.cascading2.io.protobuf.ProtobufReflectionUtil

Parse the message in a given Message container

parseMethodFor(Class<Message>) - Static method in class com.twitter.elephantbird.cascading2.io.protobuf.ProtobufReflectionUtil

Parse the method for a message

prepareBinaryWritable() - Method in class com.twitter.elephantbird.cascading2.scheme.LzoBinaryScheme

prepareBinaryWritable() - Method in class com.twitter.elephantbird.cascading2.scheme.LzoByteArrayScheme

prepareBinaryWritable() - Method in class com.twitter.elephantbird.cascading2.scheme.LzoProtobufScheme

prepareBinaryWritable() - Method in class com.twitter.elephantbird.cascading2.scheme.LzoThriftScheme

ProtobufComparator - Class in com.twitter.elephantbird.cascading2.io.protobuf

Comparator for protobufs

ProtobufComparator() - Constructor for class com.twitter.elephantbird.cascading2.io.protobuf.ProtobufComparator

ProtobufDeserializer - Class in com.twitter.elephantbird.cascading2.io.protobuf

Deserializes delimited protobufs from input stream

ProtobufDeserializer(Class<Message>) - Constructor for class com.twitter.elephantbird.cascading2.io.protobuf.ProtobufDeserializer

ProtobufReflectionUtil - Class in com.twitter.elephantbird.cascading2.io.protobuf

Utility methods for reflection based protobuf deserialization

ProtobufSerialization - Class in com.twitter.elephantbird.cascading2.io.protobuf

Serialization format class

ProtobufSerialization() - Constructor for class com.twitter.elephantbird.cascading2.io.protobuf.ProtobufSerialization

ProtobufSerializer - Class in com.twitter.elephantbird.cascading2.io.protobuf

Serializes protobufs with delimiters

ProtobufSerializer() - Constructor for class com.twitter.elephantbird.cascading2.io.protobuf.ProtobufSerializer

R

readFully(InputStream, ByteArrayOutputStream, byte[]) - Static method in class com.twitter.elephantbird.cascading2.io.protobuf.ProtobufComparator

Method used to read a protobuf input stream into a byte array

S

serialize(Message) - Method in class com.twitter.elephantbird.cascading2.io.protobuf.ProtobufSerializer

sink(FlowProcess<JobConf>, SinkCall<T, OutputCollector>) - Method in class com.twitter.elephantbird.cascading2.scheme.LzoBinaryScheme

sinkConfInit(FlowProcess<JobConf>, Tap<JobConf, RecordReader, OutputCollector>, JobConf) - Method in class com.twitter.elephantbird.cascading2.scheme.LzoByteArrayScheme

sinkConfInit(FlowProcess<JobConf>, Tap<JobConf, RecordReader, OutputCollector>, JobConf) - Method in class com.twitter.elephantbird.cascading2.scheme.LzoProtobufScheme

sinkConfInit(FlowProcess<JobConf>, Tap<JobConf, RecordReader, OutputCollector>, JobConf) - Method in class com.twitter.elephantbird.cascading2.scheme.LzoTextDelimited

sinkConfInit(FlowProcess<JobConf>, Tap<JobConf, RecordReader, OutputCollector>, JobConf) - Method in class com.twitter.elephantbird.cascading2.scheme.LzoTextLine

sinkConfInit(FlowProcess<JobConf>, Tap<JobConf, RecordReader, OutputCollector>, JobConf) - Method in class com.twitter.elephantbird.cascading2.scheme.LzoThriftScheme

sinkPrepare(FlowProcess<JobConf>, SinkCall<T, OutputCollector>) - Method in class com.twitter.elephantbird.cascading2.scheme.LzoBinaryScheme

source(FlowProcess<JobConf>, SourceCall<Object[], RecordReader>) - Method in class com.twitter.elephantbird.cascading2.scheme.LzoBinaryScheme

sourceCleanup(FlowProcess<JobConf>, SourceCall<Object[], RecordReader>) - Method in class com.twitter.elephantbird.cascading2.scheme.LzoBinaryScheme

sourceConfInit(FlowProcess<JobConf>, Tap<JobConf, RecordReader, OutputCollector>, JobConf) - Method in class com.twitter.elephantbird.cascading2.scheme.CombinedSequenceFile

sourceConfInit(FlowProcess<JobConf>, Tap<JobConf, RecordReader, OutputCollector>, JobConf) - Method in class com.twitter.elephantbird.cascading2.scheme.LzoByteArrayScheme

sourceConfInit(FlowProcess<JobConf>, Tap<JobConf, RecordReader, OutputCollector>, JobConf) - Method in class com.twitter.elephantbird.cascading2.scheme.LzoProtobufScheme

sourceConfInit(FlowProcess<JobConf>, Tap<JobConf, RecordReader, OutputCollector>, JobConf) - Method in class com.twitter.elephantbird.cascading2.scheme.LzoTextDelimited

sourceConfInit(FlowProcess<JobConf>, Tap<JobConf, RecordReader, OutputCollector>, JobConf) - Method in class com.twitter.elephantbird.cascading2.scheme.LzoTextLine

sourceConfInit(FlowProcess<JobConf>, Tap<JobConf, RecordReader, OutputCollector>, JobConf) - Method in class com.twitter.elephantbird.cascading2.scheme.LzoThriftScheme

sourcePrepare(FlowProcess<JobConf>, SourceCall<Object[], RecordReader>) - Method in class com.twitter.elephantbird.cascading2.scheme.LzoBinaryScheme

This sets up the state between succesive calls to source

A C D G L O P R S