Class FilterQueryOperation

  • All Implemented Interfaces:
    Operation, QueryOperation

    @Internal
    public class FilterQueryOperation
    extends Object
    implements QueryOperation
    Filters out rows of underlying relational operation that do not match given condition.
    • Constructor Detail

      • FilterQueryOperation

        public FilterQueryOperation​(org.apache.flink.table.expressions.ResolvedExpression condition,
                                    QueryOperation child)
    • Method Detail

      • getCondition

        public org.apache.flink.table.expressions.ResolvedExpression getCondition()
      • getResolvedSchema

        public org.apache.flink.table.catalog.ResolvedSchema getResolvedSchema()
        Description copied from interface: QueryOperation
        Resolved schema of this operation.
        Specified by:
        getResolvedSchema in interface QueryOperation
      • asSummaryString

        public String asSummaryString()
        Description copied from interface: Operation
        Returns a string that summarizes this operation for printing to a console. An implementation might skip very specific properties.
        Specified by:
        asSummaryString in interface Operation
        Returns:
        summary string of this operation for debugging purposes