flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Timo Walther (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-2828) Add interfaces for Table API input formats
Date Wed, 07 Oct 2015 12:45:26 GMT
Timo Walther created FLINK-2828:

             Summary: Add interfaces for Table API input formats
                 Key: FLINK-2828
                 URL: https://issues.apache.org/jira/browse/FLINK-2828
             Project: Flink
          Issue Type: New Feature
          Components: Table API
            Reporter: Timo Walther
            Assignee: Timo Walther

In order to support input formats for the Table API, interfaces are necessary. I propose two
types of TableSources:

- AdaptiveTableSources can adapt their output to the requirements of the plan. Although the
output schema stays the same, the TableSource can react on field resolution and/or predicates
internally and can return adapted DataSet/DataStream versions in the "translate" step.
- StaticTableSources are an easy way to provide the Table API with additional input formats
without much implementation effort (e.g. for fromCsvFile())

TableSources need to be deeply integrated into the Table API.

The TableEnvironment requires a newly introduced AbstractExecutionEnvironment (common super
class of all ExecutionEnvironments for DataSets and DataStreams).

Here's what a TableSource can see from more complicated queries:

  .filter("a===5 || a===6")
  .select("a as a4, b as b4, c as c4")
  .where("a===a4 && c==='Test' && c4==='Test2'")

// Result predicates for tableSource1:
//  List("a===5 || a===6", "b===7", "c==='Test2'")
// Result predicates for tableSource2:
//  List("c==='Test'")
// Result resolved fields for tableSource1 (true = filtering, false=selection):
//  Set(("a", true), ("a", false), ("b", true), ("b", false), ("c", false), ("c", true))
// Result resolved fields for tableSource2 (true = filtering, false=selection):
//  Set(("a", true), ("c", true))

This message was sent by Atlassian JIRA

View raw message