org.elasticsearch.hadoop.mr

Class WritableValueReader

java.lang.Object

org.elasticsearch.hadoop.serialization.builder.AbstractValueReader

org.elasticsearch.hadoop.serialization.builder.JdkValueReader

org.elasticsearch.hadoop.mr.WritableValueReader

All Implemented Interfaces:

org.elasticsearch.hadoop.serialization.builder.ValueReader, org.elasticsearch.hadoop.serialization.SettingsAware

Direct Known Subclasses:

HiveValueReader

public class WritableValueReader
extends org.elasticsearch.hadoop.serialization.builder.JdkValueReader

Nested Class Summary

Nested classes/interfaces inherited from class org.elasticsearch.hadoop.serialization.builder.AbstractValueReader

org.elasticsearch.hadoop.serialization.builder.AbstractValueReader.FieldContext

Field Summary

Fields inherited from class org.elasticsearch.hadoop.serialization.builder.JdkValueReader

arrayExclude, arrayInclude

Constructor Summary

Constructors

Constructor and Description
WritableValueReader()

Method Summary

Modifier and Type	Method and Description
java.lang.Object	addToArray(java.lang.Object array, java.util.List<java.lang.Object> value)
protected int	arrayDepth(java.lang.Object potentialArray)
protected java.lang.Object	binaryValue(byte[] value)
protected java.lang.Class<? extends Writable>	byteType()
java.lang.Object	createArray(org.elasticsearch.hadoop.serialization.FieldType type)
java.util.Map	createMap()
protected java.lang.Class<? extends Writable>	dateType()
protected java.lang.Class<? extends Writable>	doubleType()
protected java.lang.Object	nullValue()
protected java.lang.Object	parseDate(java.lang.Long value, boolean richDate)
protected java.lang.Object	parseDate(java.lang.String value, boolean richDate)
protected java.lang.Object	parseString(java.lang.String value)
protected java.lang.Object	processBoolean(java.lang.Boolean value)
protected java.lang.Object	processByte(java.lang.Byte value)
protected java.lang.Object	processDouble(java.lang.Double value)
protected java.lang.Object	processFloat(java.lang.Float value)
protected java.lang.Object	processInteger(java.lang.Integer value)
protected java.lang.Object	processLong(java.lang.Long value)
protected java.lang.Object	processShort(java.lang.Short value)
protected java.lang.Class<? extends Writable>	shortType()
protected java.lang.Object	wrapArray(java.lang.Object array, int extraDepth)

Methods inherited from class org.elasticsearch.hadoop.serialization.builder.JdkValueReader

addToMap, booleanValue, byteValue, createDate, date, dateNanos, doubleValue, floatValue, intValue, longValue, parseBoolean, parseByte, parseDateNanos, parseDouble, parseFloat, parseInteger, parseLong, parseShort, processDate, readValue, setSettings, shortValue, textValue, wrapString

Methods inherited from class org.elasticsearch.hadoop.serialization.builder.AbstractValueReader

beginField, endField, getCurrentField

Methods inherited from class java.lang.Object

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

Constructor Detail

WritableValueReader

public WritableValueReader()

Method Detail

createMap

public java.util.Map createMap()

Specified by:

createMap in interface org.elasticsearch.hadoop.serialization.builder.ValueReader

Overrides:

createMap in class org.elasticsearch.hadoop.serialization.builder.JdkValueReader

createArray

public java.lang.Object createArray(org.elasticsearch.hadoop.serialization.FieldType type)

Specified by:

createArray in interface org.elasticsearch.hadoop.serialization.builder.ValueReader

Overrides:

createArray in class org.elasticsearch.hadoop.serialization.builder.JdkValueReader

addToArray

public java.lang.Object addToArray(java.lang.Object array,
                                   java.util.List<java.lang.Object> value)

Specified by:

addToArray in interface org.elasticsearch.hadoop.serialization.builder.ValueReader

Overrides:

addToArray in class org.elasticsearch.hadoop.serialization.builder.JdkValueReader

arrayDepth

protected int arrayDepth(java.lang.Object potentialArray)

Overrides:

arrayDepth in class org.elasticsearch.hadoop.serialization.builder.JdkValueReader

wrapArray

protected java.lang.Object wrapArray(java.lang.Object array,
                                     int extraDepth)

Overrides:

wrapArray in class org.elasticsearch.hadoop.serialization.builder.JdkValueReader

dateType

protected java.lang.Class<? extends Writable> dateType()

doubleType

protected java.lang.Class<? extends Writable> doubleType()

byteType

protected java.lang.Class<? extends Writable> byteType()

shortType

protected java.lang.Class<? extends Writable> shortType()

binaryValue

protected java.lang.Object binaryValue(byte[] value)

Overrides:

binaryValue in class org.elasticsearch.hadoop.serialization.builder.JdkValueReader

processBoolean

protected java.lang.Object processBoolean(java.lang.Boolean value)

Overrides:

processBoolean in class org.elasticsearch.hadoop.serialization.builder.JdkValueReader

parseDate

protected java.lang.Object parseDate(java.lang.Long value,
                                     boolean richDate)

Overrides:

parseDate in class org.elasticsearch.hadoop.serialization.builder.JdkValueReader

parseDate

protected java.lang.Object parseDate(java.lang.String value,
                                     boolean richDate)

Overrides:

parseDate in class org.elasticsearch.hadoop.serialization.builder.JdkValueReader

processDouble

protected java.lang.Object processDouble(java.lang.Double value)

Overrides:

processDouble in class org.elasticsearch.hadoop.serialization.builder.JdkValueReader

processFloat

protected java.lang.Object processFloat(java.lang.Float value)

Overrides:

processFloat in class org.elasticsearch.hadoop.serialization.builder.JdkValueReader

processLong

protected java.lang.Object processLong(java.lang.Long value)

Overrides:

processLong in class org.elasticsearch.hadoop.serialization.builder.JdkValueReader

processInteger

protected java.lang.Object processInteger(java.lang.Integer value)

Overrides:

processInteger in class org.elasticsearch.hadoop.serialization.builder.JdkValueReader

processByte

protected java.lang.Object processByte(java.lang.Byte value)

Overrides:

processByte in class org.elasticsearch.hadoop.serialization.builder.JdkValueReader

processShort

protected java.lang.Object processShort(java.lang.Short value)

Overrides:

processShort in class org.elasticsearch.hadoop.serialization.builder.JdkValueReader

parseString

protected java.lang.Object parseString(java.lang.String value)

Overrides:

parseString in class org.elasticsearch.hadoop.serialization.builder.JdkValueReader

nullValue

protected java.lang.Object nullValue()

Overrides:

nullValue in class org.elasticsearch.hadoop.serialization.builder.JdkValueReader