Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.


Discussion thread

here (<- link to

https://lists.apache.org/

list.html?dev@flink.apache.org)

thread/ztyk68brsbmwwo66o1nvk3f6fqqhdxgk

Vote thread

here (<- link to https://lists.apache.org/list.html?dev@flink.apache.org)

JIRA

here (<- link to https://issues.apache.org/jira/browse/FLINK-XXXX)

Release

<Flink Version>

Please keep the discussion on the mailing list rather than commenting on the wiki (wiki discussions get unwieldy fast).

...

ResolvedExpression:

Code Block
languagejava

public interface ResolvedExpression extends Expression {

    /**
     * Returns a string that fully serializes this instance. The serialized string can be used for
     * storing the query in, for example, a {@link org.apache.flink.table.catalog.Catalog} as a
     * view.
     *
     * @return detailed string for persisting in a catalog
     */
    default String asSerializableString() {
        throw new TableException(
                String.format(
                        "Expression '%s' is not string serializable. Currently, only expressions that "
                                + "originated from a SQL expression have a well-defined string representation.",
                        asSummaryString()));
    }
    
    ....
}

...

QueryOperation:

Code Block

public interface QueryOperation extends Operation {

    /**
     * Returns a string that fully serializes this instance. The serialized string can be used for
     * storing the query in e.g. a {@link org.apache.flink.table.catalog.Catalog} as a view.
     *
     * @return detailed string for persisting in a catalog
     * @see Operation#asSummaryString()
     */
    default String asSerializableString() {
        throw new UnsupportedOperationException(
                "QueryOperations are not string serializable for now.");
    }
 ....   
}

...