International Business Machines Corporation

Jessica R Eidem

Jingdong Sun

Brian Robert Muras

Bin Cao

Rafal Przemyslaw Konik

Roger Alan Mittelstadt

James Dorance Gerken

Eric Alan Eckberg

Phillip V Mann

Marvin Miles Misgen

Rebeccah J Vossberg

Daniel A Wright

Stephen Peter Mroz

Laurie M Gerken

Glenn S Leckband

Ryan R Anderson

Michael D O'Connell

David L Johnson

Elias Rosedahl

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

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

Vibration shock mitigation for components in a server rack includes a server rack comprising: a first server component chassis and a second server component chassis installed in adjacent locations within the server rack; and a chassis gap filler comprising: an elastic dampening sheet configured for placement between the first server component chassis and the second server component chassis, wherein the elastic dampening sheet is further configured to cover a portion of one side of the first server component chassis; and at least two attachment points configured to secure the elastic dampening sheet to the server rack.

Vibration shock mitigation for components in a server rack

An apparatus for cooling warm air, including a rack containing one or more ventilation slots; a reservoir connected to the rack that contains a cooling solution; and a plurality of components, located within the rack, that receive and distribute the cooling solution from the reservoir. The plurality of components consist of at least one of the following structures: one or more hollow vertical louvers, one or more hollow horizontal louvers, one or more hollow diagonal louvers, and one or more hollow cylindrical louvers. Additionally, the plurality of components may comprise a flexible material that descends from a top portion of the rack, directly below the reservoir, at the same time that an activation component causes the cooling solution to flow from the reservoir into the flexible material.

Emergency cooling device

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 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

Embodiments of the preset disclosure include a method, a system, and a computer program product for rearranging a set of filters within a data streams environment. The method includes setting a first filter ordering of two or more filter processing elements. The method includes determining a filtering efficiency of the first filter ordering. The determining of the filtering efficiency includes monitoring a runtime, one or more tuples, and an amount of tuples retained after filtering of the first filter ordering. The method includes creating a second filter ordering of the two or more filter processing elements. The method includes comparing the filtering efficiency of the second filter ordering to the first filter ordering. The method includes selecting the second filter ordering in response to comparing the filtering efficiency of the second filter ordering to the filtering efficiency of the first filter ordering.

Filter optimizer for data streams

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.

Tuple level security for streams processing

Method, system, and computer program product are provided to guarantee no tuple loss and/or corruption in a real-time data streaming environment. In some embodiments, a stream of tuples is sent from an entry operator to downstream operator(s), and, at the entry operator, a mark is placed on each tuple in the stream of tuples. In an embodiment where the stream of tuples includes first, second, and subsequent tuple(s), for example, the mark may comprise a tuple-unique number and a tuple-data hash of data contained in the tuple, and the mark on the second and each subsequent tuple may further comprise a link-back hash associated with the immediately preceding tuple in the stream of tuples. In some embodiments, the link-back hash is used to check whether a tuple is lost or received out of order, and the tuple-data hash is used to check whether a received tuple is corrupt.

Using modified blockchain concepts to guarantee no tuple loss and/or no tuple corruption

Disclosed aspects relate to managing a stream computing environment. The stream computing environment may have a consistent region that includes a set of stream operators for processing a stream of tuples. An operator modification request with respect to the set of stream operators of the consistent region of the stream computing environment may be received. In response to receiving the operator modification request, a set of tuples of the stream of tuples may be detected in the consistent region. Using the operator modification request, a tuple adjustment action for the set of tuples of the stream of tuples in the consistent region may be determined. Based on the operator modification request, the set of stream operators may be modified. The set of tuples may be processed using the tuple adjustment action.

Managing a modification to a consistent region of a stream computing environment

A slam latch for mounting and unmounting a server in a rack holding a computing system is disclosed. The slam latch includes a permanent magnet. The slam latch further includes at least one magnetically attractive plate separated by a first distance from the permanent magnet, wherein the permanent magnet has a first force of attraction to the at least one plate. The permanent magnet has a second force of attraction to the at least one plate lower than the first force of attraction when the at least one plate is forceably separated from the permanent magnet by a second distance that is greater than the first distance.

Magnetic server latching system

A stream application receives a stream of tuples to be processed by a plurality of processing elements. The plurality of processing elements operating on one or more compute nodes. Each processing element has one or more stream operators. The stream application assigns one or more processing cycles to one or more segments of software code. The segments of software code are embedded in a tuple of the stream of tuples. The software-embedded tuple identifies a set of target tuples based upon operation criteria. The set of target tuples are a part of the stream of tuples. The software-embedded tuple performs an operation based on the set of identified target tuples.

Smart tuple dynamic grouping of tuples

A stream application receives a stream of tuples to be processed by a plurality of processing elements. The plurality of processing elements operate on one or more compute nodes. Each processing element has one or more stream operators. Segments of software code are embedded in a tuple of the stream of tuples. The tuple retrieves one or more compute node metrics. The compute node metrics describe one or more resources of a first compute node. The tuple obtains tuple information of one or more tuples of the stream of tuples to be processed by a first stream operator that operates on the one or more resources. The tuple determines a prospective resource disparity related to the first stream operator based on the obtained tuple information and the compute node metrics. The tuple transmits a resource request to the stream application based on the determined prospective resource disparity.

Smart tuple resource estimation

A stream application receives a stream of tuples to be processed by a plurality of processing elements operating on one or more compute nodes. Each processing element has one or more stream operators. The stream application assigns one or more processing cycles to one or more segments of software code. The segments of software code are embedded in one or more tuples of the stream of tuples. The stream application determines that a condition is met based on the processing cycles. The stream application performs an operation based on the processing cycles.

Growing community of inventors

Rochester, MN, United States of America

Jessica R Eidem