Honeywell International Inc.

Nikhil Bansal

Arnab Bhattacharjee

Ashwath Kakde

Dipanjan Saha

Abhinab Sonowal

Vishnu Vardhana Reddy Potham

Saurabh Jaiswal

Srinivas Chintha

Techniques for reconfiguring a data pipeline in a computing environment are described. In operation, a request for modifying a transformation standard of a first data pipeline is received, where the first data pipeline exists between a data ingestion system and a first database instance of a computing environment, and the first data pipeline transforms the data received from the data ingestion system in accordance with the transformation standard. A second data pipeline is then established in parallel to the first data pipeline, the second data pipeline is established between the data ingestion system and the first database instance in response to the request for modifying the transformation standard, and the second data pipeline processes the data received from the data ingestion system in accordance with a modified transformation standard. The second data pipeline is then initiated to transform the data received from the data ingestion system. The first data pipeline is then disconnected from the data ingestion system and the first database instance.

Data pipeline reconfiguration

Techniques for monitoring data synchronization among a plurality of data stores are described. In operation, a first statistic may be received for a first record set received over a first period of time at a first data store. A second statistic may then be obtained for the first record set received over the first period of time at a second data store. Based on the first statistic and the second statistic, a first intermediate state of synchronization may be ascertained between the first data store and the second data store. Further, a first metric associated with a second record set, received over a second period of time at the first data store, and a second metric associated with the second record set, received over the second period of time, may be determined. The determination may be based on the first intermediate state of synchronization. Based on the first metric and the second metric, a second intermediate state of synchronization between the first data store and the second data may be ascertained. Further, identification information of each of the records in the second record set, received at each of the first data store and the second data store, respectively, may be obtained. Based on the identification information, a final state of synchronization between the first data store and the second data store may be determined. Rendering of at least one indicator may be triggered accordingly for indicating the final state of synchronization.

Data synchronization between a plurality of data stores

Computer-implemented methods, systems, computing devices, and/or the like are provided. The computer-implemented method may include identifying a raw representation of the source data and a processed representation of the source data; selecting a read mode for reading the raw representation of the source data and the processed representation of the source data; selecting a write mode for writing the raw representation of the source data and the processed representation of the source data, wherein the write mode is based at least in part on the read mode; selecting a process mode for processing the source data, wherein the process mode is based at least in part on the write mode; selecting a representation mode for representing the processed source data; and storing the raw representation of the source data and the processed representation of the source data based at least in part on the representation mode.

Apparatuses, computer-implemented methods, and computer program products for IT/OT configuration historization

A data ingestion system prevents data duplication during a data ingestion operation by determining whether a current instance of an ingestion pending indicator file associated with a data set is present at initialization of the data ingestion operation. Upon determining that no current instance of the ingestion pending indicator file is present, the system generates and stores a new ingestion pending indicator file and performs the data ingestion operation using current watermark data. Upon determining that the current instance of the ingestion pending indicator file is not present, the system generates corrected watermark data and performs the data ingestion operation with respect to the corrected watermark data. Upon completion of the data ingestion operation, the system deletes the current instance of the ingestion pending indicator file.

Growing community of inventors

Bengaluru, India

Nikhil Bansal