de.uni_mannheim.informatik.dws.winter.datafusion

Class DataFusionEngine<RecordType extends Matchable & Fusible<SchemaElementType>,SchemaElementType extends Matchable>

java.lang.Object

de.uni_mannheim.informatik.dws.winter.datafusion.DataFusionEngine<RecordType,SchemaElementType>

Type Parameters:

RecordType - the type that represents a record

public class DataFusionEngine<RecordType extends Matchable & Fusible<SchemaElementType>,SchemaElementType extends Matchable>
extends Object

Executer class to run the data fusion based on a selected DataFusionStrategy.

Author:

Oliver Lehmberg (oli@dwslab.de)

Constructor Summary

Constructors

Constructor and Description
DataFusionEngine(DataFusionStrategy<RecordType,SchemaElementType> strategy) Creates a new instance that uses the specified data fusion strategy.

Method Summary

Modifier and Type	Method and Description
Map<String,Double>	getAttributeConsistencies(CorrespondenceSet<RecordType,SchemaElementType> correspondences, Processable<Correspondence<SchemaElementType,Matchable>> schemaCorrespondences) Calculates the consistencies of the attributes of the records in the given correspondence set according to the data fusion strategy
Set<Pair<RecordGroup<RecordType,SchemaElementType>,Double>>	getRecordGroupConsistencies(CorrespondenceSet<RecordType,SchemaElementType> correspondences, Processable<Correspondence<SchemaElementType,Matchable>> schemaCorrespondences) Calculates the consistencies of the record groups in the given correspondence set according to the data fusion strategy
DataFusionStrategy<RecordType,SchemaElementType>	getStrategy()
void	printClusterConsistencyReport(CorrespondenceSet<RecordType,SchemaElementType> correspondences, Processable<Correspondence<SchemaElementType,Matchable>> schemaCorrespondences) Calculates the consistencies of the attributes of the records in the given correspondence set according to the data fusion strategy and prints the results to the console
FusibleDataSet<RecordType,SchemaElementType>	run(CorrespondenceSet<RecordType,SchemaElementType> correspondences, Processable<Correspondence<SchemaElementType,Matchable>> schemaCorrespondences) Runs the data fusion process on the provided set of correspondences and returns a fused data set
void	writeRecordGroupsByConsistency(File path, CorrespondenceSet<RecordType,SchemaElementType> correspondences, Processable<Correspondence<SchemaElementType,Matchable>> schemaCorrespondences)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DataFusionEngine

public DataFusionEngine(DataFusionStrategy<RecordType,SchemaElementType> strategy)

Creates a new instance that uses the specified data fusion strategy.

Parameters:

strategy - the fusion strategy

Method Detail

getStrategy

public DataFusionStrategy<RecordType,SchemaElementType> getStrategy()

Returns:

the strategy

run

public FusibleDataSet<RecordType,SchemaElementType> run(CorrespondenceSet<RecordType,SchemaElementType> correspondences,
                                                        Processable<Correspondence<SchemaElementType,Matchable>> schemaCorrespondences)

Runs the data fusion process on the provided set of correspondences and returns a fused data set

Parameters:

correspondences - correspondences between the records

schemaCorrespondences - optional schema correspondences between the records

Returns:

a FusibleDataSet based on the RecordType of the CorrespondenceSet

getAttributeConsistencies

public Map<String,Double> getAttributeConsistencies(CorrespondenceSet<RecordType,SchemaElementType> correspondences,
                                                    Processable<Correspondence<SchemaElementType,Matchable>> schemaCorrespondences)

Calculates the consistencies of the attributes of the records in the given correspondence set according to the data fusion strategy

Parameters:

correspondences - correspondences between the records

schemaCorrespondences - correspondences between the schema elements

Returns:

A map with the attribute consistency values ("attribute" -> consistency)

getRecordGroupConsistencies

public Set<Pair<RecordGroup<RecordType,SchemaElementType>,Double>> getRecordGroupConsistencies(CorrespondenceSet<RecordType,SchemaElementType> correspondences,
                                                                                               Processable<Correspondence<SchemaElementType,Matchable>> schemaCorrespondences)

Calculates the consistencies of the record groups in the given correspondence set according to the data fusion strategy

Parameters:

correspondences - correspondences between the records

schemaCorrespondences - correspondences between the schema elements

Returns:

A map with the attribute consistency values ("attribute" -> consistency)

printClusterConsistencyReport

public void printClusterConsistencyReport(CorrespondenceSet<RecordType,SchemaElementType> correspondences,
                                          Processable<Correspondence<SchemaElementType,Matchable>> schemaCorrespondences)

Calculates the consistencies of the attributes of the records in the given correspondence set according to the data fusion strategy and prints the results to the console

Parameters:

correspondences - correspondences between the records

schemaCorrespondences - correspondences between the schema elements

writeRecordGroupsByConsistency

public void writeRecordGroupsByConsistency(File path,
                                           CorrespondenceSet<RecordType,SchemaElementType> correspondences,
                                           Processable<Correspondence<SchemaElementType,Matchable>> schemaCorrespondences)
                                    throws IOException

Throws:

IOException