公开(公告)号：US08478875B2

公开(公告)日：2013-07-02

申请号：US12164671

申请日：2008-06-30

申请人： Bugra Gedik ,  Kun-Lung Wu ,  Philip S. Yu

发明人： Bugra Gedik ,  Kun-Lung Wu ,  Philip S. Yu

IPC分类号： G06F15/173

CPC分类号： H04L67/10 ,  H02J3/14 ,  H04L47/10 ,  H04L47/225 ,  H04L47/41 ,  H04L49/90 ,  H04L49/901 ,  Y02D50/30 ,  Y04S20/224

摘要： One embodiment of the present method and apparatus adaptive in-operator load shedding includes receiving at least two data streams (each comprising a plurality of tuples, or data items) into respective sliding windows of memory. A throttling fraction is then calculated based on input rates associated with the data streams and on currently available processing resources. Tuples are then selected for processing from the data streams in accordance with the throttling fraction, where the selected tuples represent a subset of all tuples contained within the sliding window.

摘要翻译： 本发明的方法和设备的一个实施例是自适应操作员卸载包括将至少两个数据流（每个包括多个元组或数据项）接收到存储器的相应滑动窗口中。 然后基于与数据流相关联的输入速率和当前可用的处理资源来计算节流分数。 然后根据节流分数从数据流中选择元组进行处理，其中所选元组表示包含在滑动窗口内的所有元组的子集。

公开(公告)号：US20090049187A1

公开(公告)日：2009-02-19

申请号：US12165524

申请日：2008-06-30

申请人： BUGRA GEDIK ,  Kun-Lung Wu ,  Philip S. Yu

发明人： BUGRA GEDIK ,  Kun-Lung Wu ,  Philip S. Yu

IPC分类号： G06F15/16

CPC分类号： H04L49/90

摘要： One embodiment of the present method and apparatus adaptive load shedding includes receiving at least one data stream (comprising a plurality of tuples, or data items) into a first sliding window of memory. A subset of tuples from the received data stream is then selected for processing in accordance with at least one data stream operation, such as a data stream join operation. Tuples that are not selected for processing are ignored. The number of tuples selected and the specific tuples selected depend at least in part on a variety of dynamic parameters, including the rate at which the data stream (and any other processed data streams) is received, time delays associated with the received data stream, a direction of a join operation performed on the data stream and the values of the individual tuples with respect to an expected output.

摘要翻译： 本发明的方法和设备的一个实施例是自适应负载脱落包括将至少一个数据流（包括多个元组或数据项）接收到存储器的第一滑动窗口中。 然后根据至少一个数据流操作（例如数据流加入操作）选择来自接收到的数据流的元组的子集用于处理。 未选择处理的元组将被忽略。 所选择的元组的数量和所选择的特定元组至少部分取决于各种动态参数，包括接收数据流（和任何其他处理的数据流）的速率，与接收到的数据流相关联的时间延迟， 对数据流执行的连接操作的方向和相对于预期输出的单个元组的值。

公开(公告)号：US08117331B2

公开(公告)日：2012-02-14

申请号：US12165524

申请日：2008-06-30

申请人： Bugra Gedik ,  Kun-Lung Wu ,  Philip S. Yu

发明人： Bugra Gedik ,  Kun-Lung Wu ,  Philip S. Yu

IPC分类号： G06F15/16

CPC分类号： H04L49/90

摘要： One embodiment of the present method and apparatus adaptive load shedding includes receiving at least one data stream (comprising a plurality of tuples, or data items) into a first sliding window of memory. A subset of tuples from the received data stream is then selected for processing in accordance with at least one data stream operation, such as a data stream join operation. Tuples that are not selected for processing are ignored. The number of tuples selected and the specific tuples selected depend at least in part on a variety of dynamic parameters, including the rate at which the data stream (and any other processed data streams) is received, time delays associated with the received data stream, a direction of a join operation performed on the data stream and the values of the individual tuples with respect to an expected output.

摘要翻译： 本发明的方法和设备的一个实施例是自适应负载脱落包括将至少一个数据流（包括多个元组或数据项）接收到存储器的第一滑动窗口中。 然后根据至少一个数据流操作（例如数据流加入操作）选择来自接收到的数据流的元组的子集用于处理。 未选择处理的元组将被忽略。 所选择的元组的数量和所选择的特定元组至少部分取决于各种动态参数，包括接收数据流（和任何其他处理的数据流）的速率，与接收到的数据流相关联的时间延迟， 对数据流执行的连接操作的方向和相对于预期输出的单个元组的值。

公开(公告)号：US20080270640A1

公开(公告)日：2008-10-30

申请号：US12164671

申请日：2008-06-30

申请人： BUGRA GEDIK ,  Kun-Lung Wu ,  Philip S. Yu

发明人： BUGRA GEDIK ,  Kun-Lung Wu ,  Philip S. Yu

IPC分类号： G06F3/00

CPC分类号： H04L67/10 ,  H02J3/14 ,  H04L47/10 ,  H04L47/225 ,  H04L47/41 ,  H04L49/90 ,  H04L49/901 ,  Y02D50/30 ,  Y04S20/224

摘要： One embodiment of the present method and apparatus adaptive in-operator load shedding includes receiving at least two data streams (each comprising a plurality of tuples, or data items) into respective sliding windows of memory. A throttling fraction is then calculated based on input rates associated with the data streams and on currently available processing resources. Tuples are then selected for processing from the data streams in accordance with the throttling fraction, where the selected tuples represent a subset of all tuples contained within the sliding window.

摘要翻译： 本发明的方法和设备的一个实施例是自适应操作员卸载包括将至少两个数据流（每个包括多个元组或数据项）接收到存储器的相应滑动窗口中。 然后基于与数据流相关联的输入速率和当前可用的处理资源来计算节流分数。 然后根据节流分数从数据流中选择元组进行处理，其中所选元组表示包含在滑动窗口内的所有元组的子集。

公开(公告)号：US20120124233A1

公开(公告)日：2012-05-17

申请号：US13342487

申请日：2012-01-03

申请人： BUGRA GEDIK ,  Kun-Lung Wu ,  Philip S. Yu

发明人： BUGRA GEDIK ,  Kun-Lung Wu ,  Philip S. Yu

IPC分类号： G06F15/16

CPC分类号： H04L49/90

摘要： One embodiment of the present method and apparatus adaptive load shedding includes receiving at least one data stream (comprising a plurality of tuples, or data items) into a first sliding window of memory. A subset of tuples from the received data stream is then selected for processing in accordance with at least one data stream operation, such as a data stream join operation. Tuples that are not selected for processing are ignored. The number of tuples selected and the specific tuples selected depend at least in part on a variety of dynamic parameters, including the rate at which the data stream (and any other processed data streams) is received, time delays associated with the received data stream, a direction of a join operation performed on the data stream and the values of the individual tuples with respect to an expected output.

摘要翻译： 本发明的方法和设备的一个实施例是自适应负载脱落包括将至少一个数据流（包括多个元组或数据项）接收到存储器的第一滑动窗口中。 然后根据至少一个数据流操作（例如数据流加入操作）选择来自接收到的数据流的元组的子集用于处理。 未选择处理的元组将被忽略。 所选择的元组的数量和所选择的特定元组至少部分取决于各种动态参数，包括接收数据流（和任何其他处理的数据流）的速率，与接收到的数据流相关联的时间延迟， 对数据流执行的连接操作的方向和相对于预期输出的单个元组的值。

公开(公告)号：US07610397B2

公开(公告)日：2009-10-27

申请号：US11068137

申请日：2005-02-28

申请人： Bugra Gedik ,  Kun-Lung Wu ,  Philip S. Yu

发明人： Bugra Gedik ,  Kun-Lung Wu ,  Philip S. Yu

IPC分类号： G06F15/16

CPC分类号： H04L49/90

摘要： One embodiment of the present method and apparatus adaptive load shedding includes receiving at least one data stream (comprising a plurality of tuples, or data items) into a first sliding window of memory. A subset of tuples from the received data stream is then selected for processing in accordance with at least one data stream operation, such as a data stream join operation. Tuples that are not selected for processing are ignored. The number of tuples selected and the specific tuples selected depend at least in part on a variety of dynamic parameters, including the rate at which the data stream (and any other processed data streams) is received, time delays associated with the received data stream, a direction of a join operation performed on the data stream and the values of the individual tuples with respect to an expected output.

摘要翻译： 本发明的方法和设备的一个实施例是自适应负载脱落包括将至少一个数据流（包括多个元组或数据项）接收到存储器的第一滑动窗口中。 然后根据至少一个数据流操作（例如数据流加入操作）选择来自接收到的数据流的元组的子集用于处理。 未选择处理的元组将被忽略。 所选择的元组的数量和所选择的特定元组至少部分取决于各种动态参数，包括接收数据流（和任何其他处理的数据流）的速率，与接收到的数据流相关联的时间延迟， 对数据流执行的连接操作的方向和相对于预期输出的单个元组的值。

公开(公告)号：US20080005391A1

公开(公告)日：2008-01-03

申请号：US11447433

申请日：2006-06-05

申请人： Bugra Gedik ,  Kun-Lung Wu ,  Philip S. Yu

发明人： Bugra Gedik ,  Kun-Lung Wu ,  Philip S. Yu

IPC分类号： G06F3/00

CPC分类号： H04L67/10 ,  H02J3/14 ,  H04L47/10 ,  H04L47/225 ,  H04L47/41 ,  H04L49/90 ,  H04L49/901 ,  Y02D50/30 ,  Y04S20/224

摘要： One embodiment of the present method and apparatus adaptive in-operator load shedding includes receiving at least two data streams (each comprising a plurality of tuples, or data items) into respective sliding windows of memory. A throttling fraction is then calculated based on input rates associated with the data streams and on currently available processing resources. Tuples are then selected for processing from the data streams in accordance with the throttling fraction, where the selected tuples represent a subset of all tuples contained within the sliding window.

摘要翻译： 本发明的方法和设备的一个实施例是自适应操作员卸载包括将至少两个数据流（每个包括多个元组或数据项）接收到存储器的相应滑动窗口中。 然后基于与数据流相关联的输入速率和当前可用的处理资源来计算节流分数。 然后根据节流分数从数据流中选择元组进行处理，其中所选元组表示包含在滑动窗口内的所有元组的子集。

公开(公告)号：US08499292B2

公开(公告)日：2013-07-30

申请号：US12719364

申请日：2010-03-08

申请人： Henrique Andrade ,  Jim Challenger ,  Bugra Gedik ,  Robert Grimm ,  Martin J. Hirzel ,  Vibhore Kumar ,  Robert Soule ,  Kun-Lung Wu

发明人： Henrique Andrade ,  Jim Challenger ,  Bugra Gedik ,  Robert Grimm ,  Martin J. Hirzel ,  Vibhore Kumar ,  Robert Soule ,  Kun-Lung Wu

IPC分类号： G06F9/45

摘要： A virtual execution environment (VEE) for a streaming Intermediate Language (IL), wherein the streaming IL represents a streaming program, communicates streaming data in queues, stores data-at-rest in variables, and determines data by functions, where inputs are read from the queues and the variables, and outputs are written to the queues and the variables.

摘要翻译： 用于流式传输中间语言（IL）的虚拟执行环境（VEE），其中流IL表示流式传输程序，在队列中传送流数据，将静态数据存储在变量中，并通过功能确定数据，其中输入被读取 从队列和变量，并将输出写入队列和变量。

公开(公告)号：US08447333B2

公开(公告)日：2013-05-21

申请号：US13469291

申请日：2012-05-11

申请人： Bhuvan Bamba ,  Bugra Gedik ,  Kun-Lung Wu

发明人： Bhuvan Bamba ,  Bugra Gedik ,  Kun-Lung Wu

IPC分类号： H04W24/00

CPC分类号： H04W4/025 ,  H04W24/08

摘要： A method for processing a first data stream specifying locations of a user at different times and a second data stream specifying values of a monitored attribute at a location of interest at different times includes: receiving a location-centric trigger specifying at least one spatial predicate condition relative to the location of interest and at least one non-spatial predicate condition relevant to the location of interest, calculating a safe region that includes locations whose probability of satisfying the spatial predicate condition falls below a first threshold, calculating a safe value container that includes values whose probability of satisfying the non-spatial predicate condition falls below a second threshold, and processing the first data stream and the second data stream against the location-centric trigger, by considering only those locations that are not contained within the safe region and only those values that are not contained within the safe value container.

摘要翻译： 一种用于处理在不同时间指定用户的位置的第一数据流的方法和指定在不同时间的感兴趣位置处的被监视属性的值的第二数据流包括：接收指定至少一个空间谓词条件的位置中心触发 相对于感兴趣的位置和与感兴趣位置相关的至少一个非空间谓词条件，计算包括满足空间谓词条件的概率低于第一阈值的位置的安全区域，计算包括 满足非空间谓词条件的概率低于第二阈值的值，并且通过仅考虑不包含在安全区域内的那些位置并且仅仅是处理第一数据流和第二数据流而针对位置中心触发 那些不包含在安全值容器中的值。

公开(公告)号：US20120276923A1

公开(公告)日：2012-11-01

申请号：US13469291

申请日：2012-05-11

申请人： Bhuvan Bamba ,  Bugra Gedik ,  Kun-Lung Wu

发明人： Bhuvan Bamba ,  Bugra Gedik ,  Kun-Lung Wu

IPC分类号： H04W4/02

CPC分类号： H04W4/025 ,  H04W24/08

摘要： A method for processing a first data stream specifying locations of a user at different times and a second data stream specifying values of a monitored attribute at a location of interest at different times includes: receiving a location-centric trigger specifying at least one spatial predicate condition relative to the location of interest and at least one non-spatial predicate condition relevant to the location of interest, calculating a safe region that includes locations whose probability of satisfying the spatial predicate condition falls below a first threshold, calculating a safe value container that includes values whose probability of satisfying the non-spatial predicate condition falls below a second threshold, and processing the first data stream and the second data stream against the location-centric trigger, by considering only those locations that are not contained within the safe region and only those values that are not contained within the safe value container.

摘要翻译： 一种用于处理在不同时间指定用户的位置的第一数据流的方法和指定在不同时间的感兴趣位置处的被监视属性的值的第二数据流包括：接收指定至少一个空间谓词条件的位置中心触发 相对于感兴趣的位置和与感兴趣位置相关的至少一个非空间谓词条件，计算包括满足空间谓词条件的概率低于第一阈值的位置的安全区域，计算包括 满足非空间谓词条件的概率低于第二阈值的值，并且通过仅考虑不包含在安全区域内的那些位置并且仅仅是处理第一数据流和第二数据流而针对位置中心触发 那些不包含在安全值容器中的值。