@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方法?
scala構建springboot配置類,我應該怎么調用其中的方法?
湖上湖
2019-07-08 11:04:43