IP Library Granted Patent US 9,633,102
Granted Patent B2
US 9,633,102 · App. 14/748,960 · Granted Apr 25, 2017

Managing passthru connections on an operator graph

View Patent ↗
Loading inventors, assignments & file history…
Monitor This Case
Get email alerts when status or documents change.
Order Certified Copies
Most orders are placed with the USPTO same day — all within 24 business hours.
Order via The Patent Place →
Pre-filled with this patent's details
Quick Facts
Patent No.
US 9,633,102
App. No.
14/748,960
Granted
Apr 25, 2017
Kind
B2
Abstract

Embodiments of the disclosure provide a method, system, and computer program product for processing data such as a stream of tuples. Each tuple can contain one or more attributes. The method can include processing the attributes of the stream of tuples using stream operators operating on one or more computer processors and corresponding to one or more processing elements. The method can also include detecting an indicative element from a plurality of stream operators. The method can also include transmitting, in response to detecting the indicative element, a passthru command to a processing element corresponding to the indicative element. The method can also include altering, in response to receiving the passthru command at the processing element, a portion of attribute processing for the indicative element.

Claims (29)

1. A computer program product for processing a stream of tuples, each tuple containing one or more attributes, the computer program product comprising a computer readable storage medium having program code embodied therewith, the program code comprising computer readable program code configured to:

process the attributes of the stream of tuples using stream operators operating on one or more computer processors and corresponding one or more processing elements;

detect an indicative element from a plurality of stream operators;

transmit, in response to detecting the indicative element, a passthru command to a processing element corresponding to the indicative element, wherein the transmit the passthru command includes:

determine a performance factor of the passthru command on the processing element,

determine a threshold based on resources of a computing system, and

select, in response to the performance factor falling within the threshold, the passthru command; and

alter, in response to receiving the passthru command at the processing element, a portion of attribute processing for the indicative element.

2. The computer program product of claim 1 , wherein the detect an indicative element includes:

determine an essential indicative element; and

disable, in response to finding the essential indicative element, the plurality of stream operators.

3. The computer program product of claim 1 , wherein the transmit a passthru command includes:

determine whether a passthru feature is enabled; and

disable, in response to the passthru feature not being enabled, the plurality of stream operators.

4. The computer program product of claim 1 , wherein select the passthru command includes:

select, in response to a presence of a default passthru method, the passthru command that corresponds to the default passthru method.

5. The computer program product of claim 1 , wherein select the passthru command further includes:

associate a selected passthru command with a default passthru method.

6. The computer program product of claim 1 , wherein the passthru command is selected from writing a reference attribute, passing the tuple through the stream operator, and forming a dummy stream operator.

7. A system for processing a stream of tuples, each tuple having one or more attributes, comprising:

one or more processing elements operating on one or more computer processors configured to processes the attributes from the stream of tuples;

a stream manager configured to alter a portion of attribute processing for an indicative element in response to the processing element receiving a passthru command, further comprising:

a stream operator monitor configured to detect the indicative element from a plurality of stream operators in the one or more processing elements;

a passthru manager configured to transmit the passthru command in response to detecting the indicative element, wherein the stream manager is configured to transmit a passthru command by:

determining a performance factor of the passthru command on the processing element;

determining a threshold based on resources of a computing system; and

selecting, in response to the performance factor falling within the threshold, the passthru command.

8. The system of claim 7 , the stream manager further comprising:

a selection interface configured to present to a user, in response to detecting the indicative element, a plurality of passthru methods that are associated with passthru commands for selection.

Assignments (2)
ASSIGNMENT OF ASSIGNOR'S INTEREST Recorded Jan 15, 2021
From: INTERNATIONAL BUSINESS MACHINES CORPORATION
To: AIRBNB, INC.
Reel/Frame 056427/0193 →
ASSIGNMENT OF ASSIGNOR'S INTEREST Recorded Jun 24, 2015
From: BRANSON, MICHAEL J.; COBB, BRADFORD L.; SANTOSUOSSO, JOHN M.
To: INTERNATIONAL BUSINESS MACHINES CORPORATION
Reel/Frame 035896/0788 →