Guest User

Untitled

a guest
Mar 17th, 2016
86
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
Python 0.46 KB | None | 0 0
  1.   def printMinorMax(rdd, what):
  2.     if what == 'min':
  3.       val = rdd.min()
  4.     elif what == 'max':
  5.       val = rdd.max()
  6.     val2 = datetime.fromtimestamp(val)
  7.     print("\n#### Printing at %s" % datetime.today().strftime("%y-%m-%d %H:%M:%S") )
  8.     print("### %s %s (epoch = %s)" % (what, val2.strftime("%y-%m-%d %H:%M:%S"), val))
  9.  
  10.  
  11.   epochs.foreachRDD(lambda rdd: printMinorMax(rdd, 'min'))
  12.   epochs.foreachRDD(lambda rdd: printMinorMax(rdd, 'max'))
Advertisement
Add Comment
Please, Sign In to add comment