Skip to content
Snippets Groups Projects
Commit be0ce57d authored by Mosharaf Chowdhury's avatar Mosharaf Chowdhury
Browse files

- Fixed an compilation error due to wrong 'import' of legacy lzf libraries in DfsBroadcast.scala

 - Updated to use ning libraries.
 - Passes all unit tests
parent 5c222dbe
No related branches found
No related tags found
No related merge requests found
......@@ -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
......
......@@ -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)
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment