interactor = Interactor() fvAssembler = FeatureVectorAssembler() treeClassifer = DecisionTreeClassifer() paramMap = ParamMap() .put(interactor.features, {"genderMatch" : ["userGender", "targetGender”]}) .put(fvAssembler.features, {"features" : ["genderMatch", "userCountryIndex", ...]}) .put(treeClassifer.maxDepth, 4) pipeline = Pipeline.create(interactor, fvAssembler, treeClassifier) model = pipeline.fit(training, paramMap)