Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-35187 FLIP-435: Introduce a New Materialized Table for Simplifying Data Pipelines
  3. FLINK-35191

Support alter materialized table related syntaxes: suspend, resume, refresh, set and reset

    XMLWordPrintableJSON

Details

    Description

      SQL statement as follows:

      // suspend
      ALTER MATERIALIZED TABLE [catalog_name.][db_name.]table_name SUSPEND
      
      // resume
      ALTER MATERIALIZED TABLE [catalog_name.][db_name.]table_name RESUME
       
      [WITH('key1' = 'val1', 'key2' = 'val2')]
      
      // refresh
      ALTER MATERIALIZED TABLE [catalog_name.][db_name.]table_name REFRESH
       
      [PARTITION (key1=val1, key2=val2, ...)]
      
      // set freshness
      ALTER MATERIALIZED TABLE [catalog_name.][db_name.]table_name 
       
        SET FRESHNESS = INTERVAL '<num>' { SECOND | MINUTE | HOUR | DAY }
      
      // set refresh mode
      
      ALTER MATERIALIZED TABLE  [catalog_name.][db_name.]table_name 
       
        SET REFRESH_MODE = { FULL | CONTINUOUS }
      
      // set options
      ALTER MATERIALIZED TABLE [catalog_name.][db_name.]table_name  SET ('key' = 'val');
      
      // reset options
      ALTER MATERIALIZED TABLE [catalog_name.][db_name.]table_name RESET ('key');
      

      Attachments

        Issue Links

          Activity

            People

              hackergin Feng Jin
              lsy dalongliu
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: