Versions Compared

Key

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

...

Page properties


Discussion threadhttps://lists.apache.org/thread/686bhgwrrb4xmbfzlk60szwxos4z64t7
Vote threadTBAhttps://lists.apache.org/thread/x5tyg0sb7h3clyrv34t9rfrwn7kwy3t3
JIRA

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyFLINK-20767

ReleaseTBA1.19.0

Redo

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

...

  • Introduce a new ResolvedExpression called NestedFieldReferenceExpression to support nested fields filter pushdown.
  • Add a new API called supportsNestedFilters to SupportsFilterPushDown.

Proposed Changes

Introduce NestedFieldReferenceExpression to support nested fields filter pushdown

...

Code Block
languagejava
titleNestedFieldReferenceExpression.java
public final class NestedFieldReferenceExpression implements ResolvedExpression {

    private final String[] fieldNames;

    private final int[] fieldIndices;

    private final DataType dataType;

    public NestedFieldReferenceExpression(
            String[] fieldNames,
			int[] fieldIndices,
            DataType dataType) {
        this.fieldNames = fieldNames;
		this.fieldIndices = fieldIndices;
        this.dataType = dataType;
    }

    public String[] getFieldNames() {
        return fieldNames;
    }

    public int[] getFieldIndices() {
        return fieldIndices;
    }

    @Override
    public DataType getOutputDataType() {
        return dataType;
    }
}

Compatibility, Deprecation, and Migration Plan

...