A method implemented by a data processing system including: executing a dataflow graph that includes the plurality of components and the links, with a given component of the plurality including an input port, an audit port and an output port; processing, by the dataflow graph with the components and the links, the one or more data records representing the transaction, wherein the at least one of the components saves a state specifying one or more input records that are processed by the at least one of the components; when an error occurs during processing of one or more input records by the given component, restoring a state of the at least one of the components to the saved state; and based on the restored state, recovering at least some of the audit data for the given component of the dataflow graph.

Aspects of the disclosure provide for a circuit, in some examples, including a storage element, a co-processor, and a telemetry sequencer coupled to the storage element and the co-processor. The telemetry sequencer is configured to implement a digital state machine to receive configuration information indicating a type of telemetry data for generation, retrieve operations and operands, where the operations and the operands define a sequential series of actions for execution to generate the telemetry data, drive the co-processor with the operations and the operands by passing some of the operations and some of the operands to the co-processor for processing by the co-processor, receive, from the co-processor, and store an intermediate output of the series of actions as the telemetry data in a first format, and receive, from the co-processor, and store a final output of the series of actions as the telemetry data in a second format.

According to one embodiment, an information processing system is provided in which a web browser includes a re-display unit that acquires second image data based on information about an acquisition destination of a second conversion index file transmitted by a transmission unit, and displays the acquired second image data.

A computer-based method includes receiving, at a compute device, a collected set of system measurement facility (SMF) data from a mainframe operating system. The method includes, retrieving from a memory operatively coupled to the compute device, a set of SMF field-type identifiers. Each SMF field-type identifier having a one-to-one logical relation with a conditional value from a set of conditional values. The method includes selecting SMF field values from the collected set of SMF data, based on the set of conditional values. The SMF field values is a subset of SMF field values included in the collected set of SMF data. The method further includes executing a flattening process to produce a flattened record that includes at least one flattened SMF field value converted into a target format, and inserting the flattened record into a data repository compatible with the target format.

A machine implemented method of data processing in a data stream pipeline is provided. The data stream pipeline is formed from multiple sources of input data, and the method comprises: receiving input data from multiple sources, the data having differing format and data rates; buffering the data and transforming the data to a predetermined format; pre-processing the transformed data to create one or more output data streams, each in a respective canonical format; outputting the formatted output data stream to any data driven application and analytic platform; gathering behavioural data relating to at least one of: received input data, the receiving of the input data, the transformations applied to the input data, pre-processing of the transformed data, the output data streams, and the consumption of the output data streams; and using the gathered behavioural data to generate a signal.

A technology is provided for generating a data digest template for configuring a pipeline in a data digest system, comprising: receiving a pipeline description comprising a set of pipeline parameters operable by the data digest system, the pipeline parameters comprising at least one of a data source device descriptor, a communication channel descriptor, a flow dependency and a consuming application constraint; storing the pipeline description for modification and reuse; compiling the pipeline description using a template compiler to generate a compiled template; storing the compiled template for modification and reuse; mapping the compiled template into at least one data digest system configuration block; storing the at least one data digest system configuration block for modification and reuse; and supplying the at least one data digest system configuration block to the data digest system to configure the pipeline.

The present disclosure provides generally for a system and method for visualizing and measuring software assets. According to the present disclosure, the system interacts through an API to discover and populate all software applications within an organization in an interface that provides the user real-time information regarding the software applications. The system may provide real-time insights within an organization at all levels, with real-time feedback and metrics on what software there is, how software is being used, and software management options.

The present invention is a method and system for automatedly producing at least one desktop analytics trigger. Upon receiving at least one type of data input, the system analyzes the data input and produces at least one desktop analytics trigger based on the results of the analysis of the data input. The data input can include data on the programs, applications, or information a user utilizes during a task, to allow use of desktop process analytics. This process may be used to either generate a new desktop analytics trigger or update an existing desktop analytics trigger.

Methods and systems relating to formulating requests to a commerce management engine for product information may include a synchronization engine that estimates, using error data, future synchronization errors of product information to one or more channels. Each channel has respective product data fields for that channel and the error data relates to a prior synchronization of product information from one or more storefronts to the one or more channels and includes identified errors from the prior synchronization and corresponding corrections for resolving at least a subset of the identified errors. The synchronization may formulate a request, wherein the request requests product information for one or more products of the one or more storefronts for a future product synchronization with the one or more channels and includes a request parameter that is based on the estimated future synchronization errors.

Aspects of the disclosure provide for a circuit, in some examples, including a storage element, a co-processor, and a telemetry sequencer coupled to the storage element and the co-processor. The telemetry sequencer is configured to implement a digital state machine to receive configuration information indicating a type of telemetry data for generation, retrieve operations and operands, where the operations and the operands define a sequential series of actions for execution to generate the telemetry data, drive the co-processor with the operations and the operands by passing some of the operations and some of the operands to the co-processor for processing by the co-processor, receive, from the co-processor, and store an intermediate output of the series of actions as the telemetry data in a first format, and receive, from the co-processor, and store a final output of the series of actions as the telemetry data in a second format.