A
Size: a a a
A
AZ
СХ
СХ
R
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
}
}
IK
ЕГ
AZ
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
}
}
λ
GG
GG
λ
λ
GG
λ
GG
GG
A
AZ