Consuming streamed data records
    3.
    发明授权

    公开(公告)号:US10482098B2

    公开(公告)日:2019-11-19

    申请号:US15351126

    申请日:2016-11-14

    发明人: Michael J. Pizzo

    IPC分类号: G06F16/25

    摘要: Aspects extend to methods, systems, and computer program products for consuming streamed data records. An application binds members (e.g., columns) of a structure (e.g., record) from a data source to memory buffers, and may specify one or more members be retrieved individually or be ignored entirely. The application requests one or more records from the data source be fetched into the memory buffers until it comes across a member that doesn't match the binding. The data source notifies of the application of data that is ready to be read from the exception member. The application can create or update binding information for the member, read data from the member, or ignore the member. When finished, the application requests the data source continue processing record(s). Additional members are copied into the memory buffers until the last member is read for the (set of) record(s) or another exception member is discovered.

    CONSUMING STREAMED DATA RECORDS
    4.
    发明申请

    公开(公告)号:US20180136876A1

    公开(公告)日:2018-05-17

    申请号:US15351126

    申请日:2016-11-14

    发明人: Michael J. Pizzo

    IPC分类号: G06F3/06

    CPC分类号: G06F16/25

    摘要: Aspects extend to methods, systems, and computer program products for consuming streamed data records. An application binds members (e.g., columns) of a structure (e.g., record) from a data source to memory buffers, and may specify one or more members be retrieved individually or be ignored entirely. The application requests one or more records from the data source be fetched into the memory buffers until it comes across a member that doesn't match the binding. The data source notifies of the application of data that is ready to be read from the exception member. The application can create or update binding information for the member, read data from the member, or ignore the member. When finished, the application requests the data source continue processing record(s). Additional members are copied into the memory buffers until the last member is read for the (set of) record(s) or another exception member is discovered.