How to check if a particular keyword exists in Apache Spark

Question

Hi,

I have a text file where I need to search for particular keyword exists or not. So can anyone help me how can I do it?

Answer 1

Hey,

You can try this code to get the solution of your above query:

lines = sc.textFile(“hdfs://hadoop1.knowbigdata.com/user/student/sgiri/bigtextfile.txt”);

def isFound(line):

if line.find(“mykeyword”) > -1:

return 1;

return 0;

foundBits = lines.map(isFound);

sum = foundBits.reduce(sum);

if sum > 0:

print “FOUND”;

else:

print “NOT FOUND”;

Hope it will be helpful.