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

org.apache.crunch.scrunch
Class ScalaReflectDataFactory

java.lang.Object
  org.apache.crunch.types.avro.ReflectDataFactory
      org.apache.crunch.scrunch.ScalaReflectDataFactory

public class ScalaReflectDataFactory
extends ReflectDataFactory

An implementation of the ReflectDataFactory class to work with Scala classes.

Constructor Summary

ScalaReflectDataFactory()

Method Summary

<T> org.apache.avro.reflect.ReflectDatumReader<T>	getReader(org.apache.avro.Schema schema)
org.apache.avro.reflect.ReflectData	getReflectData()
<T> org.apache.avro.reflect.ReflectDatumWriter<T>	getWriter()

Methods inherited from class java.lang.Object

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

Constructor Detail

ScalaReflectDataFactory

public ScalaReflectDataFactory()

Method Detail

getReflectData

public org.apache.avro.reflect.ReflectData getReflectData()

Overrides:

getReflectData in class ReflectDataFactory

getReader

public <T> org.apache.avro.reflect.ReflectDatumReader<T> getReader(org.apache.avro.Schema schema)

Overrides:

getReader in class ReflectDataFactory

getWriter

public <T> org.apache.avro.reflect.ReflectDatumWriter<T> getWriter()

Overrides:

getWriter in class ReflectDataFactory