org.apache.flink.table.runtime.operators.dynamicfiltering

Class DynamicFilteringDataCollectorOperatorFactory

java.lang.Object

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

org.apache.flink.table.runtime.operators.dynamicfiltering.DynamicFilteringDataCollectorOperatorFactory

All Implemented Interfaces:

Serializable, CoordinatedOperatorFactory<Object>, StreamOperatorFactory<Object>, ProcessingTimeServiceAware

public class DynamicFilteringDataCollectorOperatorFactory
extends AbstractStreamOperatorFactory<Object>
implements CoordinatedOperatorFactory<Object>

The factory class for DynamicFilteringDataCollectorOperator.

See Also:

Serialized Form

Field Summary

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

chainingStrategy, processingTimeService

Constructor Summary

Constructors

Constructor and Description
DynamicFilteringDataCollectorOperatorFactory(RowType dynamicFilteringFieldType, List<Integer> dynamicFilteringFieldIndices, long threshold)

Method Summary

Modifier and Type	Method and Description
<T extends StreamOperator<Object>> T	createStreamOperator(StreamOperatorParameters<Object> parameters) The implementation should return an instance of OperatorEventHandler.
OperatorCoordinator.Provider	getCoordinatorProvider(String operatorName, OperatorID operatorID) Get the operator coordinator provider for this operator.
Class<? extends StreamOperator>	getStreamOperatorClass(ClassLoader classLoader) Returns the runtime class of the stream operator.
void	registerDynamicFilteringDataListenerID(String id)

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, isInputTypeConfigurable, isLegacySource, isOutputTypeConfigurable, isStreamSource, setChainingStrategy, setInputType, setOutputType

Constructor Detail

DynamicFilteringDataCollectorOperatorFactory

public DynamicFilteringDataCollectorOperatorFactory(RowType dynamicFilteringFieldType,
                                                    List<Integer> dynamicFilteringFieldIndices,
                                                    long threshold)

Method Detail

createStreamOperator

public <T extends StreamOperator<Object>> T createStreamOperator(StreamOperatorParameters<Object> parameters)

Description copied from interface: CoordinatedOperatorFactory

The implementation should return an instance of OperatorEventHandler.

Specified by:

createStreamOperator in interface CoordinatedOperatorFactory<Object>

Specified by:

createStreamOperator in interface StreamOperatorFactory<Object>

registerDynamicFilteringDataListenerID

public void registerDynamicFilteringDataListenerID(String id)

getStreamOperatorClass

public Class<? extends StreamOperator> getStreamOperatorClass(ClassLoader classLoader)

Description copied from interface: StreamOperatorFactory

Returns the runtime class of the stream operator.

Specified by:

getStreamOperatorClass in interface StreamOperatorFactory<Object>

getCoordinatorProvider

public OperatorCoordinator.Provider getCoordinatorProvider(String operatorName,
                                                           OperatorID operatorID)

Description copied from interface: CoordinatedOperatorFactory

Get the operator coordinator provider for this operator.

Specified by:

getCoordinatorProvider in interface CoordinatedOperatorFactory<Object>

Parameters:

operatorName - the name of the operator.

operatorID - the id of the operator.

Returns:

the provider of the OperatorCoordinator for this operator.