-
Notifications
You must be signed in to change notification settings - Fork 1
/
Pyspark_code.txt
49 lines (48 loc) · 1.15 KB
/
Pyspark_code.txt
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
import time
count = 0
count1 = 0
threshold1=14
threshold2=18
threshold3=18
threshold4=16
threshold5=19
while(1):
dataRDD = sc.textFile("/user/cloudera/virtualsensor1/netcat.*")
for line in dataRDD.collect():
a,b=line.split(",")
a=int(a)
b=int(b)
if(a<201):
if(b<threshold1):
print "Oxygen pump " ,a, " turned ON"
count1=a
else:
if(a==count1):
print "Oxygen pump " ,a, " turned OFF"
print("Oxygen level at ",a," OKAY")
if(200<a<401):
if(b>threshold2):
print "Fire Alarm " ,a-200, " turned ON "
else:
print("No fire or hazardous gases")
if(400<a<601):
if(b>threshold3):
print "Parking " ,a-400, " is FULL "
else:
print("Parking " ,a-400, " has spaces")
if(600<a<801):
if(b<threshold4):
print "Lights at " ,a-600, " turned ON"
count4=(a-600)
else:
if((a-600)==count4):
print "Lights at " ,a-600, " turned OFF"
print("Luminosity level at" ,(a-600), " OKAY")
if(a>800):
if(b>threshold5):
print "Garbage at " ,a-800, " is Full"
else:
print("Garbage at " ,a-800, " has space")
count=0
count1=0
time.sleep(10)