com.cloudera.crunch.io
Class At

java.lang.Object
  com.cloudera.crunch.io.At

public class At
extends Object

Static factory methods for creating various SourceTarget types.

Constructor Summary

At()

Method Summary

static <T> AvroFileSourceTarget<T>	avroFile(org.apache.hadoop.fs.Path path, AvroType<T> avroType)
static <T> AvroFileSourceTarget<T>	avroFile(String pathName, AvroType<T> avroType)
static HBaseSourceTarget	hbaseTable(String table)
static HBaseSourceTarget	hbaseTable(String table, org.apache.hadoop.hbase.client.Scan scan)
static <K,V> SeqFileTableSourceTarget<K,V>	sequenceFile(org.apache.hadoop.fs.Path path, PType<K> keyType, PType<V> valueType)
static <T> SeqFileSourceTarget<T>	sequenceFile(org.apache.hadoop.fs.Path path, PType<T> ptype)
static <K,V> SeqFileTableSourceTarget<K,V>	sequenceFile(String pathName, PType<K> keyType, PType<V> valueType)
static <T> SeqFileSourceTarget<T>	sequenceFile(String pathName, PType<T> ptype)
static TextFileSourceTarget<String>	textFile(org.apache.hadoop.fs.Path path)
static <T> TextFileSourceTarget<T>	textFile(org.apache.hadoop.fs.Path path, PType<T> ptype)
static TextFileSourceTarget<String>	textFile(String pathName)
static <T> TextFileSourceTarget<T>	textFile(String pathName, PType<T> ptype)

Methods inherited from class java.lang.Object

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

Constructor Detail

At

public At()

Method Detail

avroFile

public static <T> AvroFileSourceTarget<T> avroFile(String pathName,
                                                   AvroType<T> avroType)

avroFile

public static <T> AvroFileSourceTarget<T> avroFile(org.apache.hadoop.fs.Path path,
                                                   AvroType<T> avroType)

hbaseTable

public static HBaseSourceTarget hbaseTable(String table)

hbaseTable

public static HBaseSourceTarget hbaseTable(String table,
                                           org.apache.hadoop.hbase.client.Scan scan)

sequenceFile

public static <T> SeqFileSourceTarget<T> sequenceFile(String pathName,
                                                      PType<T> ptype)

sequenceFile

public static <T> SeqFileSourceTarget<T> sequenceFile(org.apache.hadoop.fs.Path path,
                                                      PType<T> ptype)

sequenceFile

public static <K,V> SeqFileTableSourceTarget<K,V> sequenceFile(String pathName,
                                                               PType<K> keyType,
                                                               PType<V> valueType)

sequenceFile

public static <K,V> SeqFileTableSourceTarget<K,V> sequenceFile(org.apache.hadoop.fs.Path path,
                                                               PType<K> keyType,
                                                               PType<V> valueType)

textFile

public static TextFileSourceTarget<String> textFile(String pathName)

textFile

public static TextFileSourceTarget<String> textFile(org.apache.hadoop.fs.Path path)

textFile

public static <T> TextFileSourceTarget<T> textFile(String pathName,
                                                   PType<T> ptype)

textFile

public static <T> TextFileSourceTarget<T> textFile(org.apache.hadoop.fs.Path path,
                                                   PType<T> ptype)