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

org.apache.crunch.scrunch
Class ScalaSafeReflectDatumReader<T>

java.lang.Object
  org.apache.avro.generic.GenericDatumReader<T>
      org.apache.avro.specific.SpecificDatumReader<T>
          org.apache.avro.reflect.ReflectDatumReader<T>
              org.apache.crunch.scrunch.ScalaSafeReflectDatumReader<T>

All Implemented Interfaces:

org.apache.avro.io.DatumReader<T>

public class ScalaSafeReflectDatumReader<T>
extends org.apache.avro.reflect.ReflectDatumReader<T>

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.avro.specific.SpecificDatumReader

org.apache.avro.specific.SpecificDatumReader.SchemaConstructable

Constructor Summary

ScalaSafeReflectDatumReader(org.apache.avro.Schema schema)

Method Summary

static Object	scalaIterableCheck(Object array, org.apache.avro.Schema schema)
static Object	scalaMapCheck(Object map, org.apache.avro.Schema schema)

Methods inherited from class org.apache.avro.generic.GenericDatumReader

getData, read, setExpected, setSchema, skip

Methods inherited from class java.lang.Object

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

Constructor Detail

ScalaSafeReflectDatumReader

public ScalaSafeReflectDatumReader(org.apache.avro.Schema schema)

Method Detail

scalaMapCheck

public static Object scalaMapCheck(Object map,
                                   org.apache.avro.Schema schema)

scalaIterableCheck

public static Object scalaIterableCheck(Object array,
                                        org.apache.avro.Schema schema)