Package org.apache.iceberg.flink.sink.shuffle

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>