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

Support the execution of create materialized table in continuous refresh mode

    XMLWordPrintableJSON

Details

    Description

      In continuous refresh mode, support creates materialized table and its background refresh job:

      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

        Issue Links

          Activity

            People

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

              Dates

                Created:
                Updated:
                Resolved: