This project has retired. For details please refer to its Attic page.

org.apache.crunch.io.hbase
Class HFileTarget

java.lang.Object
  org.apache.crunch.io.impl.FileTargetImpl
      org.apache.crunch.io.hbase.HFileTarget

All Implemented Interfaces:

MapReduceTarget, PathTarget, Target

public class HFileTarget
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

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

HFileTarget(org.apache.hadoop.fs.Path path, org.apache.hadoop.hbase.HColumnDescriptor hcol)

HFileTarget(String path)

Method Summary

void	configureForMapReduce(org.apache.hadoop.mapreduce.Job job, PType<?> ptype, org.apache.hadoop.fs.Path outputPath, String name)
Converter<?,?,?,?>	getConverter(PType<?> ptype) Returns the Converter to use for mapping from the output PCollection into the output values expected by this instance.
String	toString()

Methods inherited from class org.apache.crunch.io.impl.FileTargetImpl

accept, asSourceTarget, configureForMapReduce, configureForMapReduce, equals, extractPartitionNumber, 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

HFileTarget

public HFileTarget(String path)

HFileTarget

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

HFileTarget

public HFileTarget(org.apache.hadoop.fs.Path path,
                   org.apache.hadoop.hbase.HColumnDescriptor hcol)

Method Detail

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

getConverter

public Converter<?,?,?,?> getConverter(PType<?> ptype)

Description copied from interface: Target

Returns the Converter to use for mapping from the output PCollection into the output values expected by this instance.

Specified by:

getConverter in interface Target

Overrides:

getConverter in class FileTargetImpl

Parameters:

ptype - The PType of the data that is being written to this instance

Returns:

A valid Converter for the output represented by this instance

toString

public String toString()

Overrides:

toString in class FileTargetImpl