Please take a look at: python//pyspark/tests.py There're examples using sc.hadoopFile() and sc.newAPIHadoopRDD()
Cheers On Thu, Nov 26, 2015 at 4:50 AM, Patcharee Thongtra < [email protected]> wrote: > Hi, > > In python how to use inputformat/custom recordreader? > > Thanks, > Patcharee > > > --------------------------------------------------------------------- > To unsubscribe, e-mail: [email protected] > For additional commands, e-mail: [email protected] > >
