Microsoft Technology Licensing, LLC

Abhishank Sahu

Gunter Leeb

Xu Liu

Jose Fernandez

Swadhin Ajay Thakkar

Yingji Ju

Steve Chun-Hao Hu

William Edward Miao

Jordan Robert Fitzgibbon

Raveena Dayani

Sravanthi Pereddy

Embodiments disclosed herein are related to implementing a near-real-time stream processing system using the same distributed file system as a batch processing system. A data container and partition files are generated according to a partition window that specifies a time range that controls when data is to be included in the partition files. The data container is scanned to determine if the partition files are within a partition lifetime window that specifies a time range that controls how long the partition files are active for processing. For each partition file within the lifetime window, processing tasks are created based on an amount of data included in the partition files. The data in the partition files is accessed and the processing tasks are performed. Information about the partition files is recorded in a configuration data store.

Near-real-time data processing with partition files

Growing community of inventors

Renton, WA, United States of America

Abhishank Sahu