Sap Se

Dongqing Hu

Xia Yu

Methods, systems, and computer-readable storage media for receiving a first stream request, providing a first DAG representative of a data processing flow of the first stream request, comparing one or more DAGs representative of respective data processing flows of one or more running streams in a set of running streams to provide a set of comparison results, each running stream being processed by a computing machine of the stream computing system, and determining that the first stream request has a common portion with respect to a first running stream based on a first comparison result of the comparison results and, in response: providing the first stream request and the first comparison result to a computing machine that is processing the first running stream, the computing machine executing a stream merger that merges a non-common portion of the first stream request with the common portion within the first running stream.

Efficient stream computing using reuse and affinity

A log sampling and storage system reduces volumes of stored log information. A log storage engine receives a series of log messages responsive to a request. The engine compares that series to various patterns previously generated from historical log data. This comparison can reference &#x2022;a name of the request; &#x2022;a total time to process the request; &#x2022;an item count; &#x2022;a message length; and/or &#x2022;a message hash code. Comparing incoming log series with the predefined patterns, results in generation of a similarity score. If the score falls outside a tolerance, the existence of an outlier log message series is indicated, and that outlier log message series is stored in its entirety. However, if the similarity score falls within a tolerance, similarity to an existing predefined pattern is indicated. Rather than storing the (non-outlier) log message series, the engine directs storing a link to a sample log message series reflecting the pattern.

Log sampling and storage system

Disclosed herein are system, method, and computer program product embodiments for efficiently maintaining a distributed processing of data between a source and sink. An embodiment operates by maintaining a scheduler in communication with the source and the sink, wherein the source and the sink communicate over a network. The scheduler identifies an utilization of a resource unit of the source, the sink and/or the network meeting or exceeding a predetermined threshold. After identifying that the utilization of the resource unit of the source, the sink and/or the network meets or exceeds a predetermined threshold, the scheduler triggers an operator of the source and/or the sink. The operator modifies a processing of data by the at least one of the source and the sink.

Cost-effective and self-adaptive operators for distributed data processing

Disclosed herein are system, method, and computer program product embodiments for mitigating similar and/or duplicate data. An embodiment operates by a computing device receiving a first and second code segment and parsing the first and second code segments into a first and second abstract syntax tree (AST), respectively. Thereafter, the computing device generates a first and a second normalized. AST corresponding to the first and second ASTs, respectively, based on a normalization rule such that the first and second normalized ASTs correspond to a first and second normalized code segment. The computing device then derives analytical information of the first and second normalized ASTs based on the first and second normalized code segments.

Similar code analysis and template induction

Disclosed herein are system, method, and device embodiments for semantic-aware and self-corrective automatic re-architecting. An embodiment operates by determining abstract syntax trees based on source code and target code, determining method identifier information based on the abstract syntax tree of the source code, determining reference location information based on the abstract syntax tree of target code, generating updated source code based on the abstract syntax tree of the source code, and determining interface mapping information including a mapping between a first service method of the source code and a second service method of the updated service code. Some embodiments may further operate by validating the interface mapping information, and generating updated source code based on the method identifier information, the reference location information, the interface mapping information, and the abstract syntax tree of the source code.

Semantic-aware and self-corrective re-architecting system

Disclosed herein are system, method, and various embodiments for migrating a program from a first device to a second device. An embodiment operates by receiving a playbook comprising a source location of source code on the first device and a target location for the source code on the second device. An execution function for transferring the source code from the first device to the second device is determined. A set of classes on the first device to which to apply the playbook are identified. At least one internal reference and at least one external reference in the set of classes are updated. The set of classes are migrated from the source location on the first device to the target location on the second device based on the playbook. The at least one internal reference is updated after the migration, wherein the program is executable using the migrated classes after the updating.

Growing community of inventors

Shanghai, China

Dongqing Hu