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

@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方法?

湖上湖
浏览 953回答 2
2回答

临摹微笑

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