[jira] [Created] (FLINK-13218) '*.count not supported in TableApi query

[Shang Yuanchun (Jira)]

Jing Zhang created FLINK-13218:
----------------------------------

             Summary: '*.count not supported in TableApi query
                 Key: FLINK-13218
                 URL: https://issues.apache.org/jira/browse/FLINK-13218
             Project: Flink
          Issue Type: Task
            Reporter: Jing Zhang
            Assignee: Jing Zhang


The following query is not supported yet:

{code:java}
    val t = StreamTestData.get3TupleDataStream(env).toTable(tEnv, 'a, 'b, 'c)
      .groupBy('b)
      .select('b, 'a.sum, '*.count)
{code}

The following exception will be thrown.

{code:java}
org.apache.flink.table.api.ValidationException: Cannot resolve field [*], input field list:[a, b, c].

        at org.apache.flink.table.expressions.resolver.rules.ReferenceResolverRule$ExpressionResolverVisitor.failForField(ReferenceResolverRule.java:80)
        at org.apache.flink.table.expressions.resolver.rules.ReferenceResolverRule$ExpressionResolverVisitor.lambda$null$4(ReferenceResolverRule.java:75)
        at java.util.Optional.orElseThrow(Optional.java:290)
        at org.apache.flink.table.expressions.resolver.rules.ReferenceResolverRule$ExpressionResolverVisitor.lambda$null$5(ReferenceResolverRule.java:75)
        at java.util.Optional.orElseGet(Optional.java:267)
        at org.apache.flink.table.expressions.resolver.rules.ReferenceResolverRule$ExpressionResolverVisitor.lambda$visit$6(ReferenceResolverRule.java:74)
        at java.util.Optional.orElseGet(Optional.java:267)
        at org.apache.flink.table.expressions.resolver.rules.ReferenceResolverRule$ExpressionResolverVisitor.visit(ReferenceResolverRule.java:71)
        at org.apache.flink.table.expressions.resolver.rules.ReferenceResolverRule$ExpressionResolverVisitor.visit(ReferenceResolverRule.java:51)
        at
...
{code}




--
This message was sent by Atlassian JIRA
(v7.6.14#76016)