This project has retired. For details please refer to its Attic page.
At (Apache Crunch 0.4.0-incubating API)

org.apache.crunch.io
Class At

java.lang.Object
  extended by 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> org.apache.crunch.io.avro.AvroFileSourceTarget<T>
avroFile(org.apache.hadoop.fs.Path path, AvroType<T> avroType)
           
static
<T> org.apache.crunch.io.avro.AvroFileSourceTarget<T>
avroFile(String pathName, AvroType<T> avroType)
           
static
<K,V> org.apache.crunch.io.seq.SeqFileTableSourceTarget<K,V>
sequenceFile(org.apache.hadoop.fs.Path path, PType<K> keyType, PType<V> valueType)
           
static
<T> org.apache.crunch.io.seq.SeqFileSourceTarget<T>
sequenceFile(org.apache.hadoop.fs.Path path, PType<T> ptype)
           
static
<K,V> org.apache.crunch.io.seq.SeqFileTableSourceTarget<K,V>
sequenceFile(String pathName, PType<K> keyType, PType<V> valueType)
           
static
<T> org.apache.crunch.io.seq.SeqFileSourceTarget<T>
sequenceFile(String pathName, PType<T> ptype)
           
static org.apache.crunch.io.text.TextFileSourceTarget<String> textFile(org.apache.hadoop.fs.Path path)
           
static
<T> org.apache.crunch.io.text.TextFileSourceTarget<T>
textFile(org.apache.hadoop.fs.Path path, PType<T> ptype)
           
static org.apache.crunch.io.text.TextFileSourceTarget<String> textFile(String pathName)
           
static
<T> org.apache.crunch.io.text.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> org.apache.crunch.io.avro.AvroFileSourceTarget<T> avroFile(String pathName,
                                                                             AvroType<T> avroType)

avroFile

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

sequenceFile

public static <T> org.apache.crunch.io.seq.SeqFileSourceTarget<T> sequenceFile(String pathName,
                                                                               PType<T> ptype)

sequenceFile

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

sequenceFile

public static <K,V> org.apache.crunch.io.seq.SeqFileTableSourceTarget<K,V> sequenceFile(String pathName,
                                                                                        PType<K> keyType,
                                                                                        PType<V> valueType)

sequenceFile

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

textFile

public static org.apache.crunch.io.text.TextFileSourceTarget<String> textFile(String pathName)

textFile

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

textFile

public static <T> org.apache.crunch.io.text.TextFileSourceTarget<T> textFile(String pathName,
                                                                             PType<T> ptype)

textFile

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


Copyright © 2012 The Apache Software Foundation. All Rights Reserved.