Hi I intend on using the same Spark Streaming program for both real time and batch processing of my time stamped data. However with batch processing all window based operations would be meaningless because (I assume) the window is defined by the arrival times of data and it is not possible to define it using the actual timestamp on the data Itself (which is a field on my java object that represents a datapoint in my time series )
This seems like one of those things that other people may have run into and I am hoping you experts could help me with this or clarify my concept if my understanding ie incorrect Ruchir
