Reading ASN.1 files in Spark

2017-04-06 Thread Hamza HACHANI
Does any body have a spark code example where he is reading ASN.1 files ? Thx Best regards Hamza

convert JavaRDD<List> to JavaRDD

2017-04-05 Thread Hamza HACHANI
I want to convert a JavaRDD to JavaRDD. For example if there is 3 elment in List 3 Object would be created in my new JavaRDD. Does any one have an idea ?

problem reading binary source with apache streaming when using JavaStreaminContext.binaryRecordsStream()

2017-03-28 Thread Hamza HACHANI
Hi all, I'm having a binary file composed of messages which length is 57 bytes. The binary file contains exactly 10 message and its size is about 44 MB ( I ' ve already verified that ). What I do simply is reading the file via JavaStreaminContext.binaryRecordsStream("folder",57) so I

problem with the method JavaDStream.foreachRDD() SparkStreaming

2017-02-03 Thread Hamza HACHANI
Hi, I'm new to SparkStreaming. I'm using the versions 2.10 for spark core and spark streaming My issue is that when i try to use JavaPairDStream.foreachRDD : test.foreachRDD(new Function,Void>() { public Void call(JavaPairRDD rdd) {