Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- import org.apache.hadoop.io.NullWritable
- import org.apache.hadoop.mapred.lib.MultipleTextOutputFormat
- class RDDMultipleTextOutputFormat extends MultipleTextOutputFormat[Any, Any] {
- override def generateActualKey(key: Any, value: Any): Any = NullWritable.get()
- override def generateFileNameForKeyValue(key: Any, value: Any, name: String): String = key.toString
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement