为了账号安全,请及时绑定邮箱和手机立即绑定

scala构建springboot配置类,我应该怎么调用其中的方法?

/ 猿问

scala构建springboot配置类,我应该怎么调用其中的方法?

湖上湖 2019-07-08 11:04:43

@Configuration
class sparkConfig {

@Autowired
@transient
var sparkInfo: SparkInfo = _

@Bean
def getSparkSession(): SparkSession = {
val sparkSession = SparkSession.builder()
.appName(sparkInfo.getAppName)
.master(sparkInfo.getMaster)
.config("spark.driver.memory", sparkInfo.getDriverMemory)
.config("spark.worker.memory", sparkInfo.getWorkerMemory)
.config("spark.executor.memory", sparkInfo.getExecutorMemory)
.config("spark.serializer", classOf[KryoSerializer].getName)
.getOrCreate()
sparkSession
}

@Bean
@ConditionalOnMissingBean(Array(classOf[SparkSession]))
def getSparkStreaming(@Autowired sparkSession: SparkSession): StreamingContext = {
val ssc = new StreamingContext(sparkSession.sparkContext, Seconds(sparkInfo.getPeriod))
ssc
}
}

其他类中如何调用getSparkStreaming方法?

查看完整描述

2 回答

?
临摹微笑

代码就是程序员用开发工具所支持的语言写出来的源文件,是一组由字符、符号或信号码元以离散形式表示信息的明确的规则体系。代码设计的原则包括唯一确定性、标准化和通用性、可扩充性与稳定性、便于识别与记忆、力求短小与格式统一以及容易修改等。
源代码是代码的分支,某种意义上来说,源代码相当于代码。现代程序语言中,源代码可以书籍或磁带形式出现,但最为常用格式是文本文件,这种典型格式的目的是为了编译出计算机程序。

查看完整回答
反对 回复 2019-07-09
?
慕哥9229398

Jffydjjmhkhgkjjchkydjkcdkmhdymgxtmcgkgdjfjmgkkgmgxjmxkgmdkgmglxcklxlgxkmhkxmdkgkhkfkdmgkylgmhmhm mgmvmcmhxmkvmcmjtdhkdxkmhldl lymfkgdmlx vmdhncmmhccykglxkykyjtkdldjldlylykdky

查看完整回答
反对 回复 2019-07-09

添加回答

回复

举报

0/150
提交
取消
意见反馈 邀请有奖 帮助中心 APP下载
官方微信