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

public class WritableValueReader extends org.elasticsearch.hadoop.serialization.builder.JdkValueReader
  • Constructor Details

    • WritableValueReader

      public WritableValueReader()
  • Method Details

    • createMap

      public 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 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 Object addToArray(Object array, List<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(Object potentialArray)
      Overrides:
      arrayDepth in class org.elasticsearch.hadoop.serialization.builder.JdkValueReader
    • wrapArray

      protected Object wrapArray(Object array, int extraDepth)
      Overrides:
      wrapArray in class org.elasticsearch.hadoop.serialization.builder.JdkValueReader
    • dateType

      protected Class<? extends Writable> dateType()
    • doubleType

      protected Class<? extends Writable> doubleType()
    • byteType

      protected Class<? extends Writable> byteType()
    • shortType

      protected Class<? extends Writable> shortType()
    • binaryValue

      protected Object binaryValue(byte[] value)
      Overrides:
      binaryValue in class org.elasticsearch.hadoop.serialization.builder.JdkValueReader
    • processBoolean

      protected Object processBoolean(Boolean value)
      Overrides:
      processBoolean in class org.elasticsearch.hadoop.serialization.builder.JdkValueReader
    • parseDate

      protected Object parseDate(Long value, boolean richDate)
      Overrides:
      parseDate in class org.elasticsearch.hadoop.serialization.builder.JdkValueReader
    • parseDate

      protected Object parseDate(String value, boolean richDate)
      Overrides:
      parseDate in class org.elasticsearch.hadoop.serialization.builder.JdkValueReader
    • processDouble

      protected Object processDouble(Double value)
      Overrides:
      processDouble in class org.elasticsearch.hadoop.serialization.builder.JdkValueReader
    • processFloat

      protected Object processFloat(Float value)
      Overrides:
      processFloat in class org.elasticsearch.hadoop.serialization.builder.JdkValueReader
    • processLong

      protected Object processLong(Long value)
      Overrides:
      processLong in class org.elasticsearch.hadoop.serialization.builder.JdkValueReader
    • processInteger

      protected Object processInteger(Integer value)
      Overrides:
      processInteger in class org.elasticsearch.hadoop.serialization.builder.JdkValueReader
    • processByte

      protected Object processByte(Byte value)
      Overrides:
      processByte in class org.elasticsearch.hadoop.serialization.builder.JdkValueReader
    • processShort

      protected Object processShort(Short value)
      Overrides:
      processShort in class org.elasticsearch.hadoop.serialization.builder.JdkValueReader
    • parseString

      protected Object parseString(String value)
      Overrides:
      parseString in class org.elasticsearch.hadoop.serialization.builder.JdkValueReader
    • nullValue

      protected Object nullValue()
      Overrides:
      nullValue in class org.elasticsearch.hadoop.serialization.builder.JdkValueReader