Skip to content

Commit

Permalink
Merge pull request #2 from nikcomestotalk/Refactoring
Browse files Browse the repository at this point in the history
Refactoring of code
  • Loading branch information
nikcomestotalk authored Jan 19, 2018
2 parents 34cbbf1 + 885a38e commit 0e55f5b
Show file tree
Hide file tree
Showing 48 changed files with 511 additions and 1,362 deletions.
15 changes: 15 additions & 0 deletions config/config.properties
Original file line number Diff line number Diff line change
@@ -0,0 +1,15 @@
application.debug=true
listener.port= 1081
listener.limit= 10
listener.url = /query
updater.port= 1082
updater.url = /update
searchstorage.path= store
searchstorage.name= search.bin
main.basedir=${main.basedir}
#recover.method=serialize
recover.method.serialize.path=/suggest/content/search.bin
recover.method=file
recover.method.file.days=1
recover.method.file.backup.path=/suggest/content/backup/
stopwords.path = /suggest/config/stopwords.txt
File renamed without changes.
6 changes: 0 additions & 6 deletions content/config.properties

This file was deleted.

Binary file removed content/search.bin
Binary file not shown.
91 changes: 0 additions & 91 deletions example/demo.html

This file was deleted.

71 changes: 0 additions & 71 deletions example/newData.php

This file was deleted.

52 changes: 0 additions & 52 deletions example/populateData.php

This file was deleted.

8 changes: 0 additions & 8 deletions example/pos_loc.txt

This file was deleted.

57 changes: 0 additions & 57 deletions example/randomData.php

This file was deleted.

62 changes: 19 additions & 43 deletions src/main/java/com/search/suggestion/TextSuggestor.java
Original file line number Diff line number Diff line change
Expand Up @@ -6,64 +6,40 @@
import com.search.suggestion.listener.SearchListener;
import com.search.suggestion.socket.ServerHandler;
import com.search.suggestion.text.analyze.SuggestAnalyzer;
import com.search.suggestion.text.backup.SerializeDump;
import com.search.suggestion.text.recover.Recover;
import com.search.suggestion.text.recover.RecoverFactory;
import com.search.suggestion.updater.SearchUpdater;
import com.search.suggestion.util.BackupTree;
import com.search.suggestion.text.recover.RecoverFromText;

import java.io.IOException;
import java.util.ArrayList;
import java.util.List;

public final class TextSuggestor
{
private TextSuggestor() { }

public static void main(String[] args) throws IOException {
public static void main(String[] args) throws IOException, InterruptedException {

/* List<String> a = new ArrayList<String>();
a.add("HI");
a.add("HasdfaI");
a.add("asdfa");
String b = String.join("<",a);
a.clear();*/
SearchEngine<SuggestPayload> suggest = new SearchEngine.Builder<SuggestPayload>()
SearchEngine<SuggestPayload> suggestCurrent = new SearchEngine.Builder<SuggestPayload>()
.setIndex(new SuggestAdapter())
.setAnalyzer(new SuggestAnalyzer())
.build();

SearchEngine<SuggestPayload> suggestFuture = new SearchEngine.Builder<SuggestPayload>()
.setIndex(new SuggestAdapter())
.setAnalyzer(new SuggestAnalyzer())
.build();

BackupTree backupTree = new BackupTree(suggest);
backupTree.updateIndexer();

Recover recover = RecoverFactory.getInstance(suggestCurrent, suggestFuture);
recover.updateIndexer();
recover.swap();
ServerHandler serverHandler = new ServerHandler();
(new SearchUpdater(suggest)).startService(serverHandler);
(new SearchUpdater(suggestCurrent)).startService(serverHandler);

(new SearchListener(suggestCurrent)).startService(serverHandler);

(new SearchListener(suggest)).startService(serverHandler);
(new Thread(new SerializeDump(suggestCurrent))).start();

(new Thread(backupTree)).start();
}
}
/* Map<String, Integer> m = new HashMap<String,Integer>();
m.put("user",1);
m.put("category",12);
m.put("location",14);
SuggestPayload sr = new SuggestPayload("name nikhil", m);
Map<String, Integer> m1 = new HashMap<String,Integer>();
m1.put("user",2);
m1.put("category",12);
m1.put("location",10);
SuggestPayload sr1 = new SuggestPayload("dhiman nicks",m1);
Map<String, Integer> m2 = new HashMap<String,Integer>();
m2.put("user",1);
m2.put("category",10);
m2.put("location",14);
SuggestPayload sr2 = new SuggestPayload("nik dhiemn who",m2);
suggest.add(sr);
//suggest.add(sr1);
suggest.add(sr2);
Map<String, Integer> msearch = new HashMap<String,Integer>();
msearch.put("user",1);
msearch.put("category",10);
msearch.put("location",14);
SuggestPayload search = new SuggestPayload("ni", m);*/

//System.out.println(suggest.search(search));
Loading

0 comments on commit 0e55f5b

Please sign in to comment.