Не то что бы не нравится. Я пытаюсь понять как сейчас делают.
Но есть определенный bias из опыта java.
Сорри за псевдо Java\Scala:
@Componentpublic class Df1 {
@Source("hdfsPath")
public Dataframe mapDf(sourceDf) {
return sourceDf
.select ....
.where ....
}
}
@Componentpublic class Df2 {
@Source("df1")
public Dataframe mapDf(sourceDf) {
return sourceDf
.select ....
.where ....
}
}