对于使用 spark java API 的以下代码:
JavaPairRDD<TypeOne,Long> pairs = originalRows.flatMapToPair(new PairFlatMapFunction<OriginalType,TypeOne,Long>()
它采用名为 OriginalType 的 RDD 并将其映射为键类型为 TypeOne 的对。
我想知道是否可以采用 OriginalType 并在映射步骤中将其映射为两种类型的键？就像 TypeOne 和 TypeTwo 一样。或者我必须使用两个映射步骤来实现这一点...
最佳答案
您可以创建两个类型都将实现/继承的接口(interface)或通用类，并使用它而不是特定类型。
public interface IType { }
public class TypeOne implements IType { }
public class TypeTwo implements IType { }
JavaPairRDD<IType,Long> pairs = originalRows.flatMapToPair(new PairFlatMapFunction<OriginalType,IType,Long>()
关于java - Spark flatMapToPair 创建不同类型的键，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/29260756/