GG
Size: a a a
GG
O
AZ
A
O
var options = new JobOptionsВ тестах это обкладывается стартующим в начале всех тестов спарком:
optionsOrExit(args.options)
val spark = new SparkSession.Builder().getOrCreate
val integrator = Integrator(param1=options.param1)
integrator.performIntegration(spark)
train WithSparkContext extends BeforeAndAfterAll {Проблема в том что передача аргументов и запуск спарка остаются с нулевым code coverage. Как аккуратно мокнуть это поведение?
override def beforeAll() {
var spark = SparkSession.builder().getOrCreate
}
}
A
A
AZ
A
GG
A
GG
A
A
A
AZ
A
GG
GG
GG