Skip to content

Commit f04aaa4

Browse files
committed
Merge branch 'master' of github.com:apache/spark into pyspark-submit
2 parents a371d26 + e1e3416 commit f04aaa4

File tree

19 files changed

+22
-20
lines changed

19 files changed

+22
-20
lines changed

graphx/src/main/scala/org/apache/spark/graphx/lib/package-info.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -16,6 +16,6 @@
1616
*/
1717

1818
/**
19-
* Internal support for MLLib Python API.
19+
* Various analytics functions for graphs.
2020
*/
21-
package org.apache.spark.graphx.lib;
21+
package org.apache.spark.graphx.lib;

pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -129,7 +129,7 @@
129129
<jetty.version>8.1.14.v20131031</jetty.version>
130130
<chill.version>0.3.6</chill.version>
131131
<codahale.metrics.version>3.0.0</codahale.metrics.version>
132-
<avro.version>1.7.4</avro.version>
132+
<avro.version>1.7.6</avro.version>
133133
<jets3t.version>0.7.1</jets3t.version>
134134

135135
<PermGen>64m</PermGen>

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

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -183,7 +183,8 @@ object HiveMetastoreTypes extends RegexParsers {
183183
"string" ^^^ StringType |
184184
"float" ^^^ FloatType |
185185
"int" ^^^ IntegerType |
186-
"tinyint" ^^^ ShortType |
186+
"tinyint" ^^^ ByteType |
187+
"smallint" ^^^ ShortType |
187188
"double" ^^^ DoubleType |
188189
"bigint" ^^^ LongType |
189190
"binary" ^^^ BinaryType |
@@ -227,7 +228,8 @@ object HiveMetastoreTypes extends RegexParsers {
227228
case StringType => "string"
228229
case FloatType => "float"
229230
case IntegerType => "int"
230-
case ShortType =>"tinyint"
231+
case ByteType => "tinyint"
232+
case ShortType => "smallint"
231233
case DoubleType => "double"
232234
case LongType => "bigint"
233235
case BinaryType => "binary"

sql/hive/src/test/scala/org/apache/spark/sql/hive/execution/PruningSuite.scala

Lines changed: 15 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -28,100 +28,100 @@ import scala.collection.JavaConversions._
2828
class PruningSuite extends HiveComparisonTest {
2929
// Column pruning tests
3030

31-
createPruningTest("Column pruning: with partitioned table",
31+
createPruningTest("Column pruning - with partitioned table",
3232
"SELECT key FROM srcpart WHERE ds = '2008-04-08' LIMIT 3",
3333
Seq("key"),
3434
Seq("key"),
3535
Seq(
3636
Seq("2008-04-08", "11"),
3737
Seq("2008-04-08", "12")))
3838

39-
createPruningTest("Column pruning: with non-partitioned table",
39+
createPruningTest("Column pruning - with non-partitioned table",
4040
"SELECT key FROM src WHERE key > 10 LIMIT 3",
4141
Seq("key"),
4242
Seq("key"),
4343
Seq.empty)
4444

45-
createPruningTest("Column pruning: with multiple projects",
45+
createPruningTest("Column pruning - with multiple projects",
4646
"SELECT c1 FROM (SELECT key AS c1 FROM src WHERE key > 10) t1 LIMIT 3",
4747
Seq("c1"),
4848
Seq("key"),
4949
Seq.empty)
5050

51-
createPruningTest("Column pruning: projects alias substituting",
51+
createPruningTest("Column pruning - projects alias substituting",
5252
"SELECT c1 AS c2 FROM (SELECT key AS c1 FROM src WHERE key > 10) t1 LIMIT 3",
5353
Seq("c2"),
5454
Seq("key"),
5555
Seq.empty)
5656

57-
createPruningTest("Column pruning: filter alias in-lining",
57+
createPruningTest("Column pruning - filter alias in-lining",
5858
"SELECT c1 FROM (SELECT key AS c1 FROM src WHERE key > 10) t1 WHERE c1 < 100 LIMIT 3",
5959
Seq("c1"),
6060
Seq("key"),
6161
Seq.empty)
6262

63-
createPruningTest("Column pruning: without filters",
63+
createPruningTest("Column pruning - without filters",
6464
"SELECT c1 FROM (SELECT key AS c1 FROM src) t1 LIMIT 3",
6565
Seq("c1"),
6666
Seq("key"),
6767
Seq.empty)
6868

69-
createPruningTest("Column pruning: simple top project without aliases",
69+
createPruningTest("Column pruning - simple top project without aliases",
7070
"SELECT key FROM (SELECT key FROM src WHERE key > 10) t1 WHERE key < 100 LIMIT 3",
7171
Seq("key"),
7272
Seq("key"),
7373
Seq.empty)
7474

75-
createPruningTest("Column pruning: non-trivial top project with aliases",
75+
createPruningTest("Column pruning - non-trivial top project with aliases",
7676
"SELECT c1 * 2 AS double FROM (SELECT key AS c1 FROM src WHERE key > 10) t1 LIMIT 3",
7777
Seq("double"),
7878
Seq("key"),
7979
Seq.empty)
8080

8181
// Partition pruning tests
8282

83-
createPruningTest("Partition pruning: non-partitioned, non-trivial project",
83+
createPruningTest("Partition pruning - non-partitioned, non-trivial project",
8484
"SELECT key * 2 AS double FROM src WHERE value IS NOT NULL",
8585
Seq("double"),
8686
Seq("key", "value"),
8787
Seq.empty)
8888

89-
createPruningTest("Partiton pruning: non-partitioned table",
89+
createPruningTest("Partition pruning - non-partitioned table",
9090
"SELECT value FROM src WHERE key IS NOT NULL",
9191
Seq("value"),
9292
Seq("value", "key"),
9393
Seq.empty)
9494

95-
createPruningTest("Partition pruning: with filter on string partition key",
95+
createPruningTest("Partition pruning - with filter on string partition key",
9696
"SELECT value, hr FROM srcpart1 WHERE ds = '2008-04-08'",
9797
Seq("value", "hr"),
9898
Seq("value", "hr"),
9999
Seq(
100100
Seq("2008-04-08", "11"),
101101
Seq("2008-04-08", "12")))
102102

103-
createPruningTest("Partition pruning: with filter on int partition key",
103+
createPruningTest("Partition pruning - with filter on int partition key",
104104
"SELECT value, hr FROM srcpart1 WHERE hr < 12",
105105
Seq("value", "hr"),
106106
Seq("value", "hr"),
107107
Seq(
108108
Seq("2008-04-08", "11"),
109109
Seq("2008-04-09", "11")))
110110

111-
createPruningTest("Partition pruning: left only 1 partition",
111+
createPruningTest("Partition pruning - left only 1 partition",
112112
"SELECT value, hr FROM srcpart1 WHERE ds = '2008-04-08' AND hr < 12",
113113
Seq("value", "hr"),
114114
Seq("value", "hr"),
115115
Seq(
116116
Seq("2008-04-08", "11")))
117117

118-
createPruningTest("Partition pruning: all partitions pruned",
118+
createPruningTest("Partition pruning - all partitions pruned",
119119
"SELECT value, hr FROM srcpart1 WHERE ds = '2014-01-27' AND hr = 11",
120120
Seq("value", "hr"),
121121
Seq("value", "hr"),
122122
Seq.empty)
123123

124-
createPruningTest("Partition pruning: pruning with both column key and partition key",
124+
createPruningTest("Partition pruning - pruning with both column key and partition key",
125125
"SELECT value, hr FROM srcpart1 WHERE value IS NOT NULL AND hr < 12",
126126
Seq("value", "hr"),
127127
Seq("value", "hr"),

0 commit comments

Comments
 (0)