摘要:
An operator manager may be configured to determine a number of available cores and to assign the cores among a plurality of operators of a query, the operators including a running set of operators through which a plurality of query paths exist. The operator manager may include a status monitor configured to determine the number of available cores and to determine the running set of operators, a critical path selector configured to determine a critical path of the query from among the query paths and the running set of operators, and a workload manager configured to assign a first core of the available cores to a running operator of the running set and of the critical path, and to thereafter receive a new critical path from the critical path selector and to assign a second core of the available cores to the running operator of the new critical path.
摘要:
A first performance measurement of an executing task may be determined, while the task is executed by a first number of nodes operating in parallel. A second performance measurement of the executing task may be determined, while the task is being executed by a second number of nodes operating in parallel. An overhead factor characterizing a change of a parallelism overhead of executing the task with nodes executing in parallel may then be calculated, relative to a change in a number of the nodes, based on the first performance measurement and the second performance measurement. Then, an optimal number of nodes to operate in parallel to continue executing the task may be determined, based on the overhead factor.
摘要:
An operator manager may be configured to determine a number of available cores and to assign the cores among a plurality of operators of a query, the operators including a running set of operators through which a plurality of query paths exist. The operator manager may include a status monitor configured to determine the number of available cores and to determine the running set of operators, a critical path selector configured to determine a critical path of the query from among the query paths and the running set of operators, and a workload manager configured to assign a first core of the available cores to a running operator of the running set and of the critical path, and to thereafter receive a new critical path from the critical path selector and to assign a second core of the available cores to the running operator of the new critical path.
摘要:
A system may include a buffer monitor configured to monitor buffer content of a buffer being used during processing of a query workflow in which write tasks of the query workflow write data to the buffer and read tasks of the query workflow read data from the buffer, the buffer having a buffer capacity. The system may include a threshold manager configured to compare the buffer content to a low threshold and to a high threshold that are defined relative to the buffer capacity, and a speed controller configured to control a number of the write tasks relative to a number of the read tasks that are currently executing the query workflow, to thereby maintain the buffer content between the low threshold and the high threshold.
摘要:
A system may include a buffer monitor configured to monitor buffer content of a buffer being used during processing of a query workflow in which write tasks of the query workflow write data to the buffer and read tasks of the query workflow read data from the buffer, the buffer having a buffer capacity. The system may include a threshold manager configured to compare the buffer content to a low threshold and to a high threshold that are defined relative to the buffer capacity, and a speed controller configured to control a number of the write tasks relative to a number of the read tasks that are currently executing the query workflow, to thereby maintain the buffer content between the low threshold and the high threshold.
摘要:
A first performance measurement of an executing task may be determined, while the task is executed by a first number of nodes operating in parallel. A second performance measurement of the executing task may be determined, while the task is being executed by a second number of nodes operating in parallel. An overhead factor characterizing a change of a parallelism overhead of executing the task with nodes executing in parallel may then be calculated, relative to a change in a number of the nodes, based on the first performance measurement and the second performance measurement. Then, an optimal number of nodes to operate in parallel to continue executing the task may be determined, based on the overhead factor.
摘要:
A system for forecast modeling includes at least one processor and at least one database that is operably coupled to the at least one processor. The database includes a time series data module that is configured to store time series data for a domain, an exogenous data module that is configured to store exogenous data associated with multiple exogenous factors and a feedback module that is configured to collect and store feedback data from multiple online users, where the feedback data is related to the exogenous data and the exogenous factors. The system includes a data pre-processor module that is configured to use the at least one processor to identify and select a portion of the exogenous factors using the feedback data collected from the online users for use in a forecast model in combination with the time series data for the domain.
摘要:
The present disclosure relates to a computer system comprising a database including, a reallocation scheduling module, the reallocation scheduling module configured to obtain an objective function including one or more integer-valued decision variables and automatically determine a proposed reallocation scheme for each of one or more items between a plurality of locations based on the objective function, wherein determining the reallocation scheme includes finding values of one or more decision variables that optimize the objective function while obeying the one or more constraints, wherein determining a proposed reallocation scheme includes solving an integer quadratic programming problem.
摘要:
A failover manager may be configured to determine a plurality of tenants executable on a server of a plurality of servers, each tenant being a virtual machine executable on the server in communication with at least one corresponding user. The failover manager may include a replicated tenant placement selector configured to dispatch a first replicated tenant for a first tenant of the plurality of tenants to a first standby server of the plurality of servers, and configured to dispatch a second replicated tenant for a second tenant of the plurality of tenants to a second standby server of the plurality of servers. The failover manager also may include a replicated tenant loader configured to activate, based on a failure of the server, the first replicated tenant on the first standby server to replace the first tenant, and the second replicated tenant on the second standby server to replace the second tenant.
摘要:
A system for forecast modeling includes at least one processor and at least one database that is operably coupled to the at least one processor. The database includes a time series data module that is configured to store time series data for a domain, an exogenous data module that is configured to store exogenous data associated with multiple exogenous factors and a feedback module that is configured to collect and store feedback data from multiple online users, where the feedback data is related to the exogenous data and the exogenous factors. The system includes a data pre-processor module that is configured to use the at least one processor to identify and select a portion of the exogenous factors using the feedback data collected from the online users for use in a forecast model in combination with the time series data for the domain.