com.cloudera.crunch.io.avro
Class AvroFileTarget

java.lang.Object
  com.cloudera.crunch.io.impl.FileTargetImpl
      com.cloudera.crunch.io.avro.AvroFileTarget

All Implemented Interfaces:

MapReduceTarget, PathTarget, Target

public class AvroFileTarget
extends FileTargetImpl

Field Summary

Fields inherited from class com.cloudera.crunch.io.impl.FileTargetImpl

path

Constructor Summary

AvroFileTarget(org.apache.hadoop.fs.Path path)

AvroFileTarget(String path)

Method Summary

boolean	accept(OutputHandler handler, PType<?> ptype)
<T> SourceTarget<T>	asSourceTarget(PType<T> ptype)
void	configureForMapReduce(org.apache.hadoop.mapreduce.Job job, PType<?> ptype, org.apache.hadoop.fs.Path outputPath, String name)
String	toString()

Methods inherited from class com.cloudera.crunch.io.impl.FileTargetImpl

configureForMapReduce, equals, getPath, hashCode

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

AvroFileTarget

public AvroFileTarget(String path)

AvroFileTarget

public AvroFileTarget(org.apache.hadoop.fs.Path path)

Method Detail

toString

public String toString()

Overrides:

toString in class FileTargetImpl

accept

public boolean accept(OutputHandler handler,
                      PType<?> ptype)

Specified by:

accept in interface Target

Overrides:

accept in class FileTargetImpl

configureForMapReduce

public void configureForMapReduce(org.apache.hadoop.mapreduce.Job job,
                                  PType<?> ptype,
                                  org.apache.hadoop.fs.Path outputPath,
                                  String name)

Specified by:

configureForMapReduce in interface MapReduceTarget

Overrides:

configureForMapReduce in class FileTargetImpl

asSourceTarget

public <T> SourceTarget<T> asSourceTarget(PType<T> ptype)

Specified by:

asSourceTarget in interface Target

Overrides:

asSourceTarget in class FileTargetImpl