You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by fhueske <gi...@git.apache.org> on 2018/01/04 23:25:50 UTC

[GitHub] flink pull request #5132: [FLINK-8203] [FLINK-7681] [table] Make schema defi...

Github user fhueske commented on a diff in the pull request:

    https://github.com/apache/flink/pull/5132#discussion_r159761372
  
    --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/TableEnvironment.scala ---
    @@ -791,92 +824,109 @@ abstract class TableEnvironment(val config: TableConfig) {
         * Returns field names and field positions for a given [[TypeInformation]] and [[Array]] of
         * [[Expression]]. It does not handle time attributes but considers them in indices.
         *
    +    * @param isReferenceByPosition schema mode see [[isReferenceByPosition()]]
         * @param inputType The [[TypeInformation]] against which the [[Expression]]s are evaluated.
         * @param exprs     The expressions that define the field names.
         * @tparam A The type of the TypeInformation.
         * @return A tuple of two arrays holding the field names and corresponding field positions.
         */
    -  protected[flink] def getFieldInfo[A](
    +  protected def getFieldInfo[A](
    +      isReferenceByPosition: Boolean,
    --- End diff --
    
    why not call `isReferenceByPosition()` inside of `getFieldInfo()`? It has all required parameters. Moreover, we only need to call it for tuple-like types that can be resolved by pos or name.
      


---