FLINK ENGINE-BASED DATA PARSING METHOD AND APPARATUS

摘要

Disclosed in the present invention are a Flink engine-based data parsing method and apparatus. The method comprises: receiving, via a Flink platform external interface, parsing logic and data source information configured by a user; generating a parser according to the parsing logic and the data source information, and uploading the parser to a distributed file system; and parsing data to be parsed sent to a Flink data source in advance and corresponding to the data source information by using the parser obtained from the distributed system to generate parsed data. According to the present invention, a parser is generated according to parsing logic and data source information configured by a user to replace a Flink native parser, so that data to be parsed in different formats can be parsed, thereby meeting various service scenes; the parsing logic and data source information configured by the user are received by developing a Flink platform external interface to generate the parser, so that the expansibility of various services is achieved.