Abstract:
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.
Abstract:
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.
Abstract:
Embodiments of the present invention provide a method, network element device, and network system for associating a terminal device with a network. The method for associating a terminal device with a network includes: receiving an Association Request message sent by a terminal device, where the Association Request message includes information of a request for associating the terminal device with a sensor network and an IP identifier; processing, according to the Association Request message, the request for associating the terminal device with a sensor network; when it is determined, according to the IP identifier, that the terminal device requests association with an IP network, sending an IP network Association Request message to an Edge Router; receiving a result of processing, by the Edge Router, the request for associating the terminal device with the IP network; sending an Association Respond message to the terminal device.
Abstract:
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.
Abstract:
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.
Abstract:
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.
Abstract:
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.
Abstract:
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.
Abstract:
Embodiments of the present invention provide a method and device for synthesis of network traffic. The method includes extracting a first real traffic composition parameter sequence and a second real traffic composition parameter sequence from real traffic. A first synthetic traffic composition parameter sequence is generated. Relational coefficients between first traffic composition parameters and second traffic composition parameters are obtained. A second synthetic traffic composition parameter sequence is generated and synthetic traffic is generated according to the first synthetic traffic composition parameter sequence and the second synthetic traffic composition parameter sequence.
Abstract:
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.