public class DataNormalizerImpl extends Object implements DataNormalizer, Serializable
Modifier and Type | Class and Description |
---|---|
class |
DataNormalizerImpl.GraphModificationImpl
The collection of all modifications done to a graph (grouped by the rules that did them, divided into two groups: Insertions, Deletions)
|
class |
DataNormalizerImpl.RuleModificationImpl
Collection of all the insertions and deletions that were applied by a certain rule
|
static class |
DataNormalizerImpl.SerializableTransformationContext
Serialized version needed for serialization in frontend for example
|
static class |
DataNormalizerImpl.SerializableTransformedGraph
Serialized version needed for serialization in frontend for example
|
class |
DataNormalizerImpl.TripleModificationImpl
Triple that has either been deleted or inserted to a graph in one step of the normalization process
|
DataNormalizer.GraphModification, DataNormalizer.RuleModification, DataNormalizer.TripleModification
Constructor and Description |
---|
DataNormalizerImpl(Integer... groupIds)
constructs new data normalizer
|
DataNormalizerImpl(String... groupLabels)
constructs new data normalizer
|
Modifier and Type | Method and Description |
---|---|
List<DataNormalizer.GraphModification> |
debugRules(HashMap<String,String> graphs,
TransformationContext context,
TableVersion tableVersion)
collects information about graph transformations
|
DataNormalizer.GraphModification |
getGraphModifications(String graphName,
JDBCConnectionCredentials clean,
JDBCConnectionCredentials source,
TableVersion tableVersion)
collects modifications that are done to the given graph
|
void |
shutdown()
Called when the instance of the transformer is no longer needed.
|
void |
transformGraph(TransformedGraph inputGraph,
TransformationContext context)
Transforms graph.
|
public DataNormalizerImpl(Integer... groupIds)
groupIds
- the IDs of the rule groups to be used by the new instancepublic DataNormalizerImpl(String... groupLabels)
groupIds
- the Labels of the rule groups to be used by the new instancepublic List<DataNormalizer.GraphModification> debugRules(HashMap<String,String> graphs, TransformationContext context, TableVersion tableVersion) throws TransformerException
debugRules
in interface DataNormalizer
graphs
- input graphscontext
- context containing clean and dirty database connection credentialstableVersion
- specifies which version of rule tables will be used (committed / uncommitted)TransformerException
public void transformGraph(TransformedGraph inputGraph, TransformationContext context) throws TransformerException
transformGraph
in interface Transformer
inputGraph
- the graph to be transformedcontext
- the context specifying the connection credentialsTransformerException
- exceptionpublic DataNormalizer.GraphModification getGraphModifications(String graphName, JDBCConnectionCredentials clean, JDBCConnectionCredentials source, TableVersion tableVersion) throws TransformerException
graphName
- name of the graph to be transformedclean
- the clean database connection credentialssource
- the source database (the one where the transformed graph is - normally dirty database) connection credentialsTransformerException
public void shutdown() throws TransformerException
Transformer
shutdown
in interface Transformer
TransformerException
- exceptionCopyright © 2013. All Rights Reserved.