From 968f75f6afc1383692f4f33d6a1a5f8ce2ac951d Mon Sep 17 00:00:00 2001 From: Reynold Xin Date: Mon, 9 Apr 2012 21:59:56 -0700 Subject: Added an option (spark.closure.serializer) to specify the serializer for closures. This enables using Kryo as the closure serializer. --- .../main/scala/spark/bagel/examples/WikipediaPageRankStandalone.scala | 4 ++++ 1 file changed, 4 insertions(+) (limited to 'bagel/src/main') 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) } -- cgit v1.2.3