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

org.apache.crunch.io.hbase
Class HFileTarget

java.lang.Object
  extended by org.apache.crunch.io.impl.FileTargetImpl
      extended by 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


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