DETAILED ACTION
Notice of Pre-AIA or AIA Status
The present application, filed on or after March 16, 2013, is being examined under the first inventor to file provisions of the AIA .
Priority
The Instant Application, filed 05/07/2024, claims foreign priority to 202410471741.1, filed 04/18/2024. Receipt is acknowledged of certified copies of papers required by 37 CFR 1.55.
Claim Rejections - 35 USC § 103
In the event the determination of the status of the application as subject to AIA 35 U.S.C. 102 and 103 (or as subject to pre-AIA 35 U.S.C. 102 and 103) is incorrect, any correction of the statutory basis (i.e., changing from AIA to pre-AIA ) for the rejection will not be considered a new ground of rejection if the prior art relied upon, and the rationale supporting the rejection, would be the same under either status.
The following is a quotation of 35 U.S.C. 103 which forms the basis for all obviousness rejections set forth in this Office action:
A patent for a claimed invention may not be obtained, notwithstanding that the claimed invention is not identically disclosed as set forth in section 102, if the differences between the claimed invention and the prior art are such that the claimed invention as a whole would have been obvious before the effective filing date of the claimed invention to a person having ordinary skill in the art to which the claimed invention pertains. Patentability shall not be negated by the manner in which the invention was made.
Claim(s) 1-20 are rejected under 35 U.S.C. 103 as being unpatentable over Ferstay et al. (2021/0149751).
As per claim 1, Ferstay et al. teaches a method for managing storage of data in a streaming search system, the method comprising: obtaining a payload for storage;
identifying a routing key for the payload [paragraphs 0251-0253];
adding the payload to a data stream of multiple data streams serviced by index workers [paragraphs 0251-0253];
once the payload has reached a head of the stream, routing the payload [paragraphs 0121 and 0124-0128];
once the payload has reached a head of the queue of the first set of queues, partially processing the payload by an indexing thread associated with the queue to add the partially processed payload [paragraphs 0211-0212]; and
But Ferstay et al., in the same embodiment, fails to explicitly teach routing the payload from the data stream to a queue of a first set of queues based on the routing key; adding the processed payload to a queue of a second set of queues based on the routing key; once the partially processed payload has reached a head of the queue of the second set of queues, updating a shard associated with the queue of the second set of queues.
However, in a different embodiment Ferstay et al. teaches routing the payload [message] from the data stream to a queue of a first set of queues based on the routing key [marker] [paragraphs 0313-0314]; adding the processed payload [message] to a queue of a second set of queues based on the routing key [marker] [paragraphs 0320-0323 and fig. 23];
once the partially processed payload has reached a head of the queue of the second set of queues, updating a shard associated with the queue of the second set of queues [paragraphs 0324-0328].
It would have been obvious to one of ordinary skill in the art before the effective filing date of the claimed invention to combine the teachings of Ferstay et al. in order to provide efficient message queuing services to facilitate acknowledging individual messages in connection with, or on top of, a streaming data processing system [paragraph 0317].
As per claim 2, Ferstay et al. teaches the method of claim 1, wherein the streaming search system comprises a plurality of shards comprising the shard, and the streaming search system is configured to provide search results using the plurality of shards [paragraph 0087].
As per claim 3, Ferstay et al. the method of claim 1, wherein the routing key is added along with the payload to the data stream [paragraph 0103].
As per claim 4, Ferstay et al. the method of claim 1, wherein the data stream comprises payloads from endpoint devices that are to be stored in a searchable format [paragraph 0124].
As per claim 5, Ferstay et al. the method of claim 2, wherein the payload comprises data having a temporal ordering with data from other payloads in the data stream [paragraph 0150].
As per claim 6, Ferstay et al. the method of claim 1, wherein the payload is added to the data stream based on the routing key, and other payloads that are also associated with the routing key are added to the data stream to ensure that temporal ordering between the payload and the other payloads is maintained in the data stream [paragraph 0173].
As per claim 7, Ferstay et al. the method of claim 1, further comprising: after adding the payload to the data stream: adding a checkpoint to the stream [paragraph 0195].
As per claim 8, Ferstay et al. the method of claim 1, wherein the shard is associated with the routing key, and all payloads associated with the routing key are used to update the shard to retain temporal ordering between the payloads [paragraph 0212].
As per claim 9, Ferstay et al. the method of claim 8, wherein each of the payloads is associated with a corresponding event for a data structure, and each of the payloads is usable to update the data structure so long as each of the payloads is used in a same temporal order of the corresponding events [paragraph 0235].
As per claim 10, Ferstay et al. the method of claim 1, wherein updating the shard comprises: processing, by a first entity that exclusively manages the shard, the payload from the queue of the second set of queues [paragraph 0258].
As per claim 11, Ferstay et al. the method of claim 10, wherein routing the payload comprises: hashing the routing key to make an identification of the queue of the first set of queues; and adding the payload to the queue of the first set of queues based on the identification of the queue [paragraph 0201].
As per claim 12, Ferstay et al. the method of claim 1, further comprising: after updating the shard: updating a cache for the shard to indicate that the payload from the queue of the second set of queues has been processed [paragraph 0156].
As per claim 13 Ferstay et al. the method of claim 12, wherein updating the shard comprises: making a determination regarding whether the shard has been updated based on the payload using the cache; and in a first instance of the determination where the shard has not been updated based on the payload: adding information to the shard to update the shard; in a second instance of the determination where the shard has been updated based on the payload: retaining existing content of the shard to update the shard [paragraph 0167-0170].
Claims 14-20 have similar limitations as to the rejected claims above therefore they are being rejected under the same rationale.
There are prior art made of record not relied upon but is considered pertinent to applicant's disclosure. See attached.
Conclusion
Any inquiry concerning this communication or earlier communications from the examiner should be directed to RANODHI N SERRAO whose telephone number is (571)272-7967. The examiner can normally be reached Monday to Friday 8:00 am to 4:00 pm.
Examiner interviews are available via telephone, in-person, and video conferencing using a USPTO supplied web-based collaboration tool. To schedule an interview, applicant is encouraged to use the USPTO Automated Interview Request (AIR) at http://www.uspto.gov/interviewpractice.
If attempts to reach the examiner by telephone are unsuccessful, the examiner’s supervisor, John Follansbee can be reached on (571) 272-3964. The fax phone number for the organization where this application or proceeding is assigned is 571-273-8300.
Information regarding the status of published or unpublished applications may be obtained from Patent Center. Unpublished application information in Patent Center is available to registered users. To file and manage patent submissions in Patent Center, visit: https://patentcenter.uspto.gov. Visit https://www.uspto.gov/patents/apply/patent-center for more information about Patent Center and https://www.uspto.gov/patents/docx for information about filing in DOCX format. For additional questions, contact the Electronic Business Center (EBC) at 866-217-9197 (toll-free). If you would like assistance from a USPTO Customer Service Representative, call 800-786-9199 (IN USA OR CANADA) or 571-272-1000.
Ranodhi N. Serrao
/RANODHI SERRAO/
Primary Examiner, Art Unit 2444