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

Add support for SQL queries in DataSet programs

    XMLWordPrintableJSON

Details

    • New Feature
    • Status: Resolved
    • Major
    • Resolution: Implemented
    • 1.1.0
    • 1.1.0
    • Table SQL / API
    • None

    Description

      This issue covers the task of supporting SQL queries embedded in DataSet programs. In this mode, the input and output of a SQL query is a Table. For this issue, we need to make the following additions to the Table API:

      • add a tEnv.sql(query: String): Table method for converting a query result into a Table
      • integrate Calcite's SQL parser into the batch Table API translation process.

      Attachments

        Activity

          People

            vkalavri Vasia Kalavri
            vkalavri Vasia Kalavri
            Votes:
            0 Vote for this issue
            Watchers:
            3 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: