scala – 使用DecisionTreeModel Spark ML保存管道

我有一个Spark ML管道,它包含一个VectorAssembler,StringIndexer和一个DecisionTreeClassifier.使用此管道,我能够成功地拟合模型并转换我的数据框.我想存储此模型以供将来使用,但我不断收到以下错误：

Pipeline write will fail on this Pipeline because it contains a stage which does not implement Writable. 
Non-Writable stage: dtc_9c04161ed2d1 of type class org.apache.spark.ml.classification.DecisionTreeClassificationModel

我尝试过的：

val pipeline = new Pipeline().setStages(Array(assembler,labelIndexer,dt))
val model = pipeline.fit(dfIndexed)
model.write.overwrite().save("test/model/pipeline")

当我删除分类器(即dt)时,这可以正常工作.有没有一种方法可以保存DecisionTreeClassifier模型？

我的数据包含一些索引的分类值,我必须将它们映射回原始形式(我知道这需要使用IndexToString).我正在使用Spark 1.6.