Advertisement
Guest User

Untitled

a guest
Mar 31st, 2015
281
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
Scala 0.37 KB | None | 0 0
  1. import org.apache.hadoop.io.NullWritable
  2. import org.apache.hadoop.mapred.lib.MultipleTextOutputFormat
  3.  
  4. class RDDMultipleTextOutputFormat extends MultipleTextOutputFormat[Any, Any] {
  5.   override def generateActualKey(key: Any, value: Any): Any = NullWritable.get()
  6.  
  7.   override def generateFileNameForKeyValue(key: Any, value: Any, name: String): String = key.toString
  8. }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement