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

org.apache.crunch
Interface Target

All Known Subinterfaces:
MapReduceTarget, PathTarget, ReadableSourceTarget<T>, SourceTarget<T>, TableSourceTarget<K,V>

public interface Target

A Target represents the output destination of a Crunch PCollection in the context of a Crunch job.


Nested Class Summary
static class Target.WriteMode
          An enum to represent different options the client may specify for handling the case where the output path, table, etc.
 
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 handleExisting(Target.WriteMode writeMode, org.apache.hadoop.conf.Configuration conf)
          Apply the given WriteMode to this Target instance.
 

Method Detail

handleExisting

void handleExisting(Target.WriteMode writeMode,
                    org.apache.hadoop.conf.Configuration conf)
Apply the given WriteMode to this Target instance.

Parameters:
writeMode - The strategy for handling existing outputs
conf - The ever-useful Configuration instance

accept

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

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

asSourceTarget

<T> SourceTarget<T> asSourceTarget(PType<T> ptype)
Attempt to create the SourceTarget type that corresponds to this Target for the given PType, if possible. If it is not possible, return null.

Parameters:
ptype - The PType to use in constructing the SourceTarget
Returns:
A new SourceTarget or null if such a SourceTarget does not exist


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