спарка:
final class DataStreamReader
final class DataStreamWriter[T]
у них есть два метода с похожей сигнатурой:
def format(source: String): DataStreamWriter[T] // or DataStreamReader
def options(options: scala.collection.Map[String, String]): DataStreamWriter[T] // or DataStreamReader
я хочу написать имплисит который делает что-то такое (в питоне это бы был Union[...]):
implicit class KafkaWithOptions[T](input: Union[DataStreamReader, DataStreamWriter[T]]) {
def withKafkaOptions(implicit config: Config): Union[DataStreamReader, DataStreamWriter[T] = {
input.format("kafka").options(config.getConfig("inputs").asMap)
}
}
понятно что это так не работает - а можно ли как-то такое провернуть в Scala 2.12, или надо писать отдельный имплисит для каждого типа - DataStreamReader и DataStreamWriter?
input: Union[A, B] это и А и Б одновременно?
Обсуждают сегодня