This project has retired. For details please refer to its Attic page.
AvroFileTarget (Apache Crunch 0.9.0 API)

org.apache.crunch.io.avro
Class AvroFileTarget

java.lang.Object
  extended by org.apache.crunch.io.impl.FileTargetImpl
      extended by org.apache.crunch.io.avro.AvroFileTarget
All Implemented Interfaces:
MapReduceTarget, PathTarget, Target

public class AvroFileTarget
extends FileTargetImpl


Nested Class Summary
 
Nested classes/interfaces inherited from interface org.apache.crunch.Target
Target.WriteMode
 
Field Summary
 
Fields inherited from class org.apache.crunch.io.impl.FileTargetImpl
path
 
Constructor Summary
AvroFileTarget(org.apache.hadoop.fs.Path path)
           
AvroFileTarget(org.apache.hadoop.fs.Path path, FileNamingScheme fileNamingScheme)
           
AvroFileTarget(String path)
           
 
Method Summary
 boolean accept(OutputHandler handler, PType<?> ptype)
          Checks to see if this Target instance is compatible with the given PType.
<T> SourceTarget<T>
asSourceTarget(PType<T> ptype)
          Attempt to create the SourceTarget type that corresponds to this Target for the given PType, if possible.
 void configureForMapReduce(org.apache.hadoop.mapreduce.Job job, PType<?> ptype, org.apache.hadoop.fs.Path outputPath, String name)
           
 String toString()
           
 
Methods inherited from class org.apache.crunch.io.impl.FileTargetImpl
configureForMapReduce, configureForMapReduce, equals, extractPartitionNumber, getConverter, getDestFile, getFileNamingScheme, getPath, getSourcePattern, getSuccessIndicator, handleExisting, handleOutputs, hashCode, isCompatible, outputConf
 
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)

AvroFileTarget

public AvroFileTarget(org.apache.hadoop.fs.Path path,
                      FileNamingScheme fileNamingScheme)
Method Detail

toString

public String toString()
Overrides:
toString in class FileTargetImpl

accept

public boolean accept(OutputHandler handler,
                      PType<?> ptype)
Description copied from interface: Target
Checks to see if this Target instance is compatible with the given PType.

Specified by:
accept in interface Target
Overrides:
accept in class FileTargetImpl
Parameters:
handler - The OutputHandler that is managing the output for the job
ptype - The PType to check
Returns:
True if this Target can write data in the form of the given PType, false otherwise

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)
Description copied from interface: Target
Attempt to create the SourceTarget type that corresponds to this Target for the given PType, if possible. If it is not possible, return null.

Specified by:
asSourceTarget in interface Target
Overrides:
asSourceTarget in class FileTargetImpl
Parameters:
ptype - The PType to use in constructing the SourceTarget
Returns:
A new SourceTarget or null if such a SourceTarget does not exist


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