Я пытаюсь получить доступ к полю batchDuration в StreamingContext. Я не вижу общедоступного API, который бы выставлял это значение. Как получить доступ к этому полю? Это в основном размер окна потоковой работы. Мой код не имеет доступа к заданию, определяемому пользователем, чтобы получить значение оттуда.
batchDuration
StreamingContext
Создайте свой класс или объект внутри package org.apache.spark.streaming пакета, а затем используйте следующий код для получения batchDuration из StreamingContext
package org.apache.spark.streaming
val ssc: StreamingContext = ??? ssc.graph.batchDuration