Class ProjectQueryOperation

  • All Implemented Interfaces:
    Operation, QueryOperation

    @Internal
    public class ProjectQueryOperation
    extends Object
    implements QueryOperation
    Table operation that computes new table using given Expressions from its input relational operation.
    • Constructor Detail

      • ProjectQueryOperation

        public ProjectQueryOperation​(List<org.apache.flink.table.expressions.ResolvedExpression> projectList,
                                     QueryOperation child,
                                     org.apache.flink.table.catalog.ResolvedSchema resolvedSchema)
    • Method Detail

      • getProjectList

        public List<org.apache.flink.table.expressions.ResolvedExpression> getProjectList()
      • 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