Class DataStatisticsOperatorFactory
- java.lang.Object
-
- org.apache.flink.streaming.api.operators.AbstractStreamOperatorFactory<StatisticsOrRecord>
-
- org.apache.iceberg.flink.sink.shuffle.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
-
-
Constructor Summary
Constructors Constructor Description DataStatisticsOperatorFactory(Schema schema, SortOrder sortOrder, int downstreamParallelism, StatisticsType type, double closeFileCostWeightPercentage)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description <T extends org.apache.flink.streaming.api.operators.StreamOperator<StatisticsOrRecord>>
TcreateStreamOperator(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
-
-
-
-
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 interfaceorg.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 interfaceorg.apache.flink.streaming.api.operators.CoordinatedOperatorFactory<StatisticsOrRecord>
- Specified by:
createStreamOperator
in interfaceorg.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 interfaceorg.apache.flink.streaming.api.operators.StreamOperatorFactory<StatisticsOrRecord>
-
-