Skip to content

Commit 4ef1be7

Browse files
committed
fix conflicts
2 parents 269cf21 + cd1d411 commit 4ef1be7

File tree

134 files changed

+3453
-1892
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

134 files changed

+3453
-1892
lines changed

R/pkg/NAMESPACE

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -45,8 +45,6 @@ exportMethods("cache",
4545
"showDF",
4646
"sortDF",
4747
"take",
48-
"toJSON",
49-
"toRDD",
5048
"unionAll",
5149
"unpersist",
5250
"where",
@@ -95,14 +93,12 @@ export("cacheTable",
9593
"createExternalTable",
9694
"dropTempTable",
9795
"jsonFile",
98-
"jsonRDD",
9996
"loadDF",
10097
"parquetFile",
10198
"sql",
10299
"table",
103100
"tableNames",
104101
"tables",
105-
"toDF",
106102
"uncacheTable")
107103

108104
export("sparkRSQL.init",

R/pkg/R/DataFrame.R

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -272,7 +272,7 @@ setMethod("names",
272272
setMethod("registerTempTable",
273273
signature(x = "DataFrame", tableName = "character"),
274274
function(x, tableName) {
275-
callJMethod(x@sdf, "registerTempTable", tableName)
275+
invisible(callJMethod(x@sdf, "registerTempTable", tableName))
276276
})
277277

278278
#' insertInto

R/pkg/inst/profile/shell.R

Lines changed: 6 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -20,11 +20,13 @@
2020
.libPaths(c(file.path(home, "R", "lib"), .libPaths()))
2121
Sys.setenv(NOAWT=1)
2222

23-
library(utils)
24-
library(SparkR)
25-
sc <- sparkR.init(Sys.getenv("MASTER", unset = ""))
23+
# Make sure SparkR package is the last loaded one
24+
old <- getOption("defaultPackages")
25+
options(defaultPackages = c(old, "SparkR"))
26+
27+
sc <- SparkR::sparkR.init(Sys.getenv("MASTER", unset = ""))
2628
assign("sc", sc, envir=.GlobalEnv)
27-
sqlCtx <- sparkRSQL.init(sc)
29+
sqlCtx <- SparkR::sparkRSQL.init(sc)
2830
assign("sqlCtx", sqlCtx, envir=.GlobalEnv)
2931
cat("\n Welcome to SparkR!")
3032
cat("\n Spark context is available as sc, SQL context is available as sqlCtx\n")

core/src/main/resources/org/apache/spark/ui/static/dagre-d3.min.js

Lines changed: 8 additions & 6 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.
Lines changed: 83 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,83 @@
1+
/*
2+
* Licensed to the Apache Software Foundation (ASF) under one or more
3+
* contributor license agreements. See the NOTICE file distributed with
4+
* this work for additional information regarding copyright ownership.
5+
* The ASF licenses this file to You under the Apache License, Version 2.0
6+
* (the "License"); you may not use this file except in compliance with
7+
* the License. You may obtain a copy of the License at
8+
*
9+
* http://www.apache.org/licenses/LICENSE-2.0
10+
*
11+
* Unless required by applicable law or agreed to in writing, software
12+
* distributed under the License is distributed on an "AS IS" BASIS,
13+
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
14+
* See the License for the specific language governing permissions and
15+
* limitations under the License.
16+
*/
17+
18+
#dag-viz-graph svg path {
19+
stroke: #444444;
20+
stroke-width: 1.5px;
21+
}
22+
23+
#dag-viz-graph svg g.cluster rect {
24+
stroke-width: 4px;
25+
stroke-opacity: 0.5;
26+
}
27+
28+
#dag-viz-graph svg g.node circle,
29+
#dag-viz-graph svg g.node rect {
30+
fill: #444444;
31+
}
32+
33+
#dag-viz-graph svg g.node.cached circle,
34+
#dag-viz-graph svg g.node.cached rect {
35+
fill: #FF0000;
36+
}
37+
38+
/* Job page specific styles */
39+
40+
#dag-viz-graph svg.job marker#marker-arrow path {
41+
fill: #444444;
42+
stroke-width: 0px;
43+
}
44+
45+
#dag-viz-graph svg.job g.cluster rect {
46+
fill: #FFFFFF;
47+
stroke: #AADFFF;
48+
}
49+
50+
#dag-viz-graph svg.job g.cluster[id*="stage"] rect {
51+
stroke: #FFDDEE;
52+
stroke-width: 6px;
53+
}
54+
55+
#dag-viz-graph svg.job g#cross-stage-edges path {
56+
fill: none;
57+
}
58+
59+
#dag-viz-graph svg.job g.cluster text {
60+
fill: #AAAAAA;
61+
}
62+
63+
/* Stage page specific styles */
64+
65+
#dag-viz-graph svg.stage g.cluster rect {
66+
fill: #F0F8FF;
67+
stroke: #AADFFF;
68+
}
69+
70+
#dag-viz-graph svg.stage g.cluster[id*="stage"] rect {
71+
fill: #FFFFFF;
72+
stroke: #FFDDEE;
73+
stroke-width: 6px;
74+
}
75+
76+
#dag-viz-graph svg.stage g.node g.label text tspan {
77+
fill: #FFFFFF;
78+
}
79+
80+
#dag-viz-graph svg.stage g.cluster text {
81+
fill: #444444;
82+
font-weight: bold;
83+
}

0 commit comments

Comments
 (0)