Skip to content

Commit b7ba768

Browse files
committed
Added comment and checkstyle fix
1 parent 6a93459 commit b7ba768

File tree

2 files changed

+5
-2
lines changed

2 files changed

+5
-2
lines changed

sql/hive/src/main/scala/org/apache/spark/sql/hive/TableReader.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -55,7 +55,7 @@ class HadoopTableReader(
5555
@transient relation: MetastoreRelation,
5656
@transient sc: HiveContext,
5757
@transient hiveExtraConf: HiveConf)
58-
extends TableReader {
58+
extends TableReader {
5959

6060
// Choose the minimum number of splits. If mapred.map.tasks is set, then use that unless
6161
// it is smaller than what Spark suggests.

sql/hive/src/main/scala/org/apache/spark/sql/hive/execution/HiveTableScan.scala

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -64,11 +64,14 @@ case class HiveTableScan(
6464
BindReferences.bindReference(pred, relation.partitionKeys)
6565
}
6666

67+
// Create a local copy of hiveconf,so that scan specific modifications should not impact
68+
// other queries
6769
@transient
6870
private[this] val hiveExtraConf = new HiveConf(context.hiveconf)
6971

7072
@transient
71-
private[this] val hadoopReader = new HadoopTableReader(attributes, relation, context, hiveExtraConf)
73+
private[this] val hadoopReader =
74+
new HadoopTableReader(attributes, relation, context, hiveExtraConf)
7275

7376
private[this] def castFromString(value: String, dataType: DataType) = {
7477
Cast(Literal(value), dataType).eval(null)

0 commit comments

Comments
 (0)