diff options
author | Reynold Xin <reynoldx@gmail.com> | 2012-04-09 21:59:56 -0700 |
---|---|---|
committer | Reynold Xin <reynoldx@gmail.com> | 2012-04-09 21:59:56 -0700 |
commit | 968f75f6afc1383692f4f33d6a1a5f8ce2ac951d (patch) | |
tree | 9aa5f73c9c50dc5d77fc4aa5f9347a945804d06b /bagel/src | |
parent | 8c95a85438d9401017b7ef4f68282654c66276f4 (diff) | |
download | spark-968f75f6afc1383692f4f33d6a1a5f8ce2ac951d.tar.gz spark-968f75f6afc1383692f4f33d6a1a5f8ce2ac951d.tar.bz2 spark-968f75f6afc1383692f4f33d6a1a5f8ce2ac951d.zip |
Added an option (spark.closure.serializer) to specify the serializer for
closures. This enables using Kryo as the closure serializer.
Diffstat (limited to 'bagel/src')
-rw-r--r-- | bagel/src/main/scala/spark/bagel/examples/WikipediaPageRankStandalone.scala | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/bagel/src/main/scala/spark/bagel/examples/WikipediaPageRankStandalone.scala b/bagel/src/main/scala/spark/bagel/examples/WikipediaPageRankStandalone.scala index 2e38376499..7084ff97d9 100644 --- a/bagel/src/main/scala/spark/bagel/examples/WikipediaPageRankStandalone.scala +++ b/bagel/src/main/scala/spark/bagel/examples/WikipediaPageRankStandalone.scala @@ -126,6 +126,10 @@ class WPRSerializerInstance extends SerializerInstance { throw new UnsupportedOperationException() } + def deserialize[T](bytes: Array[Byte], loader: ClassLoader): T = { + throw new UnsupportedOperationException() + } + def outputStream(s: OutputStream): SerializationStream = { new WPRSerializationStream(s) } |