摘要 |
A stream processing handling arrangement provides a number of data handling blocks, selectable for forming a work flow. The blocks comprise data processing blocks. The arrangement receives selections of data handling blocks, block parameter settings and workflow property objectives, and compares the objectives with corresponding stream processing framework capabilities. The arrangement determines a stream processing framework for the work flow, provides a number software module groups, each corresponding to a different framework and comprising software modules corresponding to the data handling blocks, and chooses a group corresponding to the determined stream processing framework. The arrangement selects, in this group, software modules corresponding to the selected blocks and constructs an application using the selected software modules. |
主权项 |
1. A stream processing handling arrangement, the stream processing handling arrangement comprising a processor and memory, said memory containing computer instructions executable by said processor to operate said stream processing handling arrangement to:
provide a number of data handling blocks, selectable by a user for forming a work flow, the data handling blocks comprising data processing blocks representing data processing functions to be included in the work flow, receive, from the user, selections of data handling blocks comprising data processing blocks, parameter settings of data processing blocks and workflow property objectives, compare the workflow property objectives with corresponding stream processing framework capabilities, determine a stream processing framework for the work flow based on the comparison, provide a number software module groups, each software module group corresponding to a different stream processing framework and comprising software modules corresponding to the selectable data handling blocks, choose a software module group corresponding to the determined stream processing framework, select, in the chosen software module group, software modules corresponding to the user selected data handling blocks, and construct an application performing the activities of the work flow in the determined stream processing framework using the selected software modules. |