public class PathToKeyFunction extends Object implements org.apache.spark.api.java.function.PairFunction<scala.Tuple2<String,org.apache.spark.input.PortableDataStream>,String,scala.Tuple3<String,Integer,org.apache.spark.input.PortableDataStream>>
PathToKeyConverter
),
second is an index, and third is the original data streamConstructor and Description |
---|
PathToKeyFunction(int index,
PathToKeyConverter converter) |
Modifier and Type | Method and Description |
---|---|
scala.Tuple2<String,scala.Tuple3<String,Integer,org.apache.spark.input.PortableDataStream>> |
call(scala.Tuple2<String,org.apache.spark.input.PortableDataStream> in) |
public PathToKeyFunction(int index, PathToKeyConverter converter)
Copyright © 2020. All rights reserved.