incubator-crunch-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ki...@apache.org
Subject git commit: CRUNCH-94. Make PTypeH Serializable.
Date Thu, 11 Oct 2012 22:24:49 GMT
Updated Branches:
  refs/heads/master ad90b151d -> c3ba38e24


CRUNCH-94. Make PTypeH Serializable.


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

Branch: refs/heads/master
Commit: c3ba38e24f8aab79726e3f81605bec29ed957f84
Parents: ad90b15
Author: Kiyan Ahmadizadeh <kiyan@wibidata.com>
Authored: Thu Oct 11 00:53:37 2012 -0700
Committer: Kiyan Ahmadizadeh <kiyan@wibidata.com>
Committed: Thu Oct 11 14:49:22 2012 -0700

----------------------------------------------------------------------
 .../org/apache/crunch/scrunch/Conversions.scala    |    8 ++++----
 1 files changed, 4 insertions(+), 4 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-crunch/blob/c3ba38e2/crunch-scrunch/src/main/scala/org/apache/crunch/scrunch/Conversions.scala
----------------------------------------------------------------------
diff --git a/crunch-scrunch/src/main/scala/org/apache/crunch/scrunch/Conversions.scala b/crunch-scrunch/src/main/scala/org/apache/crunch/scrunch/Conversions.scala
index a6b8893..7928fc8 100644
--- a/crunch-scrunch/src/main/scala/org/apache/crunch/scrunch/Conversions.scala
+++ b/crunch-scrunch/src/main/scala/org/apache/crunch/scrunch/Conversions.scala
@@ -57,9 +57,9 @@ object CanParallelTransform extends LowPriorityParallelTransforms {
       }
     }
   }
-} 
+}
 
-trait PTypeH[T] {
+trait PTypeH[T] extends Serializable {
   def get(ptf: PTypeFamily): PType[T]
 }
 
@@ -140,11 +140,11 @@ object Conversions {
   implicit def jtable2ptable[K, V](jtable: JTable[K, V]) = {
     new PTable[K, V](jtable)
   }
-  
+
   implicit def jcollect2pcollect[S](jcollect: JCollection[S]) = {
     new PCollection[S](jcollect)
   }
-  
+
   implicit def jgrouped2pgrouped[K, V](jgrouped: JGroupedTable[K, V]) = {
     new PGroupedTable[K, V](jgrouped)
   }


Mime
View raw message