Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- maxData = sc.accumulator(0)
- minData = sc.accumulator(0)
- meanData = sc.accumulator(0)
- totalData = sc.accumulator(0)
- def countParallel(data):
- global maxData, minData, meanData, totalData
- maxData = data.max()
- minData = data.min()
- meanData = data.mean()
- totalData = data.count()
- return (maxData, minData, meanData, totalData)
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement