公开(公告)号：US20190148974A1

公开(公告)日：2019-05-16

申请号：US16249868

申请日：2019-01-16

申请人： Kun-Lung Wu ,  Hai-Ruo Wu ,  Chu-Xi Wu

发明人： Kun-Lung Wu ,  Hai-Ruo Wu ,  Chu-Xi Wu

IPC分类号： H02J7/14 ,  H01M10/46 ,  H01M4/56 ,  H01M4/583 ,  H01M4/38 ,  H01M4/36

摘要： A power supply device using electromagnetic power generation includes an electric motor, an electromagnet, a winding, a rechargeable unit, and a battery case. The electromagnet is operatively connected to the electric motor so that an activation of the electric motor changes a magnetic field of the electromagnet. The winding is around the electromagnet so that the change of the magnetic field of the electromagnet generates emf in the winding. The rechargeable unit is electrically connected to both the electric motor and the electromagnet so that the emf is stored in the rechargeable unit or supply to an external electric load. The battery case includes an electrical wire electrically connected to the winding.

公开(公告)号：US09158837B2

公开(公告)日：2015-10-13

申请号：US11870099

申请日：2007-10-10

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

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

IPC分类号： G06F7/00 ,  G06F17/30

CPC分类号： G06F17/30657 ,  G06F17/3066

摘要： Techniques are disclosed for adaptive source filtering and load shedding in such data stream processing systems. For example, in one aspect of the invention, a method for use in filtering data in a distributed data stream processing system, wherein a server receives and processes one or more data streams from one or more data sources, comprises the steps of the server periodically re-configuring one or more filters and sending the one or more periodically re-configured filters to the one or more data sources, and the one or more data sources performing data filtering based on the one or more periodically re-configured filters received from the server.

摘要翻译： 公开了用于这种数据流处理系统中的自适应源滤波和负载脱落的技术。 例如，在本发明的一个方面，一种用于过滤分布式数据流处理系统中的数据的方法，其中服务器从一个或多个数据源接收和处理一个或多个数据流，包括周期性地服务的步骤 重新配置一个或多个过滤器并将一个或多个周期性重新配置的过滤器发送到所述一个或多个数据源，以及所述一个或多个数据源基于从所述一个或多个数据源接收的一个或多个周期性重新配置的过滤器执行数据过滤 服务器。

公开(公告)号：US09063788B2

公开(公告)日：2015-06-23

申请号：US13594961

申请日：2012-08-27

申请人： Bugra Gedik ,  Gabriela Jacques da Silva ,  Vibhore Kumar ,  Rohit Wagle ,  Kun-Lung Wu

发明人： Bugra Gedik ,  Gabriela Jacques da Silva ,  Vibhore Kumar ,  Rohit Wagle ,  Kun-Lung Wu

IPC分类号： G06F15/16 ,  G06F9/50 ,  H04L12/26 ,  G06F17/30

CPC分类号： G06F9/5066 ,  G06F17/30516 ,  H04L43/08

摘要： Embodiments of the disclosure include a system for providing stream processing with runtime adaptation, having a stream processing application that receives an incoming data stream and a runtime infrastructure configured to execute the stream processing application. The system also includes an orchestrator configured to communicate with the runtime infrastructure and the stream processing application, the orchestrator configured to perform a method. The method includes registering one or more events, wherein each of the events is associated with a stream processing application. The method also includes monitoring, by a processor, for an occurrence of the one or more events associated with the stream processing application, wherein each of the one or more events is associated with one or more runtime metrics. The method further includes receiving an event notification, wherein the event notification includes event identification and an event context and executing an adaptation of the stream processing application.

摘要翻译： 本公开的实施例包括用于提供具有运行时适应的流处理的系统，具有接收输入数据流的流处理应用和被配置为执行流处理应用的运行时基础设施。 该系统还包括经配置以与运行时基础设施和流处理应用程序进行通信的协调者，该协调器被配置为执行方法。 该方法包括登记一个或多个事件，其中每个事件与流处理应用相关联。 该方法还包括由处理器监视与流处理应用相关联的一个或多个事件的发生，其中所述一个或多个事件中的每一个与一个或多个运行时度量相关联。 该方法还包括接收事件通知，其中事件通知包括事件识别和事件上下文以及执行流处理应用的适应。

公开(公告)号：US08972380B2

公开(公告)日：2015-03-03

申请号：US10671938

申请日：2003-09-29

申请人： Shyh-Kwei Chen ,  Kun-Lung Wu ,  Philip Shi-lung Yu

发明人： Shyh-Kwei Chen ,  Kun-Lung Wu ,  Philip Shi-lung Yu

IPC分类号： G06F7/00 ,  G06F17/30

CPC分类号： G06F17/30516 ,  G06F17/3046

摘要： A method (and structure) for monitoring continual range queries against events includes decomposing each range query with one or more predefined virtual constructs, building a query index, and using the query index to match an event with the range queries.

摘要翻译： 用于监视对事件的持续范围查询的方法（和结构）包括使用一个或多个预定义的虚拟构造来分解每个范围查询，构建查询索引，以及使用查询索引来将事件与范围查询相匹配。

公开(公告)号：US08768929B2

公开(公告)日：2014-07-01

申请号：US13517824

申请日：2012-06-14

申请人： Ahmed S. Eldawy ,  Rohit M. Khandekar ,  Kun-Lung Wu

发明人： Ahmed S. Eldawy ,  Rohit M. Khandekar ,  Kun-Lung Wu

IPC分类号： G06F17/30

CPC分类号： G06F17/30961

摘要： A system for clustering vertices in a streaming graph includes a structural sampler configured to receive a stream of edges. The structural sampler includes a reservoir manager configured to receive the stream of edges and create a structural reservoir and a support reservoir and a graph manager configured to receive the structural reservoir from the reservoir manager and to create a sampled graph from the structural reservoir, wherein the sampled graph includes one or more clusters that each include one or more connected vertices.

摘要翻译： 用于在流图中聚类顶点的系统包括被配置为接收边缘流的结构采样器。 结构采样器包括：储存器管理器，其被配置为接收边缘流并且创建结构储存器和支撑储存器以及图形管理器，其构造成从储存器管理器接收结构储存器并从结构储存器创建采样图， 采样图包括一个或多个簇，每个簇包括一个或多个连接的顶点。

公开(公告)号：US20130339357A1

公开(公告)日：2013-12-19

申请号：US13532823

申请日：2012-06-26

申请人： Ahmed S. Eldawy ,  Rohit M. Khandekar ,  Kun-Lung Wu

发明人： Ahmed S. Eldawy ,  Rohit M. Khandekar ,  Kun-Lung Wu

IPC分类号： G06F17/30

CPC分类号： G06F17/30961

摘要： Embodiments of the invention include methods for identifying one or more clusters in a streaming graph, the method includes receiving a stream of edges and sampling the stream of edges to create a structural reservoir and support reservoir. The method also includes creating a sampled graph from the structural reservoir and identifying the one or more clusters in the sampled graph by grouping one or more connected vertices in the sampled graph.

摘要翻译： 本发明的实施例包括用于识别流图中的一个或多个聚类的方法，所述方法包括接收边缘流并对边缘流进行采样以创建结构储层和支持库。 该方法还包括从结构储层创建采样图，并通过对采样图中的一个或多个连接的顶点进行分组来识别采样图中的一个或多个聚类。

公开(公告)号：US20130339355A1

公开(公告)日：2013-12-19

申请号：US13517824

申请日：2012-06-14

申请人： Ahmed S. Eldawy ,  Rohit M. Khandekar ,  Kun-Lung Wu

发明人： Ahmed S. Eldawy ,  Rohit M. Khandekar ,  Kun-Lung Wu

IPC分类号： G06F17/30

CPC分类号： G06F17/30961

摘要： A system for clustering vertices in a streaming graph includes a structural sampler configured to receive a stream of edges. The structural sampler includes a reservoir manager configured to receive the stream of edges and create a structural reservoir and a support reservoir and a graph manager configured to receive the structural reservoir from the reservoir manager and to create a sampled graph from the structural reservoir, wherein the sampled graph includes one or more clusters that each include one or more connected vertices.

摘要翻译： 用于在流图中聚类顶点的系统包括被配置为接收边缘流的结构采样器。 结构采样器包括：储存器管理器，其被配置为接收边缘流并且创建结构储存器和支撑储存器以及图形管理器，其构造成从储存器管理器接收结构储存器并从结构储存器创建采样图， 采样图包括一个或多个簇，每个簇包括一个或多个连接的顶点。

公开(公告)号：US08595732B2

公开(公告)日：2013-11-26

申请号：US12946475

申请日：2010-11-15

申请人： Kirsten W. Hildrum ,  Rohit M. Khandekar ,  Vibhore Kumar ,  Sujay S. Parekh ,  Deepak Rajan ,  Joel L. Wolf ,  Kun-Lung Wu

发明人： Kirsten W. Hildrum ,  Rohit M. Khandekar ,  Vibhore Kumar ,  Sujay S. Parekh ,  Deepak Rajan ,  Joel L. Wolf ,  Kun-Lung Wu

IPC分类号： G06F15/16

CPC分类号： G06F9/4881

摘要： A method for scheduling a data processing job includes receiving the data processing job formed of a plurality of computing units, combining the plurality of computing units into a plurality of sets of tasks, each set including tasks of about equal estimated size, and different sets having different sized tasks, and assigning the tasks to a plurality of processors using a dynamic longest processing time (DLPT) scheme.

摘要翻译： 一种用于调度数据处理作业的方法包括：接收由多个计算单元组成的数据处理作业，将多个计算单元组合成多组任务，每组任务包括约等于估计大小的任务，以及具有 不同大小的任务，以及使用动态最长处理时间（DLPT）方案将任务分配给多个处理器。

公开(公告)号：US08543579B2

公开(公告)日：2013-09-24

申请号：US11155221

申请日：2005-06-17

申请人： Shyh-Kwei Chen ,  Kun-Lung Wu ,  Philip Shi-Lung Yu

发明人： Shyh-Kwei Chen ,  Kun-Lung Wu ,  Philip Shi-Lung Yu

IPC分类号： G06F17/30 ,  G06F7/00

CPC分类号： G06F17/30516 ,  G06F17/30241 ,  G06F17/30312 ,  G06F17/30463

摘要： Range query techniques are disclosed for use in accordance with data stream processing systems. In one aspect of the invention, a technique is provided for indexing continual range queries for use in data stream processing. For example, a technique for use in processing a data stream comprises obtaining at least one range query to be associated with the data stream, and building a range query index based on the at least one range query using one or more virtual constructs such that the query index is adaptive to one or more changes in a distribution of range query sizes. The step/operation of building the range query index may further comprise building the range query index such that the range query index accommodates one or more changes in query positions outside a monitoring area of the at least one range query. In another aspect of the invention, a technique is provided for incrementally processing continual range queries against moving objects. For example, a technique for evaluating one and more continual range queries over one and more moving objects comprises maintaining a query index with one and more containment-encoded virtual constructs associated with the one and more continual range queries over the one and more moving objects, and incrementally evaluating the one or more continual range queries using the query index.

摘要翻译： 公开了根据数据流处理系统使用的范围查询技术。 在本发明的一个方面，提供了一种用于索引用于数据流处理的连续范围查询的技术。 例如，用于处理数据流的技术包括获得要与数据流相关联的至少一个范围查询，以及使用一个或多个虚拟构造基于至少一个范围查询构建范围查询索引，使得 查询索引适应范围查询大小分布中的一个或多个变化。 构建范围查询索引的步骤/操作还可以包括构建范围查询索引，使得范围查询索引适应在至少一个范围查询的监视区域之外的查询位置中的一个或多个改变。 在本发明的另一方面，提供了一种用于逐渐处理对移动对象的连续范围查询的技术。 例如，用于通过一个或多个移动对象来评估一个或多个连续范围查询的技术包括：通过在一个或多个运动对象上与一个和多个连续范围查询相关联的一个和多个包含编码的虚拟构造来维护查询索引， 并使用查询索引来递增地评估一个或多个连续范围查询。

公开(公告)号：US08479181B2

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

申请号：US12697624

申请日：2010-02-01

申请人： Henrique Andrade ,  Bugra Gedik ,  Andrew L. Frenkiel ,  Rohit M. Kandekar ,  Joel L. Wolf ,  Kun-Lung Wu

发明人： Henrique Andrade ,  Bugra Gedik ,  Andrew L. Frenkiel ,  Rohit M. Kandekar ,  Joel L. Wolf ,  Kun-Lung Wu

IPC分类号： G06F9/45

摘要： Techniques for performing capacity planning for applications running on a computational infrastructure are provided. The techniques include instrumenting an application under development to receive one or more performance metrics under a physical deployment plan, receiving the one or more performance metrics from the computational infrastructure hosting one or more applications that are currently running, using a predictive inference engine to determine how the application under development can be deployed, and using the determination to perform capacity planning for the applications on the computational infrastructure.

摘要翻译： 提供了在计算基础设施上运行的应用程序执行容量规划的技术。 这些技术包括对开发中的应用进行检测，以在物理部署计划下接收一个或多个性能指标，从托管一个或多个当前运行的应用的计算基础设施接收一个或多个性能指标，使用预测推理机来确定 可以部署正在开发的应用程序，并使用确定来对计算基础设施上的应用程序进行容量规划。