You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@crunch.apache.org by ki...@apache.org on 2012/10/12 00:24:49 UTC
git commit: CRUNCH-94. Make PTypeH Serializable.
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 <ki...@wibidata.com>
Authored: Thu Oct 11 00:53:37 2012 -0700
Committer: Kiyan Ahmadizadeh <ki...@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)
}