Does any body have a spark code example where he is reading ASN.1 files ?
Thx
Best regards
Hamza
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 ?
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 con
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) {
currentResponseCodeCounts =