Abstract:
Disclosed herein are a method and an apparatus for storing blockchain data based on error correction code. The method for storing blockchain data based on error correction code includes dividing block data to be stored into multiple subblock datasets, generating parity datasets corresponding to the block data, and storing the subblock datasets and the parity datasets in proportion to storage capacities of the blockchain data storage nodes.
Abstract:
Disclosed herein are a method and an apparatus for storing blockchain data based on error correction code. The method for storing blockchain data based on error correction code includes dividing block data to be stored into multiple subblock datasets, generating parity datasets corresponding to the block data, and storing the subblock datasets and the parity datasets in proportion to storage capacities of the blockchain data storage nodes.
Abstract:
The following description relates to a method and an apparatus for merging distributed stream processing services. A method for merging distributed stream processing services according to an example includes generating a global service tree based on one distributed stream processing service; when a new distributed stream processing service different from the one distributed stream processing service is inputted, generating an individual service tree for the new distributed stream processing service; and updating the global service tree by merging at least one node commonly existing in both the global service tree and the individual service tree. Common resources may be allocated to tasks (or instances) existing commonly in distributed stream processing services.
Abstract:
An apparatus and method for managing stream processing tasks are disclosed. The apparatus includes a task management unit and a task execution unit. The task management unit controls and manages the execution of assigned tasks. The task execution unit executes the tasks in response to a request from the task management unit, collects a memory load state and task execution frequency characteristics based on the execution of the tasks, detects low-frequency tasks based on the execution frequency characteristics if it is determined that a shortage of memory has occurred based on the memory load state, assigns rearrangement priorities to the low-frequency tasks, and rearranges the tasks based on the assigned rearrangement priorities.
Abstract:
Disclosed herein is a method for storing blockchain transaction data. The method includes selecting transaction blocks corresponding to an encoding group, generating at least one encoding chunk corresponding to each of participating nodes by performing fountain encoding on the transaction blocks, and storing the at least one encoding chunk corresponding to one of the participating nodes.
Abstract:
Disclosed herein is a method for storing blockchain transaction data. The method includes selecting at least one block file storing blockchain transactions as an encoding block file target, generating encoded chunks including parity chunks using the encoding block file target, and making at least one of the encoded chunks correspond to at least one of blockchain nodes to store at least one of the encoded chunks.