1

对于以下使用spark javaAPI 的代码：

JavaPairRDD<TypeOne,Long> pairs = originalRows.flatMapToPair(new PairFlatMapFunction<OriginalType,TypeOne,Long>()

它采用RDD, namedOriginalType并将其映射成具有 . 键类型的对TypeOne。

我想知道是否可以OriginalType在映射步骤中将其映射为两种类型的键？喜欢TypeOne和TypeTwo。或者我必须使用两个地图步骤来实现这一点......

4

1 回答 1

1

您可以创建两种类型都将实现/继承的接口或通用类，并使用它而不是特定类型。

public interface IType { }

public class TypeOne implements IType { }

public class TypeTwo implements IType { }

JavaPairRDD<IType,Long> pairs = originalRows.flatMapToPair(new PairFlatMapFunction<OriginalType,IType,Long>()
于 2015-11-06T13:50:12.927 回答