Hierarchy For Package org.apache.flink.table.runtime.operators.process

Package Hierarchies:

Class Hierarchy

  • java.lang.Object
    • org.apache.flink.table.runtime.operators.process.AbstractProcessTableOperator.RunnerContext (implements org.apache.flink.table.functions.ProcessTableFunction.Context)
    • org.apache.flink.streaming.api.operators.AbstractStreamOperatorFactory<OUT> (implements org.apache.flink.streaming.runtime.tasks.ProcessingTimeServiceAware, org.apache.flink.streaming.api.operators.StreamOperatorFactory<OUT>)
    • org.apache.flink.streaming.api.operators.AbstractStreamOperatorV2<OUT> (implements org.apache.flink.streaming.api.operators.StreamOperator<OUT>, org.apache.flink.streaming.api.operators.StreamOperatorStateHandler.CheckpointedStreamOperator)
      • org.apache.flink.table.runtime.operators.process.AbstractProcessTableOperator (implements org.apache.flink.streaming.api.operators.Triggerable<K,​N>)
        • org.apache.flink.table.runtime.operators.process.ProcessRowTableOperator (implements org.apache.flink.streaming.api.operators.OneInputStreamOperator<IN,​OUT>)
        • org.apache.flink.table.runtime.operators.process.ProcessSetTableOperator (implements org.apache.flink.streaming.api.operators.MultipleInputStreamOperator<OUT>)
    • org.apache.flink.table.runtime.operators.process.RepeatedRowData (implements org.apache.flink.table.data.RowData)
    • org.apache.flink.table.runtime.operators.process.RuntimeChangelogMode (implements java.io.Serializable)
    • org.apache.flink.table.runtime.operators.process.RuntimeStateInfo (implements java.io.Serializable)
    • org.apache.flink.table.runtime.operators.process.RuntimeTableSemantics (implements java.io.Serializable, org.apache.flink.table.functions.TableSemantics)
    • org.apache.flink.table.runtime.util.StreamRecordCollector<T> (implements org.apache.flink.util.Collector<T>)