Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-36846

Composer support add custom Operator after Source

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Open
    • Minor
    • Resolution: Unresolved
    • cdc-3.3.0, cdc-3.2.1
    • None
    • Flink CDC
    • None

    Description

      Currently, Flink CDC operators include Transform (PreTransformOperator, PostTransformOperator), route (SchemaOperator), source, and sink. Is it possible to extend Composer to allow users to embed custom operators within the stream? Some potential functionalities that custom operators could support include DDL collection and sampling synchronization for validation purposes.

      Attachments

        Activity

          People

            Unassigned Unassigned
            beryllwang JunboWang
            Votes:
            0 Vote for this issue
            Watchers:
            1 Start watching this issue

            Dates

              Created:
              Updated: