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

Class DataStatisticsOperatorFactory

java.lang.Object

org.apache.flink.streaming.api.operators.AbstractStreamOperatorFactory<StatisticsOrRecord>

org.apache.iceberg.flink.sink.shuffle.DataStatisticsOperatorFactory

All Implemented Interfaces:

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

Constructor Summary

Constructors

Constructor	Description
DataStatisticsOperatorFactory(Schema schema, SortOrder sortOrder, int downstreamParallelism, StatisticsType type, double closeFileCostWeightPercentage)

Method Summary

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(String operatorName, org.apache.flink.runtime.jobgraph.OperatorID operatorID)
Class<? extends org.apache.flink.streaming.api.operators.StreamOperator>	getStreamOperatorClass(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 Details

DataStatisticsOperatorFactory

public DataStatisticsOperatorFactory(Schema schema,
 SortOrder sortOrder,
 int downstreamParallelism,
 StatisticsType type,
 double closeFileCostWeightPercentage)

Method Details

getCoordinatorProvider

public org.apache.flink.runtime.operators.coordination.OperatorCoordinator.Provider getCoordinatorProvider(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 Class<? extends org.apache.flink.streaming.api.operators.StreamOperator> getStreamOperatorClass(ClassLoader classLoader)

Specified by:

getStreamOperatorClass in interface org.apache.flink.streaming.api.operators.StreamOperatorFactory<StatisticsOrRecord>