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

org.apache.crunch.io
Class At

java.lang.Object
  org.apache.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 <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

equals, 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)

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)