5
5
import java .io .*;
6
6
import java .util .concurrent .*;
7
7
import java .util .concurrent .ThreadPoolExecutor .CallerRunsPolicy ;
8
- import java .util .concurrent .atomic .AtomicInteger ;
9
8
import edu .tsinghua .dbgroup .*;
10
9
public class EditDistanceJoiner {
11
10
private List <String > mStrings ;
@@ -16,8 +15,6 @@ public class EditDistanceJoiner {
16
15
private int mMaxLength ;
17
16
private ArrayList <EditDistanceJoinResult > mResults ;
18
17
private ArrayList <FilteredRawResult > mRawResults ;
19
- AtomicInteger _left_cnt = new AtomicInteger ();
20
- AtomicInteger _right_cnt = new AtomicInteger ();
21
18
static class UnfilteredResult {
22
19
public int dstId ;
23
20
public int dstMatchPos ;
@@ -208,8 +205,6 @@ public int compare(FilteredRawResult o1, FilteredRawResult o2) {
208
205
r .similarity = rawResult .similarity ;
209
206
mResults .add (r );
210
207
}
211
- System .err .println ("" + resultsBeforeRefiningNum + " to " + mResults .size ());
212
- System .err .println ("left " + _left_cnt .get () + " right " + _right_cnt .get ());
213
208
return mResults ;
214
209
}
215
210
private void getResultsFromIndex (int srcId , ArrayList <UnfilteredResult > resultsBeforeRefining ){
@@ -231,7 +226,6 @@ private void getResultsFromIndex(int srcId, ArrayList<UnfilteredResult> resultsB
231
226
candidateGramPos + delta - gramNo + mThreshold ), srcLen - candidateGramLen );
232
227
for (; startPos <= endPos ; startPos ++) {
233
228
String gram = src .substring (startPos , startPos + candidateGramLen );
234
- //System.err.println("dstLen " + dstLen + " gramNo " + gramNo + " gram " + gram);
235
229
ArrayList <Integer > invertedList = mGlobalIndex .get (dstLen ).get (gramNo ).get (gram );
236
230
if (invertedList != null ) {
237
231
for (int k = 0 ; k < invertedList .size (); k ++) {
@@ -260,14 +254,12 @@ public int compare(UnfilteredResult a, UnfilteredResult b) {
260
254
}
261
255
private int filterCandidate (String src , String dst , int srcMatchPos , int dstMatchPos , int len ,
262
256
int [][] distanceBuffer ){
263
- //System.err.println(src + " : " + dst + " : " + src.substring(srcMatchPos, srcMatchPos + len));
264
257
int srcRightLen = src .length () - srcMatchPos - len ;
265
258
int dstRightLen = dst .length () - dstMatchPos - len ;
266
259
int leftThreshold = mThreshold - Math .abs (srcRightLen - dstRightLen );
267
260
int leftDistance = calculateEditDistanceWithThreshold (src , 0 , srcMatchPos ,
268
261
dst , 0 , dstMatchPos ,
269
262
leftThreshold , distanceBuffer );
270
- _left_cnt .getAndIncrement ();
271
263
if (leftDistance > leftThreshold ) {
272
264
return -1 ;
273
265
}
@@ -276,7 +268,6 @@ private int filterCandidate(String src, String dst, int srcMatchPos, int dstMatc
276
268
src , srcMatchPos + len , src .length () - srcMatchPos - len ,
277
269
dst , dstMatchPos + len , dst .length () - dstMatchPos - len ,
278
270
rightThreshold , distanceBuffer );
279
- _right_cnt .getAndIncrement ();
280
271
if (rightDistance > rightThreshold ) {
281
272
return -1 ;
282
273
}
0 commit comments