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

Support the execution of create materialized table in full refresh mode

    XMLWordPrintableJSON

Details

    Description

      In full refresh mode, support creates materialized table and its background refresh workflow:

      CREATE MATERIALIZED TABLE [catalog_name.][db_name.]table_name
       
      [ ([ <table_constraint> ]) ]
       
      [COMMENT table_comment]
       
      [PARTITIONED BY (partition_column_name1, partition_column_name2, ...)]
       
      [WITH (key1=val1, key2=val2, ...)]
       
      FRESHNESS = INTERVAL '<num>' { SECOND | MINUTE | HOUR | DAY }
       
      [REFRESH_MODE = { CONTINUOUS | FULL }]
       
      AS <select_statement>
       
      <table_constraint>:
        [CONSTRAINT constraint_name] PRIMARY KEY (column_name, ...) NOT ENFORCED
      

      Attachments

        Activity

          People

            Unassigned Unassigned
            lsy dalongliu
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

              Created:
              Updated: