Skip to content

Commit c07d05c

Browse files
committed
Merge branch 'master' into configTimeout-6980-tmp
Conflicts: core/src/main/scala/org/apache/spark/rpc/akka/AkkaRpcEnv.scala core/src/main/scala/org/apache/spark/storage/BlockManagerMaster.scala
2 parents b7fb99f + f1646e1 commit c07d05c

File tree

1,106 files changed

+31836
-13382
lines changed

Some content is hidden

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

1,106 files changed

+31836
-13382
lines changed

.rat-excludes

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -82,3 +82,4 @@ local-1426633911242/*
8282
local-1430917381534/*
8383
DESCRIPTION
8484
NAMESPACE
85+
test_support/*

LICENSE

Lines changed: 47 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -853,6 +853,52 @@ and
853853

854854
Vis.js may be distributed under either license.
855855

856+
========================================================================
857+
For dagre-d3 (core/src/main/resources/org/apache/spark/ui/static/dagre-d3.min.js):
858+
========================================================================
859+
Copyright (c) 2013 Chris Pettitt
860+
861+
Permission is hereby granted, free of charge, to any person obtaining a copy
862+
of this software and associated documentation files (the "Software"), to deal
863+
in the Software without restriction, including without limitation the rights
864+
to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
865+
copies of the Software, and to permit persons to whom the Software is
866+
furnished to do so, subject to the following conditions:
867+
868+
The above copyright notice and this permission notice shall be included in
869+
all copies or substantial portions of the Software.
870+
871+
THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
872+
IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
873+
FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
874+
AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
875+
LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
876+
OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
877+
THE SOFTWARE.
878+
879+
========================================================================
880+
For graphlib-dot (core/src/main/resources/org/apache/spark/ui/static/graphlib-dot.min.js):
881+
========================================================================
882+
Copyright (c) 2012-2013 Chris Pettitt
883+
884+
Permission is hereby granted, free of charge, to any person obtaining a copy
885+
of this software and associated documentation files (the "Software"), to deal
886+
in the Software without restriction, including without limitation the rights
887+
to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
888+
copies of the Software, and to permit persons to whom the Software is
889+
furnished to do so, subject to the following conditions:
890+
891+
The above copyright notice and this permission notice shall be included in
892+
all copies or substantial portions of the Software.
893+
894+
THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
895+
IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
896+
FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
897+
AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
898+
LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
899+
OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
900+
THE SOFTWARE.
901+
856902
========================================================================
857903
BSD-style licenses
858904
========================================================================
@@ -861,7 +907,7 @@ The following components are provided under a BSD-style license. See project lin
861907

862908
(BSD 3 Clause) core (com.github.fommil.netlib:core:1.1.2 - https://github.com/fommil/netlib-java/core)
863909
(BSD 3 Clause) JPMML-Model (org.jpmml:pmml-model:1.1.15 - https://github.com/jpmml/jpmml-model)
864-
(BSD 3-clause style license) jblas (org.jblas:jblas:1.2.3 - http://jblas.org/)
910+
(BSD 3-clause style license) jblas (org.jblas:jblas:1.2.4 - http://jblas.org/)
865911
(BSD License) AntLR Parser Generator (antlr:antlr:2.7.7 - http://www.antlr.org/)
866912
(BSD License) Javolution (javolution:javolution:5.5.1 - http://javolution.org)
867913
(BSD licence) ANTLR ST4 4.0.4 (org.antlr:ST4:4.0.4 - http://www.stringtemplate.org)

R/README.md

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -52,7 +52,7 @@ The SparkR documentation (Rd files and HTML files) are not a part of the source
5252
SparkR comes with several sample programs in the `examples/src/main/r` directory.
5353
To run one of them, use `./bin/sparkR <filename> <args>`. For example:
5454

55-
./bin/sparkR examples/src/main/r/pi.R local[2]
55+
./bin/sparkR examples/src/main/r/dataframe.R
5656

5757
You can also run the unit-tests for SparkR by running (you need to install the [testthat](http://cran.r-project.org/web/packages/testthat/index.html) package first):
5858

@@ -63,5 +63,5 @@ You can also run the unit-tests for SparkR by running (you need to install the [
6363
The `./bin/spark-submit` and `./bin/sparkR` can also be used to submit jobs to YARN clusters. You will need to set YARN conf dir before doing so. For example on CDH you can run
6464
```
6565
export YARN_CONF_DIR=/etc/hadoop/conf
66-
./bin/spark-submit --master yarn examples/src/main/r/pi.R 4
66+
./bin/spark-submit --master yarn examples/src/main/r/dataframe.R
6767
```

R/pkg/NAMESPACE

Lines changed: 33 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,9 @@
11
# Imports from base R
22
importFrom(methods, setGeneric, setMethod, setOldClass)
3-
useDynLib(SparkR, stringHashCode)
3+
4+
# Disable native libraries till we figure out how to package it
5+
# See SPARKR-7839
6+
#useDynLib(SparkR, stringHashCode)
47

58
# S3 methods exported
69
export("sparkR.init")
@@ -16,9 +19,11 @@ exportMethods("arrange",
1619
"count",
1720
"describe",
1821
"distinct",
22+
"dropna",
1923
"dtypes",
2024
"except",
2125
"explain",
26+
"fillna",
2227
"filter",
2328
"first",
2429
"group_by",
@@ -37,7 +42,7 @@ exportMethods("arrange",
3742
"registerTempTable",
3843
"rename",
3944
"repartition",
40-
"sampleDF",
45+
"sample",
4146
"sample_frac",
4247
"saveAsParquetFile",
4348
"saveAsTable",
@@ -53,38 +58,62 @@ exportMethods("arrange",
5358
"unpersist",
5459
"where",
5560
"withColumn",
56-
"withColumnRenamed")
61+
"withColumnRenamed",
62+
"write.df")
5763

5864
exportClasses("Column")
5965

6066
exportMethods("abs",
67+
"acos",
6168
"alias",
6269
"approxCountDistinct",
6370
"asc",
71+
"asin",
72+
"atan",
73+
"atan2",
6474
"avg",
6575
"cast",
76+
"cbrt",
77+
"ceiling",
6678
"contains",
79+
"cos",
80+
"cosh",
6781
"countDistinct",
6882
"desc",
6983
"endsWith",
84+
"exp",
85+
"expm1",
86+
"floor",
7087
"getField",
7188
"getItem",
89+
"hypot",
7290
"isNotNull",
7391
"isNull",
7492
"last",
7593
"like",
94+
"log",
95+
"log10",
96+
"log1p",
7697
"lower",
7798
"max",
7899
"mean",
79100
"min",
80101
"n",
81102
"n_distinct",
103+
"rint",
82104
"rlike",
105+
"sign",
106+
"sin",
107+
"sinh",
83108
"sqrt",
84109
"startsWith",
85110
"substr",
86111
"sum",
87112
"sumDistinct",
113+
"tan",
114+
"tanh",
115+
"toDegrees",
116+
"toRadians",
88117
"upper")
89118

90119
exportClasses("GroupedData")
@@ -101,6 +130,7 @@ export("cacheTable",
101130
"jsonFile",
102131
"loadDF",
103132
"parquetFile",
133+
"read.df",
104134
"sql",
105135
"table",
106136
"tableNames",

0 commit comments

Comments
 (0)