Uploaded image for project: 'Beam'
  1. Beam
  2. BEAM-7944 Improvements of portability framework to make it usable in other projects
  3. BEAM-7951

Allow runner to configure customization WindowedValue coder such as ValueOnlyWindowedValueCoder

    XMLWordPrintableJSON

    Details

    • Type: Sub-task
    • Status: Open
    • Priority: Major
    • Resolution: Unresolved
    • Affects Version/s: None
    • Fix Version/s: 2.17.0
    • Component/s: java-fn-execution
    • Labels:
      None

      Description

      The coder of WindowedValue cannot be configured and it’s always FullWindowedValueCoder. We don't need to serialize the timestamp, window and pane properties in Flink and so it will be better to make the coder configurable (i.e. allowing to use ValueOnlyWindowedValueCoder)

        Attachments

          Activity

            People

            • Assignee:
              sunjincheng121 sunjincheng
              Reporter:
              sunjincheng121 sunjincheng
            • Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

              • Created:
                Updated: