IP Library › Granted Patent US 12699746
Granted Patent B2
US 12699746 · App. 17/549,285 · Granted Aug 4, 2026

Custom publisher system integration

Inventors: Calvin Casalino (New York, NY); Edward Riker (Brooklyn, NY)
Assignee: Yext, Inc.
G06F16/958G06F16/212G06F16/9024
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 12699746
App. No.
17/549,285
Filed
Dec 13, 2021
Granted
Aug 4, 2026
Kind
B2
Art Unit
2164
USPC
707/736
Abstract

A system and method to identify a first data stream from a data graph associated with a merchant system. A configuration file associated with a publisher system to receive data associated with the merchant system is identified. Based on a configuration file associated with the publisher system, a second data stream is generated which includes the data associated with the merchant system. The second data stream is transmitted to the publisher system.

Claims (34)

1 . A method comprising:

identifying a first data stream of a first entity type from a knowledge graph associated with a merchant system, wherein the knowledge graph stores merchant data of one or more entity types that are interlinked with each other, and wherein the first data stream is configured in accordance with a first schema;

installing a configuration file comprising a first set of configuration parameters associated with the merchant system and a publisher system, wherein the publisher system is created based on the configuration file, wherein the configuration file specifies one or more mappings from a head entity in the knowledge graph associated with the merchant system to the publisher system, and a destination endpoint for the publisher system;

transforming, by a processor in real-time, based on the configuration file associated with the publisher system, the first data stream into a second data stream comprising data associated with the merchant system, wherein the transforming comprises applying a same function to each data record of a plurality of data records in the first data stream, such that the transforming is parallelized for the plurality of data records in the first data stream, wherein a second schema of the second data stream is configured in accordance with the first set of configuration parameters to enable ingestion of the data associated with the merchant system by the publisher system; and

transmitting the second data stream to the publisher system, wherein at least a portion of the data associated with the merchant system is published by the publisher system to an end-user system.

2 . The method of claim 1 , wherein the configuration file comprises a configuration-as-code (CaC) file.

3 . The method of claim 2 , wherein the CaC file comprises the set of configuration parameters defining the second schema associated with the second data stream.

4 . The method of claim 1 , wherein one or more fields of the data associated with the merchant system are transformed from the first schema of the first data stream to the second schema of the second data stream.

5 . The method of claim 1 , wherein the transforming comprises mapping a first data field of the first data stream to a second data field of the second data stream in accordance with the configuration file.

6 . The method of claim 1 , wherein the second data stream is transmitted to the publisher system via one of a file transfer, an application programming interface (API) call, or a plug-in program.

7 . The method of claim 1 , wherein one or more sets of data of the first data stream are identified for inclusion in the second data stream based on the configuration file.

8 . A system comprising:

a memory to store instructions; and

a processing device, operatively coupled to the memory, to execute the instructions to perform operations comprising:

identifying a first data stream of a first entity type from a knowledge graph associated with a merchant system, wherein the knowledge graph stores merchant data of one or more entity types that are interlinked with each other, and wherein the first data stream is configured in accordance with a first schema;

installing a configuration file comprising a first set of configuration parameters associated with the merchant system and a publisher system, wherein the publisher system is created based on the configuration file, wherein the configuration file specifies one or more mappings from a head entity in the knowledge graph associated with the merchant system to the publisher system, and a destination endpoint for the publisher system;

transforming in real-time, based on the configuration file associated with the publisher system, the first data stream into a second data stream comprising data associated with the merchant system, wherein the transforming comprises applying a same function to each data record of a plurality of data records in the first data stream, such that the transforming is parallelized for the plurality of data records in the first data stream, wherein a second schema of the second data stream is configured in accordance with the first set of configuration parameters to enable ingestion of the data associated with the merchant system by the publisher system; and

transmitting the second data stream to the publisher system, wherein at least a portion of the data associated with the merchant system is published by the publisher system to an end-user system.

9 . The system of claim 8 , wherein the configuration file comprises a configuration-as-code (CaC) file.

10 . The system of claim 9 , wherein the CaC file comprises the set of configuration parameters defining the second schema associated with the second data stream.

11 . The system of claim 8 , wherein one or more fields of the data associated with the merchant system are transformed from the first schema of the first data stream to the second schema of the second data stream.

12 . The system of claim 8 , wherein the transforming comprises mapping a first data field of the first data stream to a second data field of the second data stream in accordance with the configuration file.

13 . The system of claim 8 , wherein one or more sets of data of the first data stream are identified for inclusion in the second data stream based on the configuration file.

14 . A non-transitory computer readable storage medium comprising instructions that, when executed by a processing device, cause the processing device to perform operations comprising:

identifying a first data stream of a first entity type from a knowledge graph associated with a merchant system, wherein the knowledge graph stores merchant data of one or more entity types that are interlinked with each other, and wherein the first data stream is configured in accordance with a first schema;

installing a configuration file comprising a first set of configuration parameters associated with the merchant system and a publisher system, wherein the publisher system is created based on the configuration file, wherein the configuration file specifies one or more mappings from a head entity in the knowledge graph associated with the merchant system to the publisher system, and a destination endpoint for the publisher system;

transforming in real-time, based on the configuration file associated with the publisher system, the first data stream into a second data stream comprising data associated with the merchant system, wherein the transforming comprises applying a same function to each data record of a plurality of data records in the first data stream, such that the transforming is parallelized for the plurality of data records in the first data stream, wherein a second schema of the second data stream is configured in accordance with the first set of configuration parameters to enable ingestion of the data associated with the merchant system by the publisher system; and

transmitting the second data stream to the publisher system, wherein at least a portion of the data associated with the merchant system is published by the publisher system to an end-user system.

15 . The non-transitory computer readable storage medium of claim 14 , wherein the configuration file comprises a configuration-as-code (CaC) file.

16 . The non-transitory computer readable storage medium of claim 15 , wherein the CaC file comprises the set of configuration parameters defining the second schema associated with the second data stream.

17 . The non-transitory computer readable storage medium of claim 14 , wherein one or more fields of the data associated with the merchant system are transformed from the first schema of the first data stream to the second schema of the second data stream.

18 . The non-transitory computer readable storage medium of claim 14 , wherein the transforming comprises mapping a first data field of the first data stream to a second data field of the second data stream in accordance with the configuration file.

19 . The non-transitory computer readable storage medium of claim 14 , wherein one or more sets of data of the first data stream are identified for inclusion in the second data stream based on the configuration file.

20 . The method of claim 1 , wherein the knowledge graph is generated solely based on the merchant system.