Details

    • Type: Sub-task
    • Status: Open
    • Priority: Major
    • Resolution: Unresolved
    • Affects Version/s: None
    • Fix Version/s: None
    • Component/s: Table SQL / API
    • Labels:
      None

      Description

      Flink-8577 implements upsert from stream under proctime. This task is going to solve the order problem introduce by proctime. As proposed by Fabian in FLINK-8545, it would be good to be able to declare a time attribute that decides whether an upsert is performed or not.

      Table table = tEnv.upsertFromStream(input, 'a, 'b.rowtime.upsertOrder, 'c.key)
      

      This is a good way to solve the order problem using rowtime. And an idea comes to my mind that we can even remove the `.upsertOrder`, because the rowtime attribute can only be defined once in a table schema. Removing `.upsertOrder` also makes it easier to design api for TableSource and sql, i.e, we don't need to add another new feature for the api.

      Any suggestions are welcomed!

        Attachments

          Activity

            People

            • Assignee:
              hequn8128 Hequn Cheng
              Reporter:
              hequn8128 Hequn Cheng
            • Votes:
              0 Vote for this issue
              Watchers:
              4 Start watching this issue

              Dates

              • Created:
                Updated: