Skip to content

Commit c7e5f4a

Browse files
committed
nit
1 parent b8d8e1c commit c7e5f4a

File tree

1 file changed

+6
-7
lines changed

1 file changed

+6
-7
lines changed

mllib/src/main/scala/org/apache/spark/ml/regression/AFTSurvivalRegression.scala

Lines changed: 6 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -218,6 +218,12 @@ class AFTSurvivalRegression @Since("1.6.0") (@Since("1.6.0") override val uid: S
218218

219219
override protected def train(
220220
dataset: Dataset[_]): AFTSurvivalRegressionModel = instrumented { instr =>
221+
instr.logPipelineStage(this)
222+
instr.logDataset(dataset)
223+
instr.logParams(this, labelCol, featuresCol, censorCol, predictionCol, quantilesCol,
224+
fitIntercept, maxIter, tol, aggregationDepth, blockSize)
225+
instr.logNamedValue("quantileProbabilities.size", $(quantileProbabilities).length)
226+
221227
val instances = extractAFTPoints(dataset)
222228
if ($(blockSize) == 1 && dataset.storageLevel == StorageLevel.NONE) {
223229
instances.persist(StorageLevel.MEMORY_AND_DISK)
@@ -235,15 +241,8 @@ class AFTSurvivalRegression @Since("1.6.0") (@Since("1.6.0") override val uid: S
235241
combOp = (c1: SummarizerBuffer, c2: SummarizerBuffer) => c1.merge(c2),
236242
depth = $(aggregationDepth)
237243
)
238-
239244
val featuresStd = summarizer.std.toArray
240245
val numFeatures = featuresStd.length
241-
242-
instr.logPipelineStage(this)
243-
instr.logDataset(dataset)
244-
instr.logParams(this, labelCol, featuresCol, censorCol, predictionCol, quantilesCol,
245-
fitIntercept, maxIter, tol, aggregationDepth, blockSize)
246-
instr.logNamedValue("quantileProbabilities.size", $(quantileProbabilities).length)
247246
instr.logNumFeatures(numFeatures)
248247
instr.logNumExamples(summarizer.count)
249248
if ($(blockSize) > 1) {

0 commit comments

Comments
 (0)