diff options
| -rw-r--r-- | src/scala/spark/DfsBroadcast.scala | 2 |
1 files changed, 1 insertions, 1 deletions
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) |