Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- inst/tests/test_binary_function.R:43:6: style: Put spaces around all infix operators.
- rdd<- map(text.rdd, function(x) {x})
- ~^
- inst/tests/test_rdd.R:253:59: style: Place a space before left parenthesis, except in a function call.
- actual <- collect(flatMapValues(intRdd, function(x) { x:(x + 1) }))
- ^
- inst/tests/test_rdd.R:296:26: style: Put spaces around all infix operators.
- func <- function(x) { x*x }
- ~^~
- inst/tests/test_rdd.R:314:21: style: Put spaces around all infix operators.
- expect_true(count >=0 && count <= 4)
- ^~~
- inst/tests/test_sparkSQL.R:24:3: warning: no visible global function definition for ‘expect_equal’
- expect_equal(class(actual), "structField")
- ^~~~~~~~~~~~
- inst/tests/test_sparkSQL.R:25:3: warning: no visible global function definition for ‘expect_equal’
- expect_equal(actual$name(), expectedName)
- ^~~~~~~~~~~~
- inst/tests/test_sparkSQL.R:26:3: warning: no visible global function definition for ‘expect_equal’
- expect_equal(actual$dataType.toString(), expectedType)
- ^~~~~~~~~~~~
- inst/tests/test_sparkSQL.R:27:3: warning: no visible global function definition for ‘expect_equal’
- expect_equal(actual$nullable(), expectedNullable)
- ^~~~~~~~~~~~
- inst/tests/test_sparkSQL.R:60:28: style: Only use double-quotes.
- list(type = 'array', elementType = "integer", containsNull = TRUE))
- ^~~~~~~
- inst/tests/test_sparkSQL.R:62:28: style: Only use double-quotes.
- list(type = 'array', elementType = "integer", containsNull = TRUE))
- ^~~~~~~
- inst/tests/test_sparkSQL.R:115:3: style: Closing curly-braces should always be on their own line, unless it's followed by an else.
- }, error = function(err) {
- ^
- inst/tests/test_sparkSQL.R:130:1: style: lines should not be more than 100 characters.
- localDF <- data.frame(name=c("John", "Smith", "Sarah"), age=c(19, 23, 18), height=c(164.10, 181.4, 173.7))
- ^~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
- inst/tests/test_sparkSQL.R:605:3: style: Closing curly-braces should always be on their own line, unless it's followed by an else.
- }, error = function(err) {
- ^
- inst/tests/test_sparkSQL.R:667:80: style: Put spaces around all infix operators.
- expect_equal(collect(select(df, hypot(df$a, df$b)))[1, "HYPOT(a, b)"], sqrt(1^2 + 5^2))
- ~^~
- inst/tests/test_sparkSQL.R:667:86: style: Put spaces around all infix operators.
- expect_equal(collect(select(df, hypot(df$a, df$b)))[1, "HYPOT(a, b)"], sqrt(1^2 + 5^2))
- ~^~
- inst/tests/test_sparkSQL.R:668:80: style: Put spaces around all infix operators.
- expect_equal(collect(select(df, hypot(df$a, df$b)))[2, "HYPOT(a, b)"], sqrt(2^2 + 6^2))
- ~^~
- inst/tests/test_sparkSQL.R:668:86: style: Put spaces around all infix operators.
- expect_equal(collect(select(df, hypot(df$a, df$b)))[2, "HYPOT(a, b)"], sqrt(2^2 + 6^2))
- ~^~
- inst/tests/test_sparkSQL.R:669:80: style: Put spaces around all infix operators.
- expect_equal(collect(select(df, hypot(df$a, df$b)))[3, "HYPOT(a, b)"], sqrt(3^2 + 7^2))
- ~^~
- inst/tests/test_sparkSQL.R:669:86: style: Put spaces around all infix operators.
- expect_equal(collect(select(df, hypot(df$a, df$b)))[3, "HYPOT(a, b)"], sqrt(3^2 + 7^2))
- ~^~
- inst/tests/test_sparkSQL.R:670:80: style: Put spaces around all infix operators.
- expect_equal(collect(select(df, hypot(df$a, df$b)))[4, "HYPOT(a, b)"], sqrt(4^2 + 8^2))
- ~^~
- inst/tests/test_sparkSQL.R:670:86: style: Put spaces around all infix operators.
- expect_equal(collect(select(df, hypot(df$a, df$b)))[4, "HYPOT(a, b)"], sqrt(4^2 + 8^2))
- ~^~
- inst/tests/test_sparkSQL.R:877:43: style: Put spaces around all infix operators.
- expect_equal(count(parquetDF), count(df)*2)
- ~^~
- R/backend.R:24:10: warning: no visible global function definition for ‘callJStatic’
- cls <- callJStatic("java.lang.Class", "forName", className)
- ^~~~~~~~~~~
- R/backend.R:25:3: warning: no visible global function definition for ‘callJMethod’
- callJMethod(cls, "isInstance", jobj)
- ^~~~~~~~~~~
- R/backend.R:37:3: warning: no visible global function definition for ‘invokeJava’
- invokeJava(isStatic = FALSE, objId$id, methodName, ...)
- ^~~~~~~~~~
- R/backend.R:42:3: warning: no visible global function definition for ‘invokeJava’
- invokeJava(isStatic = TRUE, className, methodName, ...)
- ^~~~~~~~~~
- R/backend.R:47:3: warning: no visible global function definition for ‘invokeJava’
- invokeJava(isStatic = TRUE, className, methodName = "<init>", ...)
- ^~~~~~~~~~
- R/backend.R:53:3: warning: no visible global function definition for ‘invokeJava’
- invokeJava(isStatic = TRUE, "SparkRHandler", "rm", objId)
- ^~~~~~~~~~
- R/backend.R:76:24: warning: no visible binding for global variable ‘.toRemoveJobjs’
- objsToRemove <- ls(.toRemoveJobjs)
- ^~~~~~~~~~~~~~
- R/backend.R:80:15: warning: no visible global function definition for ‘removeJObject’
- removeJObject(e)
- ^~~~~~~~~~~~~
- R/backend.R:82:39: warning: no visible binding for global variable ‘.toRemoveJobjs’
- rm(list = objsToRemove, envir = .toRemoveJobjs)
- ^~~~~~~~~~~~~~
- R/backend.R:89:3: warning: no visible global function definition for ‘writeBoolean’
- writeBoolean(rc, isStatic)
- ^~~~~~~~~~~~
- R/backend.R:90:3: warning: no visible global function definition for ‘writeString’
- writeString(rc, objId)
- ^~~~~~~~~~~
- R/backend.R:91:3: warning: no visible global function definition for ‘writeString’
- writeString(rc, methodName)
- ^~~~~~~~~~~
- R/backend.R:94:3: warning: no visible global function definition for ‘writeInt’
- writeInt(rc, length(args))
- ^~~~~~~~
- R/backend.R:95:3: warning: no visible global function definition for ‘writeArgs’
- writeArgs(rc, args)
- ^~~~~~~~~
- R/backend.R:103:3: warning: no visible global function definition for ‘writeInt’
- writeInt(rc, length(bytesToSend))
- ^~~~~~~~
- R/backend.R:108:29: warning: no visible binding for global variable ‘.sparkREnv’
- conn <- get(".sparkRCon", .sparkREnv)
- ^~~~~~~~~~
- R/backend.R:112:19: warning: no visible global function definition for ‘readInt’
- returnStatus <- readInt(conn)
- ^~~~~~~
- R/backend.R:114:3: warning: no visible global function definition for ‘readObject’
- readObject(conn)
- ^~~~~~~~~~
- R/broadcast.R:45:3: warning: no visible global function definition for ‘new’, Did you mean 'news'?
- new("Broadcast", id = id)
- ^~~
- R/broadcast.R:84:16: warning: no visible binding for global variable ‘.broadcastNames’
- bcasts <- ls(.broadcastNames)
- ^~~~~~~~~~~~~~~
- R/broadcast.R:85:29: warning: no visible binding for global variable ‘.broadcastNames’
- rm(list = bcasts, envir = .broadcastNames)
- ^~~~~~~~~~~~~~~
- R/client.R:26:40: warning: no visible binding for global variable ‘.sparkREnv’
- return(get(".sparkRcon", envir = .sparkREnv))
- ^~~~~~~~~~
- R/client.R:33:37: warning: no visible binding for global variable ‘.sparkREnv’
- assign(".sparkRCon", con, envir = .sparkREnv)
- ^~~~~~~~~~
- R/client.R:60:25: warning: no visible global function definition for ‘determineSparkSubmitBin’
- sparkSubmitBinName <- determineSparkSubmitBin()
- ^~~~~~~~~~~~~~~~~~~~~~~
- R/client.R:66:19: warning: no visible global function definition for ‘generateSparkSubmitArgs’
- combinedArgs <- generateSparkSubmitArgs(args, sparkHome, jars, sparkSubmitOpts, packages)
- ^~~~~~~~~~~~~~~~~~~~~~~
- R/column.R:41:3: warning: no visible global function definition for ‘new’, Did you mean 'news'?
- new("Column", jc)
- ^~~
- R/column.R:45:3: warning: no visible global function definition for ‘column’, Did you mean 'colSums'?
- column(callJStatic("org.apache.spark.sql.functions", "col", x))
- ^~~~~~
- R/column.R:45:10: warning: no visible global function definition for ‘callJStatic’
- column(callJStatic("org.apache.spark.sql.functions", "col", x))
- ^~~~~~~~~~~
- R/column.R:68:21: style: Put spaces around all infix operators.
- binary_mathfunctions<- c("atan2", "hypot")
- ~^
- R/column.R:76:19: warning: no visible global function definition for ‘callJMethod’
- callJMethod(e1@jc, "unary_$minus")
- ^~~~~~~~~~~
- R/column.R:78:19: warning: no visible global function definition for ‘callJMethod’
- callJMethod(e1@jc, operators[[op]])
- ^~~~~~~~~~~
- R/column.R:78:38: warning: no visible binding for global variable ‘operators’
- callJMethod(e1@jc, operators[[op]])
- ^~~~~~~~~
- R/column.R:85:25: warning: no visible global function definition for ‘callJStatic’
- jc <- callJStatic("org.apache.spark.sql.functions", operators[[op]], e1@jc, e2)
- ^~~~~~~~~~~
- R/column.R:85:71: warning: no visible binding for global variable ‘operators’
- jc <- callJStatic("org.apache.spark.sql.functions", operators[[op]], e1@jc, e2)
- ^~~~~~~~~
- R/column.R:87:19: warning: no visible global function definition for ‘callJMethod’
- callJMethod(e1@jc, operators[[op]], e2)
- ^~~~~~~~~~~
- R/column.R:87:38: warning: no visible binding for global variable ‘operators’
- callJMethod(e1@jc, operators[[op]], e2)
- ^~~~~~~~~
- R/column.R:90:15: warning: no visible global function definition for ‘column’, Did you mean 'colSums'?
- column(jc)
- ^~~~~~
- R/column.R:98:15: warning: no visible global function definition for ‘column’, Did you mean 'colSums'?
- column(callJMethod(x@jc, name))
- ^~~~~~
- R/column.R:98:22: warning: no visible global function definition for ‘callJMethod’
- column(callJMethod(x@jc, name))
- ^~~~~~~~~~~
- R/column.R:109:21: warning: no visible global function definition for ‘callJMethod’
- jc <- callJMethod(x@jc, name, data)
- ^~~~~~~~~~~
- R/column.R:110:15: warning: no visible global function definition for ‘column’, Did you mean 'colSums'?
- column(jc)
- ^~~~~~
- R/column.R:124:21: warning: no visible global function definition for ‘callJStatic’
- jc <- callJStatic("org.apache.spark.sql.functions", name, x@jc)
- ^~~~~~~~~~~
- R/column.R:125:15: warning: no visible global function definition for ‘column’, Did you mean 'colSums'?
- column(jc)
- ^~~~~~
- R/column.R:136:21: warning: no visible global function definition for ‘callJStatic’
- jc <- callJStatic("org.apache.spark.sql.functions", name, y@jc, x)
- ^~~~~~~~~~~
- R/column.R:137:15: warning: no visible global function definition for ‘column’, Did you mean 'colSums'?
- column(jc)
- ^~~~~~
- R/column.R:143:5: warning: no visible global function definition for ‘createOperator’
- createOperator(op)
- ^~~~~~~~~~~~~~
- R/column.R:146:5: warning: no visible global function definition for ‘createColumnFunction1’
- createColumnFunction1(name)
- ^~~~~~~~~~~~~~~~~~~~~
- R/column.R:149:5: warning: no visible global function definition for ‘createColumnFunction2’
- createColumnFunction2(name)
- ^~~~~~~~~~~~~~~~~~~~~
- R/column.R:152:5: warning: no visible global function definition for ‘createStaticFunction’
- createStaticFunction(x)
- ^~~~~~~~~~~~~~~~~~~~
- R/column.R:155:5: warning: no visible global function definition for ‘createBinaryMathfunctions’
- createBinaryMathfunctions(name)
- ^~~~~~~~~~~~~~~~~~~~~~~~~
- R/context.R:22:27: warning: no visible global function definition for ‘callJMethod’
- defaultParallelism <- callJMethod(sc, "defaultParallelism")
- ^~~~~~~~~~~
- R/context.R:51:11: warning: no visible global function definition for ‘callJMethod’
- jrdd <- callJMethod(sc, "textFile", path, getMinPartitions(sc, minPartitions))
- ^~~~~~~~~~~
- R/context.R:51:45: warning: no visible global function definition for ‘getMinPartitions’
- jrdd <- callJMethod(sc, "textFile", path, getMinPartitions(sc, minPartitions))
- ^~~~~~~~~~~~~~~~
- R/context.R:53:3: warning: no visible global function definition for ‘RDD’, Did you mean 'D'?
- RDD(jrdd, "string")
- ^~~
- R/context.R:79:11: warning: no visible global function definition for ‘callJMethod’
- jrdd <- callJMethod(sc, "objectFile", path, getMinPartitions(sc, minPartitions))
- ^~~~~~~~~~~
- R/context.R:79:47: warning: no visible global function definition for ‘getMinPartitions’
- jrdd <- callJMethod(sc, "objectFile", path, getMinPartitions(sc, minPartitions))
- ^~~~~~~~~~~~~~~~
- R/context.R:81:3: warning: no visible global function definition for ‘RDD’, Did you mean 'D'?
- RDD(jrdd, "byte")
- ^~~
- R/context.R:124:31: style: Place a space before left parenthesis, except in a function call.
- slices <- split(coll, rep(1:(numSlices + 1), each = sliceLen)[1:length(coll)])
- ^
- R/context.R:133:3: warning: no visible global function definition for ‘RDD’, Did you mean 'D'?
- RDD(jrdd, "byte")
- ^~~
- R/context.R:202:17: warning: no visible global function definition for ‘callJMethod’
- jBroadcast <- callJMethod(sc, "broadcast", serializedObj)
- ^~~~~~~~~~~
- R/context.R:203:22: warning: no visible global function definition for ‘callJMethod’
- id <- as.character(callJMethod(jBroadcast, "id"))
- ^~~~~~~~~~~
- R/context.R:205:3: warning: no visible global function definition for ‘Broadcast’, Did you mean 'jBroadcast'?
- Broadcast(id, object, jBroadcast, objName)
- ^~~~~~~~~
- R/context.R:224:13: warning: no visible global function definition for ‘callJMethod’
- invisible(callJMethod(sc, "setCheckpointDir", suppressWarnings(normalizePath(dirName))))
- ^~~~~~~~~~~
- R/DataFrame.R:52:3: warning: no visible global function definition for ‘new’, Did you mean 'news'?
- new("DataFrame", sdf, isCached)
- ^~~
- R/DataFrame.R:815:3: warning: no visible global function definition for ‘column’, Did you mean 'colSums'?
- column(callJMethod(x@sdf, "col", c))
- ^~~~~~
- R/DataFrame.R:815:10: warning: no visible global function definition for ‘callJMethod’
- column(callJMethod(x@sdf, "col", c))
- ^~~~~~~~~~~
- R/DataFrame.R:1317:46: style: Only use double-quotes.
- signature(df = "DataFrame", path = 'character'),
- ^~~~~~~~~~~
- R/DataFrame.R:1325:18: style: Place a space before left parenthesis, except in a function call.
- if (!(mode %in% allModes)) {
- ^
- R/DataFrame.R:1331:26: style: Only use double-quotes.
- options[['path']] <- path
- ^~~~~~
- R/DataFrame.R:1340:46: style: Only use double-quotes.
- signature(df = "DataFrame", path = 'character'),
- ^~~~~~~~~~~
- R/DataFrame.R:1378:51: style: Only use double-quotes.
- signature(df = "DataFrame", tableName = 'character', source = 'character',
- ^~~~~~~~~~~
- R/DataFrame.R:1378:73: style: Only use double-quotes.
- signature(df = "DataFrame", tableName = 'character', source = 'character',
- ^~~~~~~~~~~
- R/DataFrame.R:1379:28: style: Only use double-quotes.
- mode = 'character'),
- ^~~~~~~~~~~
- R/DataFrame.R:1387:18: style: Place a space before left parenthesis, except in a function call.
- if (!(mode %in% allModes)) {
- ^
- R/deserialize.R:38:11: warning: no visible global function definition for ‘readType’
- type <- readType(con)
- ^~~~~~~~
- R/deserialize.R:39:3: warning: no visible global function definition for ‘readTypedObject’
- readTypedObject(con, type)
- ^~~~~~~~~~~~~~~
- R/deserialize.R:58:16: warning: no visible global function definition for ‘readInt’
- stringLen <- readInt(con)
- ^~~~~~~
- R/deserialize.R:72:14: warning: no visible global function definition for ‘readInt’
- as.logical(readInt(con))
- ^~~~~~~
- R/deserialize.R:80:11: warning: no visible global function definition for ‘readString’
- as.Date(readString(con))
- ^~~~~~~~~~
- R/deserialize.R:84:8: warning: no visible global function definition for ‘readDouble’
- t <- readDouble(con)
- ^~~~~~~~~~
- R/deserialize.R:90:11: warning: no visible global function definition for ‘readType’
- type <- readType(con)
- ^~~~~~~~
- R/deserialize.R:91:10: warning: no visible global function definition for ‘readInt’
- len <- readInt(con)
- ^~~~~~~
- R/deserialize.R:95:17: warning: no visible global function definition for ‘readTypedObject’
- l[[i]] <- readTypedObject(con, type)
- ^~~~~~~~~~~~~~~
- R/deserialize.R:104:14: warning: no visible global function definition for ‘readInt’
- dataLen <- readInt(con)
- ^~~~~~~
- R/deserialize.R:105:3: warning: local variable ‘data’ assigned but may not be used
- data <- readBin(con, raw(), as.integer(dataLen), endian = "big")
- ^~~~
- R/deserialize.R:109:3: warning: local variable ‘data’ assigned but may not be used
- data <- readBin(con, raw(), as.integer(dataLen), endian = "big")
- ^~~~
- R/deserialize.R:116:14: warning: no visible global function definition for ‘readInt’
- dataLen <- readInt(con)
- ^~~~~~~
- R/deserialize.R:121:14: warning: no visible global function definition for ‘readInt’
- dataLen <- readInt(con)
- ^~~~~~~
- R/deserialize.R:127:18: warning: no visible global function definition for ‘readInt’
- dataLen <- readInt(con)
- ^~~~~~~
- R/deserialize.R:142:12: warning: no visible global function definition for ‘readRow’, Did you mean 'readRDS'?
- row <- readRow(inputCon)
- ^~~~~~~
- R/deserialize.R:158:3: warning: no visible global function definition for ‘readRow’, Did you mean 'readRDS'?
- readRow(rawObj)
- ^~~~~~~
- R/deserialize.R:162:14: warning: no visible global function definition for ‘readInt’
- numCols <- readInt(inputCon)
- ^~~~~~~
- R/deserialize.R:165:14: warning: no visible global function definition for ‘readObject’
- obj <- readObject(inputCon)
- ^~~~~~~~~~
- R/deserialize.R:181:14: warning: no visible global function definition for ‘readObject’
- value <- readObject(inputCon)
- ^~~~~~~~~~
- R/generics.R:254:35: style: Closing curly-braces should always be on their own line, unless it's followed by an else.
- standardGeneric("intersection") })
- ^
- R/generics.R:553:40: style: Closing curly-braces should always be on their own line, unless it's followed by an else.
- standardGeneric("withColumnRenamed") })
- ^
- R/group.R:42:3: warning: no visible global function definition for ‘new’, Did you mean 'news'?
- new("GroupedData", sgd)
- ^~~
- R/group.R:127:22: warning: no visible global function definition for ‘callJMethod’
- sdf <- callJMethod(x@sgd, name, toSeq(...))
- ^~~~~~~~~~~
- R/group.R:127:47: warning: no visible global function definition for ‘toSeq’
- sdf <- callJMethod(x@sgd, name, toSeq(...))
- ^~~~~
- R/group.R:128:15: warning: no visible global function definition for ‘dataFrame’, Did you mean 'data.frame'?
- dataFrame(sdf)
- ^~~~~~~~~
- R/group.R:134:5: warning: no visible global function definition for ‘createMethod’
- createMethod(name)
- ^~~~~~~~~~~~
- R/jobj.R:34:47: warning: no visible binding for global variable ‘.sparkREnv’
- jobj$appId == get(".scStartTime", envir = .sparkREnv)
- ^~~~~~~~~~
- R/jobj.R:41:13: warning: no visible global function definition for ‘jobj’, Did you mean 'nobs'?
- newObj <- jobj(objId)
- ^~~~
- R/jobj.R:59:44: warning: no visible binding for global variable ‘.sparkREnv’
- obj$appId <- get(".scStartTime", envir = .sparkREnv)
- ^~~~~~~~~~
- R/jobj.R:63:22: warning: no visible binding for global variable ‘cleanup.jobj’
- reg.finalizer(obj, cleanup.jobj)
- ^~~~~~~~~~~~
- R/jobj.R:75:10: warning: no visible global function definition for ‘callJMethod’
- cls <- callJMethod(x, "getClass")
- ^~~~~~~~~~~
- R/jobj.R:76:11: warning: no visible global function definition for ‘callJMethod’
- name <- callJMethod(cls, "getName")
- ^~~~~~~~~~~
- R/jobj.R:99:15: warning: no visible binding for global variable ‘.validJobjs’
- valid <- ls(.validJobjs)
- ^~~~~~~~~~~
- R/jobj.R:100:28: warning: no visible binding for global variable ‘.validJobjs’
- rm(list = valid, envir = .validJobjs)
- ^~~~~~~~~~~
- R/jobj.R:102:20: warning: no visible binding for global variable ‘.toRemoveJobjs’
- removeList <- ls(.toRemoveJobjs)
- ^~~~~~~~~~~~~~
- R/jobj.R:103:33: warning: no visible binding for global variable ‘.toRemoveJobjs’
- rm(list = removeList, envir = .toRemoveJobjs)
- ^~~~~~~~~~~~~~
- R/pairRDD.R:206:63: style: Closing curly-braces should always be on their own line, unless it's followed by an else.
- get(name, .broadcastNames) })
- ^
- R/pairRDD.R:882:27: style: Place a space before left parenthesis, except in a function call.
- res[(len + 1):(len + count)] <- rep(list(elem), count)
- ^
- R/pairRDD.R:882:37: style: Place a space before left parenthesis, except in a function call.
- res[(len + 1):(len + count)] <- rep(list(elem), count)
- ^
- R/RDD.R:88:6: style: Place a space before left parenthesis, except in a function call.
- !(e$isCached || e$isCheckpointed)
- ^
- R/RDD.R:100:32: style: Place a space before left parenthesis, except in a function call.
- func(partIndex, prev@func(partIndex, part))
- ^
- R/RDD.R:121:3: warning: no visible global function definition for ‘new’, Did you mean 'news'?
- new("RDD", jrdd, serializedMode, isCached, isCheckpointed)
- ^~~
- R/RDD.R:125:3: warning: no visible global function definition for ‘new’, Did you mean 'news'?
- new("PipelinedRDD", prev, func, NULL)
- ^~~
- R/RDD.R:844:25: style: Place a space before left parenthesis, except in a function call.
- res[(len + 1):(len + count)] <- rep(list(elem), count)
- ^
- R/RDD.R:844:35: style: Place a space before left parenthesis, except in a function call.
- res[(len + 1):(len + count)] <- rep(list(elem), count)
- ^
- R/RDD.R:1106:13: warning: no visible global function definition for ‘mapPartitions’
- newRdd <- mapPartitions(x, partitionFunc)
- ^~~~~~~~~~~~~
- R/RDD.R:1110:11: warning: no visible global function definition for ‘getJRDD’
- jrdd <- getJRDD(newRdd)
- ^~~~~~~
- R/RDD.R:1112:24: warning: no visible global function definition for ‘getSerializedMode’
- serializedModeRDD <- getSerializedMode(newRdd)
- ^~~~~~~~~~~~~~~~~
- R/RDD.R:1124:21: warning: no visible global function definition for ‘callJMethod’
- partitionArr <- callJMethod(jrdd, "collectPartitions", as.list(as.integer(index)))
- ^~~~~~~~~~~
- R/RDD.R:1264:15: style: Words within variable and function names should be separated by '_' rather than '.'.
- trim.trailing.func <- function(x) {
- ^~~~~~~~~~~~~~~~~~
- R/RDD.R:1267:44: style: Words within variable and function names should be separated by '_' rather than '.'.
- input <- unlist(lapply(part, trim.trailing.func))
- ^~~~~~~~~~~~~~~~~~
- R/RDD.R:1269:27: style: Words within variable and function names should be separated by '_' rather than '.'.
- lapply(res, trim.trailing.func)
- ^~~~~~~~~~~~~~~~~~
- R/schema.R:45:37: warning: no visible global function definition for ‘callJMethod’
- obj$fields <- function() { lapply(callJMethod(obj$jobj, "fields"), structField) }
- ^~~~~~~~~~~
- R/schema.R:45:70: warning: no visible binding for global variable ‘structField’
- obj$fields <- function() { lapply(callJMethod(obj$jobj, "fields"), structField) }
- ^~~~~~~~~~~
- R/schema.R:60:3: warning: no visible global function definition for ‘structType’
- structType(stObj)
- ^~~~~~~~~~
- R/schema.R:76:30: style: Closing curly-braces should always be on their own line, unless it's followed by an else.
- sep = "") })
- ^
- R/schema.R:107:28: warning: no visible global function definition for ‘callJMethod’
- obj$name <- function() { callJMethod(x, "name") }
- ^~~~~~~~~~~
- R/schema.R:108:32: warning: no visible global function definition for ‘callJMethod’
- obj$dataType <- function() { callJMethod(x, "dataType") }
- ^~~~~~~~~~~
- R/schema.R:109:41: warning: no visible global function definition for ‘callJMethod’
- obj$dataType.toString <- function() { callJMethod(obj$dataType(), "toString") }
- ^~~~~~~~~~~
- R/schema.R:110:45: warning: no visible global function definition for ‘callJMethod’
- obj$dataType.simpleString <- function() { callJMethod(obj$dataType(), "simpleString") }
- ^~~~~~~~~~~
- R/schema.R:111:32: warning: no visible global function definition for ‘callJMethod’
- obj$nullable <- function() { callJMethod(x, "nullable") }
- ^~~~~~~~~~~
- R/schema.R:148:3: warning: no visible global function definition for ‘structField’
- structField(sfObj)
- ^~~~~~~~~~~
- R/serialize.R:76:3: warning: no visible global function definition for ‘writeString’
- writeString(con, value$id)
- ^~~~~~~~~~~
- R/serialize.R:81:3: warning: no visible global function definition for ‘writeInt’
- writeInt(con, as.integer(nchar(utfVal, type = "bytes") + 1))
- ^~~~~~~~
- R/serialize.R:95:3: warning: no visible global function definition for ‘writeInt’
- writeInt(con, as.integer(value))
- ^~~~~~~~
- R/serialize.R:100:3: warning: no visible global function definition for ‘writeRaw’
- writeRaw(outputCon, outputSer)
- ^~~~~~~~
- R/serialize.R:105:14: warning: no visible global function definition for ‘serializeRow’
- bytes <- serializeRow(r)
- ^~~~~~~~~~~~
- R/serialize.R:106:5: warning: no visible global function definition for ‘writeRaw’
- writeRaw(outputCon, bytes)
- ^~~~~~~~
- R/serialize.R:113:3: warning: no visible global function definition for ‘writeRow’
- writeRow(rawObj, row)
- ^~~~~~~~
- R/serialize.R:119:3: warning: no visible global function definition for ‘writeInt’
- writeInt(con, numCols)
- ^~~~~~~~
- R/serialize.R:121:5: warning: no visible global function definition for ‘writeObject’
- writeObject(con, row[[i]])
- ^~~~~~~~~~~
- R/serialize.R:126:3: warning: no visible global function definition for ‘writeInt’
- writeInt(con, length(batch))
- ^~~~~~~~
- R/serialize.R:143:28: style: Only use double-quotes.
- POSIXlt = 't',
- ^~~
- R/serialize.R:144:28: style: Only use double-quotes.
- POSIXct = 't',
- ^~~
- R/serialize.R:161:3: warning: no visible global function definition for ‘writeType’
- writeType(con, elemType)
- ^~~~~~~~~
- R/serialize.R:162:3: warning: no visible global function definition for ‘writeInt’
- writeInt(con, length(arr))
- ^~~~~~~~
- R/serialize.R:166:7: warning: no visible global function definition for ‘writeObject’
- writeObject(con, a, FALSE)
- ^~~~~~~~~~~
- R/serialize.R:173:3: warning: no visible global function definition for ‘writeInt’
- writeInt(con, length(list))
- ^~~~~~~~
- R/serialize.R:175:5: warning: no visible global function definition for ‘writeObject’
- writeObject(con, elem)
- ^~~~~~~~~~~
- R/serialize.R:183:3: warning: no visible global function definition for ‘writeInt’
- writeInt(con, len)
- ^~~~~~~~
- R/serialize.R:185:5: warning: no visible global function definition for ‘writeList’
- writeList(con, as.list(ls(env)))
- ^~~~~~~~~
- R/serialize.R:187:5: warning: no visible global function definition for ‘writeGenericList’
- writeGenericList(con, as.list(vals))
- ^~~~~~~~~~~~~~~~
- R/serialize.R:192:3: warning: no visible global function definition for ‘writeString’
- writeString(con, as.character(date))
- ^~~~~~~~~~~
- R/serialize.R:196:3: warning: no visible global function definition for ‘writeDouble’
- writeDouble(con, as.double(time))
- ^~~~~~~~~~~
- R/serialize.R:205:7: warning: no visible global function definition for ‘writeObject’
- writeObject(con, a)
- ^~~~~~~~~~~
- R/sparkR.R:25:3: style: Closing curly-braces should always be on their own line, unless it's followed by an else.
- }, error = function(err) {
- ^
- R/sparkR.R:34:10: warning: no visible binding for global variable ‘.sparkREnv’
- env <- .sparkREnv
- ^~~~~~~~~~
- R/sparkR.R:39:7: warning: no visible global function definition for ‘callJMethod’
- callJMethod(sc, "stop")
- ^~~~~~~~~~~
- R/sparkR.R:44:7: warning: no visible global function definition for ‘callJStatic’
- callJStatic("SparkRHandler", "stopBackend")
- ^~~~~~~~~~~
- R/sparkR.R:63:3: warning: no visible global function definition for ‘clearBroadcastVariables’
- clearBroadcastVariables()
- ^~~~~~~~~~~~~~~~~~~~~~~
- R/sparkR.R:66:3: warning: no visible global function definition for ‘clearJobjs’
- clearJobjs()
- ^~~~~~~~~~
- R/sparkR.R:107:3: warning: local variable ‘sparkMem’ assigned but may not be used
- sparkMem <- Sys.getenv("SPARK_MEM", "1024m")
- ^~~~~~~~
- R/sparkR.R:113:5: warning: local variable ‘collapseChar’ assigned but may not be used
- collapseChar <- ":"
- ^~~~~~~~~~~~
- R/sparkR.R:143:26: style: Only use double-quotes.
- f <- file(path, open='rb')
- ^~~~
- R/sparkR.R:144:20: warning: no visible global function definition for ‘readInt’
- backendPort <- readInt(f)
- ^~~~~~~
- R/sparkR.R:145:20: warning: no visible global function definition for ‘readInt’
- monitorPort <- readInt(f)
- ^~~~~~~
- R/sparkR.R:158:5: warning: no visible global function definition for ‘connectBackend’
- connectBackend("localhost", backendPort)
- ^~~~~~~~~~~~~~
- R/sparkR.R:159:3: style: Closing curly-braces should always be on their own line, unless it's followed by an else.
- }, error = function(err) {
- ^
- R/sparkR.R:226:40: warning: no visible binding for global variable ‘.sparkREnv’
- return(get(".sparkRSQLsc", envir = .sparkREnv))
- ^~~~~~~~~~
- R/sparkR.R:231:5: warning: no visible global function definition for ‘sparkR.init’
- sparkR.init()
- ^~~~~~~~~~~
- R/sparkR.R:239:46: warning: no visible binding for global variable ‘.sparkREnv’
- assign(".sparkRSQLsc", sqlContext, envir = .sparkREnv)
- ^~~~~~~~~~
- R/sparkR.R:257:41: warning: no visible binding for global variable ‘.sparkREnv’
- return(get(".sparkRHivesc", envir = .sparkREnv))
- ^~~~~~~~~~
- R/sparkR.R:262:5: warning: no visible global function definition for ‘sparkR.init’
- sparkR.init()
- ^~~~~~~~~~~
- R/sparkR.R:267:10: warning: no visible global function definition for ‘callJMethod’
- ssc <- callJMethod(sc, "sc")
- ^~~~~~~~~~~
- R/sparkR.R:269:5: warning: no visible global function definition for ‘newJObject’
- newJObject("org.apache.spark.sql.hive.HiveContext", ssc)
- ^~~~~~~~~~
- R/sparkR.R:270:3: style: Closing curly-braces should always be on their own line, unless it's followed by an else.
- }, error = function(err) {
- ^
- R/sparkR.R:274:44: warning: no visible binding for global variable ‘.sparkREnv’
- assign(".sparkRHivesc", hiveCtx, envir = .sparkREnv)
- ^~~~~~~~~~
- R/sparkR.R:292:3: warning: no visible global function definition for ‘callJMethod’
- callJMethod(sc, "setJobGroup", groupId, description, interruptOnCancel)
- ^~~~~~~~~~~
- R/sparkR.R:305:3: warning: no visible global function definition for ‘callJMethod’
- callJMethod(sc, "clearJobGroup")
- ^~~~~~~~~~~
- R/sparkR.R:319:3: warning: no visible global function definition for ‘callJMethod’
- callJMethod(sc, "cancelJobGroup", groupId)
- ^~~~~~~~~~~
- R/SQLContext.R:57:9: warning: no visible global function definition for ‘structField’
- structField(names[[i]], types[[i]], TRUE)
- ^~~~~~~~~~~
- R/SQLContext.R:59:15: warning: no visible binding for global variable ‘structType’
- do.call(structType, fields)
- ^~~~~~~~~~
- R/SQLContext.R:107:11: warning: no visible global function definition for ‘callJStatic’
- sc <- callJStatic("org.apache.spark.sql.api.r.SQLUtils", "getJavaSparkContext", sqlContext)
- ^~~~~~~~~~~
- R/SQLContext.R:108:12: warning: no visible global function definition for ‘parallelize’
- rdd <- parallelize(sc, data)
- ^~~~~~~~~~~
- R/SQLContext.R:116:12: warning: no visible global function definition for ‘first’, Did you mean 'dist'?
- row <- first(rdd)
- ^~~~~
- R/SQLContext.R:138:26: warning: no visible binding for global variable ‘infer_type’
- types <- lapply(row, infer_type)
- ^~~~~~~~~~
- R/SQLContext.R:140:7: warning: no visible global function definition for ‘structField’
- structField(names[[i]], types[[i]], TRUE)
- ^~~~~~~~~~~
- R/SQLContext.R:142:23: warning: no visible binding for global variable ‘structType’
- schema <- do.call(structType, fields)
- ^~~~~~~~~~
- R/SQLContext.R:148:11: warning: no visible global function definition for ‘getJRDD’
- jrdd <- getJRDD(lapply(rdd, function(x) x), "row")
- ^~~~~~~
- R/SQLContext.R:149:11: warning: no visible global function definition for ‘callJMethod’
- srdd <- callJMethod(jrdd, "rdd")
- ^~~~~~~~~~~
- R/SQLContext.R:152:3: warning: no visible global function definition for ‘dataFrame’, Did you mean 'data.frame'?
- dataFrame(sdf)
- ^~~~~~~~~
- R/SQLContext.R:207:10: warning: no visible global function definition for ‘callJMethod’
- sdf <- callJMethod(sqlContext, "jsonFile", path)
- ^~~~~~~~~~~
- R/SQLContext.R:208:3: warning: no visible global function definition for ‘dataFrame’, Did you mean 'data.frame'?
- dataFrame(sdf)
- ^~~~~~~~~
- R/SQLContext.R:232:10: warning: no visible global function definition for ‘serializeToString’
- rdd <- serializeToString(rdd)
- ^~~~~~~~~~~~~~~~~
- R/SQLContext.R:234:12: warning: no visible global function definition for ‘callJMethod’
- sdf <- callJMethod(sqlContext, "jsonRDD", callJMethod(getJRDD(rdd), "rdd"), samplingRatio)
- ^~~~~~~~~~~
- R/SQLContext.R:234:12: warning: no visible global function definition for ‘callJMethod’
- sdf <- callJMethod(sqlContext, "jsonRDD", callJMethod(getJRDD(rdd), "rdd"), samplingRatio)
- ^~~~~~~~~~~
- R/SQLContext.R:234:59: warning: no visible global function definition for ‘getJRDD’
- sdf <- callJMethod(sqlContext, "jsonRDD", callJMethod(getJRDD(rdd), "rdd"), samplingRatio)
- ^~~~~~~
- R/SQLContext.R:235:5: warning: no visible global function definition for ‘dataFrame’, Did you mean 'data.frame'?
- dataFrame(sdf)
- ^~~~~~~~~
- R/SQLContext.R:255:10: warning: no visible global function definition for ‘callJMethod’
- sdf <- callJMethod(sqlContext, "parquetFile", paths)
- ^~~~~~~~~~~
- R/SQLContext.R:256:3: warning: no visible global function definition for ‘dataFrame’, Did you mean 'data.frame'?
- dataFrame(sdf)
- ^~~~~~~~~
- R/SQLContext.R:278:9: warning: no visible global function definition for ‘callJMethod’
- sdf <- callJMethod(sqlContext, "sql", sqlQuery)
- ^~~~~~~~~~~
- R/SQLContext.R:279:2: warning: no visible global function definition for ‘dataFrame’, Did you mean 'data.frame'?
- dataFrame(sdf)
- ^~~~~~~~~
- R/SQLContext.R:302:10: warning: no visible global function definition for ‘callJMethod’
- sdf <- callJMethod(sqlContext, "table", tableName)
- ^~~~~~~~~~~
- R/SQLContext.R:303:3: warning: no visible global function definition for ‘dataFrame’, Did you mean 'data.frame'?
- dataFrame(sdf)
- ^~~~~~~~~
- R/SQLContext.R:324:5: warning: no visible global function definition for ‘callJMethod’
- callJMethod(sqlContext, "tables")
- ^~~~~~~~~~~
- R/SQLContext.R:326:5: warning: no visible global function definition for ‘callJMethod’
- callJMethod(sqlContext, "tables", databaseName)
- ^~~~~~~~~~~
- R/SQLContext.R:328:3: warning: no visible global function definition for ‘dataFrame’, Did you mean 'data.frame'?
- dataFrame(jdf)
- ^~~~~~~~~
- R/SQLContext.R:349:5: warning: no visible global function definition for ‘callJMethod’
- callJMethod(sqlContext, "tableNames")
- ^~~~~~~~~~~
- R/SQLContext.R:351:5: warning: no visible global function definition for ‘callJMethod’
- callJMethod(sqlContext, "tableNames", databaseName)
- ^~~~~~~~~~~
- R/SQLContext.R:375:3: warning: no visible global function definition for ‘callJMethod’
- callJMethod(sqlContext, "cacheTable", tableName)
- ^~~~~~~~~~~
- R/SQLContext.R:397:3: warning: no visible global function definition for ‘callJMethod’
- callJMethod(sqlContext, "uncacheTable", tableName)
- ^~~~~~~~~~~
- R/SQLContext.R:411:3: warning: no visible global function definition for ‘callJMethod’
- callJMethod(sqlContext, "clearCache")
- ^~~~~~~~~~~
- R/SQLContext.R:434:3: warning: no visible global function definition for ‘callJMethod’
- callJMethod(sqlContext, "dropTempTable", tableName)
- ^~~~~~~~~~~
- R/SQLContext.R:458:14: warning: no visible global function definition for ‘varargsToEnv’
- options <- varargsToEnv(...)
- ^~~~~~~~~~~~
- R/SQLContext.R:460:14: style: Only use double-quotes.
- options[['path']] <- path
- ^~~~~~
- R/SQLContext.R:463:47: warning: no visible binding for global variable ‘.sparkREnv’
- sqlContext <- get(".sparkRSQLsc", envir = .sparkREnv)
- ^~~~~~~~~~
- R/SQLContext.R:472:12: warning: no visible global function definition for ‘callJStatic’
- sdf <- callJStatic("org.apache.spark.sql.api.r.SQLUtils", "loadDF", sqlContext, source, options)
- ^~~~~~~~~~~
- R/SQLContext.R:474:3: warning: no visible global function definition for ‘dataFrame’, Did you mean 'data.frame'?
- dataFrame(sdf)
- ^~~~~~~~~
- R/SQLContext.R:481:3: warning: no visible global function definition for ‘read.df’, Did you mean 'read.dcf'?
- read.df(sqlContext, path, source, schema, ...)
- ^~~~~~~
- R/SQLContext.R:507:14: warning: no visible global function definition for ‘varargsToEnv’
- options <- varargsToEnv(...)
- ^~~~~~~~~~~~
- R/SQLContext.R:509:14: style: Only use double-quotes.
- options[['path']] <- path
- ^~~~~~
- R/SQLContext.R:511:10: warning: no visible global function definition for ‘callJMethod’
- sdf <- callJMethod(sqlContext, "createExternalTable", tableName, source, options)
- ^~~~~~~~~~~
- R/SQLContext.R:512:3: warning: no visible global function definition for ‘dataFrame’, Did you mean 'data.frame'?
- dataFrame(sdf)
- ^~~~~~~~~
- R/utils.R:25:14: warning: no visible global function definition for ‘callJMethod’
- arrSize <- callJMethod(jList, "size")
- ^~~~~~~~~~~
- R/utils.R:35:14: style: Place a space before left parenthesis, except in a function call.
- lapply(0:(arrSize - 1),
- ^
- R/utils.R:37:20: warning: no visible global function definition for ‘callJMethod’
- obj <- callJMethod(jList, "get", as.integer(index))
- ^~~~~~~~~~~
- R/utils.R:44:29: warning: no visible global function definition for ‘callJMethod’
- keyBytes <- callJMethod(obj, "_1")
- ^~~~~~~~~~~
- R/utils.R:45:29: warning: no visible global function definition for ‘callJMethod’
- valBytes <- callJMethod(obj, "_2")
- ^~~~~~~~~~~
- R/utils.R:62:26: warning: no visible global function definition for ‘readRowList’
- res <- readRowList(obj)
- ^~~~~~~~~~~
- R/utils.R:136:20: warning: no visible global function definition for ‘mult31AndAdd’
- hashC <- mult31AndAdd(hashC, asciiVals[k])
- ^~~~~~~~~~~~
- R/utils.R:163:11: warning: no visible global function definition for ‘wrapInt’
- wrapInt(as.numeric(a) + as.numeric(b))
- ^~~~~~~
- R/utils.R:191:5: warning: no visible global function definition for ‘getJRDD’
- getJRDD(ser.rdd, serializedMode = "string")
- ^~~~~~~
- R/utils.R:282:12: warning: no visible global function definition for ‘genCompactLists’
- lists <- genCompactLists(tagged_list, cnull)
- ^~~~~~~~~~~~~~~
- R/utils.R:283:3: warning: no visible global function definition for ‘mergeCompactLists’
- mergeCompactLists(lists[[1]], lists[[2]])
- ^~~~~~~~~~~~~~~~~
- R/utils.R:365:3: warning: no visible global function definition for ‘callJStatic’
- callJStatic("org.apache.spark.sql.api.r.SQLUtils", "toSeq", list(...))
- ^~~~~~~~~~~
- R/utils.R:370:3: warning: no visible global function definition for ‘callJStatic’
- callJStatic("org.apache.spark.sql.api.r.SQLUtils", "toSeq", l)
- ^~~~~~~~~~~
- R/utils.R:407:11: warning: no visible global function definition for ‘addItemToAccumulator’
- addItemToAccumulator(defVars, as.character(defVar))
- ^~~~~~~~~~~~~~~~~~~~
- R/utils.R:418:41: warning: no visible global function definition for ‘addItemToAccumulator’
- lapply(newArgs, function(arg) { addItemToAccumulator(defVars, arg) })
- ^~~~~~~~~~~~~~~~~~~~
- R/utils.R:451:1: style: Trailing whitespace is superfluous.
- ^~~~~~~~~
- R/utils.R:476:22: warning: no visible global function definition for ‘cleanClosure’
- obj <- cleanClosure(obj, checkedFuncs)
- ^~~~~~~~~~~~
- R/utils.R:506:16: warning: no visible global function definition for ‘initAccumulator’
- defVars <- initAccumulator()
- ^~~~~~~~~~~~~~~
- R/utils.R:510:7: warning: no visible global function definition for ‘addItemToAccumulator’
- addItemToAccumulator(defVars, argNames[i])
- ^~~~~~~~~~~~~~~~~~~~
- R/utils.R:513:5: warning: no visible global function definition for ‘processClosure’
- processClosure(func.body, oldEnv, defVars, checkedFuncs, newEnv)
- ^~~~~~~~~~~~~~
- R/utils.R:540:10: warning: no visible global function definition for ‘lapplyPartition’
- x <- lapplyPartition(x, appendLength)
- ^~~~~~~~~~~~~~~
- R/utils.R:541:14: warning: no visible global function definition for ‘lapplyPartition’
- other <- lapplyPartition(other, appendLength)
- ^~~~~~~~~~~~~~~
- R/utils.R:553:21: warning: no visible global function definition for ‘getSerializedMode’
- serializerMode <- getSerializedMode(rdd)
- ^~~~~~~~~~~~~~~~~
- R/utils.R:575:26: style: Place a space before left parenthesis, except in a function call.
- values <- part[(lengthOfKeys + 1) : (len - 1)]
- ^
- R/utils.R:581:18: warning: no visible global function definition for ‘mergeCompactLists’
- return(mergeCompactLists(keys, values))
- ^~~~~~~~~~~~~~~~~
- R/utils.R:598:3: warning: no visible global function definition for ‘PipelinedRDD’
- PipelinedRDD(rdd, partitionFunc)
- ^~~~~~~~~~~~
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement