org.apache.crunch

Interface Target

All Known Subinterfaces:

MapReduceTarget, PathTarget, ReadableSourceTarget<T>, SourceTarget<T>, TableSourceTarget<K,V>

All Known Implementing Classes:

PathTargetImpl

public interface Target

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

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
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

Methods

Modifier and Type	Method and Description
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