flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Aljoscha Krettek (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-990) Scala API: Compiler Hints are not forwarded
Date Mon, 30 Jun 2014 12:23:24 GMT

    [ https://issues.apache.org/jira/browse/FLINK-990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14047605#comment-14047605

Aljoscha Krettek commented on FLINK-990:

Why did you only add the {{applyHints}} call in line 108 in CompilerHints.scala and not in
the other methods where {{addCardinality}} is called?

Also, the system is a mess there because the way the annotations and hints are handled here
is from a time when the system used annotations to specify those hints and did not really
provide an API. This stuff will have to be reworked to bring the scala interface up to speed
with the java interface.

> Scala API: Compiler Hints are not forwarded
> -------------------------------------------
>                 Key: FLINK-990
>                 URL: https://issues.apache.org/jira/browse/FLINK-990
>             Project: Flink
>          Issue Type: Bug
>            Reporter: Till Rohrmann
>            Assignee: Till Rohrmann
> The Scala API contains functions such as preserve, observe, neglect, uniqueKey etc. which
can be used to specify compiler hints. However, they are not forwarded to the compiler. Thus
an operation:
> DataSet[A] ds = input.map{ x=> x}
> ds.preserve(x=>x, y=>y)
> which should say that the fields stay constant, does not have an effect. 

This message was sent by Atlassian JIRA

View raw message