and a Storage Device

BACKGROUND OOOI3 Many applications analyze streaming data from sensors, mobile devices, social rnedia, etc. for analysis and/or processing. For example, such data may be used to ascertain business intelligence, statistics, etc. Often times, most recently received data is the most frequently demanded as it may provide the most up-to-date information.

BRIEF DESCRIPTION OF THE DRAWINGS

[0002] FIG. 1 is a block diagram of an example processor system including an example event pipe manager implemented In accordance with the teachings of this disclosure.

[00033 FIG . 2 illustrates an example event pipe manager that may be used to implement the event pipe manager of FIG, 1 ,

|0004] FIG. 3 i an example data flow diagram illustrating n an example flow of data managed by the event pipe manager of FIGS, 1 and/or 2.

|0O0S3 FIG. 4 is a flowchart representative of example machine readable instructions that may he executed to Implement the example event pipe manager of FIGS. 1 and/o 2 to retrieve and/or provide event data,

[OOOSJ F IG, 5 Is a flowchart representative of other example machine readable instructions that may he executed to implement the example event pipe manager of FIGS. 1 and/or 2 to retrieve and/or provide event data. [OO07JF1G. 6 is a flowchart representative of example machine readable instructions that may be executed to implement the example event pipe manager of FIGS. 1 and/or 2 to analyze received data,

DETAILED DESCRIPTION:

[0008] Example methods, apparatus, and articles of manufacture are disclosed herein for a cache event manager. Examples disclosed herein involve managing receipt, analysis, and access to event data using event pipes In a cache and corresponding data tables in main memory, Examples disclosed herein enable access to event data buffered in a cache to enable access to most recently received event data in real-time. Accordingly, instant or near instant access is available to data received at a system befo e the data is written to main memory of the system using the examples disclosed herein,

00093 A central processing unit (CPU) cache locally stores data from a main memory (e.g., a volatile memory device, a non-volatile memory device, etc.). In some examples, a cache is used in a processor platform to increase speed of data operations because storing data to a cache is faster than writing data to main memory. Accordingly, a cache may act as a buffer for received data to allow time for the CPU and/or a memory controller to write tie received data to main memory. For example, a central processing unit (CPU) of a processor platform stores received/retrieved data (e.g. , event data

representative of real-time messages, real-time events, real-time social media messages, etc) from a device and/or network in communication with the processor platform and stores the received data in the cache (e.g., in an event pipe, etc.) until the data is written by the CPU and/or memory controller to the main memory,

[00101 In some examples, data in a cache line or cache pipe is written to main memory on an individual basis (e,g„ based on first-ln first-out {FIFO}, a priority basis, etc,} as soon as the CPU and/or memory controller is available to write a c ch line to the main memory, In some examples, the CPU and/or memory controller perform(s) bulk inserts, which, as used herein, involve periodically or aperiodical!y writing all d&is from the cache to main memory. Accordingly, in such examples, a time delay exists between when data is received at the processor platform and when the data ma be accessible for retrieval from main memory,

[0011| Continuously collected event data can provide advantages for gaining business intelligence throug analysis of the events represented by the event data. In many instances, most recently received data (e.g., approximately the most recently received 1% of data) can be the most frequently (e.g.,

approximately 99% of the time) demanded data. Accordingly, having the ability to access most recently received event data from a cache and/or corresponding event data In storage device or database can be advantageous in providing the most accurate analytics and analysis of the corresponding events,

0012 An example method disclosed herein Includes, in response to receiving a request to retrieve data received at a server, retrieving firs data from a cache and retrieving second data from a storage device, in which the first data was received during a first time period and the second data was received during a second time period prior to the first time period. Further the example method includes providing the first data and the second data as combined data based on the first time period and the second time period. In some examples, an example event pipe stores the first data in the cache and an example data table stores the second data in the storage device (e.g. _; a database, main memory, etc.). Examples disclosed herein Involve identifying a schema associated with event data and generating a pipe scan function corresponding to the first event pipe based on th schema to enable access to and/or retrieve data from an event pipe of a cache.

013]An example apparatus disclosed herein includes an event analyzer to sort event data received at a server into a corresponding event pipe in a cache associated with the server. Further the apparatus includes a data retriever to retrieve cached event data from the event pipe and stored event data from a data table of a non-volatile memory associated with the server, in which the data tabl corresponds to the event pipe based on a schema of the cached event data and the stored event data. The example data retriever may combine the cached event data and stored event data to create combined event data and an example evert pipe interface of the example apparatus may provide the combined event data in response !o the request lor the event data.

00143 Examples disclosed herein involve buffering event data in an event pipe of a cache thai is identified by an event pipe and shifting the event data from the event pipe to a data table of a storage devic after the event data is buffered in the cache for a period of time . Some examples further involve buffering the retrieved second data from the cache and th data stored in the data table and providing the data and the second data as combined data.

£001 $3 As used herein, "event data" is representative of data associated with events (e.g., social media posts, sensor data, data from mobile devices, etc.) from a received data stream or flow of data, "pipe data" includes event data that is stored in an event pipe of a cache, and "ta le data" includes event data that is stored In a data table (e,g, _; a database) of main memory. As used herein, a pipe or event pipe Is a designated data structure (e.g., a queue, buffer, cache line, etc.) of a cache that stores, at leas temporarily, data and/or event data. Example event data, example pipe data, and/or example table data may include data from a plurality of events. For example an event pipe may include event data identifying several social media posts, sensor measurements, etc,

£00163 FIG. ^ & a block diagram of an example processor system 100 including an example event pipe manager 110 Implemented in accordance with the teachings of this disclosure. ^" The processor system TOO may be a server (e.g,, a web service server), a computer, or any other type of computing device. The processor system 100 also includes a cache 120, a processor core 130 (or a central processing unit (CPU)}, a memory controller 132, a volatile memory 140, and a nonvolatile memor 150. In the illustrated example of FIG. 1 , a memory bus 170 facilitates communication between the cache 120, the memory controller 132, the volatil memory 140, and the nonvolatile memory 150. The processor core 130 of the illustrated example of FIG. 1 is hardware. For example, the processor core 130 can be implemented by at least one of integrated circuits, logic circuits, microprocessors or controllers from any desired family or manufacturer. [0017J The volatile memory 140 of the illustrated example of FIG. 1 is any volatile memory storage device thai stores data when powered, but loses memory state when power is removed. For example, the volatile memory 140 may be implemented by Synchronous Dynamic Random Access Memory (SDRAM), Dynamic Random Access Memory (ORA ), Static Random Access Memory (SRAM), RAMBUS Dynamic Random Access Memory (RDRAM) and/or any other type of volatile memory. The non-volatile memory 150 of FIG. 1 is any non-volatile memory storage device (e.g., phase-change memory, memristor memory, flash memory, etc) that is capable of storing data when powered and when not powered.

[0018] The example cache 120 in FIG, 1 is a local storage circuit that may be collocated on a same device 175 (e.g., a semiconductor ch p) as the processor core 130, the memory controller 132, and/or the event pipe manager 110, In the illustrated example of FIG, 1 _s the processor core 130 can perform faster read and/or write operations when accessing data in the cache 120 than when accessing data In th volatile memory 140 and or in the non-volatile memory 150 via the memory bus 170. Accordingly, the event pipe manager 1 0, the processor core 130, and/or the memory controller 132 may load data received at the processor platform 100 into the cache 120 so tha the processor core 130 can access and/or process the received data relatively quickly using the cache 120, in some examples, the cache 120 acts as a buffer to temporarily store data (e.g., event data) received at the processor platform 100 prior to the data being stored in main memory {e.g. , see FIG, 3).

[001$] The event pipe manager 110 in the illustrated example of FIG, 1 manages event data received at the processor platform 100. As used herein, event data is data (e.g. , streamed data, social media posts, senso data, device data, etc) that is stored and/or buffered in event pipes 1 2 as pipe data in the cache 120 and/o is stored in corresponding data tables as table data in main memory (e.g., the volatile memory 140 and/or the non-volatile memory 150). The example cache 120 ma be comprised partially or entirely of event pipes 122. In some examples, the event pipe manager 110 may be Implemented via the memory controller 132 and/or managed by the memory controller 132, The event pipe manager 110 and/or the memory controlter 132 of the illustrated e am le of FIG, 1 may Implement different techniques to determine a duration that data remains in the cache 20. For example, the event pipe manager 110 may manag the length of time (e.g., a threshold period of time, such as five minutes, 10 minutes, etc) that data in the event pipes 122 remai in the corresponding event pipes 122, In some examples, the event pipe manager 110 and/or the memory controller 132 htefs) data (e.g., copies data) from the cache 120 (e.g.,. from an event pipe 122) to the volatile memory 140 and/or the nonvolatile memor ISO before the data is removed from the cache 120, For example, the event pipe manager 0 may copy event data from a event pipe 122 to a corresponding data table of the non-volatile memory 150 after the event data Is buffered in the cache 120 for first period of time e,g,, 1 minute), in such an example, the event pipe manager 110 may then remove the event data from the event pipe 1 2 after feeing buffered for a second period of time (e.g., 5 minutes). Accordingly, in this example, multiple nstances of the event data exist in both the event pipe 122 of the cache 120 and a corresponding data table of the non-volatile memory 150..

[0020] The example cache 1 0 of FIG, 1 includes N event pipes 122. Each event pi s 122 includes an example schema ($») 126 (where 1 identifies a particular event pipe 122} and example pipe dat ; 1 8, As used herein for readability, example event pipei 122 has a schema Si 126 and pipe data? 128. example event i es 122 has a schema Ss 126 and pipe dafas 1 8, and so on. An example ttmestamp may be included with the pipe data* 1 8 to indicate a time that the corresponding pipe data;: 128 was received (e.g., by the processor system 100, event pipe manager 110., memory controller 132, etc) and/or stored in the cache 120. The schema & 126 of FIG. 1 may he an identifier (e,g, _; an indicator identifying a characteristic such as a name, user name, account, format, protocol, address, etc) corresponding to the pipe data, 1 S. in the illustrated example, the event pipe manager 110 manages the event data cached {buffered} in each event pipes 122 based on the schema ¾ 12 and/or timestamps corresponding to the pipe datai 128, as described herein, f or example, event data having schema Srmay e loaded Into corresponding event pipei 122 in a queue (i.e., chronologically),

00211 The example event pipes 122 store event datas 128 for a corresponding flow of data (e.g., streaming data) having a schema Ss 128, For ex mple, a first event pipei 122 ma correspond to a social network feed of a particular user, group, category, etc. (e.g., "tweets" from a Twitter® account, posts from a Pacehook® account, etc). In such an example, the schema Si 128 may represent at least one of a username, a social network type, a message format, etc. of the social network feed and the pipe data ? 128 may be the data contents (e.g., text data, Image data, video data, audio data, etc.) of the social network feed. In some examples, the event data may be data streamed from sensors or other devices that provide information for analytics, intelligence, etc,

|O022| As disclosed herein, the event pipe manager 110 of FIG, 1 may be implemented via hardware, software, and/or firmware . The example event pipe manager 110 controls and/or performs operations (e.g., read and write) using event data (e.g.., pipe data. 126) that is stored in the event pipes 122 and/or data tables in main memory (e.g., as table data in the nonvolatile memory 140 and/or non-volatile memor ISO) in accordance with this disclosure, More specifically, examples disclosed herein enable the event pipe manager 110 to retrieve data from the event pipes 1 2 and/or analyze data to be stored in the event pipes 122.

The example processor platform 100 of the illustrated example of FIG. 1 further includes an interface circuit 180. The interface circuit 180 may he implemented by any type of interface standard, such as an Ethernet interface, a universal serial bus (USB), and/or a Peripheral Component interconnect (PCI) express interface.

[00243 In the illustrated example of FIG. 1 , at least one input device(s) 182 Is(are) connected to the interface circuit 80, The input device(s) 182 permit(s) a user to enter data and/or command into the processor core 130. As described herein, a user may request event dat from the cach and/or main memory via the input devlce(s) 182, The input deviee(s) 182 can be

implemented by, for example, an audio sensor, a microphone, a camera (still or video), a keyboard, a button, a mouse, a touchscreen, a track-pad, trackball, ISO-point and/or a voice recognition system,

{002SJ At least one output device{s) 184 Is(are) aiso connected to the interface circuit 180 of the illustrated example. The output devices 184 can; be Implemented, for example, b display devices (e.g., a Sight, emitting diode (LED), an organic Sight emitting diode (OL D), a liquid crystal display, a cathode ray tube display (CRT), a touchscreen, a tactile output device, a light emitting diode (LED), a printer and/or speakers). The interface circuit 180 of the illustrated example, thus, typically includes a graphics driver card, a graphics driver chip or a graphics driver processor.

[0026] The interface circuit 180 of the illustrated example also includes a communication device such as a transmitter, a receiver, a transceiver, a modem and/or network interfac card to facilitate exchange of data wit external machines (e.g., computing devices of any kind) via a network 186 (e.g., an Ethernet connection, a digital subscriber line (DSL), a telephone line, coaxial cable, a cellular telephone system, etc.).

0 2?]The processor platform 100 of the illustrated example also includes at least one mass storage device 80 for storing software and/or data.

Examples of such mass storage devices 190 include floppy disk drives, hard drive disks, compact disk drives,. Blu-ray€> disk drives, RAID systems, and digital versatile disk (DVD) drives. In some examples, the mass storage devices 190 may be implemented using the non-volatile memory 150,

100281 FIG. 2: illustrates an example event pipe manager 110 that may he used to implement the event pipe manager 110 of FIG. 1 , The event pipe manager 110 includes an event analyzer 210 having a sorter 212 and a schema definer 214. The example event pipe manager 110 further Includes an example event pipe interface 220, an example timestamper 230, an example event cache writer 240, and an example data retriever 250. The data retriever 250 Includes an example pipe scanner 252, an example table scanner 254, and an example data combiner 256. In the illustrated example of FIG. 2, a communication bus 280 facilitates communication between the event analyzer 210, the event pipe interface 220 _» the timestamper 230, the event cache writer 240, and the dat retriever 250.

00291 The ©v nt pipe manager 110 of the illustrated example of FIG, 2 analyzes data to/from and/or through the example processor platform 100 of FIG, 1. When event data is received at the example processor platform 100, such as from the network 186, the example sorter 212 of the event pipe analyzer 210 identifies a schema (e.g., using information in a packet header, such as metadata, name, format, protocol etc.) of the event data and determines a corresponding event pipe 122 in the cache 1 0 to which the event data is to be cached. The example sorter 212 forwards the event data to the cache 1 0 to be cached and/or buffered In the determined event pipe 122,

|003OJAs described herein, example schema ¾ (e.g., schema Si , ¾ ... SH 1 6} may b defined and/or Identified based on user preferences and/or settings. For example, a user may specify at least one characteristic's} of event data tha Is(are) to be used to define and-'or Identify schama Si of the event data. Example characteristics of the data include data profile information (e.g., user name, user demographics, metadata, etc.) and/or data type (e.g., data format, data protocol, etc.). In some examples, when event data is received, the event analyzer 210 instructs the schema deflner 214 to generate a schema

corresponding to the event data. The schema definer 214 forwards the generated schema ¾ to the cache 120 to create a new event pipe 122, to the pipe scanner 252 to generate a new pipe sca function (e.g., a user defined function (UDF)}, and to main memory (e.g., the main memory 320 of FIG. 3} to generate a new dat table (see FIG, 3 . Accordingly, a new event pipe 122, pipe scan function, and data table are generated for data having the same schema.

|003tjln some examples, the sorter 212 of FIG. 2 Identifies a schema S; of the event data and sorts the event data into the corresponding event pipes 122 based on the schema ¾. In some examples, when the sorter 2 2 does not identify a particular schema S««w of the event data corresponding to an event pipe 122 in the cache 120, the sorter 212 loads the data into a new event 1 0 that is created based on the schema S;m. [00323 The exam le event pipe interface 220 of FIG. 2. which may be implemented by an application programming interface (API), enables user control and/or communication (e.g., via the Interface 180 of FIG. } with the event pipe manager 1 0 of FIG, 2. As described herein, the event pipe interface 220 receives user requests for event data (e.g., structured query language (SQL) queries from the input device(s) 182} in the cache 120 and/or main memory of the processor system 100. The pip interface 220 forwards such requests to the data retriever 250. The p pe interface 220 provides the corresponding event data to the user (e.g.. via the output device{$) 134) upon receipt from the data retriever 250, In some examples, the event pipe interface 220 may be implemented via the interface circuit 180, the input device(s) 182 _» and/or the output deviee(s) 84.

[00 33 The example time stamper 230 fimestamps received event data. For example, the timestsamper 230 may timestamp the event data based on when the even data is received at the processor platform 10, based on when the event data is analyzed by the event pipe manager 10, and/or based on when the event data is stored in an event i es 122 of the cache 120. in some examples, timing Information is included in the event data indicating a time of an event corresponding to the event data (e,g,, when the event was created, posted to an account, etc). In such examples, the imestamper 230 may timestam the event data with the corresponding time indicated in the timing information. As described herein, the data retriever 250 refers to the timestamp to identify data received and/or created during a designated time period (e.g., a time period specified in user request for data),

|O034JT e event cache write 240 of the illustrated example of FIG. 2 writes event data from the cache 12:0 to corresponding event tables in main memory. As illustrated in the data flow 300 of FIG. 3, event data Is stored in corresponding event pipes of the cache 120 and pipe data* 128 from the event pipes 122 is forwarded to corresponding data tables 322 (e.g., databases) in main memory 320, The example main memory 320 may be implemented at least one of the volatile memory 140, the non-volatile memory 150, and/or the mass storage 190 of FIG. 1. The example cache writer 240 writes (e.g., writes a copy) and/or shifts (e.g., writes a copy and removes) the pipe data* 128 from an event pipe; 122 of the cache 120 to a corresponding data table, 322 of the main memory 320 based on the schema ¾ to be stored as table data* 328. in other words, in the illustrated example of FIG. 3 _< the cache event writer 240 identifies the schema ¾ of the event pipe, 122 and/or pipe data 123 and stores (e.g., writes, shifts, etc.) the pipe data? 128 Irs the data table; 322 having th same schem S;to create the table data 128.

[003$] In some examples, the event cache writer 240 of FIG. 2 performs a bulk insert and writes all or a portion of the event data 128 from the event pipes 122 of the cache to the corresponding data tables 322 in the main memory 320, in some examples, the event cache writer 240 derives a SQL insert from the s hema defined by the schema define 214 to perform the bulk insert. For example, the event cache writer 240 may write pipe data 128 periodically (e.g., every 5 minutes, every minute, etc) or when an amount of event data 128 stored in the cache 120 reaches a threshold (e.g., a percentage capacity of the cache 1 0). in som examples, the event cache writer 240 may write event data 128 from each event pipe; 1 2 at different rates. For example, the event cache writer 240 may write first pipe data? 128 from the first event pipe? 122 to a corresponding data tablet 322 in the main memory 320 every minute and write second pipe dataj 128 from a second event pipea 122 to a corresponding data tahie-i i the main memory 320 every two minutes.

[06363 ^ ⁿ some examples, the event cache writer 240 monitors

corresponding settings for each pipes 1 2 in the cache 120, Such example settings may include granule (e,g,, 1 minute), start-time, end»¾me (e.g., the most recent time timestamp), etc. of a class of the event i e! 122, In some examples, the event data is written to the main memory after a first period of time (e g . 1 minute) and removed from the cache 120 after a second period of time (e,g„ 5 minutes), in other words, pipe data 1 8 from an event pipe Is copied to the main memory 320 before the pipe data 128 is removed from the cache 1 0,. Accordingly, multiple Instances of the event data of an event pipe; 122 may exist in an event pipe. 122 of the cache 120 and a corresponding data tables 322 of the main memory 320. The event cache writer 240 then writes o shifts the pipe data to the main memory 320 based on the settings for each individual pipe 122.

003?3 in response to data requests received via the event pipe interface 220, the example data retriever 250 of FIG. 2 retrieves and provides

corresponding event data to the event pipe interface (e.g., for presentation to a user). For example, a request fo data retrieval may identify a schema ¾, characteristic of a schema Si and/or a period of time associated with the data having the schema ¾. in some examples, the period of time may include a most ^' recent period of time (e.g., the minute,, the last 5 minutes, the last hour, the last 8 hours, etc.). In such examples, the data retriever 250 is capable of retrieving data from the cache 120 in addition to the main memory 320.

[00383 The example data retriever 250 uses the pipe scanner 252 to retrieve data from data pipes 122 in the cache 120, The example pipe scanner 252 uses schema information from the schema definer 214 to generate a pipe scan function; (e.g., a UDF) from the schema ¾ for a corresponding event i e; 122. The example pipe scan function retrieves event data from the

corresponding event pipe 122. in some examples, the pip scan function acts as a web service and retrieves the event data using a hypertext transfer protocol (HTTP). Accordingly, using the event pipe interface 220 (e.g., an application programming interface), a user, via the pipe scan function, is able to access (e.g., request receive event data) the event pipes 22 of the cache 120.

[00393 The ^ ^a retriever 250 of the illustrated example of FIG, 2 uses the table scanner 264 to access table data 328 from the main memory 320. The example table scanner 254 retrieves data from the data tables 322 having a schema Ss corresponding to the schema of the event pipes 122 from the data tables 322. using any suitable data retrieval techniques for accessing data from a database, storage device, etc.

[004-03 The example data combiner 256 of FIG. 2 combines event data retrieved from an event ipes 22 by the pipe scanner 252 and event data retrieved from a corresponding data tables 322 by the table scanner 254. in some examples, the data combiner 258 compares pipe data* 128 retrieved from an event pi es 1 2 and table data 328 retrieved from a data fable;: 322 to determine whether there is an overlap In the event data. In other words, the data combiner 256 determines whether pipe data* 128 from the event pi e; 122 matches table data 328 from the data table; 322. The data combiner 256 accounts for the overlap by providing the data as combined data. The example combined data only includes one instance of the overlap data (I.e., multiple copies of matching data is not provided). In other words, the example data combiner 258 determines a logical union of the event data in the pipe data* 122 and the table data; 128. Accordingly, the example data combiner 258 may combine data from the event pipes 122 and the data ta les 322 to present a block of event data having a schema ¾ that was received during a period of time that include a most recent period of time. In such examples, the example event pipe manager 110 is capable of providing real-time data by having the ability to access the cache 120 and/or the main memory 320 to retrieve event data in response to a request for event data that was received during a period of time that includes a most recent period of time.

|0041] in the illustrated example of FIG. 2, the example event pipe interface 220 receive event data from the event pipes 122 and/or data tables 322. The example event data may be received as combined data (e.g.. a union of data) having a given schema Si from both an event pipe 122 and the corresponding data tables 322 based on a request from a user for event data received during a time period that is longer than the time period that data is stored in the cache 120, in some examples, if the time period identified in a request for data is less than a time period during which event dat is stored i the cache 120, the example data my only be data from an event pipe 122, The example event pipe interface 220 provides the requested data (e.g., as

combined data, as a union of the pipe data* 12.8 and the table dates 328, etc ) to the user; for example using the output device(s} 184 of FIG. 1. Accordingly, in response to a user requesting data having an identified schema Si, the example event pipe manager 10 can retrieve the corresponding data from both the event pipe 122 and/or data ables 322 and provide the example data to the user via the even pi e interface 220. [0042} While an example manner of implementing the event pipe manager 110 of FIG. 1 is illustrated in FIG. 2, at least one of the elements, processes and/or devices illustrated in FIG. 2 may be combined, divided, rearranged, omitted, eliminated and/or implemented in any other way. Further, the example event analyzer, including the example sorter 212 and/or the example schema definer 214, the example event pipe interface 220, the example iimestampe 230, the example event cache writer 240, the example data retriever 250, including the example pipe scanner 262, the example table scanner 254, and/or the example data combiner 256, and/or, more generally, the example event pipe manager 1 10 of FIG, 2 may be Implemented by hardware, software, firmware and/or any combination of hardware, software and/or firmware, Thus, for example, any of the example event analyzer, including the example sorter 212 and/or the example schema definer 214, the example event pipe interface 220, the example imesfamper 230, the example event cache writer 240, the example data retriever 250, including the example pipe scanner 252, the example table scanner 254, and/or the example data combiner 258, and/or, more generally, the example event pipe manager 110 could he

Implemented by at least one analog or digital circuit^), logic eircuifs), programmable processors), application specific integrated circuit(s) (AS!Cfs)}, programmable logic device(s) (PLP{$)} and/or field programmable logic devicefs) {FPLDCs} . When reading any of the apparatus or system claims of this patent to cover a purely software and/o firmware implementation, at least one of the example event analyzer, including the example sorter 212 and/or the example schema definer 214, the example event pipe interface 220, the example fimestamper 2:30, the example event cache writer 240, the example data retriever 250, including the example pipe scanner, the example table scanner 254, and/or the example data combiner 258 is/are hereby expressly defined to include a tangible computer readable storage device or storage disk such as a memory, a digital versatile disk (DVD), a compact disk (CO), a Blu~ray disk, etc. storing the software and/o firmware. Further still, the example event pipe manager 110 of FIG, 2 may include at least one elements), process(es) and/or device(s) in addition to, or instead of, those illustrated In FIG. 2, and/or may include more than one of any or all of the illustrated elements, processes and devices,

0043] Flowcharts representative of example machine readable instructions for Implementing the event pipe manager 110 of FIG, 2 are shown in FIGS, 4, 5, and/or 6, In this example, the machine readable Instructions

comprise a program for execution by a processor such as the processor 112 shown in th example processor platform 100 discussed below in connection with FIG, 1. The program may be embodied in software stored on a tangible computer readable storage medium such as a CD-ROM, a floppy disk, a hard drive, a digital versatile disk (DVD), a Blu-ray disk, or a memory associated with the processor 112, hut the entire program and/or parts thereof could alternatively b executed by a device other than the processor 112 and/or embodied in firmware or dedicated hardware. Further, although the example program is described win reference to the flowcharts illustrated in FIGS, 4, 5, and/or 6, many othe methods of implementing the example event pipe manager 10 may alternatively be used. For example, the order of execution of the blocks in each of the FIGS, 4, 5, and/or 8 may be changed, and/or some of the blocks

described may be changed, eliminated, or combined,

[0044] Trie program 400 of FIG. 4 begins with an initiation of the event pipe manager 110 of FIGS. 1 and/o 2 to monitor for data retrieval requests (e.g., upon start of the processor platform 00, upon receiving Instructions from a user, etc.). At block 410, the example event pipe manager 1 0 monitors for data retrieval requests (e.g., an SQL query). For example, th event pipe manager 110 may monitor the interface 80 and/or input devices 182 for data retrieval requests via the event pipe interface 220, If no data retrieval request is received at block 410, the event pipe ma nager 110 continues to monitor for data retrieval requests (control returns to block 41 ), if a data retrieval request is received at block 410 of FIG, 4, control advances to block 420.

|804S|At block 420 of th illustrated example of FIG. 4, the data retriever 250 retrieves data from a cache. For example, at block 420, the pipe scanner 252 of the data retriever 250 executes a pipe scan function to retrieve first data from the cache 120. At block 430, the data retriever 250 retrieves event data from a storage (e.g., a storage devic , a main memory including a volatile memory and/or a non-volatile memory, etc). For example, at block 430, the table scanner 264 of the data retriever 250 may retrieve second data from a data table In the non-volatile memory 150 of FIG, 1.

[00463 At block 440 of FIG. 4, the data retriever 250, via the event pipe interface 220, provides the data from the cache 120 and the storage device as combined data. For example, the data combiner 2S8 of the data retriever 250 may perform a logical union of the data retrieved from the cach 120 and the storage device. Accordingly, after the data retriever 250 provides (e.g., to a user or requestor of the data retrieval request in 410) the combined data, the program 400 ends.

[00473 The program 600 of FiG. 5 egins with an initiation of the event pipe manager 110 of FIGS. 1 and/or 2 to monitor for data retrieval requests (e.g., upon start of the processor platform 100, upon receiving Instructions from a user, etc.). At block 510, the example event pipe manager 110 monitors fo data retrieval requests (e.g., an SQL query), if no data retrieval request is received, the event pipe manager 110 continues to monitor fo data retrieval requests (control returns to block 510). if data retrieval request is received, control advances to block 520. At block 520, the event pipe Interface 220 analyses the received data retrieval request. For example, at block 520, the event pipe interface 220 identifies a schema corresponding to the requested data, a time period associated with the requested data {e.g., when the requested data was received, sent, etc), etc. Based on the analysis of the data retrieval request, the example event pipe interface 220 instructs the data retriever 250 to retrieve corresponding event data (e.g., pipe data 128 and/or table data 328) from the corresponding event pipe 1 2 a nd/or from the corresponding data table 322.. in other words, the even pipe interface 220 provides the schema and/o time period identified in the data retrieval request. The pip scanner 252 retrieves data from the event cache 120 if a corresponding event pipe 122 includes data received during a time period included in the time period identified In the data retrieval request (block S30). Additionally or alternatively, the table scanner 254 retrieves data from the main memory 320 If a corresponding data table 322 includes data associated with (e.g., received during, posted during, created during, etc.) a time period included in the time period identified in the data retrieval request (block 530), in such examples, th pipe scanner 252 and/or the table scanner 254 may refer to timestamps associated with the event data In the event pipe 122 and/or data table 322,

[00481 At block 540 of the illustrated example of FIG. 5, the data combiner 256 of the data retriever 250 combines data from the corresponding event pipe 122 and the corresponding data table 322 to generate combined data such that ail data having a requested schema and received during a requested period is determined and provided. As described herein, the data combiner 258 identifies overlap data between event data in the event pipe 122 and event data in the data table 322. The data retriever 250 provides the retrieved data as combined data via the event pipe interface 220 to a use (e.g., via a display of the output devices; s) 184} at block 550. For example, at block 550, the combined data may he provided as a list of chronologically ordered event data received during a time period. As a more detailed example, the. combine data in block 550 may include social media posts of a user received at the processor platform 100 within a most recent tim period and stored in an event pipe 122 of the cache 120 and social media posts from the same user received during a time period adjacent to the most recent time period and stored in the a data table 322 of the main memory 320, In such an example, a request for such data may identif the user and the time period (e.g., from 8:00AM to 5 00PM, the last S hours, etc.), which includes the most recent time period (e.g., m 4:55PM to S.QOPM, the last 5 minutes, etc.) and the time period adjacent the most recent time period (e.g. , 8:00AM to 4:S5P _t th 7 hours and 55 minutes prior to the last 5 minutes, etc.).

δδ49| At block 580, the event pipe manager 1 0 determines whether to continue monitoring for data retrieval req uests. If the event pipe manager 110 is to continue monitoring for data retrieval requests, control returns to block §10. If at block 560, the event pipe manager 110 is not to continue monitoring for data requests (e,g„ due to a shutdown, power failure, instructions from user, etc.), the program 500 ends. O50]T e program 800 of FIG. 6 begins with an initiation of the event pipe manager 110 to monitor for received event data (e.g., upon start of the processor platform 100, upon receiving instructions from a user, etc.). The example program 600 may he executed simultaneously i the programs 400, 500, prior to the programs 400, 500 o after the programs 400, 500 of FIGS. 4 and/or 5. At block 810, the event analyzer 210 of the event pipe manager 110 monitors for received event data. If the event analyzer 210 determines that no event data has been received, the event analyzer 210 continues to monitor for ^' received event data (block 010), If; at block 61Q, _: th event analyzer 210 determines that event data has been received, the event analyzer 210 analyzes the received data to determine a schema of the received event data (block 620), in some examples, at block 6 , the event analyzer 210 ma identif a schema associated with th event dat (e,g,, th schema Is identified in a header of th even data). Additionally or alternatively, at block 620, the event analyzer 210 may generate a schema from the event data and/or information associated with the event data (e.g., header information, metadata, user information, format, etc.),

[005 3 At block 630 of the example program 600 of FIG. 6, the event analyzer 210 determines whether the determined schem from block 620 corresponds to a schema of an event pipe 122 in the cache 120 and/or to a schem of a data table 322 in the main memory 330. If, at block 630, the sorter 212 determines that the determined schema does not correspond to a schema in an event pipe 122 or a data table 322 , the example schema definer 214 generates, based on the determined schema, a new event pipe 22 in the cache 120, a new data table 322 in the main memor 320, and a new pipe scan function to identify and/or retrieve the event data from the new event pipe 122 (block 040), if, at block 630, the example sorter 214 does determine that the determined schema corresponds to an event pipe in the cache 120 and/or a data fable 322 in the main memory 320, control advances to block 880, After block 630 and/or block 640, the example sorter 212 writes the received event data to the corresponding: event pipe 122 in the cache 120. 0S2 A block 660 of FIG. 8, the example event pipe manager 110 determines whether it is to continue to monitor for received event data. If, at block 680, the event pipe manager 110 determines that it is to continue to monitor for received data, control returns to block 610, if, at block 660, the event pipe manager 110 determines that is not to continue to monitor for received data, the program 600 ends.

0S3JAs mentioned above, the example processes of FIGS. 4 and/or 5 may be implemented using coded instructions (e.g. _; compute and/or machine ^' readable instructions) stored on a tangible computer readable storag medium such as a hard disk drive, a flash memory, a read-only memor ROM), a compact disk (CD), a digital versatile disk DVD), a cache, a random-access memory (RAM) and/or any other storage device or storage disk in which information is stored for any duration (e.g., for extended time periods, permanently, for brief Instances, for temporarily buffering, and/or for caching of the information). As used herein, the term tangible computer readable storage medium Is expressly defined to induce any type of computer readable storage devic and/or storage disk and to exclude propagating signals and to exclud transmission media. As used herein, "tangible computer readable storage medium" and "tangible machine readable storage medium" are used

interchangeably. Additionally or alternatively, the example processes of FIGS, 4 and/or 5 may be implemented using coded instructions (e.g., computer and or machine readable instructions) stored on a non-transitory computer and/or machine readable medium such as a hard disk drive, a flash memory, a readonly memory, a compact disk, a digital versatile disk, a cache, a random-access memory and/or any other storage device or storage disk in which information is stored for any duration (e g , for extended time periods, permanently, for brief instances, for temporarily buffering, and/or for caching of the information). As used herein, the term non-transitory computer readable medium is expressly defined to include any type of computer readable storage device and/o storag disk and to exclude propagating signals and to exclude transmission media, As used herein, when the phrase "at least" is used as the transition term in a preamble of a claim, it is o en-ended in the same manner as the term

"comprising" is open ended.

005 3 From the foregoing, it will be appreciated that the above disclosed methods, apparatus and articles of manufacture enable mat-time retrieval of event data from an event pipe of a cache and/or a data table from main memory. Examples disclosed herein involve generating an example event pipe, a pipe scan function, and/or a data table based on a schema associated with event data. In response to receiving a data retrieval request for event data having the example schema, data received during a most recent time period is retrieved from an event pipe in a cache and dat received prior to the most recent time period ma be retrieved from the data table. The event data from the event pipe and the event data from the data table can be combined and provided as combined data representative of dat received during a designated time period, O0SS3 Although certain example methods, apparatus and articles of manufacture have been disclosed herein, the scope of coverage of this patent is not limited thereto. On the contrary, this patent covers ail methods, apparatu and articles of manufacture fairly failing within the scope of the claims of this patent.