| /dports/devel/spark/spark-2.1.1/R/pkg/R/ |
| H A D | SQLContext.R | 136 sparkSession <- getSparkSession() functionVar
174 sparkSession <- getSparkSession() functionVar
209 sparkSession <- getSparkSession() functionVar
355 sparkSession <- getSparkSession() functionVar
427 sparkSession <- getSparkSession() functionVar
449 sparkSession <- getSparkSession() functionVar
501 sparkSession <- getSparkSession() functionVar
535 sparkSession <- getSparkSession() functionVar
564 sparkSession <- getSparkSession() functionVar
586 sparkSession <- getSparkSession() functionVar
[all …]
|
| /dports/devel/spark/spark-2.1.1/python/pyspark/ml/ |
| H A D | util.py | 86 def session(self, sparkSession): argument
122 def session(self, sparkSession): argument
175 def session(self, sparkSession): argument
209 def session(self, sparkSession): argument
|
| /dports/devel/spark/spark-2.1.1/R/pkg/inst/tests/testthat/ |
| H A D | test_jvm_api.R | 20 sparkSession <- sparkR.session(enableHiveSupport = FALSE) globalVar
|
| H A D | test_take.R | 33 sparkSession <- sparkR.session(enableHiveSupport = FALSE) globalVar
|
| H A D | test_includePackage.R | 21 sparkSession <- sparkR.session(enableHiveSupport = FALSE) globalVar
|
| H A D | test_broadcast.R | 21 sparkSession <- sparkR.session(enableHiveSupport = FALSE) globalVar
|
| H A D | test_Serde.R | 20 sparkSession <- sparkR.session(enableHiveSupport = FALSE) globalVar
|
| H A D | test_binaryFile.R | 21 sparkSession <- sparkR.session(enableHiveSupport = FALSE) globalVar
|
| H A D | test_parallelize_collect.R | 36 sparkSession <- sparkR.session(enableHiveSupport = FALSE) globalVar
|
| H A D | test_binary_function.R | 21 sparkSession <- sparkR.session(enableHiveSupport = FALSE) globalVar
|
| /dports/devel/spark/spark-2.1.1/sql/core/src/test/scala/org/apache/spark/sql/execution/benchmark/ |
| H A D | BenchmarkBase.scala | 30 lazy val sparkSession = SparkSession.builder constant
|
| /dports/devel/spark/spark-2.1.1/sql/hive-thriftserver/src/main/scala/org/apache/spark/sql/hive/thriftserver/ |
| H A D | SparkSQLEnv.scala | 47 val sparkSession = SparkSession.builder.config(sparkConf).enableHiveSupport().getOrCreate() constant
|
| /dports/devel/spark/spark-2.1.1/sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/ |
| H A D | PruneFileSourcePartitions.scala | 50 val sparkSession = fsRelation.sparkSession constant
|
| /dports/misc/py-xgboost/xgboost-1.5.1/jvm-packages/xgboost4j-spark/src/test/scala/ml/dmlc/xgboost4j/scala/spark/ |
| H A D | FeatureSizeValidatingSuite.scala | 56 val sparkSession = SparkSession.builder().getOrCreate() constant
|
| H A D | XGBoostClassifierSuite.scala | 282 val sparkSession = SparkSession.builder().getOrCreate() constant
303 val sparkSession = SparkSession.builder().getOrCreate() constant
|
| /dports/misc/xgboost/xgboost-1.5.1/jvm-packages/xgboost4j-spark/src/test/scala/ml/dmlc/xgboost4j/scala/spark/ |
| H A D | FeatureSizeValidatingSuite.scala | 56 val sparkSession = SparkSession.builder().getOrCreate() constant
|
| H A D | XGBoostClassifierSuite.scala | 282 val sparkSession = SparkSession.builder().getOrCreate() constant
303 val sparkSession = SparkSession.builder().getOrCreate() constant
|
| /dports/devel/spark/spark-2.1.1/sql/hive/src/main/scala/org/apache/spark/sql/hive/ |
| H A D | HiveStrategies.scala | 34 val sparkSession: SparkSession constant
|
| /dports/devel/spark/spark-2.1.1/repl/scala-2.11/src/main/scala/org/apache/spark/repl/ |
| H A D | Main.scala | 40 var sparkSession: SparkSession = _ variable
|
| /dports/devel/spark/spark-2.1.1/sql/core/src/main/scala/org/apache/spark/sql/streaming/ |
| H A D | StreamingQuery.scala | 66 def sparkSession: SparkSession method
|
| /dports/devel/spark/spark-2.1.1/sql/core/src/main/scala/org/apache/spark/sql/execution/ |
| H A D | CacheManager.scala | 97 val sparkSession = query.sparkSession constant
|
| /dports/devel/spark/spark-2.1.1/sql/core/src/main/scala/org/apache/spark/sql/ |
| H A D | KeyValueGroupedDataset.scala | 52 private def sparkSession = queryExecution.sparkSession method
|
| /dports/devel/spark/spark-2.1.1/mllib/src/main/scala/org/apache/spark/ml/tuning/ |
| H A D | CrossValidator.scala | 98 val sparkSession = dataset.sparkSession constant
|
| /dports/devel/spark/spark-2.1.1/mllib/src/main/scala/org/apache/spark/ml/clustering/ |
| H A D | KMeans.scala | 227 val sparkSession = super.sparkSession constant
|
| /dports/devel/spark/spark-2.1.1/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/ |
| H A D | ProgressReporter.scala | 62 protected def sparkSession: SparkSession method
|