-
公开(公告)号：US20180357267A1
公开(公告)日：2018-12-13
申请号：US15968574
申请日：2018-05-01
IPC分类号： G06F17/30
CPC分类号： G06F17/30365 , G06F17/30292 , G06F17/30368 , G06F17/30516
摘要： A method includes receiving, at a processor, event stream data, the event stream data including a plurality of events associated with changes to an instance of a subject. The method further includes receiving, at the processor of the computing device, input indicating correction data. The method further includes outputting, from the processor of the computing device, modified event stream data to a storage device. The modified event stream data is generated based on the correction data by modifying an event of the event stream data, adding a first event to the event stream data, deleting a second event from the event stream data, or a combination thereof.
-
公开(公告)号：US20180203902A1
公开(公告)日：2018-07-19
申请号：US15705625
申请日：2017-09-15
发明人： Bradley W. Fawcett
CPC分类号： G06F17/30516 , G06F9/5027
摘要： Disclosed aspects relate to managing a set of development data for operator fusion management in a stream computing environment having a plurality of stream operators. A set of operator attributes of the plurality of stream operators may be collected by an operator fusion management engine in the stream computing environment. A set of candidate operator fusion management operations may be determined with respect to the plurality of stream operators. The set of candidate operator fusion management operations may be determined by the operator fusion management engine based on the set of operator attributes. At least one of the set of candidate operator fusion management operations may be performed in the stream computing environment with respect to the plurality of stream operators.
-
公开(公告)号：US20180196730A1
公开(公告)日：2018-07-12
申请号：US15401011
申请日：2017-01-07
CPC分类号： G06F11/366 , G06F9/4843 , G06F17/30516
摘要： Disclosed aspects relate to debug management in a distributed batch data processing environment which uses a shared pool of configurable computing resources. A debug configuration to fire a breakpoint based on an achievement of a debug criterion may be initiated in the distributed batch data processing environment. A data block may be detected in the distributed batch data processing environment. The data block may be analyzed with respect to the debug criterion by a debug management engine. Achievement of the debug criterion by the data block may be determined by the debug management engine. In response to determining the achievement of the debug criterion by the data block, the breakpoint may be fired based on the achievement of the debug criterion.
-
公开(公告)号：US09998511B2
公开(公告)日：2018-06-12
申请号：US15635774
申请日：2017-06-28
CPC分类号： H04L65/4076 , G06F11/2007 , G06F17/30312 , G06F17/30516 , G06F19/00 , G06F2201/85 , G16H10/60 , G16H50/70 , H04L65/605
摘要： A system processes streaming data and includes at least one processor. The system may write streaming data received from a data source as messages in queues at a queuing cluster. The queuing cluster includes a coordinator node to direct the messages to non-coordinator nodes of the queuing cluster. The system may retrieve the data from the queues based on subscription of topics and store the retrieved data in a consumable repository.
-
公开(公告)号：US09990236B2
公开(公告)日：2018-06-05
申请号：US14982375
申请日：2015-12-29
发明人： Songshan Zhang
CPC分类号： G06F9/5083 , G06F17/30516 , G06F17/30958 , H04L29/08
摘要： A service scheduling method, applied to a stream computing system, is presented. The stream computing system includes a master control node and multiple working nodes, and the master control node is configured to schedule sub-services included in the service to the multiple working nodes for processing. The method includes acquiring a stream computing application graph of the service; dividing the stream computing application graph according to operator degrees and operator potentials of operators in the stream computing application graph and according to a division quantity for dividing the stream computing application graph, to obtain divided sub-graphs with the division quantity; and scheduling a sub-service corresponding to an operator included in each divided sub-graph to a working node corresponding to the divided sub-graph for processing. The method provided in embodiments of the present disclosure can enable services to use physical resources and network resources in a balanced manner.
-
公开(公告)号：US09984143B2
公开(公告)日：2018-05-29
申请号：US14668561
申请日：2015-03-25
发明人： Gang Luo , Chunqiang Tang , Philip Shi-lung Yu
CPC分类号： G06F17/30598 , G06F17/30011 , G06F17/30117 , G06F17/30312 , G06F17/30516 , G06F17/30684
摘要： There are provided a system and method for resource adaptive, real-time new event detection. The method includes capturing, from among documents in a document streaming environment that includes a plurality of remote streaming document sources, first-story documents. The method further includes storing any of the documents determined to be the first-story documents in a memory. The method also includes classifying the documents as important or non-important based on pre-specified criteria. The method additionally includes storing, in the memory, only information of the documents classified as important, when the memory overflows. The method further includes discarding the documents that are classified as non-important when a document consumption rate from the memory is less than a document insertion rate into the memory. The method additionally includes removing the information of the documents classified as important from the memory subsequent to one of consumption and processing by a consumer.
-
7.发明授权公开(公告)号：US09984126B2
公开(公告)日：2018-05-29
申请号：US14445950
申请日：2014-07-29
申请人： salesforce.com, inc.
CPC分类号： G06F17/30516 , G06F17/30867 , G06Q50/01 , H04L51/16
摘要： Disclosed are techniques for identifying data items to display in a feed of an enterprise social networking system. A first subset of data items is identified as associated with an inner circle of data sources with which a user interacts at or exceeding a designated frequency, a second subset of data items is identified as associated with an interest graph associated with the user, and a third subset of data items is identified as associated with a group or an organization. A highlights feed can be displayed with different channels, where a first channel is defined by the first subset of data items, a second channel is defined by the second subset of data items, and a third channel is defined by the third subset of data items.
-
公开(公告)号：US09984125B1
公开(公告)日：2018-05-29
申请号：US13801827
申请日：2013-03-13
IPC分类号： G06F17/30
CPC分类号： G06F17/30516 , G06F17/30539 , G06F17/30893
摘要： A computer-implemented method of providing time series data includes maintaining by a web server user account data for each of a plurality of user accounts. Each account is associated with a user. The method includes, for each user having a user account, serving by the web server a set of web pages configured to support uploading of time series data to the web server, including updates of such data from time to time; storing by the web server the uploaded time series data; and serving by the web server a set of web pages configured to present such data to such user. Related methods include a method for web-publishing the data, and loading the data into applications running locally. There is also provided a digital storage medium encoded with instructions that when loaded into a computer establish processes that implement any of these methods.
-
公开(公告)号：US09971851B2
公开(公告)日：2018-05-15
申请号：US14749073
申请日：2015-06-24
CPC分类号： G06F17/30958 , G06F17/30516 , G06F17/30864 , H04L65/605 , H04L67/28
摘要： A stream of tuples may be processed by receiving at a first stream operator a first tuple from a stream of tuples. In response to receiving the first tuple, port mutability conditions for a first stream operator and a second stream operator may be analyzed. In response to identifying the port mutability conditions for a first stream operator and a second stream operator, a first set of attribute mutability conditions for the first tuple received at the first stream operator may be identified. Based on the first set of attribute mutability conditions, a reference of an attribute from the first tuple may be generated where the reference is added to a second tuple passing from the first stream operator to the second stream operator.
-
公开(公告)号：US09971810B2
公开(公告)日：2018-05-15
申请号：US15427927
申请日：2017-02-08
CPC分类号： H04L65/4069 , G06F11/0709 , G06F11/0751 , G06F11/0793 , G06F11/3006 , G06F11/3409 , G06F17/30516 , G06F17/30575 , H04L43/04 , H04L43/06 , H04L43/0811 , H04L43/16 , H04L65/60 , H04L65/601 , H04L65/602
摘要： Embodiments of the present disclosure include a method, a system, and a computer program product for fusing a stream operator into more than one processing element within a streaming application. The method includes receiving an instruction to concurrently fuse, into a second processing element, a stream operator of interest that is fused into a first processing element. The method includes determining whether the stream operator of interest is stateful. The method includes compiling, in response to determining the stream operator of interest is stateful, a clone of the stream operator of interest into the second processing element so that the clone is synchronized with the stream operator of interest.
-
-
-
-
-
-
-
-
-
搜索结果
1432 条记录 (耗时 0.04 秒)