Skip to content

Commit 59df9ee

Browse files
committed
Merge remote-tracking branch 'origin/master' into review-pr7410
2 parents ed4d179 + de5e531 commit 59df9ee

File tree

541 files changed

+24009
-10152
lines changed

Some content is hidden

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

541 files changed

+24009
-10152
lines changed

.gitignore

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -74,3 +74,7 @@ metastore/
7474
warehouse/
7575
TempStatsStore/
7676
sql/hive-thriftserver/test_warehouses
77+
78+
# For R session data
79+
.RHistory
80+
.RData

R/install-dev.bat

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -25,3 +25,9 @@ set SPARK_HOME=%~dp0..
2525
MKDIR %SPARK_HOME%\R\lib
2626

2727
R.exe CMD INSTALL --library="%SPARK_HOME%\R\lib" %SPARK_HOME%\R\pkg\
28+
29+
rem Zip the SparkR package so that it can be distributed to worker nodes on YARN
30+
pushd %SPARK_HOME%\R\lib
31+
%JAVA_HOME%\bin\jar.exe cfM "%SPARK_HOME%\R\lib\sparkr.zip" SparkR
32+
popd
33+

R/install-dev.sh

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -42,4 +42,8 @@ Rscript -e ' if("devtools" %in% rownames(installed.packages())) { library(devtoo
4242
# Install SparkR to $LIB_DIR
4343
R CMD INSTALL --library=$LIB_DIR $FWDIR/pkg/
4444

45+
# Zip the SparkR package so that it can be distributed to worker nodes on YARN
46+
cd $LIB_DIR
47+
jar cfM "$LIB_DIR/sparkr.zip" SparkR
48+
4549
popd > /dev/null

R/pkg/DESCRIPTION

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -34,4 +34,5 @@ Collate:
3434
'serialize.R'
3535
'sparkR.R'
3636
'stats.R'
37+
'types.R'
3738
'utils.R'

R/pkg/NAMESPACE

Lines changed: 13 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -23,9 +23,11 @@ export("setJobGroup",
2323
exportClasses("DataFrame")
2424

2525
exportMethods("arrange",
26+
"as.data.frame",
2627
"attach",
2728
"cache",
2829
"collect",
30+
"coltypes",
2931
"columns",
3032
"count",
3133
"cov",
@@ -153,6 +155,7 @@ exportMethods("%in%",
153155
"isNaN",
154156
"isNotNull",
155157
"isNull",
158+
"kurtosis",
156159
"lag",
157160
"last",
158161
"last_day",
@@ -205,12 +208,17 @@ exportMethods("%in%",
205208
"shiftLeft",
206209
"shiftRight",
207210
"shiftRightUnsigned",
211+
"sd",
208212
"sign",
209213
"signum",
210214
"sin",
211215
"sinh",
212216
"size",
217+
"skewness",
213218
"soundex",
219+
"stddev",
220+
"stddev_pop",
221+
"stddev_samp",
214222
"sqrt",
215223
"startsWith",
216224
"substr",
@@ -229,6 +237,10 @@ exportMethods("%in%",
229237
"unhex",
230238
"unix_timestamp",
231239
"upper",
240+
"var",
241+
"variance",
242+
"var_pop",
243+
"var_samp",
232244
"weekofyear",
233245
"when",
234246
"year")
@@ -262,6 +274,4 @@ export("structField",
262274
"structType",
263275
"structType.jobj",
264276
"structType.structField",
265-
"print.structType")
266-
267-
export("as.data.frame")
277+
"print.structType")

0 commit comments

Comments
 (0)