Class DataStatisticsOperatorFactory

  • All Implemented Interfaces:
    java.io.Serializable, org.apache.flink.streaming.api.operators.CoordinatedOperatorFactory<StatisticsOrRecord>, org.apache.flink.streaming.api.operators.OneInputStreamOperatorFactory<org.apache.flink.table.data.RowData,​StatisticsOrRecord>, org.apache.flink.streaming.api.operators.StreamOperatorFactory<StatisticsOrRecord>, org.apache.flink.streaming.runtime.tasks.ProcessingTimeServiceAware

    @Internal
    public class DataStatisticsOperatorFactory
    extends org.apache.flink.streaming.api.operators.AbstractStreamOperatorFactory<StatisticsOrRecord>
    implements org.apache.flink.streaming.api.operators.CoordinatedOperatorFactory<StatisticsOrRecord>, org.apache.flink.streaming.api.operators.OneInputStreamOperatorFactory<org.apache.flink.table.data.RowData,​StatisticsOrRecord>
    See Also:
    Serialized Form
    • Field Summary

      • Fields inherited from class org.apache.flink.streaming.api.operators.AbstractStreamOperatorFactory

        chainingStrategy, processingTimeService
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      <T extends org.apache.flink.streaming.api.operators.StreamOperator<StatisticsOrRecord>>
      T
      createStreamOperator​(org.apache.flink.streaming.api.operators.StreamOperatorParameters<StatisticsOrRecord> parameters)  
      org.apache.flink.runtime.operators.coordination.OperatorCoordinator.Provider getCoordinatorProvider​(java.lang.String operatorName, org.apache.flink.runtime.jobgraph.OperatorID operatorID)  
      java.lang.Class<? extends org.apache.flink.streaming.api.operators.StreamOperator> getStreamOperatorClass​(java.lang.ClassLoader classLoader)  
      • Methods inherited from class org.apache.flink.streaming.api.operators.AbstractStreamOperatorFactory

        getChainingStrategy, getMailboxExecutor, setChainingStrategy, setMailboxExecutor, setProcessingTimeService
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
      • Methods inherited from interface org.apache.flink.streaming.api.operators.StreamOperatorFactory

        getChainingStrategy, getOperatorAttributes, isInputTypeConfigurable, isLegacySource, isOutputTypeConfigurable, isStreamSource, setChainingStrategy, setInputType, setOutputType
    • Constructor Detail

      • DataStatisticsOperatorFactory

        public DataStatisticsOperatorFactory​(Schema schema,
                                             SortOrder sortOrder,
                                             int downstreamParallelism,
                                             StatisticsType type,
                                             double closeFileCostWeightPercentage)
    • Method Detail

      • getCoordinatorProvider

        public org.apache.flink.runtime.operators.coordination.OperatorCoordinator.Provider getCoordinatorProvider​(java.lang.String operatorName,
                                                                                                                   org.apache.flink.runtime.jobgraph.OperatorID operatorID)
        Specified by:
        getCoordinatorProvider in interface org.apache.flink.streaming.api.operators.CoordinatedOperatorFactory<StatisticsOrRecord>
      • createStreamOperator

        public <T extends org.apache.flink.streaming.api.operators.StreamOperator<StatisticsOrRecord>> T createStreamOperator​(org.apache.flink.streaming.api.operators.StreamOperatorParameters<StatisticsOrRecord> parameters)
        Specified by:
        createStreamOperator in interface org.apache.flink.streaming.api.operators.CoordinatedOperatorFactory<StatisticsOrRecord>
        Specified by:
        createStreamOperator in interface org.apache.flink.streaming.api.operators.StreamOperatorFactory<StatisticsOrRecord>
      • getStreamOperatorClass

        public java.lang.Class<? extends org.apache.flink.streaming.api.operators.StreamOperator> getStreamOperatorClass​(java.lang.ClassLoader classLoader)
        Specified by:
        getStreamOperatorClass in interface org.apache.flink.streaming.api.operators.StreamOperatorFactory<StatisticsOrRecord>