lastValidTime
InputDStream
leftOuterJoin
JavaPairDStream
PairDStreamFunctions