System, Method, and Computer Program Product for Performing Analysis of Transaction Data

A computer-implemented method for performing analysis of transaction data, comprising:

• receiving, with at least one connector, streaming data from a streaming data feed, wherein the streaming data comprises a plurality of key value pairs, wherein key data of each key value pair comprises a data identifier of a plurality of data identifiers and value data of each key value pair comprises transaction data associated with each transaction of a plurality of transactions, wherein each data identifier of the plurality of data identifiers is associated with transaction data so that the transaction data associated with each individual transaction of the plurality of transactions is separated by an individual data identifier of the plurality of data identifiers;
• filtering, with at least one connector, the streaming data using at least one predetermined key data parameter to provide filtered data, wherein the filtered data comprises filtered transaction data associated with at least one transaction that corresponds to value data of a key value pair, and wherein the key value pair includes the at least one predetermined key data parameter;
• determining, with at least one connector, whether the filtered transaction data associated with the at least one transaction corresponds to at least one predetermined transaction activity parameter based on filtering the streaming data;
• and
• asynchronously storing, with at least one connector, the filtered transaction data associated with the at least one transaction in at least one data structure based on determining that the filtered transaction data associated with the at least one transaction corresponds to the at least one predetermined transaction activity parameter.

A computer program product for performing analysis of transaction data, the computer program product comprising at least one non-transitory computer-readable medium including one or more instructions that, when executed by at least one connector, cause the at least one connector to:

• receive streaming data from a streaming data feed, wherein the streaming data comprises a plurality of key value pairs, wherein key data of each key value pair comprises a data identifier of a plurality of data identifiers and value data of each key value pair comprises transaction data associated with each transaction of a plurality of transactions, wherein each data identifier of the plurality of data identifiers is associated with transaction data so that the transaction data associated with each individual transaction of the plurality of transactions is separated by an individual data identifier of the plurality of data identifiers;
• filter the streaming data using at least one predetermined key data parameter to provide filtered data, wherein the filtered data comprises filtered transaction data associated with at least one transaction that corresponds to value data of a key value pair, and wherein the key value pair includes the at least one predetermined key data parameter;
• determine whether the filtered transaction data associated with the at least one transaction corresponds to at least one predetermined transaction activity parameter based on filtering the streaming data;
• asynchronously store the filtered transaction data associated with the at least one transaction in at least one data structure based on determining that the filtered transaction data associated with the at least one transaction corresponds to the at least one predetermined transaction activity parameter;
• and
• forego asynchronously storing the filtered transaction data associated with the at least one transaction in at least one data structure based on determining that the filtered transaction data associated with the at least one transaction does not correspond to the at least one predetermined transaction activity parameter.