C D E G H I L M N O P R S T V W

C

close() - Method in class com.twitter.maple.hbase.HBaseTapCollector

close() - Method in class com.twitter.maple.tap.TupleMemoryInputFormat.TupleRecordReader

collect(Object, Object) - Method in class com.twitter.maple.hbase.HBaseTapCollector

Method collect writes the given values to the Tap this instance encapsulates.

COLUMN_LIST - Static variable in class com.twitter.maple.hbase.mapred.TableInputFormat

space delimited list of columns

com.etsy.cascading.tap.local - package com.etsy.cascading.tap.local

com.twitter.maple.hbase - package com.twitter.maple.hbase

com.twitter.maple.hbase.mapred - package com.twitter.maple.hbase.mapred

com.twitter.maple.tap - package com.twitter.maple.tap

commitResource(JobConf) - Method in class com.twitter.maple.tap.MemorySinkTap

commitResource(JobConf) - Method in class com.twitter.maple.tap.StdoutTap

configure(JobConf) - Method in class com.twitter.maple.hbase.mapred.TableInputFormat

createKey() - Method in class com.twitter.maple.tap.TupleMemoryInputFormat.TupleRecordReader

createResource(Properties) - Method in class com.etsy.cascading.tap.local.LocalTap

createResource(JobConf) - Method in class com.twitter.maple.hbase.HBaseTap

createValue() - Method in class com.twitter.maple.tap.TupleMemoryInputFormat.TupleRecordReader

D

decodeBytes(String) - Static method in class com.twitter.maple.tap.TupleMemoryInputFormat

deleteResource(Properties) - Method in class com.etsy.cascading.tap.local.LocalTap

deleteResource(JobConf) - Method in class com.twitter.maple.hbase.HBaseTap

E

encodeBytes(byte[]) - Static method in class com.twitter.maple.tap.TupleMemoryInputFormat

ENCODING - Static variable in class com.twitter.maple.tap.TupleMemoryInputFormat

equals(Object) - Method in class com.etsy.cascading.tap.local.LocalTap

equals(Object) - Method in class com.twitter.maple.hbase.HBaseScheme

equals(Object) - Method in class com.twitter.maple.hbase.HBaseTap

equals(Object) - Method in class com.twitter.maple.tap.MemorySourceTap

G

getFamilyNames() - Method in class com.twitter.maple.hbase.HBaseScheme

Method getFamilyNames returns the set of familyNames of this HBaseScheme object.

getHBaseAdmin(JobConf) - Method in class com.twitter.maple.hbase.HBaseTap

getId() - Method in class com.twitter.maple.tap.MemorySourceTap.MemorySourceScheme

getIdentifier() - Method in class com.etsy.cascading.tap.local.LocalTap

getIdentifier() - Method in class com.twitter.maple.hbase.HBaseTap

getIdentifier() - Method in class com.twitter.maple.tap.MemorySourceTap

getLength() - Method in class com.twitter.maple.tap.TupleMemoryInputFormat.TupleInputSplit

getLocations() - Method in class com.twitter.maple.tap.TupleMemoryInputFormat.TupleInputSplit

getModifiedTime(Properties) - Method in class com.etsy.cascading.tap.local.LocalTap

getModifiedTime(JobConf) - Method in class com.twitter.maple.hbase.HBaseTap

getModifiedTime(JobConf) - Method in class com.twitter.maple.tap.MemorySourceTap

getPath() - Method in class com.twitter.maple.hbase.HBaseTap

getPath() - Method in class com.twitter.maple.tap.MemorySourceTap

getPos() - Method in class com.twitter.maple.tap.TupleMemoryInputFormat.TupleRecordReader

getProgress() - Method in class com.twitter.maple.tap.TupleMemoryInputFormat.TupleRecordReader

getRecordReader(InputSplit, JobConf, Reporter) - Method in class com.twitter.maple.tap.TupleMemoryInputFormat

getSplits(JobConf, int) - Method in class com.twitter.maple.tap.TupleMemoryInputFormat

getTableName() - Method in class com.twitter.maple.hbase.HBaseTap

Method getTableName returns the tableName of this HBaseTap object.

getTableName(JobConf) - Static method in class com.twitter.maple.hbase.mapred.TableInputFormat

getTempDir() - Static method in class com.twitter.maple.tap.MemorySinkTap

getTempDir() - Static method in class com.twitter.maple.tap.StdoutTap

getTuples() - Method in class com.twitter.maple.tap.MemorySourceTap.MemorySourceScheme

H

hashCode() - Method in class com.etsy.cascading.tap.local.LocalTap

hashCode() - Method in class com.twitter.maple.hbase.HBaseScheme

hashCode() - Method in class com.twitter.maple.hbase.HBaseTap

HBaseScheme - Class in com.twitter.maple.hbase

The HBaseScheme class is a Scheme subclass.

HBaseScheme(Fields, String, Fields) - Constructor for class com.twitter.maple.hbase.HBaseScheme

Constructor HBaseScheme creates a new HBaseScheme instance.

HBaseScheme(Fields, String[], Fields[]) - Constructor for class com.twitter.maple.hbase.HBaseScheme

Constructor HBaseScheme creates a new HBaseScheme instance.

HBaseScheme(Fields, Fields) - Constructor for class com.twitter.maple.hbase.HBaseScheme

Constructor HBaseScheme creates a new HBaseScheme instance using fully qualified column names

HBaseScheme(Fields, Fields[]) - Constructor for class com.twitter.maple.hbase.HBaseScheme

Constructor HBaseScheme creates a new HBaseScheme instance using fully qualified column names

HBaseTap - Class in com.twitter.maple.hbase

The HBaseTap class is a Tap subclass.

HBaseTap(String, HBaseScheme) - Constructor for class com.twitter.maple.hbase.HBaseTap

Constructor HBaseTap creates a new HBaseTap instance.

HBaseTap(String, HBaseScheme, SinkMode) - Constructor for class com.twitter.maple.hbase.HBaseTap

Constructor HBaseTap creates a new HBaseTap instance.

HBaseTap(String, String, HBaseScheme) - Constructor for class com.twitter.maple.hbase.HBaseTap

Constructor HBaseTap creates a new HBaseTap instance.

HBaseTap(String, String, HBaseScheme, SinkMode) - Constructor for class com.twitter.maple.hbase.HBaseTap

Constructor HBaseTap creates a new HBaseTap instance.

HBaseTapCollector - Class in com.twitter.maple.hbase

Class HBaseTapCollector is a kind of TupleEntrySchemeCollector that writes tuples to the resource managed by a particular HBaseTap instance.

HBaseTapCollector(FlowProcess<JobConf>, Tap<JobConf, RecordReader, OutputCollector>) - Constructor for class com.twitter.maple.hbase.HBaseTapCollector

Constructor TapCollector creates a new TapCollector instance.

I

INPUT_TABLE - Static variable in class com.twitter.maple.hbase.mapred.TableInputFormat

Use this jobconf param to specify the input table

L

LocalTap<SourceCtx,SinkCtx> - Class in com.etsy.cascading.tap.local

A shunt around the restrictions on taps that can run under the LocalFlowProcess.

LocalTap(String, Scheme<JobConf, RecordReader, OutputCollector, SourceCtx, SinkCtx>, SinkMode) - Constructor for class com.etsy.cascading.tap.local.LocalTap

LocalTap(String, Scheme<JobConf, RecordReader, OutputCollector, SourceCtx, SinkCtx>) - Constructor for class com.etsy.cascading.tap.local.LocalTap

M

MemorySinkTap - Class in com.twitter.maple.tap

MemorySinkTap(List<Tuple>, Fields) - Constructor for class com.twitter.maple.tap.MemorySinkTap

MemorySinkTap(List<Tuple>) - Constructor for class com.twitter.maple.tap.MemorySinkTap

MemorySourceScheme(List<Tuple>, Fields, String) - Constructor for class com.twitter.maple.tap.MemorySourceTap.MemorySourceScheme

MemorySourceTap - Class in com.twitter.maple.tap

MemorySourceTap(List<Tuple>, Fields) - Constructor for class com.twitter.maple.tap.MemorySourceTap

MemorySourceTap.MemorySourceScheme - Class in com.twitter.maple.tap

N

next(TupleWrapper, NullWritable) - Method in class com.twitter.maple.tap.TupleMemoryInputFormat.TupleRecordReader

numTuples - Variable in class com.twitter.maple.tap.TupleMemoryInputFormat.TupleInputSplit

O

openForRead(FlowProcess<Properties>, RecordReader) - Method in class com.etsy.cascading.tap.local.LocalTap

openForRead(FlowProcess<JobConf>, RecordReader) - Method in class com.twitter.maple.hbase.HBaseTap

openForRead(FlowProcess<JobConf>, RecordReader<TupleWrapper, NullWritable>) - Method in class com.twitter.maple.tap.MemorySourceTap

openForWrite(FlowProcess<Properties>, OutputCollector) - Method in class com.etsy.cascading.tap.local.LocalTap

openForWrite(FlowProcess<JobConf>, OutputCollector) - Method in class com.twitter.maple.hbase.HBaseTap

P

prepare() - Method in class com.twitter.maple.hbase.HBaseTapCollector

R

readFields(DataInput) - Method in class com.twitter.maple.tap.TupleMemoryInputFormat.TupleInputSplit

resourceExists(Properties) - Method in class com.etsy.cascading.tap.local.LocalTap

resourceExists(JobConf) - Method in class com.twitter.maple.hbase.HBaseTap

resourceExists(JobConf) - Method in class com.twitter.maple.tap.MemorySourceTap

retrieveTuples(JobConf, String) - Static method in class com.twitter.maple.tap.TupleMemoryInputFormat

S

SCHEME - Static variable in class com.twitter.maple.hbase.HBaseTap

Field SCHEME

setTableName(JobConf, String) - Static method in class com.twitter.maple.hbase.mapred.TableInputFormat

sink(FlowProcess<JobConf>, SinkCall<Object[], OutputCollector>) - Method in class com.twitter.maple.hbase.HBaseScheme

sink(FlowProcess<JobConf>, SinkCall<Void, Void>) - Method in class com.twitter.maple.tap.MemorySourceTap.MemorySourceScheme

sinkConfInit(FlowProcess<JobConf>, Tap<JobConf, RecordReader, OutputCollector>, JobConf) - Method in class com.twitter.maple.hbase.HBaseScheme

sinkConfInit(FlowProcess<JobConf>, JobConf) - Method in class com.twitter.maple.hbase.HBaseTap

sinkConfInit(FlowProcess<JobConf>, Tap<JobConf, RecordReader<TupleWrapper, NullWritable>, Void>, JobConf) - Method in class com.twitter.maple.tap.MemorySourceTap.MemorySourceScheme

source(FlowProcess<JobConf>, SourceCall<Object[], RecordReader>) - Method in class com.twitter.maple.hbase.HBaseScheme

source(FlowProcess<JobConf>, SourceCall<Object[], RecordReader<TupleWrapper, NullWritable>>) - Method in class com.twitter.maple.tap.MemorySourceTap.MemorySourceScheme

sourceCleanup(FlowProcess<JobConf>, SourceCall<Object[], RecordReader>) - Method in class com.twitter.maple.hbase.HBaseScheme

sourceCleanup(FlowProcess<JobConf>, SourceCall<Object[], RecordReader<TupleWrapper, NullWritable>>) - Method in class com.twitter.maple.tap.MemorySourceTap.MemorySourceScheme

sourceConfInit(FlowProcess<JobConf>, Tap<JobConf, RecordReader, OutputCollector>, JobConf) - Method in class com.twitter.maple.hbase.HBaseScheme

sourceConfInit(FlowProcess<JobConf>, JobConf) - Method in class com.twitter.maple.hbase.HBaseTap

sourceConfInit(FlowProcess<JobConf>, Tap<JobConf, RecordReader<TupleWrapper, NullWritable>, Void>, JobConf) - Method in class com.twitter.maple.tap.MemorySourceTap.MemorySourceScheme

sourcePrepare(FlowProcess<JobConf>, SourceCall<Object[], RecordReader>) - Method in class com.twitter.maple.hbase.HBaseScheme

sourcePrepare(FlowProcess<JobConf>, SourceCall<Object[], RecordReader<TupleWrapper, NullWritable>>) - Method in class com.twitter.maple.tap.MemorySourceTap.MemorySourceScheme

StdoutTap - Class in com.twitter.maple.tap

StdoutTap() - Constructor for class com.twitter.maple.tap.StdoutTap

storeTuples(JobConf, String, List<Tuple>) - Static method in class com.twitter.maple.tap.TupleMemoryInputFormat

T

TableInputFormat - Class in com.twitter.maple.hbase.mapred

Convert HBase tabular data into a format that is consumable by Map/Reduce.

TableInputFormat() - Constructor for class com.twitter.maple.hbase.mapred.TableInputFormat

toString() - Method in class com.etsy.cascading.tap.local.LocalTap

tuple - Variable in class com.twitter.maple.tap.TupleWrapper

TupleInputSplit() - Constructor for class com.twitter.maple.tap.TupleMemoryInputFormat.TupleInputSplit

TupleInputSplit(int) - Constructor for class com.twitter.maple.tap.TupleMemoryInputFormat.TupleInputSplit

TupleMemoryInputFormat - Class in com.twitter.maple.tap

TupleMemoryInputFormat() - Constructor for class com.twitter.maple.tap.TupleMemoryInputFormat

TupleMemoryInputFormat.TupleInputSplit - Class in com.twitter.maple.tap

TupleMemoryInputFormat.TupleRecordReader - Class in com.twitter.maple.tap

TupleRecordReader(List<Tuple>) - Constructor for class com.twitter.maple.tap.TupleMemoryInputFormat.TupleRecordReader

TUPLES_PROPERTY - Static variable in class com.twitter.maple.tap.TupleMemoryInputFormat

TupleWrapper - Class in com.twitter.maple.tap

TupleWrapper() - Constructor for class com.twitter.maple.tap.TupleWrapper

V

validateInput(JobConf) - Method in class com.twitter.maple.hbase.mapred.TableInputFormat

W

write(DataOutput) - Method in class com.twitter.maple.tap.TupleMemoryInputFormat.TupleInputSplit

C D E G H I L M N O P R S T V W