diff options
| author | Mosharaf Chowdhury <mosharaf@mosharaf-ubuntu.(none)> | 2010-12-15 18:34:27 -0800 |
|---|---|---|
| committer | Mosharaf Chowdhury <mosharaf@mosharaf-ubuntu.(none)> | 2010-12-15 18:34:27 -0800 |
| commit | be0ce57de24a8e2a1941d7ce81089043624dc5c0 (patch) | |
| tree | 75d595732c96dbd0c1be51416b5df65990e82481 | |
| parent | 5c222dbe284664af3547d1d9d67d4846bf36f4ed (diff) | |
| download | spark-be0ce57de24a8e2a1941d7ce81089043624dc5c0.tar.gz spark-be0ce57de24a8e2a1941d7ce81089043624dc5c0.tar.bz2 spark-be0ce57de24a8e2a1941d7ce81089043624dc5c0.zip | |
- Fixed an compilation error due to wrong 'import' of legacy lzf libraries in DfsBroadcast.scala
- Updated to use ning libraries.
- Passes all unit tests
| -rw-r--r-- | src/scala/spark/Broadcast.scala | 2 | ||||
| -rw-r--r-- | src/scala/spark/DfsBroadcast.scala | 2 |
2 files changed, 1 insertions, 3 deletions
diff --git a/src/scala/spark/Broadcast.scala b/src/scala/spark/Broadcast.scala index 17a530e49f..6b097903de 100644 --- a/src/scala/spark/Broadcast.scala +++ b/src/scala/spark/Broadcast.scala @@ -14,8 +14,6 @@ import scala.collection.mutable.Map import org.apache.hadoop.conf.Configuration import org.apache.hadoop.fs.{FileSystem, Path, RawLocalFileSystem} -import com.ning.compress.lzf.{LZFInputStream, LZFOutputStream} - @serializable trait Broadcast[T] { val uuid = UUID.randomUUID diff --git a/src/scala/spark/DfsBroadcast.scala b/src/scala/spark/DfsBroadcast.scala index 3178076916..480d6dd9b1 100644 --- a/src/scala/spark/DfsBroadcast.scala +++ b/src/scala/spark/DfsBroadcast.scala @@ -7,7 +7,7 @@ import java.util.UUID import org.apache.hadoop.conf.Configuration import org.apache.hadoop.fs.{FileSystem, Path, RawLocalFileSystem} -import spark.compress.lzf.{LZFInputStream, LZFOutputStream} +import com.ning.compress.lzf.{LZFInputStream, LZFOutputStream} @serializable class DfsBroadcast[T](@transient var value_ : T, isLocal: Boolean) |