1

spark javaAPIを使用した次のコードの場合:

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

RDDという名前の を取り、それを のOriginalTypeキー タイプのペアにマップしますTypeOne。

OriginalTypeマップステップ中に、それを2種類のキーにマップすることは可能ですか? と のようTypeOneにTypeTwo。または、これを実現するには 2 つのマップ ステップを使用する必要があります...

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 に答える