Uploaded image for project: 'Beam'
  1. Beam
  2. BEAM-8848 Flink: Memory efficient GBK implementation for batch runner
  3. BEAM-8849

Flink: Support multiple translation of a single URN in batch runner.

Details

    • Sub-task
    • Status: Resolved
    • P2
    • Resolution: Fixed
    • None
    • 2.23.0
    • runner-flink
    • None

    Description

      We need to be able to have multiple translations for a single URN (right now we want to have a special translation for GBK with non-merging windowing). We'll introduce a new `canTranslate` method for all translators, that can be used by runner to decide, which translation to use based on `PTransform` properties.

      Attachments

        Activity

          People

            dmvk David Morávek
            dmvk David Morávek
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: