Disclosed are computer-implemented methods, non-transitory computer-readable media, and systems for processing blockchain transactions. An example of a computer-implemented system includes a storage subsystem including one or more storage devices that store blockchain data, and one or more processors configured to support a first thread pool and a second thread pool. The second thread pool is dedicated to the storage subsystem. The system receives M blockchain transactions and executes N blockchain transactions out of the M blockchain transactions in parallel using K threads of the first thread pool. For blockchain transactions distributed to each one of the K threads, one or more coroutines are used for each blockchain transaction so that the blockchain transactions are executed asynchronously using the coroutines. A blockchain block is generated to include the M blockchain transactions and added to a blockchain stored in the storage subsystem.

The present application provides a blockchain consensus method, apparatus and device, and the method includes: dividing transaction information in a transaction pool into N transaction information sets, where N is a natural number greater than 1; performing consensus on the N transaction information sets in parallel, to obtain a first consensus result corresponding to each transaction information set; and determining, according to a first consensus result corresponding to a first i transaction information set, a second consensus result corresponding to an i-th transaction information set, where i takes 1, 2, . . . , N-1 and N in sequence. The accuracy of the consensus results can be ensured, performing consensus on the N transaction information sets in the transaction pool in parallel is realized, consensus efficiency is increased, and thereby an overall performance of a blockchain network can be improved.

The present disclosure relates to Application Programming Interface (API) framework that discloses a computer implemented method, polling service system, and non-transitory computer readable medium for providing dynamic endpoints for performing data transactions with a corresponding candidate application server. The method has two phases: a polling phase and a transaction phase. In the polling phase, the polling service system receives a first API request from one or more source devices and provides a dynamic endpoint for the one or more source devices to interact with the corresponding candidate application server of their requirement. In the transaction phase, the corresponding candidate application server receives a second API request from the one or more source devices through the dynamic endpoint generated during the polling phase, and performs data transactions.

Embodiments of the invention are directed to enabling access transaction systems to accept different communication protocols. In some embodiment, an access device receives, from a portable device, an indication that a transaction is to be performed by exchanging transaction information between the portable device and a remote computer, wherein the remote computer is configured to communicate using a first communication protocol. Next, the access device determines that the portable device is configured to communicate using a second communication protocol. The access device then converts communications between the portable device and the remote computer from the second communication protocol to the first communication protocol to assist the portable device and the remote computer in exchanging the transaction information.

A data storage apparatus and a data prediction method thereof are provided. The data storage apparatus includes a memory unit and a prediction unit. The prediction unit acquires a plurality of access location data of a plurality of data access actions of a prior access history of the memory unit. The prediction unit analyzes the prior access history of the memory unit. The prediction unit performs a quantification process on the access location data to acquire a plurality of quantized data corresponding to the prior access history. The prediction unit predicts a data pre-accessing target of the memory unit according to the quantized data.

In response to an allocation request of a target transaction, transaction allocation indexes respectively corresponding to the at least two node devices are determined. A coordinator node device of the target transaction in the at least two node devices is determined based on the transaction allocation indexes respectively corresponding to the at least two node devices. The coordinator node device coordinates the target transaction. Each coordinator node device coordinates a transaction as a decentralized device so that the transaction can be processed across nodes, which is conducive to improving efficiency of transaction processing, reliability of transaction processing, and system performance of a database system.

Aspects of the present disclosure involve systems, methods, devices, and the like for segmentation of the processor architecture platform. In one embodiment, a system and method are introduced which enable the use of a segmented platform in an extended network. The segmented platform is introduced for processing using standardized plugins enabling the use of processing and services available at the segmented network. In another embodiment, processing on the segmented platform can include the integration of microservices for the completion of the transaction.

A client computer may split a process into sub-processes, send each sub-processes to a different group of peers in a blockchain network, wherein each group has at least one peer from each essential organization in the blockchain network, receive processed sub-transactions from the peers in the blockchain network, validate each sub-transaction, and validate the transaction based on the validation of all sub-transactions, wherein all sub-transaction must be valid for the transaction to be valid.

A method for processing data exactly once using transactional stream writes includes receiving, from a client, a batch of data blocks for storage on memory hardware in communication with the data processing hardware. The batch of data blocks is associated with a corresponding sequence number and represents a number of rows of a table stored on the memory hardware. The method also includes partitioning the batch of data blocks into a plurality of sub-batches of data blocks. For each sub-batch of data blocks, the method further includes assigning the sub-batch of data blocks to a buffered stream; writing, using the assigned buffered stream, the sub-batch of data blocks to the memory hardware; updating a storage log with an intent to commit the sub-batch of data blocks using the assigned buffered stream; and committing the sub-batch of data blocks to the memory hardware.

A system includes first and second subsystems and a third processor. The first subsystem includes a first memory and a first processor. The first memory stores data, which includes metadata associated with transmitted metadata fields. The first processor transmits the data to the second subsystem. The second subsystem includes a second memory and a second processor. The second memory stores expected metadata fields. The second processor receives the data. The third processor determines that the first subsystem transmitted the data to the second subsystem and that a mismatch exists between the transmitted and expected metadata fields. In response, the third processor prevents the second subsystem from executing an application configured to process the data using the expected metadata fields. The third processor resolves the mismatch by modifying the expected metadata fields such that they correspond to the transmitted metadata fields and allows the second subsystem to execute the application.