Repository: crunch Updated Branches: refs/heads/apache-crunch-0.8 e5e23b560 -> 1101f913b
CRUNCH-391: Add return type info to Scrunch's Avros.reflects Project: http://git-wip-us.apache.org/repos/asf/crunch/repo Commit: http://git-wip-us.apache.org/repos/asf/crunch/commit/1101f913 Tree: http://git-wip-us.apache.org/repos/asf/crunch/tree/1101f913 Diff: http://git-wip-us.apache.org/repos/asf/crunch/diff/1101f913 Branch: refs/heads/apache-crunch-0.8 Commit: 1101f913b7b7f218a814f971a335c21ecf6bfdd9 Parents: e5e23b5 Author: Josh Wills <[email protected]> Authored: Fri May 9 07:50:12 2014 -0700 Committer: Josh Wills <[email protected]> Committed: Fri May 9 07:51:37 2014 -0700 ---------------------------------------------------------------------- .../src/main/scala/org/apache/crunch/scrunch/PTypeFamily.scala | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/crunch/blob/1101f913/crunch-scrunch/src/main/scala/org/apache/crunch/scrunch/PTypeFamily.scala ---------------------------------------------------------------------- diff --git a/crunch-scrunch/src/main/scala/org/apache/crunch/scrunch/PTypeFamily.scala b/crunch-scrunch/src/main/scala/org/apache/crunch/scrunch/PTypeFamily.scala index ea69d4f..636b4e2 100644 --- a/crunch-scrunch/src/main/scala/org/apache/crunch/scrunch/PTypeFamily.scala +++ b/crunch-scrunch/src/main/scala/org/apache/crunch/scrunch/PTypeFamily.scala @@ -20,7 +20,7 @@ package org.apache.crunch.scrunch import org.apache.crunch.{Pair => CPair, Tuple3 => CTuple3, Tuple4 => CTuple4, MapFn} import org.apache.crunch.types.{PType, PTypeFamily => PTF} import org.apache.crunch.types.writable.WritableTypeFamily -import org.apache.crunch.types.avro.{AvroTypeFamily, Avros => CAvros} +import org.apache.crunch.types.avro.{AvroType, AvroTypeFamily, Avros => CAvros} import java.lang.{Long => JLong, Double => JDouble, Integer => JInt, Float => JFloat, Boolean => JBoolean} import java.util.{Collection => JCollection} import scala.collection.JavaConversions._ @@ -131,5 +131,5 @@ object Avros extends PTypeFamily { CAvros.REFLECT_DATA_FACTORY = new ScalaReflectDataFactory() - def reflects[T: ClassManifest]() = CAvros.reflects(classManifest[T].erasure) + def reflects[T: ClassManifest]() = CAvros.reflects(classManifest[T].erasure).asInstanceOf[AvroType[T]] }
