International Business Machines Corporation

Alibaba Group Holding Limited

Roger Alan Mittelstadt

Rafal Przemyslaw Konik

Brian Robert Muras

Mark William Theuer

Chad Allen Olstad

Randy Lynn Egan

Paul Reuben Day

Shawn Joseph Baranczyk

Jessica R Eidem

Jingdong Sun

Scott Patrick Hanson

Craig Stephen Aldrich

Jane Ann Vold

Stephanie A Burrichter

Robert J Bestgen

Anne Marie Ryg

Dale M Stahl

Lee William Jameson

A sharable resource of a first user's environment is identified. The sharable resource is configured as sharable in a shared computer environment. A matching resource that is sufficiently similar to the sharable resource is located. The matching resource is used by pre-existing users of the shared computer environment. Agreement from the pre-existing users for the first user to access the matching resource is obtained. The first user is then provided access to the matching resource.

Flexible sharing in shared computer environments

Each of one or more commit cycles may be associated with a predicted number of updates. A statistics collection time for a database table can be determined by estimating a sum of predicted updates included in one or more commit cycles. Whether the estimated sum of predicted updates is greater than a first threshold may be determined. In addition, a progress point for a first one of the commit cycles can be determined. A time to collect statistics may be selected based on the progress point of the first commit cycle.

Dynamically adjusting statistics collection time in a database management system

In an embodiment, a method for controlling a database in a streaming application includes receiving, by a compute node, data for transmission as streaming data on a network connected to the compute node and a database. The compute node then assembles a body portion of a tuple to include the data and assembles a header portion of the tuple to include a database statement that identifies a change to be made by the database to an aspect of the database in a format that is identifiable by the database. The compute node then transmits the tuple having the header portion thereof and the body portion thereof on the network as streaming data with the header and body portions of the tuple being directed to the database.

Streaming tuple database control

Disclosed aspects relate to query plan management associated with a shared pool of configurable computing resources. A query, which relates to a set of data located on the shared pool of configurable computing resources, is detected. A virtual machine includes the set of data. With respect to the virtual machine, a set of burden values of performing a set of asset actions is determined. Based on the set of burden values, a query plan to access the set of data is established. Using at least one asset action of the set of asset actions, the query plan is processed.

Query plan management associated with a shared pool of configurable computing resources

Disclosed aspects relate to transforming a user-defined table function (UDTF) to a derived table in a database management system (DBMS). It may be detected by the DBMS that a query indicates the UDTF. A derived table may be constructed from the UDTF. The derived table may be derived from a set of statements of the UDTF. The derived table may be introduced to the query to fulfill the UDTF. A query plan may be generated for the query by the DBMS. The query plan may be generated in response to introducing the derived table in the query.

Transforming a user-defined table function to a derived table in a database management system

A structured query language (SQL) query is configured to present a selected portion of a result set to a user interface. The selected portion of the result set can be based on an offset criteria appended to the SQL query. The offset criteria determines a location of a first presented instance of the selected portion of the result set. The offset criteria is configured to determine the location of the first presented instance of the selected portion of the result set independent of a number of instances appearing between a first instance of the result set and the first presented instance of the selected portion of the result set.

Result set output criteria

A tuple manager of a database system processes partial tuples from a streaming application and stores them in a database. The partial tuples may include a large object (LOB) that arrives at the database at a different time than the rest of the corresponding tuple. A tuple manager stores partial tuples and uses a partial tuples index to track the partial tuples and coordinate recombination of corresponding partial tuples. The database allows queries to be run on the partial data before the tuples are reconstructed allowing faster access to potentially important data before the arrival and processing of a partial tuple such as an LOB.

Storing partial tuples from a streaming application in a database system

A blockchain configuration may require constant and large amounts of resources to maintain a growing structure. One example method of operation may include receiving blockchain transactions and creating a blockchain block, identifying miner devices to process the blockchain block, identifying expenses associated with each of the miner devices, selecting an optimal cost miner device among the miner devices based on the identified expenses associated with each of the miner devices, and assigning the optimal cost miner device to solve the blockchain block.

Blockchain expense and resource utilization optimization

A sequence object manager provides a sequence object with a dynamic cache block size that indicates a block size of values to be added to the sequence object when the cache values are exhausted. The dynamic block size allows the sequence object manager to optimize performance and storage space depending on applications using the sequence object. The dynamically block size is set and maintained by the sequence object manager based on observed performance and historical trends of the applications. A seed value may be provided by the user to initially set the dynamic block size.

Database sequence object having a dynamic cache block size

A streams manager includes a connection converter that allows converting at run-time a static connection to a dynamic connection, and converting at run-time a dynamic connection to a static connection. One or more conversion criteria are defined that determine when a conversion of one or more connections is needed at run-time. When conversion criteria for converting a static connection from a first processing element to a second processing element to a dynamic connection is satisfied, the first processing element interacts with the streams manager and with the second processing element to dynamically change the static connection to a dynamic connection. When conversion criteria for converting a dynamic connection from a first processing element to a second processing element to a static connection is satisfied, the first processing element interacts with the streams manager and with the second processing element to dynamically change the dynamic connection to a static connection.

Dynamically converting static and dynamic connections in a streaming application

A method, system, and computer program product to manage a database is disclosed. The method, system, and computer program product may include structuring the database to have a first table having an index and a second table. A first key of the first table may be related to a second key of the second table. The method, system, and computer program product may include creating an entry locator in the index. The method, system, and computer program product may include maintaining an association between the second key of the second table and the entry locator of the index.

Management of a database system

Systems and methods for providing automatic fork protection including determining that a transaction having fork protection was included in a first block that was appended to a blockchain, that a hash of the first block was validated, that a consensus decision was made by validator nodes approving the first block for addition to the blockchain, that a second block was appended to the blockchain after the first block, that the second block comprises a hash that is not based on the first block, that the first block was on a first fork and the second block was on a second fork, that the blockchain was resolved in favor of the second fork, and that the transaction failed as a result of the blockchain being resolved in favor of the second fork. The method including compensating a party that submitted the failed transaction based on the fork protection.

Blockchain: automatic fork protection

Dynamic connections between processing elements of a streaming application are managed in a distributed manner by the processing elements to increase efficiency and performance of real-time connection updates. A streams application management service includes a connection manager that notifies all processing elements when a job with a new processing element is submitted. Each processing element dynamically maintains its own connections based on one or more of the following conditions: connection data received from the streams management service, and a behavior change of the processing element. Then the processing element reports connection updates to the connection manager in the streams management service. The connection manager may store updated connection information in the connection data.

Distributed management of dynamic processing element connections in streaming applications

A public operator processes data streams from multiple operators in different streaming applications to reduce resource costs and increase efficiency in a streaming system. The public operator uses tuple level security with a unique key for each streaming application to securely process the data streams. A stream security module (SSM) manages encryption to and from the public operators to insure other streaming applications with access to the shared public operator don't have access to data of other applications that may belong to other customers or users. The stream security module may be incorporated into the streams manager of a streaming system.

Growing community of inventors

Byron, MN, United States of America

Roger Alan Mittelstadt