@Configurationclass sparkConfig {@Autowired@transientvar sparkInfo: SparkInfo = _@Beandef 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 回答
临摹微笑
TA贡献1982条经验 获得超2个赞
代码就是程序员用开发工具所支持的语言写出来的源文件,是一组由字符、符号或信号码元以离散形式表示信息的明确的规则体系。代码设计的原则包括唯一确定性、标准化和通用性、可扩充性与稳定性、便于识别与记忆、力求短小与格式统一以及容易修改等。
源代码是代码的分支,某种意义上来说,源代码相当于代码。现代程序语言中,源代码可以书籍或磁带形式出现,但最为常用格式是文本文件,这种典型格式的目的是为了编译出计算机程序。
- 2 回答
- 0 关注
- 989 浏览
添加回答
举报
0/150
提交
取消