Skip to content

Commit

Permalink
Merge pull request #726 from gnanaprakash-ravi/z4-317
Browse files Browse the repository at this point in the history
remove deterministicMatching oss
  • Loading branch information
sonalgoyal authored Nov 21, 2023
2 parents 4bdff77 + f966115 commit 5659bbf
Show file tree
Hide file tree
Showing 5 changed files with 0 additions and 210 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,6 @@
import org.apache.commons.logging.LogFactory;
import org.junit.jupiter.api.Test;

import zingg.enterprise.common.client.DeterministicMatching;

public class TestArguments {

Expand Down
48 changes: 0 additions & 48 deletions docs/stepbystep/configuration/deterministicMatching.md

This file was deleted.

5 changes: 0 additions & 5 deletions examples/febrl/FebrlExample.py
Original file line number Diff line number Diff line change
Expand Up @@ -32,11 +32,6 @@
args.setData(inputPipe)
outputPipe = CsvPipe("resultFebrl", "/tmp/febrlOutput")

dm1 = DeterministicMatching('fname','stNo','add1')
dm2 = DeterministicMatching('ssn')
dm3 = DeterministicMatching('fname','stNo','lname')
args.setDeterministicMatchingCondition(dm1,dm2,dm3)

args.setOutput(outputPipe)

options = ClientOptions([ClientOptions.PHASE,"match"])
Expand Down
130 changes: 0 additions & 130 deletions examples/febrl/configDeterministicMatching.json

This file was deleted.

26 changes: 0 additions & 26 deletions python/zingg/client.py
Original file line number Diff line number Diff line change
Expand Up @@ -367,21 +367,6 @@ class ZinggWithSpark(Zingg):
def __init__(self, args, options):
self.client = getJVM().zingg.spark.client.SparkClient(args.getArgs(), options.getClientOptions(), getSparkSession()._jsparkSession)


class DeterministicMatching:
def __init__(self,*matchCond):
fieldNamesArray = getGateway().new_array(getJVM().java.lang.String, len(matchCond))
for idx, fieldName in enumerate(matchCond):
fieldNamesArray[idx] = fieldName
self.deterministicMatching = getJVM().zingg.common.client.DeterministicMatching(fieldNamesArray)

def getDeterministicMatching(self):
""" Method to getDeterministicMatching
:return: DeterministicMatching parameter value
:rtype: DeterministicMatching
"""
return self.deterministicMatching

class Arguments:
""" This class helps supply match arguments to Zingg. There are 3 basic steps in any match process.
Expand Down Expand Up @@ -490,17 +475,6 @@ def setModelId(self, id):
def getModelId(self):
return self.args.getModelId()

def setDeterministicMatchingCondition(self, *detMatchConds):
""" Method to set the DeterministicMatchingCondition used for matching
:param detMatchConds: DeterministicMatching object
:type detMatchConds: DeterministicMatching
"""

detMatchCondArr = getGateway().new_array(getJVM().zingg.common.client.DeterministicMatching, len(detMatchConds))
for idx, detM in enumerate(detMatchConds):
detMatchCondArr[idx] = detM.getDeterministicMatching()
self.args.setDeterministicMatching(detMatchCondArr)

def setZinggDir(self, f):
""" Method to set the location for Zingg to save its internal computations and models. Please set it to a place where the program has to write access.
Expand Down

0 comments on commit 5659bbf

Please sign in to comment.