Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

remove deterministicMatching oss #726

Merged
merged 1 commit into from
Nov 21, 2023
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
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