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

org.apache.crunch.io.hbase
Class HBaseValueConverter<V>

java.lang.Object
  org.apache.crunch.io.hbase.HBaseValueConverter<V>

All Implemented Interfaces:

Serializable, Converter<Object,V,V,Iterable<V>>

public class HBaseValueConverter<V>
extends Object
implements Converter<Object,V,V,Iterable<V>>

See Also:

Serialized Form

Constructor Summary

HBaseValueConverter(Class<V> serializationClass)

Method Summary

boolean	applyPTypeTransforms() If true, convert the inputs or outputs from this Converter instance before (for outputs) or after (for inputs) using the associated PType#getInputMapFn and PType#getOutputMapFn calls.
V	convertInput(Object key, V value)
Iterable<V>	convertIterableInput(Object key, Iterable<V> value)
Class<Object>	getKeyClass()
Class<V>	getValueClass()
Object	outputKey(V value)
V	outputValue(V value)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

HBaseValueConverter

public HBaseValueConverter(Class<V> serializationClass)

Method Detail

convertInput

public V convertInput(Object key,
                      V value)

Specified by:

convertInput in interface Converter<Object,V,V,Iterable<V>>

outputKey

public Object outputKey(V value)

Specified by:

outputKey in interface Converter<Object,V,V,Iterable<V>>

outputValue

public V outputValue(V value)

Specified by:

outputValue in interface Converter<Object,V,V,Iterable<V>>

getKeyClass

public Class<Object> getKeyClass()

Specified by:

getKeyClass in interface Converter<Object,V,V,Iterable<V>>

getValueClass

public Class<V> getValueClass()

Specified by:

getValueClass in interface Converter<Object,V,V,Iterable<V>>

applyPTypeTransforms

public boolean applyPTypeTransforms()

Description copied from interface: Converter

If true, convert the inputs or outputs from this Converter instance before (for outputs) or after (for inputs) using the associated PType#getInputMapFn and PType#getOutputMapFn calls.

Specified by:

applyPTypeTransforms in interface Converter<Object,V,V,Iterable<V>>

convertIterableInput

public Iterable<V> convertIterableInput(Object key,
                                        Iterable<V> value)

Specified by:

convertIterableInput in interface Converter<Object,V,V,Iterable<V>>