public class TupleMemoryInputFormat extends java.lang.Object implements org.apache.hadoop.mapred.InputFormat<TupleWrapper,org.apache.hadoop.io.NullWritable>
| Modifier and Type | Class and Description |
|---|---|
static class |
TupleMemoryInputFormat.TupleInputSplit |
static class |
TupleMemoryInputFormat.TupleRecordReader |
| Modifier and Type | Field and Description |
|---|---|
static java.lang.String |
ENCODING |
static java.lang.String |
TUPLES_PROPERTY |
| Constructor and Description |
|---|
TupleMemoryInputFormat() |
| Modifier and Type | Method and Description |
|---|---|
static byte[] |
decodeBytes(java.lang.String str) |
static java.lang.String |
encodeBytes(byte[] bytes) |
org.apache.hadoop.mapred.RecordReader<TupleWrapper,org.apache.hadoop.io.NullWritable> |
getRecordReader(org.apache.hadoop.mapred.InputSplit is,
org.apache.hadoop.mapred.JobConf jc,
org.apache.hadoop.mapred.Reporter rprtr) |
org.apache.hadoop.mapred.InputSplit[] |
getSplits(org.apache.hadoop.mapred.JobConf jc,
int i) |
static java.util.List<cascading.tuple.Tuple> |
retrieveTuples(org.apache.hadoop.mapred.JobConf conf,
java.lang.String key) |
static void |
storeTuples(org.apache.hadoop.mapred.JobConf conf,
java.lang.String key,
java.util.List<cascading.tuple.Tuple> tuples) |
public static final java.lang.String ENCODING
public static final java.lang.String TUPLES_PROPERTY
public org.apache.hadoop.mapred.InputSplit[] getSplits(org.apache.hadoop.mapred.JobConf jc,
int i)
throws java.io.IOException
getSplits in interface org.apache.hadoop.mapred.InputFormat<TupleWrapper,org.apache.hadoop.io.NullWritable>java.io.IOExceptionpublic org.apache.hadoop.mapred.RecordReader<TupleWrapper,org.apache.hadoop.io.NullWritable> getRecordReader(org.apache.hadoop.mapred.InputSplit is, org.apache.hadoop.mapred.JobConf jc, org.apache.hadoop.mapred.Reporter rprtr) throws java.io.IOException
getRecordReader in interface org.apache.hadoop.mapred.InputFormat<TupleWrapper,org.apache.hadoop.io.NullWritable>java.io.IOExceptionpublic static java.lang.String encodeBytes(byte[] bytes)
public static byte[] decodeBytes(java.lang.String str)
public static void storeTuples(org.apache.hadoop.mapred.JobConf conf,
java.lang.String key,
java.util.List<cascading.tuple.Tuple> tuples)
public static java.util.List<cascading.tuple.Tuple> retrieveTuples(org.apache.hadoop.mapred.JobConf conf,
java.lang.String key)