crunch-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jwi...@apache.org
Subject git commit: CRUNCH-334: Expose new Avro generic methods in Scrunch APIs. Contributed by Magnus Runesson.
Date Tue, 28 Jan 2014 14:28:14 GMT
Updated Branches:
  refs/heads/apache-crunch-0.8 5f6651db1 -> da0b14bda


CRUNCH-334: Expose new Avro generic methods in Scrunch APIs. Contributed by Magnus Runesson.


Project: http://git-wip-us.apache.org/repos/asf/crunch/repo
Commit: http://git-wip-us.apache.org/repos/asf/crunch/commit/da0b14bd
Tree: http://git-wip-us.apache.org/repos/asf/crunch/tree/da0b14bd
Diff: http://git-wip-us.apache.org/repos/asf/crunch/diff/da0b14bd

Branch: refs/heads/apache-crunch-0.8
Commit: da0b14bdae54919aeb4a1589fc6e032787aa42ee
Parents: 5f6651d
Author: Josh Wills <jwills@apache.org>
Authored: Tue Jan 28 05:44:19 2014 -0800
Committer: Josh Wills <jwills@apache.org>
Committed: Tue Jan 28 06:26:55 2014 -0800

----------------------------------------------------------------------
 .../src/main/scala/org/apache/crunch/scrunch/IO.scala         | 7 ++++++-
 1 file changed, 6 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/crunch/blob/da0b14bd/crunch-scrunch/src/main/scala/org/apache/crunch/scrunch/IO.scala
----------------------------------------------------------------------
diff --git a/crunch-scrunch/src/main/scala/org/apache/crunch/scrunch/IO.scala b/crunch-scrunch/src/main/scala/org/apache/crunch/scrunch/IO.scala
index 89b331b..99b10e9 100644
--- a/crunch-scrunch/src/main/scala/org/apache/crunch/scrunch/IO.scala
+++ b/crunch-scrunch/src/main/scala/org/apache/crunch/scrunch/IO.scala
@@ -19,11 +19,14 @@ package org.apache.crunch.scrunch
 
 import org.apache.crunch.io.{From => from, To => to, At => at}
 import org.apache.crunch.types.avro.AvroType
-import org.apache.hadoop.fs.Path;
+import org.apache.hadoop.conf.Configuration
+import org.apache.hadoop.fs.Path
 
 trait From {
   def avroFile[T](path: String, atype: AvroType[T]) = from.avroFile(path, atype)
   def avroFile[T](path: Path, atype: AvroType[T]) = from.avroFile(path, atype)
+  def avroFile(path: Path) = from.avroFile(path)
+  def avroFile(path: Path, conf: Configuration) = from.avroFile(path, conf)
   def textFile(path: String) = from.textFile(path)
   def textFile(path: Path) = from.textFile(path)
 }
@@ -42,6 +45,8 @@ object To extends To
 trait At {
   def avroFile[T](path: String, atype: AvroType[T]) = at.avroFile(path, atype)
   def avroFile[T](path: Path, atype: AvroType[T]) = at.avroFile(path, atype)
+  def avroFile(path: Path) = at.avroFile(path)
+  def avroFile(path: Path, conf: Configuration) = at.avroFile(path, conf)
   def textFile(path: String) = at.textFile(path)
   def textFile(path: Path) = at.textFile(path)
 }


Mime
View raw message