Huawei Technologies Co., Limited

Cheng He

Lujia Pan

Gong Zhang

Wei Fan

Xun Yang

Yi Long

Yong Cheng

Qun Huang

Zhenguo Li

Ke Yi

Mingzhen Xia

Ge Luo

Yunlong Shi

Pak-Ching Lee

Dayang Feng

Yunbo Li

Guangyu Shi

Xiuqiang He

Shuqiang Wang

Kin Nang Lau

Hongbo Zhang

Xiaosong Liu

Guangjian Tian

Jiefeng Cheng

Wenliang Zhang

Kaibin Huang

Yanping Xiang

Yongjun Dai

Andrey Osin

Jianneng Liu

In a data processing method, a worker node in a distributed data processing system receives first data from an upstream worker node. The first data has been stored in a buffer of the upstream worker node. The worker node sends a first portion of the first data to a persistent storage device of the distributed data processing system for persistent backup, and performs computational processing on the first data to generate second data. Prior to completing performing computational processing on the first data, the worker node sends acknowledgement information to the upstream worker node to instruct the upstream node to delete the first data from the buffer of the upstream worker node. The worker node then sends the second data to a downstream worker node in the distributed data processing system for further processing by the downstream worker node.

Data processing method and apparatus

An electronic device comprising a USB port and a PCB is provided. A first cabling layer of the PCB has a first floating area and a line outside the first floating area, an insulation medium is between the first floating area and the line, a second cabling layer of the PCB is adjacent to the first cabling layer and has a first metal area, an orthographic projection of the first floating area on the second cabling layer and the first metal area have an overlapping area, and the first floating area is not connected to the first metal area; and a metal housing of the USB port has a plurality of fixed contacts fastened to the PCB and not connected to a ground of the PCB, the contacts include a first fixed contact connected to the first floating area and not connected to the first metal area.

Device with USB port

The present invention discloses a method and apparatus for querying a nondeterministic graph, which are used to implement quick query of a nondeterministic graph, reduce query complexity, and improve query efficiency. The method comprises receiving a query instruction, where the query instruction is used to query a nondeterministic graph for data that satisfies a query condition; determining two vertices in the nondeterministic graph according to the query instruction; determining all possible paths that use one vertex in the two vertices as a start point and the other vertex as an end point; calculate a probability of a first event or a second event corresponding to each of the paths; and obtaining, according to the probability of the first event or the probability of the second event, a query result corresponding to the query instruction.

Method and apparatus for querying nondeterministic graph

A stream computer system and a method for processing a data stream in a stream computing system are disclosed. The method includes a first working node invokes at least one execution unit to process a data stream according to an initial parallelism degree, a control node collects information reflecting data traffic between the first working node and a second working node, and information reflecting data processing speed of the first working node, determines an optimized parallelism degree for the first working node according to the collected information, and adjusts the parallelism degree of the first working node to be consistent with the optimized parallelism degree.

Data processing method in stream computing system, control node, and stream computing system

A deep neural network to which data category information is added is established locally, to-be-identified data is input to an input layer of the deep neural network generated based on the foregoing data category information, and information of a category to which the to-be-identified data belongs is acquired, where the information of the category is output by an output layer of the deep neural network. A deep neural network is established based on data category information, such that category information of to-be-identified data is conveniently and rapidly obtained using the deep neural network, thereby implementing a category identification function of the deep neural network, and facilitating discovery of an underlying law of the to-be-identified data according to the category information of the to-be-identified data.

Data category identification method and apparatus based on deep neural network

A method for compressing flow data, including: generating multiple line segments according to flow data and a predefined maximum error that are acquired; obtaining a target piecewise linear function according to the multiple line segments, where the target piecewise linear function includes multiple linear functions, and an intersection set of value ranges of independent variables of every two linear functions among the multiple linear functions includes a maximum of one value; and outputting a reference data point according to the target piecewise linear function, where the reference data point includes a point of continuity and a point of discontinuity of the target piecewise linear function. In this way, a maximum error, a target piecewise linear function is further determined according to the multiple line segments, and a point of continuity and a point of discontinuity of the target piecewise linear function are used to represent compressed flow data.

Method and device for compressing flow data

A fault tolerance method is provided for a distributed stream processing system. The method includes: obtaining, by a working node, information of a failed node, and receiving retransmission data sent by an upstream node, where the retransmission data is originally sent by a source node to the failed node; determining, according to the information of the failed node, whether the failed node is related to the working node; and if the failed node is related to the working node, processing the received retransmission data, and sending the processed retransmission data to a downstream node. In the present application, retransmission data sent by an upstream node is received by a working node, and after it is determined that a failed node is related to the working node, the received retransmission data is processed, so that the retransmission data sent by the upstream node is processed only when the failed node is related to the working node.

Fault tolerance method for distributed stream processing system

A stream computer system and a method for processing a data stream in a stream computing system are disclosed. In an embodiment, the method includes collecting data traffic information between each working node and other working nodes and processing speed information for each working node, determining an optimized parallelism degree for each working node according to the collected data traffic information and processing speed information and adjusting a parallelism degree of the working node according to the optimized parallelism degree of the working node.

A junk information filtering method, including: detecting an Hypertext Transfer Protocol (HTTP) request data packet set generated according to that a user visits a target uniform resource locator (URL) by using a browser of a client, where the HTTP request data packet set includes at least one junk information request data packet and at least one non-junk information request data packet; identifying the junk information request data packet in the HTTP request data packet set according to a preset classification rule; and preventing, according to a preset interception policy, a destination host corresponding to the junk information request data packet from returning a junk information response data packet to the client. The embodiments of the present invention further disclose a junk information filtering apparatus. According to the present invention, accuracy of web page junk information filtering can be improved and user traffic can be saved.

Junk information filtering method and apparatus

A method, an apparatus, and a system for identifying an abnormal IP data stream, which are used to improve identification accuracy. The method provided by the embodiments of the present invention includes: receiving Y elements sent by a data collection node; mapping the Y elements to N buckets; acquiring a bucket in the N buckets as a target bucket; acquiring r upper traffic limits of a first object in r buckets within the current time interval, the first object is any object mapped to the target bucket; and identifying, according to a preset abnormal object type and the r upper traffic limits within the current time interval, whether the first object is an abnormal object, where the preset abnormal object type is a heavy hitter or a heavy changer.

Method, apparatus, and system for identifying abnormal IP data stream

A method for compressing flow data, including: constructing multiple line segments according to flow data and a predefined maximum error that are acquired; obtaining a target piecewise linear function according to the multiple line segments, where the target piecewise linear function includes multiple linear functions, and an intersection set of value ranges of independent variables of every two linear functions among the multiple linear functions includes a maximum of one value; and outputting a reference data point according to the target piecewise linear function, where the reference data point includes a point of continuity and a point of discontinuity of the target piecewise linear function. In this way, a maximum error, a target piecewise linear function is further determined according to the multiple line segments, and a point of continuity and a point of discontinuity of the target piecewise linear function are used to represent compressed flow data.

Embodiments of the present invention provide a method and an apparatus for network traffic simulation. The method includes: obtaining traffic information and user requirement information of a to-be-simulated IP network; analyzing the traffic information to generate a traffic characteristic; according to correspondence between user requirement information and traffic models, obtaining a traffic model corresponding to the user requirement information; and generating, through simulation, traffic of the to-be-simulated IP network according to the traffic characteristic and the traffic model. The embodiments of the present invention can improve flexibility and an emulation degree of traffic simulation.

Method and apparatus for network traffic simulation

The present invention discloses a communication method, a device and a communication system. The technical solutions provided by the present invention include: a Base Station Router (BSR) and a service server. The BSR is configured to make a Mobile Station (MS) access a network, obtain information of multiple transmission paths from the service server during a process for the MS to apply to the service server for a service, and provide a communication service for the MS and the service server by using a multi-path transmission scheme. The service server, connected with the BSR, is configured to obtain information of QoS required by the service applied by the MS, determine the multiple transmission paths according to the information of the QoS, and communicate with the MS by using the multi-path transmission scheme.

Method and apparatus for coordinated multi-point transmission with negotiated quality of service

A pre-processing method and system for cooperative communication are provided. The method includes: after obtaining channel matrices collected by a Base Station (BS), obtaining Multiple-Input Multiple-Output (MIMO) Cooperation Area (CA) information, in which the MIMO CA information includes cooperation information between BSs, and the cooperation information between the BSs is used to determine an interference relation between MIMO CAs; combining the channel matrices of a User Equipment (UE) according to the interference relation between the MIMO CAs; and performing pre-coding computation of the UE by using the combined channel matrices.

Pre-processing method, system, and apparatus for cooperative communication

A method, an apparatus and a system for cooperative resources scheduling and cooperative communication are provided. The method for cooperative resources includes: obtaining, by a network central controller, statistical information of all the users dominated by it in a first time period, dividing base stations to base station cooperative clusters according to the statistical information, and transmitting cooperative cluster dividing result to the base stations. The corresponding method and apparatus for cooperative communication are also provided. The solutions of the embodiments of the present disclosure can increase the transmission rate and user experience for the users at the edge of the cooperative cluster, and improve the fairness of the system users, while reducing the signaling overhead of the system, separating the computational tasks and reducing the difficulty of implementing the whole system.

Growing community of inventors

Shenzhen, China

Cheng He