Skip to content

Commit

Permalink
unnecessary methods for broadcast
Browse files Browse the repository at this point in the history
  • Loading branch information
scwf committed Oct 20, 2014
1 parent eadc4c5 commit 414cc24
Showing 1 changed file with 0 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -67,10 +67,6 @@ class HadoopTableReader(
private val _broadcastedHiveConf =
sc.sparkContext.broadcast(new SerializableWritable(hiveExtraConf))

def broadcastedHiveConf = _broadcastedHiveConf

def hiveConf = _broadcastedHiveConf.value.value

override def makeRDDForTable(hiveTable: HiveTable): RDD[Row] =
makeRDDForTable(
hiveTable,
Expand Down

0 comments on commit 414cc24

Please sign in to comment.