java.lang.Object
com.pervasive.datarush.operators.AbstractLogicalOperator
com.pervasive.datarush.operators.CompositeOperator
com.pervasive.datarush.matching.tune.AnalyzeDuplicateKeys
- All Implemented Interfaces:
LogicalOperator
Provides an analysis of the quality of a set of blocking keys
over data to be deduplicated.
As each record in a given block must be compared to every other
record in the block during deduplication, the smaller the block
sizes, the better the performance. This
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprotected voidCompose the body of this operator.Gets the fields to use for key blocking.getInput()Gets the record port providing the input data to analyze.voidsetBlockingKeys(List<String> keys) Sets the fields to use for key blocking.Methods inherited from class com.pervasive.datarush.operators.AbstractLogicalOperator
disableParallelism, getInputPorts, getOutputPorts, newInput, newInput, newOutput, newRecordInput, newRecordInput, newRecordOutput, notifyError
-
Constructor Details
-
AnalyzeDuplicateKeys
public AnalyzeDuplicateKeys()Analyzes the data without blocking keys. In this case, the data is one giant block. Set the blocking keys usingsetBlockingKeys(List)
-
-
Method Details
-
getInput
Gets the record port providing the input data to analyze.- Returns:
- the input port for the operation
-
getBlockingKeys
Gets the fields to use for key blocking.- Returns:
- the blocking keys
-
setBlockingKeys
Sets the fields to use for key blocking.- Parameters:
keys- the blocking keys
-
compose
Description copied from class:CompositeOperatorCompose the body of this operator. Implementations should do the following:- Perform any validation of configuration, input types, etc
- Instantiate and configure sub-operators, adding them to the provided context via
the method
OperatorComposable.add(O) - Create necessary connections via the method
OperatorComposable.connect(P, P). This includes connections from the composite's input ports to sub-operators, connections between sub-operators, and connections from sub-operators output ports to the composite's output ports
- Specified by:
composein classCompositeOperator- Parameters:
ctx- the context
-