Flink从入门到精通100篇（二十四）-对Flink SQL Client 源码做深度解析

前言

本文基于 Flink 1.12-SNAPSHOT，使用sql client命令行提交insert语句进行整个流程的分析。

sql-client.sh embedded --update "INSERT INTO user_log_sink2 SELECT * FROM user_log"

 

Initialize the environment

主类：org.apache.flink.table.client.SqlClient#main

  

   

    

     

    
    

     

      public static void main(String[] args) {
     
    
   

    

     

    
    

     

        if (args.length < 1) {
     
    
   

    

     

    
    

     

         CliOptionsParser.printHelpClient();
     
    
   

    

     

    
    

     

         return;
     
    
   

    

     

    
    

     

        }
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

        switch (args[0]) {
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

         case MODE_EMBEDDED:
     
    
   

    

     

    
    

     

          // remove mode
     
    
   

    

     

    
    

     

          final String[] modeArgs = Arrays.copyOfRange(args, 1, args.length);
     
    
   

    

     

    
    

     

          final CliOptions options = CliOptionsParser.parseEmbeddedModeClient(modeArgs);
     
    
   

    

     

    
    

     

          if (options.isPrintHelp()) {
     
    
   

    

     

    
    

     

           CliOptionsParser.printHelpEmbeddedModeClient();
     
    
   

    

     

    
    

     

          } else {
     
    
   

    

     

    
    

     

           try {
     
    
   

    

     

    
    

     

            final SqlClient client = new SqlClient(true, options);
     
    
   

    

     

    
    

     

            client.start();
     
    
   

    

     

    
    

     

           } catch (SqlClientException e) {
     
    
   

    

     

    
    

     

            // make space in terminal
     
    
   

    

     

    
    

     

            System.out.println();
     
    
   

    

     

    
    

     

            System.out.println();
     
    
   

    

     

    
    

     

            LO
     
    
  
 

文章来源: wenyusuran.blog.csdn.net，作者：文宇肃然，版权归原作者所有，如需转载，请联系作者。

原文链接：wenyusuran.blog.csdn.net/article/details/122184715