Skip to content

D
DS_Project_Part1
Commit 58cc723c authored by Ali Saeed's avatar Ali Saeed
Browse files
Options

Project part 1

parents
Hide whitespace changes
Inline Side-by-side
Showing with 1817 additions and 0 deletions
Notes.pdf 0 → 100644
View file @ 58cc723c
File added
registration-discovery-leader-reelection-cordinator-workers/.idea/artifacts/Service_Registration_and_Discovery_jar.xml 0 → 100644
View file @ 58cc723c
<component name="ArtifactManager">
<artifact type="jar" name="Service-Registration-and-Discovery:jar">
<output-path>$PROJECT_DIR$/out/artifacts/Service_Registration_and_Discovery_jar</output-path>
<root id="archive" name="Service-Registration-and-Discovery.jar">
<element id="module-output" name="Service-Registration-and-Discovery" />
<element id="extracted-dir" path="$MAVEN_REPOSITORY$/io/netty/netty-tcnative-boringssl-static/2.0.61.Final/netty-tcnative-boringssl-static-2.0.61.Final-osx-aarch_64.jar" path-in-jar="/" />
<element id="extracted-dir" path="$MAVEN_REPOSITORY$/io/netty/netty-tcnative-boringssl-static/2.0.61.Final/netty-tcnative-boringssl-static-2.0.61.Final-linux-aarch_64.jar" path-in-jar="/" />
<element id="extracted-dir" path="$MAVEN_REPOSITORY$/commons-io/commons-io/2.11.0/commons-io-2.11.0.jar" path-in-jar="/" />
<element id="extracted-dir" path="$MAVEN_REPOSITORY$/io/netty/netty-common/4.1.94.Final/netty-common-4.1.94.Final.jar" path-in-jar="/" />
<element id="extracted-dir" path="$MAVEN_REPOSITORY$/io/netty/netty-transport-native-epoll/4.1.94.Final/netty-transport-native-epoll-4.1.94.Final-linux-x86_64.jar" path-in-jar="/" />
<element id="extracted-dir" path="$MAVEN_REPOSITORY$/org/apache/zookeeper/zookeeper-jute/3.9.1/zookeeper-jute-3.9.1.jar" path-in-jar="/" />
<element id="extracted-dir" path="$MAVEN_REPOSITORY$/ch/qos/logback/logback-classic/1.2.10/logback-classic-1.2.10.jar" path-in-jar="/" />
<element id="extracted-dir" path="$MAVEN_REPOSITORY$/io/netty/netty-tcnative-boringssl-static/2.0.61.Final/netty-tcnative-boringssl-static-2.0.61.Final-osx-x86_64.jar" path-in-jar="/" />
<element id="extracted-dir" path="$MAVEN_REPOSITORY$/org/slf4j/slf4j-api/1.7.30/slf4j-api-1.7.30.jar" path-in-jar="/" />
<element id="extracted-dir" path="$MAVEN_REPOSITORY$/org/apache/yetus/audience-annotations/0.12.0/audience-annotations-0.12.0.jar" path-in-jar="/" />
<element id="extracted-dir" path="$MAVEN_REPOSITORY$/io/netty/netty-tcnative-classes/2.0.61.Final/netty-tcnative-classes-2.0.61.Final.jar" path-in-jar="/" />
<element id="extracted-dir" path="$MAVEN_REPOSITORY$/io/netty/netty-buffer/4.1.94.Final/netty-buffer-4.1.94.Final.jar" path-in-jar="/" />
<element id="extracted-dir" path="$MAVEN_REPOSITORY$/io/netty/netty-codec/4.1.94.Final/netty-codec-4.1.94.Final.jar" path-in-jar="/" />
<element id="extracted-dir" path="$MAVEN_REPOSITORY$/io/netty/netty-transport-classes-epoll/4.1.94.Final/netty-transport-classes-epoll-4.1.94.Final.jar" path-in-jar="/" />
<element id="extracted-dir" path="$MAVEN_REPOSITORY$/org/apache/zookeeper/zookeeper/3.9.1/zookeeper-3.9.1.jar" path-in-jar="/" />
<element id="extracted-dir" path="$MAVEN_REPOSITORY$/io/netty/netty-tcnative-boringssl-static/2.0.61.Final/netty-tcnative-boringssl-static-2.0.61.Final.jar" path-in-jar="/" />
<element id="extracted-dir" path="$MAVEN_REPOSITORY$/io/netty/netty-transport-native-unix-common/4.1.94.Final/netty-transport-native-unix-common-4.1.94.Final.jar" path-in-jar="/" />
<element id="extracted-dir" path="$MAVEN_REPOSITORY$/io/netty/netty-tcnative-boringssl-static/2.0.61.Final/netty-tcnative-boringssl-static-2.0.61.Final-linux-x86_64.jar" path-in-jar="/" />
<element id="extracted-dir" path="$MAVEN_REPOSITORY$/ch/qos/logback/logback-core/1.2.10/logback-core-1.2.10.jar" path-in-jar="/" />
<element id="extracted-dir" path="$MAVEN_REPOSITORY$/io/netty/netty-resolver/4.1.94.Final/netty-resolver-4.1.94.Final.jar" path-in-jar="/" />
<element id="extracted-dir" path="$MAVEN_REPOSITORY$/io/netty/netty-transport/4.1.94.Final/netty-transport-4.1.94.Final.jar" path-in-jar="/" />
<element id="extracted-dir" path="$MAVEN_REPOSITORY$/io/netty/netty-tcnative-boringssl-static/2.0.61.Final/netty-tcnative-boringssl-static-2.0.61.Final-windows-x86_64.jar" path-in-jar="/" />
<element id="extracted-dir" path="$MAVEN_REPOSITORY$/io/netty/netty-handler/4.1.94.Final/netty-handler-4.1.94.Final.jar" path-in-jar="/" />
</root>
</artifact>
</component>
\ No newline at end of file
registration-discovery-leader-reelection-cordinator-workers/.idea/compiler.xml 0 → 100644
View file @ 58cc723c
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="CompilerConfiguration">
<annotationProcessing>
<profile name="Maven default annotation processors profile" enabled="true">
<sourceOutputDir name="target/generated-sources/annotations" />
<sourceTestOutputDir name="target/generated-test-sources/test-annotations" />
<outputRelativeToContentRoot value="true" />
<module name="Service-Registration-and-Discovery" />
</profile>
</annotationProcessing>
</component>
</project>
\ No newline at end of file
registration-discovery-leader-reelection-cordinator-workers/.idea/encodings.xml 0 → 100644
View file @ 58cc723c
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="Encoding">
<file url="file://$PROJECT_DIR$/src/main/java" charset="UTF-8" />
<file url="file://$PROJECT_DIR$/src/main/resources" charset="UTF-8" />
</component>
</project>
\ No newline at end of file
registration-discovery-leader-reelection-cordinator-workers/.idea/jarRepositories.xml 0 → 100644
View file @ 58cc723c
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="RemoteRepositoriesConfiguration">
<remote-repository>
<option name="id" value="central" />
<option name="name" value="Central Repository" />
<option name="url" value="https://repo.maven.apache.org/maven2" />
</remote-repository>
<remote-repository>
<option name="id" value="central" />
<option name="name" value="Maven Central repository" />
<option name="url" value="https://repo1.maven.org/maven2" />
</remote-repository>
<remote-repository>
<option name="id" value="jboss.community" />
<option name="name" value="JBoss Community repository" />
<option name="url" value="https://repository.jboss.org/nexus/content/repositories/public/" />
</remote-repository>
</component>
</project>
\ No newline at end of file
registration-discovery-leader-reelection-cordinator-workers/.idea/misc.xml 0 → 100644
View file @ 58cc723c
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="ExternalStorageConfigurationManager" enabled="true" />
<component name="MavenProjectsManager">
<option name="originalFiles">
<list>
<option value="$PROJECT_DIR$/pom.xml" />
</list>
</option>
</component>
<component name="ProjectRootManager" version="2" languageLevel="JDK_17" default="true" project-jdk-name="17 (2)" project-jdk-type="JavaSDK" />
</project>
\ No newline at end of file
registration-discovery-leader-reelection-cordinator-workers/.idea/uiDesigner.xml 0 → 100644
View file @ 58cc723c
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="Palette2">
<group name="Swing">
<item class="com.intellij.uiDesigner.HSpacer" tooltip-text="Horizontal Spacer" icon="/com/intellij/uiDesigner/icons/hspacer.svg" removable="false" auto-create-binding="false" can-attach-label="false">
<default-constraints vsize-policy="1" hsize-policy="6" anchor="0" fill="1" />
</item>
<item class="com.intellij.uiDesigner.VSpacer" tooltip-text="Vertical Spacer" icon="/com/intellij/uiDesigner/icons/vspacer.svg" removable="false" auto-create-binding="false" can-attach-label="false">
<default-constraints vsize-policy="6" hsize-policy="1" anchor="0" fill="2" />
</item>
<item class="javax.swing.JPanel" icon="/com/intellij/uiDesigner/icons/panel.svg" removable="false" auto-create-binding="false" can-attach-label="false">
<default-constraints vsize-policy="3" hsize-policy="3" anchor="0" fill="3" />
</item>
<item class="javax.swing.JScrollPane" icon="/com/intellij/uiDesigner/icons/scrollPane.svg" removable="false" auto-create-binding="false" can-attach-label="true">
<default-constraints vsize-policy="7" hsize-policy="7" anchor="0" fill="3" />
</item>
<item class="javax.swing.JButton" icon="/com/intellij/uiDesigner/icons/button.svg" removable="false" auto-create-binding="true" can-attach-label="false">
<default-constraints vsize-policy="0" hsize-policy="3" anchor="0" fill="1" />
<initial-values>
<property name="text" value="Button" />
</initial-values>
</item>
<item class="javax.swing.JRadioButton" icon="/com/intellij/uiDesigner/icons/radioButton.svg" removable="false" auto-create-binding="true" can-attach-label="false">
<default-constraints vsize-policy="0" hsize-policy="3" anchor="8" fill="0" />
<initial-values>
<property name="text" value="RadioButton" />
</initial-values>
</item>
<item class="javax.swing.JCheckBox" icon="/com/intellij/uiDesigner/icons/checkBox.svg" removable="false" auto-create-binding="true" can-attach-label="false">
<default-constraints vsize-policy="0" hsize-policy="3" anchor="8" fill="0" />
<initial-values>
<property name="text" value="CheckBox" />
</initial-values>
</item>
<item class="javax.swing.JLabel" icon="/com/intellij/uiDesigner/icons/label.svg" removable="false" auto-create-binding="false" can-attach-label="false">
<default-constraints vsize-policy="0" hsize-policy="0" anchor="8" fill="0" />
<initial-values>
<property name="text" value="Label" />
</initial-values>
</item>
<item class="javax.swing.JTextField" icon="/com/intellij/uiDesigner/icons/textField.svg" removable="false" auto-create-binding="true" can-attach-label="true">
<default-constraints vsize-policy="0" hsize-policy="6" anchor="8" fill="1">
<preferred-size width="150" height="-1" />
</default-constraints>
</item>
<item class="javax.swing.JPasswordField" icon="/com/intellij/uiDesigner/icons/passwordField.svg" removable="false" auto-create-binding="true" can-attach-label="true">
<default-constraints vsize-policy="0" hsize-policy="6" anchor="8" fill="1">
<preferred-size width="150" height="-1" />
</default-constraints>
</item>
<item class="javax.swing.JFormattedTextField" icon="/com/intellij/uiDesigner/icons/formattedTextField.svg" removable="false" auto-create-binding="true" can-attach-label="true">
<default-constraints vsize-policy="0" hsize-policy="6" anchor="8" fill="1">
<preferred-size width="150" height="-1" />
</default-constraints>
</item>
<item class="javax.swing.JTextArea" icon="/com/intellij/uiDesigner/icons/textArea.svg" removable="false" auto-create-binding="true" can-attach-label="true">
<default-constraints vsize-policy="6" hsize-policy="6" anchor="0" fill="3">
<preferred-size width="150" height="50" />
</default-constraints>
</item>
<item class="javax.swing.JTextPane" icon="/com/intellij/uiDesigner/icons/textPane.svg" removable="false" auto-create-binding="true" can-attach-label="true">
<default-constraints vsize-policy="6" hsize-policy="6" anchor="0" fill="3">
<preferred-size width="150" height="50" />
</default-constraints>
</item>
<item class="javax.swing.JEditorPane" icon="/com/intellij/uiDesigner/icons/editorPane.svg" removable="false" auto-create-binding="true" can-attach-label="true">
<default-constraints vsize-policy="6" hsize-policy="6" anchor="0" fill="3">
<preferred-size width="150" height="50" />
</default-constraints>
</item>
<item class="javax.swing.JComboBox" icon="/com/intellij/uiDesigner/icons/comboBox.svg" removable="false" auto-create-binding="true" can-attach-label="true">
<default-constraints vsize-policy="0" hsize-policy="2" anchor="8" fill="1" />
</item>
<item class="javax.swing.JTable" icon="/com/intellij/uiDesigner/icons/table.svg" removable="false" auto-create-binding="true" can-attach-label="false">
<default-constraints vsize-policy="6" hsize-policy="6" anchor="0" fill="3">
<preferred-size width="150" height="50" />
</default-constraints>
</item>
<item class="javax.swing.JList" icon="/com/intellij/uiDesigner/icons/list.svg" removable="false" auto-create-binding="true" can-attach-label="false">
<default-constraints vsize-policy="6" hsize-policy="2" anchor="0" fill="3">
<preferred-size width="150" height="50" />
</default-constraints>
</item>
<item class="javax.swing.JTree" icon="/com/intellij/uiDesigner/icons/tree.svg" removable="false" auto-create-binding="true" can-attach-label="false">
<default-constraints vsize-policy="6" hsize-policy="6" anchor="0" fill="3">
<preferred-size width="150" height="50" />
</default-constraints>
</item>
<item class="javax.swing.JTabbedPane" icon="/com/intellij/uiDesigner/icons/tabbedPane.svg" removable="false" auto-create-binding="true" can-attach-label="false">
<default-constraints vsize-policy="3" hsize-policy="3" anchor="0" fill="3">
<preferred-size width="200" height="200" />
</default-constraints>
</item>
<item class="javax.swing.JSplitPane" icon="/com/intellij/uiDesigner/icons/splitPane.svg" removable="false" auto-create-binding="false" can-attach-label="false">
<default-constraints vsize-policy="3" hsize-policy="3" anchor="0" fill="3">
<preferred-size width="200" height="200" />
</default-constraints>
</item>
<item class="javax.swing.JSpinner" icon="/com/intellij/uiDesigner/icons/spinner.svg" removable="false" auto-create-binding="true" can-attach-label="true">
<default-constraints vsize-policy="0" hsize-policy="6" anchor="8" fill="1" />
</item>
<item class="javax.swing.JSlider" icon="/com/intellij/uiDesigner/icons/slider.svg" removable="false" auto-create-binding="true" can-attach-label="false">
<default-constraints vsize-policy="0" hsize-policy="6" anchor="8" fill="1" />
</item>
<item class="javax.swing.JSeparator" icon="/com/intellij/uiDesigner/icons/separator.svg" removable="false" auto-create-binding="false" can-attach-label="false">
<default-constraints vsize-policy="6" hsize-policy="6" anchor="0" fill="3" />
</item>
<item class="javax.swing.JProgressBar" icon="/com/intellij/uiDesigner/icons/progressbar.svg" removable="false" auto-create-binding="true" can-attach-label="false">
<default-constraints vsize-policy="0" hsize-policy="6" anchor="0" fill="1" />
</item>
<item class="javax.swing.JToolBar" icon="/com/intellij/uiDesigner/icons/toolbar.svg" removable="false" auto-create-binding="false" can-attach-label="false">
<default-constraints vsize-policy="0" hsize-policy="6" anchor="0" fill="1">
<preferred-size width="-1" height="20" />
</default-constraints>
</item>
<item class="javax.swing.JToolBar$Separator" icon="/com/intellij/uiDesigner/icons/toolbarSeparator.svg" removable="false" auto-create-binding="false" can-attach-label="false">
<default-constraints vsize-policy="0" hsize-policy="0" anchor="0" fill="1" />
</item>
<item class="javax.swing.JScrollBar" icon="/com/intellij/uiDesigner/icons/scrollbar.svg" removable="false" auto-create-binding="true" can-attach-label="false">
<default-constraints vsize-policy="6" hsize-policy="0" anchor="0" fill="2" />
</item>
</group>
</component>
</project>
\ No newline at end of file
registration-discovery-leader-reelection-cordinator-workers/logs/leader.log 0 → 100644
View file @ 58cc723c
2024-01-25 23:37:22,998 INFO Registration_Discovery.Leader [main] Enter your Search Query:
2024-01-25 23:37:42,566 INFO Registration_Discovery.Leader [main] Search Query: while process run
2024-01-25 23:37:42,584 INFO Registration_Discovery.Leader [Thread-0] Searching on worker: 10.80.0.10:1234
2024-01-25 23:37:42,660 INFO Registration_Discovery.Leader [main]
2024-01-25 23:37:42,667 INFO Registration_Discovery.Leader [main] Terms Info In: Text.txt Document:
2024-01-25 23:37:42,678 INFO Registration_Discovery.Leader [main] (Term: process , Term Frequency: 0.07633587786259542)
2024-01-25 23:37:42,679 INFO Registration_Discovery.Leader [main] (Term: run , Term Frequency: 0.030534351145038167)
2024-01-25 23:37:42,679 INFO Registration_Discovery.Leader [main] (Term: while , Term Frequency: 0.007633587786259542)
2024-01-25 23:37:42,685 INFO Registration_Discovery.Leader [main]
2024-01-25 23:37:42,685 INFO Registration_Discovery.Leader [main] ................................................
2024-01-25 23:37:42,685 INFO Registration_Discovery.Leader [main] Terms Info In: Text1.txt Document:
2024-01-25 23:37:42,685 INFO Registration_Discovery.Leader [main] (Term: process , Term Frequency: 0.08181818181818182)
2024-01-25 23:37:42,685 INFO Registration_Discovery.Leader [main] (Term: run , Term Frequency: 0.03636363636363636)
2024-01-25 23:37:42,685 INFO Registration_Discovery.Leader [main] (Term: while , Term Frequency: 0.00909090909090909)
2024-01-25 23:37:42,685 INFO Registration_Discovery.Leader [main]
2024-01-25 23:37:42,685 INFO Registration_Discovery.Leader [main] ................................................
2024-01-25 23:37:42,685 INFO Registration_Discovery.Leader [main] Terms Info In: Text2.txt Document:
2024-01-25 23:37:42,685 INFO Registration_Discovery.Leader [main] (Term: process , Term Frequency: 0.0)
2024-01-25 23:37:42,685 INFO Registration_Discovery.Leader [main] (Term: run , Term Frequency: 0.023923444976076555)
2024-01-25 23:37:42,685 INFO Registration_Discovery.Leader [main] (Term: while , Term Frequency: 0.004784688995215311)
2024-01-25 23:37:42,685 INFO Registration_Discovery.Leader [main]
2024-01-25 23:37:42,685 INFO Registration_Discovery.Leader [main] ................................................
2024-01-25 23:37:42,686 INFO Registration_Discovery.Leader [main] Number Of Documents Which Contains Our Terms:
2024-01-25 23:37:42,686 INFO Registration_Discovery.Leader [main] Total Documents: 3.0
2024-01-25 23:37:42,686 INFO Registration_Discovery.Leader [main] Term: process , Count: 2.0
2024-01-25 23:37:42,686 INFO Registration_Discovery.Leader [main] Term: run , Count: 3.0
2024-01-25 23:37:42,686 INFO Registration_Discovery.Leader [main] Term: while , Count: 3.0
2024-01-25 23:37:42,686 INFO Registration_Discovery.Leader [main] -------------------------
2024-01-25 23:37:42,687 INFO Registration_Discovery.Leader [main] IDFs Info:
2024-01-25 23:37:42,687 INFO Registration_Discovery.Leader [main] Term: process , Term IDF: 0.17609125905568124
2024-01-25 23:37:42,687 INFO Registration_Discovery.Leader [main] Term: run , Term IDF: 0.0
2024-01-25 23:37:42,687 INFO Registration_Discovery.Leader [main] Term: while , Term IDF: 0.0
2024-01-25 23:37:42,687 INFO Registration_Discovery.Leader [main] -------------------------
2024-01-25 23:37:42,687 INFO Registration_Discovery.Leader [main]
2024-01-25 23:37:42,688 INFO Registration_Discovery.Leader [main] Sorted Documents By Scores:
2024-01-25 23:37:42,688 INFO Registration_Discovery.Leader [main] Document: Text1.txt , Document score: 0.014407466650010282
2024-01-25 23:37:42,688 INFO Registration_Discovery.Leader [main] Document: Text.txt , Document score: 0.013442080843945133
2024-01-25 23:37:42,689 INFO Registration_Discovery.Leader [main] Document: Text2.txt , Document score: 0.0
2024-01-25 23:37:42,689 INFO Registration_Discovery.Leader [main] Enter your Search Query:
2024-01-25 23:38:07,489 INFO Registration_Discovery.Leader [main] Search Query: ali zein ahmad
2024-01-25 23:38:07,490 INFO Registration_Discovery.Leader [Thread-1] Searching on worker: 10.80.0.10:1234
2024-01-25 23:38:07,509 INFO Registration_Discovery.Leader [main]
2024-01-25 23:38:07,510 INFO Registration_Discovery.Leader [main] Terms Info In: Text.txt Document:
2024-01-25 23:38:07,510 INFO Registration_Discovery.Leader [main] (Term: zein , Term Frequency: 0.0)
2024-01-25 23:38:07,510 INFO Registration_Discovery.Leader [main] (Term: ahmad , Term Frequency: 0.16030534351145037)
2024-01-25 23:38:07,510 INFO Registration_Discovery.Leader [main] (Term: ali , Term Frequency: 0.2366412213740458)
2024-01-25 23:38:07,510 INFO Registration_Discovery.Leader [main]
2024-01-25 23:38:07,510 INFO Registration_Discovery.Leader [main] ................................................
2024-01-25 23:38:07,510 INFO Registration_Discovery.Leader [main] Terms Info In: Text1.txt Document:
2024-01-25 23:38:07,510 INFO Registration_Discovery.Leader [main] (Term: zein , Term Frequency: 0.20909090909090908)
2024-01-25 23:38:07,510 INFO Registration_Discovery.Leader [main] (Term: ahmad , Term Frequency: 0.0)
2024-01-25 23:38:07,510 INFO Registration_Discovery.Leader [main] (Term: ali , Term Frequency: 0.10909090909090909)
2024-01-25 23:38:07,510 INFO Registration_Discovery.Leader [main]
2024-01-25 23:38:07,510 INFO Registration_Discovery.Leader [main] ................................................
2024-01-25 23:38:07,511 INFO Registration_Discovery.Leader [main] Terms Info In: Text2.txt Document:
2024-01-25 23:38:07,511 INFO Registration_Discovery.Leader [main] (Term: zein , Term Frequency: 0.28708133971291866)
2024-01-25 23:38:07,511 INFO Registration_Discovery.Leader [main] (Term: ahmad , Term Frequency: 0.0)
2024-01-25 23:38:07,511 INFO Registration_Discovery.Leader [main] (Term: ali , Term Frequency: 0.37320574162679426)
2024-01-25 23:38:07,511 INFO Registration_Discovery.Leader [main]
2024-01-25 23:38:07,511 INFO Registration_Discovery.Leader [main] ................................................
2024-01-25 23:38:07,511 INFO Registration_Discovery.Leader [main] Number Of Documents Which Contains Our Terms:
2024-01-25 23:38:07,511 INFO Registration_Discovery.Leader [main] Total Documents: 3.0
2024-01-25 23:38:07,511 INFO Registration_Discovery.Leader [main] Term: zein , Count: 2.0
2024-01-25 23:38:07,511 INFO Registration_Discovery.Leader [main] Term: ahmad , Count: 1.0
2024-01-25 23:38:07,511 INFO Registration_Discovery.Leader [main] Term: ali , Count: 3.0
2024-01-25 23:38:07,511 INFO Registration_Discovery.Leader [main] -------------------------
2024-01-25 23:38:07,511 INFO Registration_Discovery.Leader [main] IDFs Info:
2024-01-25 23:38:07,512 INFO Registration_Discovery.Leader [main] Term: zein , Term IDF: 0.17609125905568124
2024-01-25 23:38:07,512 INFO Registration_Discovery.Leader [main] Term: ahmad , Term IDF: 0.47712125471966244
2024-01-25 23:38:07,512 INFO Registration_Discovery.Leader [main] Term: ali , Term IDF: 0.0
2024-01-25 23:38:07,512 INFO Registration_Discovery.Leader [main] -------------------------
2024-01-25 23:38:07,512 INFO Registration_Discovery.Leader [main]
2024-01-25 23:38:07,512 INFO Registration_Discovery.Leader [main] Sorted Documents By Scores:
2024-01-25 23:38:07,512 INFO Registration_Discovery.Leader [main] Document: Text.txt , Document score: 0.0764850866344497
2024-01-25 23:38:07,512 INFO Registration_Discovery.Leader [main] Document: Text2.txt , Document score: 0.05055251456143959
2024-01-25 23:38:07,512 INFO Registration_Discovery.Leader [main] Document: Text1.txt , Document score: 0.036819081438915165
2024-01-25 23:38:07,513 INFO Registration_Discovery.Leader [main] Enter your Search Query:
2024-01-25 23:39:16,806 INFO Registration_Discovery.Leader [main] Search Query: while process run ali zein the ahmad ;
2024-01-25 23:39:16,808 INFO Registration_Discovery.Leader [Thread-2] Searching on worker: 10.80.0.10:1234
2024-01-25 23:39:16,845 INFO Registration_Discovery.Leader [main]
2024-01-25 23:39:16,845 INFO Registration_Discovery.Leader [main] Terms Info In: Text.txt Document:
2024-01-25 23:39:16,846 INFO Registration_Discovery.Leader [main] (Term: the , Term Frequency: 0.0)
2024-01-25 23:39:16,846 INFO Registration_Discovery.Leader [main] (Term: process , Term Frequency: 0.07633587786259542)
2024-01-25 23:39:16,846 INFO Registration_Discovery.Leader [main] (Term: zein , Term Frequency: 0.0)
2024-01-25 23:39:16,846 INFO Registration_Discovery.Leader [main] (Term: run , Term Frequency: 0.030534351145038167)
2024-01-25 23:39:16,846 INFO Registration_Discovery.Leader [main] (Term: ; , Term Frequency: 0.10687022900763359)
2024-01-25 23:39:16,846 INFO Registration_Discovery.Leader [main] (Term: while , Term Frequency: 0.007633587786259542)
2024-01-25 23:39:16,846 INFO Registration_Discovery.Leader [main] (Term: ahmad , Term Frequency: 0.16030534351145037)
2024-01-25 23:39:16,846 INFO Registration_Discovery.Leader [main] (Term: ali , Term Frequency: 0.2366412213740458)
2024-01-25 23:39:16,846 INFO Registration_Discovery.Leader [main]
2024-01-25 23:39:16,846 INFO Registration_Discovery.Leader [main] ................................................
2024-01-25 23:39:16,846 INFO Registration_Discovery.Leader [main] Terms Info In: Text1.txt Document:
2024-01-25 23:39:16,846 INFO Registration_Discovery.Leader [main] (Term: the , Term Frequency: 0.01818181818181818)
2024-01-25 23:39:16,846 INFO Registration_Discovery.Leader [main] (Term: process , Term Frequency: 0.08181818181818182)
2024-01-25 23:39:16,846 INFO Registration_Discovery.Leader [main] (Term: zein , Term Frequency: 0.20909090909090908)
2024-01-25 23:39:16,846 INFO Registration_Discovery.Leader [main] (Term: run , Term Frequency: 0.03636363636363636)
2024-01-25 23:39:16,847 INFO Registration_Discovery.Leader [main] (Term: ; , Term Frequency: 0.10909090909090909)
2024-01-25 23:39:16,847 INFO Registration_Discovery.Leader [main] (Term: while , Term Frequency: 0.00909090909090909)
2024-01-25 23:39:16,847 INFO Registration_Discovery.Leader [main] (Term: ahmad , Term Frequency: 0.0)
2024-01-25 23:39:16,847 INFO Registration_Discovery.Leader [main] (Term: ali , Term Frequency: 0.10909090909090909)
2024-01-25 23:39:16,847 INFO Registration_Discovery.Leader [main]
2024-01-25 23:39:16,847 INFO Registration_Discovery.Leader [main] ................................................
2024-01-25 23:39:16,847 INFO Registration_Discovery.Leader [main] Terms Info In: Text2.txt Document:
2024-01-25 23:39:16,847 INFO Registration_Discovery.Leader [main] (Term: the , Term Frequency: 0.004784688995215311)
2024-01-25 23:39:16,847 INFO Registration_Discovery.Leader [main] (Term: process , Term Frequency: 0.0)
2024-01-25 23:39:16,847 INFO Registration_Discovery.Leader [main] (Term: zein , Term Frequency: 0.28708133971291866)
2024-01-25 23:39:16,847 INFO Registration_Discovery.Leader [main] (Term: run , Term Frequency: 0.023923444976076555)
2024-01-25 23:39:16,847 INFO Registration_Discovery.Leader [main] (Term: ; , Term Frequency: 0.05741626794258373)
2024-01-25 23:39:16,847 INFO Registration_Discovery.Leader [main] (Term: while , Term Frequency: 0.004784688995215311)
2024-01-25 23:39:16,847 INFO Registration_Discovery.Leader [main] (Term: ahmad , Term Frequency: 0.0)
2024-01-25 23:39:16,847 INFO Registration_Discovery.Leader [main] (Term: ali , Term Frequency: 0.37320574162679426)
2024-01-25 23:39:16,847 INFO Registration_Discovery.Leader [main]
2024-01-25 23:39:16,847 INFO Registration_Discovery.Leader [main] ................................................
2024-01-25 23:39:16,848 INFO Registration_Discovery.Leader [main] Number Of Documents Which Contains Our Terms:
2024-01-25 23:39:16,848 INFO Registration_Discovery.Leader [main] Total Documents: 3.0
2024-01-25 23:39:16,848 INFO Registration_Discovery.Leader [main] Term: the , Count: 2.0
2024-01-25 23:39:16,848 INFO Registration_Discovery.Leader [main] Term: process , Count: 2.0
2024-01-25 23:39:16,848 INFO Registration_Discovery.Leader [main] Term: zein , Count: 2.0
2024-01-25 23:39:16,848 INFO Registration_Discovery.Leader [main] Term: run , Count: 3.0
2024-01-25 23:39:16,848 INFO Registration_Discovery.Leader [main] Term: ; , Count: 3.0
2024-01-25 23:39:16,848 INFO Registration_Discovery.Leader [main] Term: while , Count: 3.0
2024-01-25 23:39:16,848 INFO Registration_Discovery.Leader [main] Term: ahmad , Count: 1.0
2024-01-25 23:39:16,848 INFO Registration_Discovery.Leader [main] Term: ali , Count: 3.0
2024-01-25 23:39:16,848 INFO Registration_Discovery.Leader [main] -------------------------
2024-01-25 23:39:16,849 INFO Registration_Discovery.Leader [main] IDFs Info:
2024-01-25 23:39:16,849 INFO Registration_Discovery.Leader [main] Term: the , Term IDF: 0.17609125905568124
2024-01-25 23:39:16,849 INFO Registration_Discovery.Leader [main] Term: process , Term IDF: 0.17609125905568124
2024-01-25 23:39:16,849 INFO Registration_Discovery.Leader [main] Term: zein , Term IDF: 0.17609125905568124
2024-01-25 23:39:16,849 INFO Registration_Discovery.Leader [main] Term: run , Term IDF: 0.0
2024-01-25 23:39:16,849 INFO Registration_Discovery.Leader [main] Term: ; , Term IDF: 0.0
2024-01-25 23:39:16,849 INFO Registration_Discovery.Leader [main] Term: while , Term IDF: 0.0
2024-01-25 23:39:16,849 INFO Registration_Discovery.Leader [main] Term: ahmad , Term IDF: 0.47712125471966244
2024-01-25 23:39:16,849 INFO Registration_Discovery.Leader [main] Term: ali , Term IDF: 0.0
2024-01-25 23:39:16,849 INFO Registration_Discovery.Leader [main] -------------------------
2024-01-25 23:39:16,849 INFO Registration_Discovery.Leader [main]
2024-01-25 23:39:16,849 INFO Registration_Discovery.Leader [main] Sorted Documents By Scores:
2024-01-25 23:39:16,849 INFO Registration_Discovery.Leader [main] Document: Text.txt , Document score: 0.08992716747839483
2024-01-25 23:39:16,849 INFO Registration_Discovery.Leader [main] Document: Text1.txt , Document score: 0.05442820734448329
2024-01-25 23:39:16,849 INFO Registration_Discovery.Leader [main] Document: Text2.txt , Document score: 0.05139505647079692
2024-01-25 23:39:16,849 INFO Registration_Discovery.Leader [main] Enter your Search Query:
2024-01-25 23:40:20,083 INFO Registration_Discovery.Leader [main] Search Query: ali
2024-01-25 23:40:20,085 INFO Registration_Discovery.Leader [Thread-3] Searching on worker: 10.80.0.10:12345
2024-01-25 23:40:20,085 INFO Registration_Discovery.Leader [Thread-4] Searching on worker: 10.80.0.10:1234
2024-01-25 23:40:20,134 INFO Registration_Discovery.Leader [main]
2024-01-25 23:40:20,136 INFO Registration_Discovery.Leader [main] Terms Info In: Text2.txt Document:
2024-01-25 23:40:20,136 INFO Registration_Discovery.Leader [main] (Term: ali , Term Frequency: 0.37320574162679426)
2024-01-25 23:40:20,136 INFO Registration_Discovery.Leader [main]
2024-01-25 23:40:20,136 INFO Registration_Discovery.Leader [main] ................................................
2024-01-25 23:40:20,136 INFO Registration_Discovery.Leader [main] Terms Info In: Text.txt Document:
2024-01-25 23:40:20,136 INFO Registration_Discovery.Leader [main] (Term: ali , Term Frequency: 0.2366412213740458)
2024-01-25 23:40:20,136 INFO Registration_Discovery.Leader [main]
2024-01-25 23:40:20,136 INFO Registration_Discovery.Leader [main] ................................................
2024-01-25 23:40:20,136 INFO Registration_Discovery.Leader [main] Terms Info In: Text1.txt Document:
2024-01-25 23:40:20,136 INFO Registration_Discovery.Leader [main] (Term: ali , Term Frequency: 0.10909090909090909)
2024-01-25 23:40:20,136 INFO Registration_Discovery.Leader [main]
2024-01-25 23:40:20,136 INFO Registration_Discovery.Leader [main] ................................................
2024-01-25 23:40:20,137 INFO Registration_Discovery.Leader [main] Number Of Documents Which Contains Our Terms:
2024-01-25 23:40:20,137 INFO Registration_Discovery.Leader [main] Total Documents: 3.0
2024-01-25 23:40:20,137 INFO Registration_Discovery.Leader [main] Term: ali , Count: 3.0
2024-01-25 23:40:20,137 INFO Registration_Discovery.Leader [main] -------------------------
2024-01-25 23:40:20,137 INFO Registration_Discovery.Leader [main] IDFs Info:
2024-01-25 23:40:20,137 INFO Registration_Discovery.Leader [main] Term: ali , Term IDF: 0.0
2024-01-25 23:40:20,137 INFO Registration_Discovery.Leader [main] -------------------------
2024-01-25 23:40:20,137 INFO Registration_Discovery.Leader [main]
2024-01-25 23:40:20,137 INFO Registration_Discovery.Leader [main] Sorted Documents By Scores:
2024-01-25 23:40:20,138 INFO Registration_Discovery.Leader [main] Document: Text.txt , Document score: 0.0
2024-01-25 23:40:20,139 INFO Registration_Discovery.Leader [main] Document: Text1.txt , Document score: 0.0
2024-01-25 23:40:20,139 INFO Registration_Discovery.Leader [main] Document: Text2.txt , Document score: 0.0
2024-01-25 23:40:20,139 INFO Registration_Discovery.Leader [main] Enter your Search Query:
2024-01-25 23:40:30,412 INFO Registration_Discovery.Leader [main] Search Query: zein
2024-01-25 23:40:30,415 INFO Registration_Discovery.Leader [Thread-5] Searching on worker: 10.80.0.10:12345
2024-01-25 23:40:30,416 INFO Registration_Discovery.Leader [Thread-6] Searching on worker: 10.80.0.10:1234
2024-01-25 23:40:30,436 INFO Registration_Discovery.Leader [main]
2024-01-25 23:40:30,437 INFO Registration_Discovery.Leader [main] Terms Info In: Text2.txt Document:
2024-01-25 23:40:30,437 INFO Registration_Discovery.Leader [main] (Term: zein , Term Frequency: 0.28708133971291866)
2024-01-25 23:40:30,437 INFO Registration_Discovery.Leader [main]
2024-01-25 23:40:30,437 INFO Registration_Discovery.Leader [main] ................................................
2024-01-25 23:40:30,437 INFO Registration_Discovery.Leader [main] Terms Info In: Text.txt Document:
2024-01-25 23:40:30,438 INFO Registration_Discovery.Leader [main] (Term: zein , Term Frequency: 0.0)
2024-01-25 23:40:30,438 INFO Registration_Discovery.Leader [main]
2024-01-25 23:40:30,438 INFO Registration_Discovery.Leader [main] ................................................
2024-01-25 23:40:30,438 INFO Registration_Discovery.Leader [main] Terms Info In: Text1.txt Document:
2024-01-25 23:40:30,438 INFO Registration_Discovery.Leader [main] (Term: zein , Term Frequency: 0.20909090909090908)
2024-01-25 23:40:30,438 INFO Registration_Discovery.Leader [main]
2024-01-25 23:40:30,438 INFO Registration_Discovery.Leader [main] ................................................
2024-01-25 23:40:30,438 INFO Registration_Discovery.Leader [main] Number Of Documents Which Contains Our Terms:
2024-01-25 23:40:30,438 INFO Registration_Discovery.Leader [main] Total Documents: 3.0
2024-01-25 23:40:30,438 INFO Registration_Discovery.Leader [main] Term: zein , Count: 2.0
2024-01-25 23:40:30,438 INFO Registration_Discovery.Leader [main] -------------------------
2024-01-25 23:40:30,439 INFO Registration_Discovery.Leader [main] IDFs Info:
2024-01-25 23:40:30,439 INFO Registration_Discovery.Leader [main] Term: zein , Term IDF: 0.17609125905568124
2024-01-25 23:40:30,439 INFO Registration_Discovery.Leader [main] -------------------------
2024-01-25 23:40:30,439 INFO Registration_Discovery.Leader [main]
2024-01-25 23:40:30,439 INFO Registration_Discovery.Leader [main] Sorted Documents By Scores:
2024-01-25 23:40:30,439 INFO Registration_Discovery.Leader [main] Document: Text2.txt , Document score: 0.05055251456143959
2024-01-25 23:40:30,439 INFO Registration_Discovery.Leader [main] Document: Text1.txt , Document score: 0.036819081438915165
2024-01-25 23:40:30,439 INFO Registration_Discovery.Leader [main] Document: Text.txt , Document score: 0.0
2024-01-25 23:40:30,440 INFO Registration_Discovery.Leader [main] Enter your Search Query:
2024-01-25 23:41:00,580 INFO Registration_Discovery.Leader [main] Search Query: ali zein
2024-01-25 23:41:00,582 INFO Registration_Discovery.Leader [Thread-7] Searching on worker: 10.80.0.10:12345
2024-01-25 23:41:00,583 INFO Registration_Discovery.Leader [Thread-8] Searching on worker: 10.80.0.10:1234
2024-01-25 23:41:00,627 INFO Registration_Discovery.Leader [main]
2024-01-25 23:41:00,637 INFO Registration_Discovery.Leader [main] Terms Info In: Text.txt Document:
2024-01-25 23:41:00,638 INFO Registration_Discovery.Leader [main] (Term: zein , Term Frequency: 0.0)
2024-01-25 23:41:00,638 INFO Registration_Discovery.Leader [main] (Term: ali , Term Frequency: 0.2366412213740458)
2024-01-25 23:41:00,638 INFO Registration_Discovery.Leader [main]
2024-01-25 23:41:00,638 INFO Registration_Discovery.Leader [main] ................................................
2024-01-25 23:41:00,638 INFO Registration_Discovery.Leader [main] Terms Info In: Text1.txt Document:
2024-01-25 23:41:00,638 INFO Registration_Discovery.Leader [main] (Term: zein , Term Frequency: 0.20909090909090908)
2024-01-25 23:41:00,638 INFO Registration_Discovery.Leader [main] (Term: ali , Term Frequency: 0.10909090909090909)
2024-01-25 23:41:00,638 INFO Registration_Discovery.Leader [main]
2024-01-25 23:41:00,638 INFO Registration_Discovery.Leader [main] ................................................
2024-01-25 23:41:00,639 INFO Registration_Discovery.Leader [main] Terms Info In: Text2.txt Document:
2024-01-25 23:41:00,639 INFO Registration_Discovery.Leader [main] (Term: zein , Term Frequency: 0.28708133971291866)
2024-01-25 23:41:00,639 INFO Registration_Discovery.Leader [main] (Term: ali , Term Frequency: 0.37320574162679426)
2024-01-25 23:41:00,639 INFO Registration_Discovery.Leader [main]
2024-01-25 23:41:00,639 INFO Registration_Discovery.Leader [main] ................................................
2024-01-25 23:41:00,639 INFO Registration_Discovery.Leader [main] Number Of Documents Which Contains Our Terms:
2024-01-25 23:41:00,639 INFO Registration_Discovery.Leader [main] Total Documents: 3.0
2024-01-25 23:41:00,639 INFO Registration_Discovery.Leader [main] Term: zein , Count: 2.0
2024-01-25 23:41:00,639 INFO Registration_Discovery.Leader [main] Term: ali , Count: 3.0
2024-01-25 23:41:00,640 INFO Registration_Discovery.Leader [main] -------------------------
2024-01-25 23:41:00,640 INFO Registration_Discovery.Leader [main] IDFs Info:
2024-01-25 23:41:00,640 INFO Registration_Discovery.Leader [main] Term: zein , Term IDF: 0.17609125905568124
2024-01-25 23:41:00,640 INFO Registration_Discovery.Leader [main] Term: ali , Term IDF: 0.0
2024-01-25 23:41:00,640 INFO Registration_Discovery.Leader [main] -------------------------
2024-01-25 23:41:00,640 INFO Registration_Discovery.Leader [main]
2024-01-25 23:41:00,640 INFO Registration_Discovery.Leader [main] Sorted Documents By Scores:
2024-01-25 23:41:00,640 INFO Registration_Discovery.Leader [main] Document: Text2.txt , Document score: 0.05055251456143959
2024-01-25 23:41:00,641 INFO Registration_Discovery.Leader [main] Document: Text1.txt , Document score: 0.036819081438915165
2024-01-25 23:41:00,641 INFO Registration_Discovery.Leader [main] Document: Text.txt , Document score: 0.0
2024-01-25 23:41:00,641 INFO Registration_Discovery.Leader [main] Enter your Search Query:
2024-01-25 23:41:29,921 INFO Registration_Discovery.Leader [main] Search Query: ali zein ahmad
2024-01-25 23:41:29,923 INFO Registration_Discovery.Leader [Thread-9] Searching on worker: 10.80.0.10:12345
2024-01-25 23:41:29,923 INFO Registration_Discovery.Leader [Thread-10] Searching on worker: 10.80.0.10:1234
2024-01-25 23:41:29,950 INFO Registration_Discovery.Leader [main]
2024-01-25 23:41:29,951 INFO Registration_Discovery.Leader [main] Terms Info In: Text2.txt Document:
2024-01-25 23:41:29,951 INFO Registration_Discovery.Leader [main] (Term: zein , Term Frequency: 0.28708133971291866)
2024-01-25 23:41:29,951 INFO Registration_Discovery.Leader [main] (Term: ahmad , Term Frequency: 0.0)
2024-01-25 23:41:29,951 INFO Registration_Discovery.Leader [main] (Term: ali , Term Frequency: 0.37320574162679426)
2024-01-25 23:41:29,951 INFO Registration_Discovery.Leader [main]
2024-01-25 23:41:29,951 INFO Registration_Discovery.Leader [main] ................................................
2024-01-25 23:41:29,952 INFO Registration_Discovery.Leader [main] Terms Info In: Text.txt Document:
2024-01-25 23:41:29,952 INFO Registration_Discovery.Leader [main] (Term: zein , Term Frequency: 0.0)
2024-01-25 23:41:29,952 INFO Registration_Discovery.Leader [main] (Term: ahmad , Term Frequency: 0.16030534351145037)
2024-01-25 23:41:29,952 INFO Registration_Discovery.Leader [main] (Term: ali , Term Frequency: 0.2366412213740458)
2024-01-25 23:41:29,952 INFO Registration_Discovery.Leader [main]
2024-01-25 23:41:29,952 INFO Registration_Discovery.Leader [main] ................................................
2024-01-25 23:41:29,952 INFO Registration_Discovery.Leader [main] Terms Info In: Text1.txt Document:
2024-01-25 23:41:29,952 INFO Registration_Discovery.Leader [main] (Term: zein , Term Frequency: 0.20909090909090908)
2024-01-25 23:41:29,952 INFO Registration_Discovery.Leader [main] (Term: ahmad , Term Frequency: 0.0)
2024-01-25 23:41:29,952 INFO Registration_Discovery.Leader [main] (Term: ali , Term Frequency: 0.10909090909090909)
2024-01-25 23:41:29,952 INFO Registration_Discovery.Leader [main]
2024-01-25 23:41:29,952 INFO Registration_Discovery.Leader [main] ................................................
2024-01-25 23:41:29,953 INFO Registration_Discovery.Leader [main] Number Of Documents Which Contains Our Terms:
2024-01-25 23:41:29,953 INFO Registration_Discovery.Leader [main] Total Documents: 3.0
2024-01-25 23:41:29,953 INFO Registration_Discovery.Leader [main] Term: zein , Count: 2.0
2024-01-25 23:41:29,953 INFO Registration_Discovery.Leader [main] Term: ahmad , Count: 1.0
2024-01-25 23:41:29,954 INFO Registration_Discovery.Leader [main] Term: ali , Count: 3.0
2024-01-25 23:41:29,954 INFO Registration_Discovery.Leader [main] -------------------------
2024-01-25 23:41:29,954 INFO Registration_Discovery.Leader [main] IDFs Info:
2024-01-25 23:41:29,954 INFO Registration_Discovery.Leader [main] Term: zein , Term IDF: 0.17609125905568124
2024-01-25 23:41:29,954 INFO Registration_Discovery.Leader [main] Term: ahmad , Term IDF: 0.47712125471966244
2024-01-25 23:41:29,954 INFO Registration_Discovery.Leader [main] Term: ali , Term IDF: 0.0
2024-01-25 23:41:29,954 INFO Registration_Discovery.Leader [main] -------------------------
2024-01-25 23:41:29,954 INFO Registration_Discovery.Leader [main]
2024-01-25 23:41:29,954 INFO Registration_Discovery.Leader [main] Sorted Documents By Scores:
2024-01-25 23:41:29,954 INFO Registration_Discovery.Leader [main] Document: Text.txt , Document score: 0.0764850866344497
2024-01-25 23:41:29,954 INFO Registration_Discovery.Leader [main] Document: Text2.txt , Document score: 0.05055251456143959
2024-01-25 23:41:29,954 INFO Registration_Discovery.Leader [main] Document: Text1.txt , Document score: 0.036819081438915165
2024-01-25 23:41:29,954 INFO Registration_Discovery.Leader [main] Enter your Search Query:
2024-01-25 23:42:28,016 INFO Registration_Discovery.Leader [main-EventThread] Enter your Search Query:
2024-01-25 23:42:41,474 INFO Registration_Discovery.Leader [main-EventThread] Search Query: hello
2024-01-25 23:42:41,490 INFO Registration_Discovery.Leader [Thread-0] Searching on worker: 10.80.0.10:12345
2024-01-25 23:42:41,517 INFO Registration_Discovery.Leader [main-EventThread]
2024-01-25 23:42:41,524 INFO Registration_Discovery.Leader [main-EventThread] Terms Info In: Text.txt Document:
2024-01-25 23:42:41,529 INFO Registration_Discovery.Leader [main-EventThread] (Term: hello , Term Frequency: 0.022900763358778626)
2024-01-25 23:42:41,529 INFO Registration_Discovery.Leader [main-EventThread]
2024-01-25 23:42:41,529 INFO Registration_Discovery.Leader [main-EventThread] ................................................
2024-01-25 23:42:41,529 INFO Registration_Discovery.Leader [main-EventThread] Terms Info In: Text1.txt Document:
2024-01-25 23:42:41,529 INFO Registration_Discovery.Leader [main-EventThread] (Term: hello , Term Frequency: 0.0)
2024-01-25 23:42:41,529 INFO Registration_Discovery.Leader [main-EventThread]
2024-01-25 23:42:41,529 INFO Registration_Discovery.Leader [main-EventThread] ................................................
2024-01-25 23:42:41,529 INFO Registration_Discovery.Leader [main-EventThread] Terms Info In: Text2.txt Document:
2024-01-25 23:42:41,530 INFO Registration_Discovery.Leader [main-EventThread] (Term: hello , Term Frequency: 0.0)
2024-01-25 23:42:41,530 INFO Registration_Discovery.Leader [main-EventThread]
2024-01-25 23:42:41,530 INFO Registration_Discovery.Leader [main-EventThread] ................................................
2024-01-25 23:42:41,530 INFO Registration_Discovery.Leader [main-EventThread] Number Of Documents Which Contains Our Terms:
2024-01-25 23:42:41,530 INFO Registration_Discovery.Leader [main-EventThread] Total Documents: 3.0
2024-01-25 23:42:41,530 INFO Registration_Discovery.Leader [main-EventThread] Term: hello , Count: 1.0
2024-01-25 23:42:41,531 INFO Registration_Discovery.Leader [main-EventThread] -------------------------
2024-01-25 23:42:41,531 INFO Registration_Discovery.Leader [main-EventThread] IDFs Info:
2024-01-25 23:42:41,531 INFO Registration_Discovery.Leader [main-EventThread] Term: hello , Term IDF: 0.47712125471966244
2024-01-25 23:42:41,531 INFO Registration_Discovery.Leader [main-EventThread] -------------------------
2024-01-25 23:42:41,531 INFO Registration_Discovery.Leader [main-EventThread]
2024-01-25 23:42:41,532 INFO Registration_Discovery.Leader [main-EventThread] Sorted Documents By Scores:
2024-01-25 23:42:41,533 INFO Registration_Discovery.Leader [main-EventThread] Document: Text.txt , Document score: 0.010926440947778528
2024-01-25 23:42:41,533 INFO Registration_Discovery.Leader [main-EventThread] Document: Text1.txt , Document score: 0.0
2024-01-25 23:42:41,533 INFO Registration_Discovery.Leader [main-EventThread] Document: Text2.txt , Document score: 0.0
2024-01-25 23:42:41,534 INFO Registration_Discovery.Leader [main-EventThread] Enter your Search Query:
2024-01-25 23:42:53,733 INFO Registration_Discovery.Leader [main-EventThread] Search Query: ali
2024-01-25 23:42:53,735 INFO Registration_Discovery.Leader [Thread-1] Searching on worker: 10.80.0.10:12345
2024-01-25 23:42:53,745 INFO Registration_Discovery.Leader [main-EventThread]
2024-01-25 23:42:53,747 INFO Registration_Discovery.Leader [main-EventThread] Terms Info In: Text.txt Document:
2024-01-25 23:42:53,747 INFO Registration_Discovery.Leader [main-EventThread] (Term: ali , Term Frequency: 0.2366412213740458)
2024-01-25 23:42:53,747 INFO Registration_Discovery.Leader [main-EventThread]
2024-01-25 23:42:53,747 INFO Registration_Discovery.Leader [main-EventThread] ................................................
2024-01-25 23:42:53,747 INFO Registration_Discovery.Leader [main-EventThread] Terms Info In: Text1.txt Document:
2024-01-25 23:42:53,747 INFO Registration_Discovery.Leader [main-EventThread] (Term: ali , Term Frequency: 0.10909090909090909)
2024-01-25 23:42:53,747 INFO Registration_Discovery.Leader [main-EventThread]
2024-01-25 23:42:53,747 INFO Registration_Discovery.Leader [main-EventThread] ................................................
2024-01-25 23:42:53,747 INFO Registration_Discovery.Leader [main-EventThread] Terms Info In: Text2.txt Document:
2024-01-25 23:42:53,747 INFO Registration_Discovery.Leader [main-EventThread] (Term: ali , Term Frequency: 0.37320574162679426)
2024-01-25 23:42:53,747 INFO Registration_Discovery.Leader [main-EventThread]
2024-01-25 23:42:53,747 INFO Registration_Discovery.Leader [main-EventThread] ................................................
2024-01-25 23:42:53,747 INFO Registration_Discovery.Leader [main-EventThread] Number Of Documents Which Contains Our Terms:
2024-01-25 23:42:53,747 INFO Registration_Discovery.Leader [main-EventThread] Total Documents: 3.0
2024-01-25 23:42:53,747 INFO Registration_Discovery.Leader [main-EventThread] Term: ali , Count: 3.0
2024-01-25 23:42:53,747 INFO Registration_Discovery.Leader [main-EventThread] -------------------------
2024-01-25 23:42:53,747 INFO Registration_Discovery.Leader [main-EventThread] IDFs Info:
2024-01-25 23:42:53,747 INFO Registration_Discovery.Leader [main-EventThread] Term: ali , Term IDF: 0.0
2024-01-25 23:42:53,748 INFO Registration_Discovery.Leader [main-EventThread] -------------------------
2024-01-25 23:42:53,748 INFO Registration_Discovery.Leader [main-EventThread]
2024-01-25 23:42:53,748 INFO Registration_Discovery.Leader [main-EventThread] Sorted Documents By Scores:
2024-01-25 23:42:53,748 INFO Registration_Discovery.Leader [main-EventThread] Document: Text.txt , Document score: 0.0
2024-01-25 23:42:53,748 INFO Registration_Discovery.Leader [main-EventThread] Document: Text1.txt , Document score: 0.0
2024-01-25 23:42:53,748 INFO Registration_Discovery.Leader [main-EventThread] Document: Text2.txt , Document score: 0.0
2024-01-25 23:42:53,748 INFO Registration_Discovery.Leader [main-EventThread] Enter your Search Query:
2024-01-25 23:43:54,002 INFO Registration_Discovery.Leader [main-EventThread] Enter your Search Query:
registration-discovery-leader-reelection-cordinator-workers/logs/project.log 0 → 100644
View file @ 58cc723c
2024-01-25 23:37:13,699 INFO Registration_Discovery.Application [main] Connected
2024-01-25 23:37:18,457 INFO Registration_Discovery.Application [main] Connected
2024-01-25 23:37:22,951 DEBUG Registration_Discovery.Application [main-EventThread] Successfully connected to Zookeeper
2024-01-25 23:37:22,979 INFO Registration_Discovery.LeaderElection [main] I'm a leader
2024-01-25 23:37:22,983 INFO Registration_Discovery.ServiceRegistry [main] The cluster addresses are: []
2024-01-25 23:37:30,042 DEBUG Registration_Discovery.Application [main-EventThread] Successfully connected to Zookeeper
2024-01-25 23:37:30,068 INFO Registration_Discovery.LeaderElection [main] I'm not a leader
2024-01-25 23:37:30,085 DEBUG Registration_Discovery.ServiceRegistry [main] Registered to service registry
2024-01-25 23:37:30,115 INFO Registration_Discovery.ServiceRegistry [main-EventThread] The cluster addresses are: [10.80.0.10:1234]
2024-01-25 23:40:01,423 INFO Registration_Discovery.Application [main] Connected
2024-01-25 23:40:12,284 DEBUG Registration_Discovery.Application [main-EventThread] Successfully connected to Zookeeper
2024-01-25 23:40:12,314 INFO Registration_Discovery.LeaderElection [main] I'm not a leader
2024-01-25 23:40:12,347 DEBUG Registration_Discovery.ServiceRegistry [main] Registered to service registry
2024-01-25 23:40:12,368 INFO Registration_Discovery.ServiceRegistry [main-EventThread] The cluster addresses are: [10.80.0.10:12345, 10.80.0.10:1234]
2024-01-25 23:42:27,983 INFO Registration_Discovery.LeaderElection [main-EventThread] I'm a leader
2024-01-25 23:42:28,008 INFO Registration_Discovery.ServiceRegistry [main-EventThread] The cluster addresses are: [10.80.0.10:12345]
2024-01-25 23:43:53,983 INFO Registration_Discovery.LeaderElection [main-EventThread] I'm a leader
2024-01-25 23:43:53,995 INFO Registration_Discovery.ServiceRegistry [main-EventThread] The cluster addresses are: []
registration-discovery-leader-reelection-cordinator-workers/logs/worker.log 0 → 100644
View file @ 58cc723c
2024-01-25 23:37:42,620 INFO Registration_Discovery.Worker [main] Search query: while process run
2024-01-25 23:37:42,622 INFO Registration_Discovery.Worker [main] Received document: Text.txt
2024-01-25 23:37:42,622 INFO Registration_Discovery.Worker [main] Received document: Text1.txt
2024-01-25 23:37:42,622 INFO Registration_Discovery.Worker [main] Received document: Text2.txt
2024-01-25 23:37:42,623 INFO Registration_Discovery.Worker [main]
2024-01-25 23:37:42,624 INFO Registration_Discovery.Worker [main] Results in Text.txt Document:
2024-01-25 23:37:42,626 INFO Registration_Discovery.Worker [main] (Term: while, Frequency: 1.0, Total Document Words: 131, Term Frequency (Percentage): 0.007633587786259542)
2024-01-25 23:37:42,628 INFO Registration_Discovery.Worker [main] (Term: process, Frequency: 10.0, Total Document Words: 131, Term Frequency (Percentage): 0.07633587786259542)
2024-01-25 23:37:42,632 INFO Registration_Discovery.Worker [main] (Term: run, Frequency: 4.0, Total Document Words: 131, Term Frequency (Percentage): 0.030534351145038167)
2024-01-25 23:37:42,632 INFO Registration_Discovery.Worker [main] ................................................
2024-01-25 23:37:42,632 INFO Registration_Discovery.Worker [main] Results in Text1.txt Document:
2024-01-25 23:37:42,633 INFO Registration_Discovery.Worker [main] (Term: while, Frequency: 1.0, Total Document Words: 110, Term Frequency (Percentage): 0.00909090909090909)
2024-01-25 23:37:42,634 INFO Registration_Discovery.Worker [main] (Term: process, Frequency: 9.0, Total Document Words: 110, Term Frequency (Percentage): 0.08181818181818182)
2024-01-25 23:37:42,634 INFO Registration_Discovery.Worker [main] (Term: run, Frequency: 4.0, Total Document Words: 110, Term Frequency (Percentage): 0.03636363636363636)
2024-01-25 23:37:42,634 INFO Registration_Discovery.Worker [main] ................................................
2024-01-25 23:37:42,635 INFO Registration_Discovery.Worker [main] Results in Text2.txt Document:
2024-01-25 23:37:42,636 INFO Registration_Discovery.Worker [main] (Term: while, Frequency: 1.0, Total Document Words: 209, Term Frequency (Percentage): 0.004784688995215311)
2024-01-25 23:37:42,637 INFO Registration_Discovery.Worker [main] (Term: process, Frequency: 0.0, Total Document Words: 209, Term Frequency (Percentage): 0.0)
2024-01-25 23:37:42,638 INFO Registration_Discovery.Worker [main] (Term: run, Frequency: 5.0, Total Document Words: 209, Term Frequency (Percentage): 0.023923444976076555)
2024-01-25 23:37:42,638 INFO Registration_Discovery.Worker [main] ................................................
2024-01-25 23:38:07,493 INFO Registration_Discovery.Worker [main] Search query: ali zein ahmad
2024-01-25 23:38:07,494 INFO Registration_Discovery.Worker [main] Received document: Text.txt
2024-01-25 23:38:07,494 INFO Registration_Discovery.Worker [main] Received document: Text1.txt
2024-01-25 23:38:07,494 INFO Registration_Discovery.Worker [main] Received document: Text2.txt
2024-01-25 23:38:07,494 INFO Registration_Discovery.Worker [main]
2024-01-25 23:38:07,494 INFO Registration_Discovery.Worker [main] Results in Text.txt Document:
2024-01-25 23:38:07,495 INFO Registration_Discovery.Worker [main] (Term: ali, Frequency: 31.0, Total Document Words: 131, Term Frequency (Percentage): 0.2366412213740458)
2024-01-25 23:38:07,496 INFO Registration_Discovery.Worker [main] (Term: zein, Frequency: 0.0, Total Document Words: 131, Term Frequency (Percentage): 0.0)
2024-01-25 23:38:07,496 INFO Registration_Discovery.Worker [main] (Term: ahmad, Frequency: 21.0, Total Document Words: 131, Term Frequency (Percentage): 0.16030534351145037)
2024-01-25 23:38:07,497 INFO Registration_Discovery.Worker [main] ................................................
2024-01-25 23:38:07,497 INFO Registration_Discovery.Worker [main] Results in Text1.txt Document:
2024-01-25 23:38:07,497 INFO Registration_Discovery.Worker [main] (Term: ali, Frequency: 12.0, Total Document Words: 110, Term Frequency (Percentage): 0.10909090909090909)
2024-01-25 23:38:07,498 INFO Registration_Discovery.Worker [main] (Term: zein, Frequency: 23.0, Total Document Words: 110, Term Frequency (Percentage): 0.20909090909090908)
2024-01-25 23:38:07,498 INFO Registration_Discovery.Worker [main] (Term: ahmad, Frequency: 0.0, Total Document Words: 110, Term Frequency (Percentage): 0.0)
2024-01-25 23:38:07,498 INFO Registration_Discovery.Worker [main] ................................................
2024-01-25 23:38:07,499 INFO Registration_Discovery.Worker [main] Results in Text2.txt Document:
2024-01-25 23:38:07,500 INFO Registration_Discovery.Worker [main] (Term: ali, Frequency: 78.0, Total Document Words: 209, Term Frequency (Percentage): 0.37320574162679426)
2024-01-25 23:38:07,501 INFO Registration_Discovery.Worker [main] (Term: zein, Frequency: 60.0, Total Document Words: 209, Term Frequency (Percentage): 0.28708133971291866)
2024-01-25 23:38:07,502 INFO Registration_Discovery.Worker [main] (Term: ahmad, Frequency: 0.0, Total Document Words: 209, Term Frequency (Percentage): 0.0)
2024-01-25 23:38:07,502 INFO Registration_Discovery.Worker [main] ................................................
2024-01-25 23:39:16,810 INFO Registration_Discovery.Worker [main] Search query: while process run ali zein the ahmad ;
2024-01-25 23:39:16,810 INFO Registration_Discovery.Worker [main] Received document: Text.txt
2024-01-25 23:39:16,810 INFO Registration_Discovery.Worker [main] Received document: Text1.txt
2024-01-25 23:39:16,810 INFO Registration_Discovery.Worker [main] Received document: Text2.txt
2024-01-25 23:39:16,810 INFO Registration_Discovery.Worker [main]
2024-01-25 23:39:16,811 INFO Registration_Discovery.Worker [main] Results in Text.txt Document:
2024-01-25 23:39:16,811 INFO Registration_Discovery.Worker [main] (Term: while, Frequency: 1.0, Total Document Words: 131, Term Frequency (Percentage): 0.007633587786259542)
2024-01-25 23:39:16,812 INFO Registration_Discovery.Worker [main] (Term: process, Frequency: 10.0, Total Document Words: 131, Term Frequency (Percentage): 0.07633587786259542)
2024-01-25 23:39:16,813 INFO Registration_Discovery.Worker [main] (Term: run, Frequency: 4.0, Total Document Words: 131, Term Frequency (Percentage): 0.030534351145038167)
2024-01-25 23:39:16,814 INFO Registration_Discovery.Worker [main] (Term: ali, Frequency: 31.0, Total Document Words: 131, Term Frequency (Percentage): 0.2366412213740458)
2024-01-25 23:39:16,815 INFO Registration_Discovery.Worker [main] (Term: zein, Frequency: 0.0, Total Document Words: 131, Term Frequency (Percentage): 0.0)
2024-01-25 23:39:16,816 INFO Registration_Discovery.Worker [main] (Term: the, Frequency: 0.0, Total Document Words: 131, Term Frequency (Percentage): 0.0)
2024-01-25 23:39:16,816 INFO Registration_Discovery.Worker [main] (Term: ahmad, Frequency: 21.0, Total Document Words: 131, Term Frequency (Percentage): 0.16030534351145037)
2024-01-25 23:39:16,817 INFO Registration_Discovery.Worker [main] (Term: ;, Frequency: 14.0, Total Document Words: 131, Term Frequency (Percentage): 0.10687022900763359)
2024-01-25 23:39:16,817 INFO Registration_Discovery.Worker [main] ................................................
2024-01-25 23:39:16,818 INFO Registration_Discovery.Worker [main] Results in Text1.txt Document:
2024-01-25 23:39:16,818 INFO Registration_Discovery.Worker [main] (Term: while, Frequency: 1.0, Total Document Words: 110, Term Frequency (Percentage): 0.00909090909090909)
2024-01-25 23:39:16,818 INFO Registration_Discovery.Worker [main] (Term: process, Frequency: 9.0, Total Document Words: 110, Term Frequency (Percentage): 0.08181818181818182)
2024-01-25 23:39:16,819 INFO Registration_Discovery.Worker [main] (Term: run, Frequency: 4.0, Total Document Words: 110, Term Frequency (Percentage): 0.03636363636363636)
2024-01-25 23:39:16,819 INFO Registration_Discovery.Worker [main] (Term: ali, Frequency: 12.0, Total Document Words: 110, Term Frequency (Percentage): 0.10909090909090909)
2024-01-25 23:39:16,820 INFO Registration_Discovery.Worker [main] (Term: zein, Frequency: 23.0, Total Document Words: 110, Term Frequency (Percentage): 0.20909090909090908)
2024-01-25 23:39:16,821 INFO Registration_Discovery.Worker [main] (Term: the, Frequency: 2.0, Total Document Words: 110, Term Frequency (Percentage): 0.01818181818181818)
2024-01-25 23:39:16,822 INFO Registration_Discovery.Worker [main] (Term: ahmad, Frequency: 0.0, Total Document Words: 110, Term Frequency (Percentage): 0.0)
2024-01-25 23:39:16,823 INFO Registration_Discovery.Worker [main] (Term: ;, Frequency: 12.0, Total Document Words: 110, Term Frequency (Percentage): 0.10909090909090909)
2024-01-25 23:39:16,823 INFO Registration_Discovery.Worker [main] ................................................
2024-01-25 23:39:16,825 INFO Registration_Discovery.Worker [main] Results in Text2.txt Document:
2024-01-25 23:39:16,825 INFO Registration_Discovery.Worker [main] (Term: while, Frequency: 1.0, Total Document Words: 209, Term Frequency (Percentage): 0.004784688995215311)
2024-01-25 23:39:16,826 INFO Registration_Discovery.Worker [main] (Term: process, Frequency: 0.0, Total Document Words: 209, Term Frequency (Percentage): 0.0)
2024-01-25 23:39:16,827 INFO Registration_Discovery.Worker [main] (Term: run, Frequency: 5.0, Total Document Words: 209, Term Frequency (Percentage): 0.023923444976076555)
2024-01-25 23:39:16,829 INFO Registration_Discovery.Worker [main] (Term: ali, Frequency: 78.0, Total Document Words: 209, Term Frequency (Percentage): 0.37320574162679426)
2024-01-25 23:39:16,830 INFO Registration_Discovery.Worker [main] (Term: zein, Frequency: 60.0, Total Document Words: 209, Term Frequency (Percentage): 0.28708133971291866)
2024-01-25 23:39:16,831 INFO Registration_Discovery.Worker [main] (Term: the, Frequency: 1.0, Total Document Words: 209, Term Frequency (Percentage): 0.004784688995215311)
2024-01-25 23:39:16,833 INFO Registration_Discovery.Worker [main] (Term: ahmad, Frequency: 0.0, Total Document Words: 209, Term Frequency (Percentage): 0.0)
2024-01-25 23:39:16,834 INFO Registration_Discovery.Worker [main] (Term: ;, Frequency: 12.0, Total Document Words: 209, Term Frequency (Percentage): 0.05741626794258373)
2024-01-25 23:39:16,835 INFO Registration_Discovery.Worker [main] ................................................
2024-01-25 23:40:20,088 INFO Registration_Discovery.Worker [main] Search query: ali
2024-01-25 23:40:20,088 INFO Registration_Discovery.Worker [main] Received document: Text2.txt
2024-01-25 23:40:20,088 INFO Registration_Discovery.Worker [main]
2024-01-25 23:40:20,089 INFO Registration_Discovery.Worker [main] Results in Text2.txt Document:
2024-01-25 23:40:20,091 INFO Registration_Discovery.Worker [main] (Term: ali, Frequency: 78.0, Total Document Words: 209, Term Frequency (Percentage): 0.37320574162679426)
2024-01-25 23:40:20,091 INFO Registration_Discovery.Worker [main] ................................................
2024-01-25 23:40:20,113 INFO Registration_Discovery.Worker [main] Search query: ali
2024-01-25 23:40:20,115 INFO Registration_Discovery.Worker [main] Received document: Text.txt
2024-01-25 23:40:20,115 INFO Registration_Discovery.Worker [main] Received document: Text1.txt
2024-01-25 23:40:20,116 INFO Registration_Discovery.Worker [main]
2024-01-25 23:40:20,117 INFO Registration_Discovery.Worker [main] Results in Text.txt Document:
2024-01-25 23:40:20,119 INFO Registration_Discovery.Worker [main] (Term: ali, Frequency: 31.0, Total Document Words: 131, Term Frequency (Percentage): 0.2366412213740458)
2024-01-25 23:40:20,120 INFO Registration_Discovery.Worker [main] ................................................
2024-01-25 23:40:20,121 INFO Registration_Discovery.Worker [main] Results in Text1.txt Document:
2024-01-25 23:40:20,122 INFO Registration_Discovery.Worker [main] (Term: ali, Frequency: 12.0, Total Document Words: 110, Term Frequency (Percentage): 0.10909090909090909)
2024-01-25 23:40:20,122 INFO Registration_Discovery.Worker [main] ................................................
2024-01-25 23:40:30,421 INFO Registration_Discovery.Worker [main] Search query: zein
2024-01-25 23:40:30,422 INFO Registration_Discovery.Worker [main] Received document: Text2.txt
2024-01-25 23:40:30,422 INFO Registration_Discovery.Worker [main]
2024-01-25 23:40:30,422 INFO Registration_Discovery.Worker [main] Results in Text2.txt Document:
2024-01-25 23:40:30,423 INFO Registration_Discovery.Worker [main] (Term: zein, Frequency: 60.0, Total Document Words: 209, Term Frequency (Percentage): 0.28708133971291866)
2024-01-25 23:40:30,423 INFO Registration_Discovery.Worker [main] ................................................
2024-01-25 23:40:30,429 INFO Registration_Discovery.Worker [main] Search query: zein
2024-01-25 23:40:30,429 INFO Registration_Discovery.Worker [main] Received document: Text.txt
2024-01-25 23:40:30,429 INFO Registration_Discovery.Worker [main] Received document: Text1.txt
2024-01-25 23:40:30,430 INFO Registration_Discovery.Worker [main]
2024-01-25 23:40:30,430 INFO Registration_Discovery.Worker [main] Results in Text.txt Document:
2024-01-25 23:40:30,431 INFO Registration_Discovery.Worker [main] (Term: zein, Frequency: 0.0, Total Document Words: 131, Term Frequency (Percentage): 0.0)
2024-01-25 23:40:30,431 INFO Registration_Discovery.Worker [main] ................................................
2024-01-25 23:40:30,432 INFO Registration_Discovery.Worker [main] Results in Text1.txt Document:
2024-01-25 23:40:30,433 INFO Registration_Discovery.Worker [main] (Term: zein, Frequency: 23.0, Total Document Words: 110, Term Frequency (Percentage): 0.20909090909090908)
2024-01-25 23:40:30,433 INFO Registration_Discovery.Worker [main] ................................................
2024-01-25 23:41:00,589 INFO Registration_Discovery.Worker [main] Search query: ali zein
2024-01-25 23:41:00,589 INFO Registration_Discovery.Worker [main] Received document: Text.txt
2024-01-25 23:41:00,589 INFO Registration_Discovery.Worker [main] Received document: Text1.txt
2024-01-25 23:41:00,589 INFO Registration_Discovery.Worker [main]
2024-01-25 23:41:00,590 INFO Registration_Discovery.Worker [main] Results in Text.txt Document:
2024-01-25 23:41:00,591 INFO Registration_Discovery.Worker [main] (Term: ali, Frequency: 31.0, Total Document Words: 131, Term Frequency (Percentage): 0.2366412213740458)
2024-01-25 23:41:00,592 INFO Registration_Discovery.Worker [main] (Term: zein, Frequency: 0.0, Total Document Words: 131, Term Frequency (Percentage): 0.0)
2024-01-25 23:41:00,592 INFO Registration_Discovery.Worker [main] ................................................
2024-01-25 23:41:00,593 INFO Registration_Discovery.Worker [main] Results in Text1.txt Document:
2024-01-25 23:41:00,594 INFO Registration_Discovery.Worker [main] (Term: ali, Frequency: 12.0, Total Document Words: 110, Term Frequency (Percentage): 0.10909090909090909)
2024-01-25 23:41:00,595 INFO Registration_Discovery.Worker [main] (Term: zein, Frequency: 23.0, Total Document Words: 110, Term Frequency (Percentage): 0.20909090909090908)
2024-01-25 23:41:00,595 INFO Registration_Discovery.Worker [main] ................................................
2024-01-25 23:41:00,621 INFO Registration_Discovery.Worker [main] Search query: ali zein
2024-01-25 23:41:00,621 INFO Registration_Discovery.Worker [main] Received document: Text2.txt
2024-01-25 23:41:00,621 INFO Registration_Discovery.Worker [main]
2024-01-25 23:41:00,622 INFO Registration_Discovery.Worker [main] Results in Text2.txt Document:
2024-01-25 23:41:00,623 INFO Registration_Discovery.Worker [main] (Term: ali, Frequency: 78.0, Total Document Words: 209, Term Frequency (Percentage): 0.37320574162679426)
2024-01-25 23:41:00,624 INFO Registration_Discovery.Worker [main] (Term: zein, Frequency: 60.0, Total Document Words: 209, Term Frequency (Percentage): 0.28708133971291866)
2024-01-25 23:41:00,624 INFO Registration_Discovery.Worker [main] ................................................
2024-01-25 23:41:29,926 INFO Registration_Discovery.Worker [main] Search query: ali zein ahmad
2024-01-25 23:41:29,926 INFO Registration_Discovery.Worker [main] Received document: Text2.txt
2024-01-25 23:41:29,926 INFO Registration_Discovery.Worker [main]
2024-01-25 23:41:29,927 INFO Registration_Discovery.Worker [main] Results in Text2.txt Document:
2024-01-25 23:41:29,928 INFO Registration_Discovery.Worker [main] (Term: ali, Frequency: 78.0, Total Document Words: 209, Term Frequency (Percentage): 0.37320574162679426)
2024-01-25 23:41:29,929 INFO Registration_Discovery.Worker [main] (Term: zein, Frequency: 60.0, Total Document Words: 209, Term Frequency (Percentage): 0.28708133971291866)
2024-01-25 23:41:29,930 INFO Registration_Discovery.Worker [main] (Term: ahmad, Frequency: 0.0, Total Document Words: 209, Term Frequency (Percentage): 0.0)
2024-01-25 23:41:29,930 INFO Registration_Discovery.Worker [main] ................................................
2024-01-25 23:41:29,940 INFO Registration_Discovery.Worker [main] Search query: ali zein ahmad
2024-01-25 23:41:29,940 INFO Registration_Discovery.Worker [main] Received document: Text.txt
2024-01-25 23:41:29,940 INFO Registration_Discovery.Worker [main] Received document: Text1.txt
2024-01-25 23:41:29,940 INFO Registration_Discovery.Worker [main]
2024-01-25 23:41:29,941 INFO Registration_Discovery.Worker [main] Results in Text.txt Document:
2024-01-25 23:41:29,942 INFO Registration_Discovery.Worker [main] (Term: ali, Frequency: 31.0, Total Document Words: 131, Term Frequency (Percentage): 0.2366412213740458)
2024-01-25 23:41:29,942 INFO Registration_Discovery.Worker [main] (Term: zein, Frequency: 0.0, Total Document Words: 131, Term Frequency (Percentage): 0.0)
2024-01-25 23:41:29,943 INFO Registration_Discovery.Worker [main] (Term: ahmad, Frequency: 21.0, Total Document Words: 131, Term Frequency (Percentage): 0.16030534351145037)
2024-01-25 23:41:29,943 INFO Registration_Discovery.Worker [main] ................................................
2024-01-25 23:41:29,944 INFO Registration_Discovery.Worker [main] Results in Text1.txt Document:
2024-01-25 23:41:29,944 INFO Registration_Discovery.Worker [main] (Term: ali, Frequency: 12.0, Total Document Words: 110, Term Frequency (Percentage): 0.10909090909090909)
2024-01-25 23:41:29,945 INFO Registration_Discovery.Worker [main] (Term: zein, Frequency: 23.0, Total Document Words: 110, Term Frequency (Percentage): 0.20909090909090908)
2024-01-25 23:41:29,946 INFO Registration_Discovery.Worker [main] (Term: ahmad, Frequency: 0.0, Total Document Words: 110, Term Frequency (Percentage): 0.0)
2024-01-25 23:41:29,946 INFO Registration_Discovery.Worker [main] ................................................
2024-01-25 23:42:41,496 INFO Registration_Discovery.Worker [main] Search query: hello
2024-01-25 23:42:41,497 INFO Registration_Discovery.Worker [main] Received document: Text.txt
2024-01-25 23:42:41,497 INFO Registration_Discovery.Worker [main] Received document: Text1.txt
2024-01-25 23:42:41,497 INFO Registration_Discovery.Worker [main] Received document: Text2.txt
2024-01-25 23:42:41,497 INFO Registration_Discovery.Worker [main]
2024-01-25 23:42:41,498 INFO Registration_Discovery.Worker [main] Results in Text.txt Document:
2024-01-25 23:42:41,498 INFO Registration_Discovery.Worker [main] (Term: hello, Frequency: 3.0, Total Document Words: 131, Term Frequency (Percentage): 0.022900763358778626)
2024-01-25 23:42:41,499 INFO Registration_Discovery.Worker [main] ................................................
2024-01-25 23:42:41,499 INFO Registration_Discovery.Worker [main] Results in Text1.txt Document:
2024-01-25 23:42:41,500 INFO Registration_Discovery.Worker [main] (Term: hello, Frequency: 0.0, Total Document Words: 110, Term Frequency (Percentage): 0.0)
2024-01-25 23:42:41,502 INFO Registration_Discovery.Worker [main] ................................................
2024-01-25 23:42:41,502 INFO Registration_Discovery.Worker [main] Results in Text2.txt Document:
2024-01-25 23:42:41,503 INFO Registration_Discovery.Worker [main] (Term: hello, Frequency: 0.0, Total Document Words: 209, Term Frequency (Percentage): 0.0)
2024-01-25 23:42:41,504 INFO Registration_Discovery.Worker [main] ................................................
2024-01-25 23:42:53,737 INFO Registration_Discovery.Worker [main] Search query: ali
2024-01-25 23:42:53,737 INFO Registration_Discovery.Worker [main] Received document: Text.txt
2024-01-25 23:42:53,737 INFO Registration_Discovery.Worker [main] Received document: Text1.txt
2024-01-25 23:42:53,738 INFO Registration_Discovery.Worker [main] Received document: Text2.txt
2024-01-25 23:42:53,738 INFO Registration_Discovery.Worker [main]
2024-01-25 23:42:53,738 INFO Registration_Discovery.Worker [main] Results in Text.txt Document:
2024-01-25 23:42:53,738 INFO Registration_Discovery.Worker [main] (Term: ali, Frequency: 31.0, Total Document Words: 131, Term Frequency (Percentage): 0.2366412213740458)
2024-01-25 23:42:53,738 INFO Registration_Discovery.Worker [main] ................................................
2024-01-25 23:42:53,739 INFO Registration_Discovery.Worker [main] Results in Text1.txt Document:
2024-01-25 23:42:53,739 INFO Registration_Discovery.Worker [main] (Term: ali, Frequency: 12.0, Total Document Words: 110, Term Frequency (Percentage): 0.10909090909090909)
2024-01-25 23:42:53,739 INFO Registration_Discovery.Worker [main] ................................................
2024-01-25 23:42:53,740 INFO Registration_Discovery.Worker [main] Results in Text2.txt Document:
2024-01-25 23:42:53,741 INFO Registration_Discovery.Worker [main] (Term: ali, Frequency: 78.0, Total Document Words: 209, Term Frequency (Percentage): 0.37320574162679426)
2024-01-25 23:42:53,741 INFO Registration_Discovery.Worker [main] ................................................
registration-discovery-leader-reelection-cordinator-workers/pom.xml 0 → 100644
View file @ 58cc723c
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<groupId>org.example</groupId>
<artifactId>Service-Registration-and-Discovery</artifactId>
<version>1.0-SNAPSHOT</version>
<properties>
<maven.compiler.source>17</maven.compiler.source>
<maven.compiler.target>17</maven.compiler.target>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
</properties>
<dependencies>
<dependency>
<groupId>org.apache.zookeeper</groupId>
<artifactId>zookeeper</artifactId>
<version>3.9.1</version>
</dependency>
<dependency>
<groupId>io.grpc</groupId>
<artifactId>grpc-stub</artifactId>
<version>1.53.0</version>
</dependency>
<dependency>
<groupId>io.grpc</groupId>
<artifactId>grpc-protobuf</artifactId>
<version>1.53.0</version>
</dependency>
<dependency>
<groupId>io.grpc</groupId>
<artifactId>grpc-netty-shaded</artifactId>
<version>1.53.0</version>
<scope>runtime</scope>
</dependency>
<dependency>
<groupId>javax.annotation</groupId>
<artifactId>javax.annotation-api</artifactId>
<version>1.3.2</version>
</dependency>
<dependency>
<groupId>ch.qos.logback</groupId>
<artifactId>logback-core</artifactId>
<version>1.2.10</version>
</dependency>
<!-- Logback Classic (API + Implementation) -->
<dependency>
<groupId>ch.qos.logback</groupId>
<artifactId>logback-classic</artifactId>
<version>1.2.10</version>
</dependency>
</dependencies>
<build>
<sourceDirectory>src/main/java</sourceDirectory>
<outputDirectory>target/classes</outputDirectory>
<plugins>
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-compiler-plugin</artifactId>
<version>3.12.1</version>
<configuration>
<source>17</source>
<target>17</target>
</configuration>
</plugin>
<plugin>
<groupId>org.xolstice.maven.plugins</groupId>
<artifactId>protobuf-maven-plugin</artifactId>
<version>0.6.1</version>
<configuration>
<protocArtifact>com.google.protobuf:protoc:3.17.3:exe:windows-x86_64</protocArtifact>
<pluginId>grpc-java</pluginId>
<pluginArtifact>io.grpc:protoc-gen-grpc-java:1.41.0:exe:windows-x86_64</pluginArtifact>
<protoSourceRoot>src/main/proto</protoSourceRoot>
</configuration>
<executions>
<execution>
<goals>
<goal>compile</goal>
<goal>compile-custom</goal>
</goals>
</execution>
</executions>
</plugin>
</plugins>
</build>
</project>
\ No newline at end of file
registration-discovery-leader-reelection-cordinator-workers/src/main/java/Registration_Discovery/Application.java 0 → 100644
View file @ 58cc723c
package Registration_Discovery;
import org.apache.zookeeper.KeeperException;
import org.apache.zookeeper.WatchedEvent;
import org.apache.zookeeper.Watcher;
import org.apache.zookeeper.ZooKeeper;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.io.IOException;
public class Application implements Watcher {
private static final Logger logger = LoggerFactory.getLogger(Application.class);
private static final String address = "192.168.181.136:2181";
private static final int SESSION_TIMEOUT = 3000; //dead client
private static final int DEFAULT_PORT = 8080;
private ZooKeeper zooKeeper;
public static void main(String[] args) throws IOException, InterruptedException, KeeperException {
int currentServerPort = args.length == 1 ? Integer.parseInt(args[0]) : DEFAULT_PORT;
Application application = new Application();
ZooKeeper zooKeeper = application.connectToZookeeper();
logger.info("Connected");
ServiceRegistry serviceRegistry = new ServiceRegistry(zooKeeper);
OnElectionAction onElectionAction = new OnElectionAction(serviceRegistry, currentServerPort);
LeaderElection leaderElection = new LeaderElection(zooKeeper, onElectionAction);
leaderElection.volunteerForLeadership();
leaderElection.reelectLeader();
application.run();
application.close();
}
public ZooKeeper connectToZookeeper() throws IOException {
this.zooKeeper = new ZooKeeper(address, SESSION_TIMEOUT, this);
return zooKeeper;
}
public void run() throws InterruptedException {
synchronized (zooKeeper) {
zooKeeper.wait();
}
}
private void close() throws InterruptedException {
this.zooKeeper.close();
}
@Override
public void process(WatchedEvent watchedEvent) {
switch (watchedEvent.getType()) {
case None:
if (watchedEvent.getState() == Event.KeeperState.SyncConnected) {
logger.debug("Successfully connected to Zookeeper");
} else if (watchedEvent.getState() == Event.KeeperState.Disconnected) {
synchronized (zooKeeper) {
logger.debug("Disconnected from Zookeeper");
zooKeeper.notifyAll();
}
} else if (watchedEvent.getState() == Event.KeeperState.Closed) {
logger.debug("Closed Successfully");
}
break;
}
}
}
registration-discovery-leader-reelection-cordinator-workers/src/main/java/Registration_Discovery/DataForSearch.java 0 → 100644
View file @ 58cc723c
package Registration_Discovery;
import java.io.Serializable;
import java.util.List;
public class DataForSearch implements Serializable {
private String searchQuery;
private List<Document> documents;
public DataForSearch(String searchQuery, List<Document> documents) {
this.searchQuery = searchQuery;
this.documents = documents;
}
public String getSearchQuery() {
return searchQuery;
}
public List<Document> getDocuments() {
return documents;
}
public void setSearchQuery(String searchQuery) {
this.searchQuery = searchQuery;
}
public void setDocuments(List<Document> documents) {
this.documents = documents;
}
}
registration-discovery-leader-reelection-cordinator-workers/src/main/java/Registration_Discovery/Document.java 0 → 100644
View file @ 58cc723c
package Registration_Discovery;
import java.io.Serializable;
public class Document implements Serializable, Comparable<Document> {
private String name;
public Document(String name) {
this.name = name;
}
public String getName() {
return name;
}
@Override
public int compareTo(Document doc2) {
return this.name.compareTo(doc2.getName());
}
}
registration-discovery-leader-reelection-cordinator-workers/src/main/java/Registration_Discovery/DocumentTermsInfo.java 0 → 100644
View file @ 58cc723c
package Registration_Discovery;
import java.io.Serializable;
import java.util.HashMap;
public class DocumentTermsInfo implements Serializable {
private Document document;
private HashMap<String,Double> termFrequency;
public DocumentTermsInfo() {
}
public DocumentTermsInfo(Document document, HashMap<String, Double> termFrequency) {
this.document = document;
this.termFrequency = termFrequency;
}
public Document getDocument() {
return document;
}
public void setDocument(Document document) {
this.document = document;
}
public HashMap<String, Double> getTermFrequency() {
return termFrequency;
}
public void setTermFrequency(HashMap<String, Double> termFrequency) {
this.termFrequency = termFrequency;
}
}
registration-discovery-leader-reelection-cordinator-workers/src/main/java/Registration_Discovery/Leader.java 0 → 100644
View file @ 58cc723c
package Registration_Discovery;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.io.IOException;
import java.io.InputStream;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.net.Socket;
import java.net.URL;
import java.nio.file.Files;
import java.nio.file.Path;
import java.nio.file.Paths;
import java.util.*;
public class Leader {
private int PORT = 12345;
private ServiceRegistry serviceRegistry;
List<DocumentTermsInfo> documentTermsInfo;
private static final String FOLDER_PATH = "D:\\DS_Project\\resources";
private static final Logger logger = LoggerFactory.getLogger(Leader.class);
public Leader(int port, ServiceRegistry serviceRegistry) {
this.PORT = port;
this.serviceRegistry = serviceRegistry;
}
public void start() throws IOException, InterruptedException {
String searchQuery = "";
while (!searchQuery.equals("exit")) {
documentTermsInfo = new ArrayList<>();
Scanner scanner = new Scanner(System.in);
logger.info("Enter your Search Query: ");
searchQuery = scanner.nextLine();
logger.info("Search Query: "+searchQuery);
if(!searchQuery.isEmpty()){
// Get the list of documents from the resources folder
List<Document> documents = getDocumentsFromResources();
Map<Document,Double> documentsScores = new HashMap<>();
List<String> allServiceAddresses = serviceRegistry.getAllServiceAddresses();
int numAddresses = allServiceAddresses.size();
int numDocuments = documents.size();
if(numAddresses != 0){
if(numDocuments != 0){
int documentsPerAddress = numDocuments / numAddresses;
int remainingDocuments = numDocuments % numAddresses;
List<Thread> threads = new ArrayList<>();
int startIndex = 0;
for (String address : allServiceAddresses) {
int endIndex = startIndex + documentsPerAddress;
if (remainingDocuments > 0) {
endIndex++;
remainingDocuments--;
}
List<Document> subDocuments = new ArrayList<>();
for(int i= startIndex; i<endIndex;i++){
subDocuments.add(documents.get(i));
}
startIndex = endIndex;
DataForSearch dataForSearch = new DataForSearch(searchQuery, subDocuments);
Thread thread = new Thread(() -> {
try {
startSearchOnWorker(address, dataForSearch);
} catch (IOException | InterruptedException e) {
e.printStackTrace();
logger.error("Interrupted while searching on workers: {}", e.getMessage());
}
});
thread.start();
threads.add(thread);
}
for (Thread thread : threads) {
thread.join();
}
logger.info("\n\n");
displayDocumentTermsInfos(documentTermsInfo);
Map<String,Double> IDFs = calculateIDF(documentTermsInfo, (double) numDocuments,searchQuery);
documentsScores = calculateDocumentsScore(IDFs ,documentTermsInfo);
TreeMap<Document, Double> sortedDocumentsScores = sortDocumentsScores(documentsScores);
displaySortedScores(sortedDocumentsScores);
}
else {
logger.info("No results !!!!");
}
}
else {
logger.info("Try again later !!!!");
}
}else {
logger.info("Please enter search query !!!");
}
}
}
private Map<Document, Double> calculateDocumentsScore(Map<String, Double> idFs, List<DocumentTermsInfo> documentTermsInfo) {
Map<Document, Double> documentsScores = new TreeMap<>();
for(DocumentTermsInfo docTermsInfo : documentTermsInfo){
Document document = docTermsInfo.getDocument();
Double score = 0.0;
for (Map.Entry<String, Double> entry : docTermsInfo.getTermFrequency().entrySet()) {
String term = entry.getKey();
Double termFreq = entry.getValue();
score = score + (idFs.get(term)*termFreq);
}
documentsScores.put(document,score);
}
return documentsScores;
}
private List<Document> getDocumentsFromResources() {
List<Document> documents = new ArrayList<>();
try {
Path resourcesPath = Paths.get(FOLDER_PATH);
// Filter out only regular files
Files.walk(resourcesPath)
.filter(Files::isRegularFile)
.forEach(path -> {
String fileName = resourcesPath.relativize(path).toString();
Document document = new Document(fileName);
documents.add(document);
});
} catch (IOException e) {
e.printStackTrace();
}
return documents;
}
private void displayDocumentTermsInfos(List<DocumentTermsInfo> documentTermsInfoList) {
System.out.println();
System.out.println();
for (DocumentTermsInfo documentTermsInfo : documentTermsInfoList) {
Document document = documentTermsInfo.getDocument();
HashMap<String, Double> termsInfo = documentTermsInfo.getTermFrequency();
logger.info("Terms Info In: "+document.getName()+" Document:");
for (Map.Entry<String, Double> entry : termsInfo.entrySet()) {
String term = entry.getKey();
Double freq = entry.getValue();
logger.info("(Term: " + term + " , Term Frequency: "+freq+")");
}
logger.info("\n");
logger.info("................................................");
}
}
private void startSearchOnWorker(String workerAddress,DataForSearch dataForSearch) throws IOException, InterruptedException {
String[] addressParts = workerAddress.split(":");
int port = Integer.parseInt(addressParts[1]);
String ipAddress = addressParts[0];
logger.info(String.format("Searching on worker: %s ", ipAddress + ":" + port));
try {
// Create a socket connection to the worker
Socket socket = new Socket(ipAddress, port);
// Create an ObjectOutputStream for sending the data for search
ObjectOutputStream objectStream = new ObjectOutputStream(socket.getOutputStream());
// Send the data for search to the worker
objectStream.writeObject(dataForSearch);
// Create an ObjectInputStream for receiving the document scores
ObjectInputStream inputStream = new ObjectInputStream(socket.getInputStream());
// Receive the document scores from the worker
List<DocumentTermsInfo> docTermsInfo = (List<DocumentTermsInfo>) inputStream.readObject();
synchronized (documentTermsInfo) {
documentTermsInfo.addAll(docTermsInfo);
}
// Close the socket connection
socket.close();
} catch (IOException | ClassNotFoundException e) {
// Handle connection or communication error
e.printStackTrace();
logger.error("Interrupted while opening socket with worker: {}", e.getMessage());
}
}
private Map<String,Double> calculateIDF(List<DocumentTermsInfo> documentTermsInfo,Double totalDocuments ,String searchQuery){
Map<String,Double> IDFs = new HashMap<>();
Map<String, Double> wordDocumentCount = new HashMap<>();
String[] queryWords = searchQuery.split("\\s+");
for(DocumentTermsInfo documentTermsInfo1 :documentTermsInfo ){
for (Map.Entry<String, Double> entry : documentTermsInfo1.getTermFrequency().entrySet()) {
String term = entry.getKey();
Double count = entry.getValue();
if(count > 0.0){
wordDocumentCount.put(term, wordDocumentCount.getOrDefault(term, 0.0) + 1);
}
}
}
logger.info("Number Of Documents Which Contains Our Terms: ");
logger.info("Total Documents: "+ totalDocuments);
for (Map.Entry<String, Double> entry : wordDocumentCount.entrySet()) {
String term = entry.getKey();
Double count = entry.getValue();
logger.info("Term: " + term + " , Count: "+ count);
}
logger.info("-------------------------");
for (String word : queryWords) {
Double idf = 0.0;
Double documentsContainsWord = wordDocumentCount.getOrDefault(word,0.0);
if(documentsContainsWord != 0.0){
idf = Math.log10( totalDocuments / documentsContainsWord);
}
IDFs.put(word,idf);
}
logger.info("IDFs Info: ");
for (Map.Entry<String, Double> entry : IDFs.entrySet()) {
String term = entry.getKey();
Double idf = entry.getValue();
logger.info("Term: " + term + " , Term IDF: "+idf);
}
logger.info("-------------------------");
logger.info("\n");
return IDFs;
}
private TreeMap<Document, Double> sortDocumentsScores(Map<Document, Double> documentsScores) {
Comparator<Document> comparator = new Comparator<Document>() {
@Override
public int compare(Document doc1, Document doc2) {
Double score1 = documentsScores.get(doc1);
Double score2 = documentsScores.get(doc2);
int scoreComparison = score2.compareTo(score1);
if (scoreComparison != 0) {
return scoreComparison;
} else {
return doc1.compareTo(doc2);
}
}
};
TreeMap<Document, Double> sortedMap = new TreeMap<>(comparator);
sortedMap.putAll(documentsScores);
return sortedMap;
}
private void displaySortedScores(TreeMap<Document, Double> sortedScores) {
logger.info("Sorted Documents By Scores:");
for (Map.Entry<Document, Double> entry : sortedScores.entrySet()) {
Document document = entry.getKey();
Double score = entry.getValue();
logger.info("Document: " + document.getName() + " , Document score: " + score);
}
}
}
registration-discovery-leader-reelection-cordinator-workers/src/main/java/Registration_Discovery/LeaderElection.java 0 → 100644
View file @ 58cc723c
package Registration_Discovery;
import org.apache.zookeeper.*;
import org.apache.zookeeper.data.Stat;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.util.Collections;
import java.util.List;
public class LeaderElection implements Watcher {
private static final Logger logger = LoggerFactory.getLogger(LeaderElection.class);
private static final String ELECTION_NAMESPACE = "/election";
private String currentZnodeName;
private ZooKeeper zooKeeper;
private OnElectionCallback onElectionCallback;
public LeaderElection(ZooKeeper zooKeeper, OnElectionCallback onElectionCallback) {
this.zooKeeper = zooKeeper;
this.onElectionCallback = onElectionCallback;
}
public void volunteerForLeadership() throws InterruptedException, KeeperException {
String znodePrefix = ELECTION_NAMESPACE + "/c_";
String znodeFullPath = zooKeeper.create(znodePrefix, new byte[]{}, ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL_SEQUENTIAL);
System.out.println(znodeFullPath);
this.currentZnodeName = znodeFullPath.replace(ELECTION_NAMESPACE + "/", "");
}
public void reelectLeader() throws InterruptedException, KeeperException {
String predecessorName = "";
Stat predecessorStat = null;
//this while to guarantee get predecessor even if it deleted just before zookeeper.exist
while (predecessorStat == null) {
List<String> children = zooKeeper.getChildren(ELECTION_NAMESPACE, false);
Collections.sort(children);
String smallestChild = children.get(0); //the first element
if (smallestChild.equals(currentZnodeName)) {
logger.info("I'm a leader");
onElectionCallback.onElectedToBeLeader();
return;
} else {
System.out.println("I'm not a leader");
logger.info("I'm not a leader");
int predecessorIndex = children.indexOf(currentZnodeName) - 1;
predecessorName = children.get(predecessorIndex);
predecessorStat = zooKeeper.exists(ELECTION_NAMESPACE + "/" + predecessorName, this);
}
}
onElectionCallback.onWorker();
// System.out.println("Watching znode " + predecessorName);
logger.info("Watching znode {}", predecessorName);
System.out.println();
}
@Override
public void process(WatchedEvent watchedEvent) {
switch (watchedEvent.getType()) {
case NodeDeleted:
try {
reelectLeader();
} catch (InterruptedException e) {
throw new RuntimeException(e);
} catch (KeeperException e) {
throw new RuntimeException(e);
}
break;
}
}
}
registration-discovery-leader-reelection-cordinator-workers/src/main/java/Registration_Discovery/OnElectionAction.java 0 → 100644
View file @ 58cc723c
package Registration_Discovery;
import org.apache.zookeeper.KeeperException;
import java.io.IOException;
import java.net.InetAddress;
import java.net.UnknownHostException;
public class OnElectionAction implements OnElectionCallback {
private final ServiceRegistry serviceRegistry;
private final int port;
public OnElectionAction(ServiceRegistry serviceRegistry, int port) {
this.serviceRegistry = serviceRegistry;
this.port = port;
}
@Override
public void onElectedToBeLeader() {
serviceRegistry.unregisterFromCluster();
serviceRegistry.registerForUpdates();
Leader leader = new Leader(port, serviceRegistry);
try {
leader.start();
} catch (IOException e) {
throw new RuntimeException(e);
} catch (InterruptedException e) {
throw new RuntimeException(e);
}
}
@Override
public void onWorker() {
try {
String ipAddress = InetAddress.getLocalHost().getHostAddress();
String currentServerAddress = String.format("%s:%s", ipAddress, port);
serviceRegistry.registerToCluster(currentServerAddress);
Worker worker = new Worker(port);
worker.start();
} catch (InterruptedException e) {
e.printStackTrace();
} catch (UnknownHostException e) {
e.printStackTrace();
} catch (KeeperException e) {
e.printStackTrace();
}
}
}
registration-discovery-leader-reelection-cordinator-workers/src/main/java/Registration_Discovery/OnElectionCallback.java 0 → 100644
View file @ 58cc723c
package Registration_Discovery;
public interface OnElectionCallback {
void onElectedToBeLeader();
void onWorker();
}
registration-discovery-leader-reelection-cordinator-workers/src/main/java/Registration_Discovery/ServiceRegistry.java 0 → 100644
View file @ 58cc723c
package Registration_Discovery;
import org.apache.zookeeper.*;
import org.apache.zookeeper.data.Stat;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.util.ArrayList;
import java.util.Collections;
import java.util.List;
public class ServiceRegistry implements Watcher {
private static final Logger logger = LoggerFactory.getLogger(ServiceRegistry.class);
private static final String REGISTRY_ZNODE = "/service_registry";
private final ZooKeeper zooKeeper;
private String currentZnode = null;
private List<String> allServiceAddresses = null;
public List<String> getAllServiceAddresses() {
return allServiceAddresses;
}
public ServiceRegistry(ZooKeeper zooKeeper) {
this.zooKeeper = zooKeeper;
createServiceRegistryZnode();
}
private void createServiceRegistryZnode() {
try {
if (zooKeeper.exists(REGISTRY_ZNODE, false) == null) {
zooKeeper.create(REGISTRY_ZNODE, new byte[]{}, ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
}
} catch (KeeperException e) {
e.printStackTrace();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
public void registerToCluster(String metadata) throws KeeperException, InterruptedException {
if (this.currentZnode != null) {
// System.out.println("Already registered to service registry");
logger.debug("Already registered to service registry");
return;
}
this.currentZnode = zooKeeper.create(REGISTRY_ZNODE + "/n_", metadata.getBytes(),
ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL_SEQUENTIAL);
// System.out.println("Registered to service registry");
logger.debug("Registered to service registry");
}
public void registerForUpdates() {
try {
updateAddresses();
} catch (KeeperException e) {
e.printStackTrace();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
public void unregisterFromCluster() {
try {
if (currentZnode != null && zooKeeper.exists(currentZnode, false) != null) {
zooKeeper.delete(currentZnode, -1);
}
} catch (KeeperException e) {
e.printStackTrace();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
private synchronized void updateAddresses() throws KeeperException, InterruptedException {
List<String> workerZnodes = zooKeeper.getChildren(REGISTRY_ZNODE, this);
List<String> addresses = new ArrayList<>(workerZnodes.size());
for (String workerZnode : workerZnodes) {
String workerFullPath = REGISTRY_ZNODE + "/" + workerZnode;
Stat stat = zooKeeper.exists(workerFullPath, false);
if (stat == null) {
continue;
}
byte[] addressBytes = zooKeeper.getData(workerFullPath, false, stat);
String address = new String(addressBytes);
addresses.add(address);
}
this.allServiceAddresses = Collections.unmodifiableList(addresses);
// System.out.println("The cluster addresses are: " + this.allServiceAddresses);
logger.info("The cluster addresses are: {}",this.allServiceAddresses);
}
@Override
public void process(WatchedEvent watchedEvent) {
try {
updateAddresses();
} catch (KeeperException e) {
throw new RuntimeException(e);
} catch (InterruptedException e) {
throw new RuntimeException(e);
}
}
}
registration-discovery-leader-reelection-cordinator-workers/src/main/java/Registration_Discovery/Worker.java 0 → 100644
View file @ 58cc723c
package Registration_Discovery;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;
import java.net.URL;
import java.util.*;
public class Worker {
private int PORT = 12345;
private static final Logger logger = LoggerFactory.getLogger(Worker.class);
public Worker(int port) {
this.PORT = port;
}
public void start() {
// Start the worker to receive the list of documents
receiveDataForSearchFromLeader();
}
private void receiveDataForSearchFromLeader() {
// Create a server socket to listen for incoming connections
try (ServerSocket serverSocket = new ServerSocket(PORT)) {
// Infinite loop to continuously listen for connections
while (true) {
// Accept incoming connection from the leader
Socket socket = serverSocket.accept();
// Create an ObjectInputStream for receiving the list of documents
ObjectInputStream objectStream = new ObjectInputStream(socket.getInputStream());
// Receive the list of documents from the leader
DataForSearch receivedData = (DataForSearch) objectStream.readObject();
logger.info("Search query: {}", receivedData.getSearchQuery());
// Process the received list of documents
for (Document document : receivedData.getDocuments()) {
logger.info("Received document: {}", document.getName());
}
logger.info("");
List<DocumentTermsInfo> documentTermsInfos = calculateDocumentScores(receivedData.getDocuments(), receivedData.getSearchQuery());
sendDocumentTermsInfoToLeader(socket, documentTermsInfos);
// Close the socket connection
socket.close();
}
} catch (IOException | ClassNotFoundException e) {
// Handle connection or communication error
e.printStackTrace();
logger.error("An error occurred while receiving data from leader", e);
}
}
private List<DocumentTermsInfo> calculateDocumentScores(List<Document> documents, String searchQuery) {
List<DocumentTermsInfo> documentTermsInfos = new ArrayList<>();
// Split the search query into words
String[] queryWords = searchQuery.split("\\s+");
// Calculate the score for each document
for (Document document : documents) {
String filePath = "D:\\DS_Project\\resources\\" + document.getName(); // Complete path to your file
File file = new File(filePath);
if (!file.exists()) {
logger.warn("File not found: {}", filePath);
continue;
}
// Open an input stream to read the file
try (InputStream inputStream = new FileInputStream(file)) {
// Read the file contents
byte[] data = inputStream.readAllBytes();
String fileContent = new String(data);
// Calculate the score for the document based on the search query
DocumentTermsInfo documentTermsInfo = calculateScore(fileContent, queryWords,document.getName());
documentTermsInfos.add(documentTermsInfo);
} catch (IOException e) {
logger.error("An error occurred while calculating the document scores", e);
e.printStackTrace();
}
}
return documentTermsInfos;
}
private DocumentTermsInfo calculateScore(String fileContent, String[] queryWords, String docName) {
DocumentTermsInfo documentTermsInfo = new DocumentTermsInfo();
Document document = new Document(docName);
documentTermsInfo.setDocument(document);
HashMap<String,Double> termsInfo = new HashMap<String,Double>();
double TF = 0.0;
logger.info("Results in {} Document:", docName);
for (String word : queryWords) {
Double termFrequency = 0.0;
double wordCountInDocument = countWordOccurrences(fileContent, word);
String[] documentWords = fileContent.split("\\s+");
termFrequency = calculateTermFrequency(wordCountInDocument,documentWords.length);
logger.info("(Term: {}, Frequency: {}, Total Document Words: {}, Term Frequency (Percentage): {})", word, wordCountInDocument, documentWords.length, termFrequency);
termsInfo.put(word,termFrequency);
}
logger.info("................................................");
documentTermsInfo.setTermFrequency(termsInfo);
return documentTermsInfo;
}
private double countWordOccurrences(String fileContent, String word) {
String[] documentWords = fileContent.split("\\s+");
double count = 0;
for (String documentWord : documentWords) {
if (documentWord.toLowerCase().contains(word.toLowerCase())) {
count++;
}
}
return count;
}
private double calculateTermFrequency(double wordCountInDocument,double documentWordsCount) {
double TF = 0.0;
if(documentWordsCount != 0){
TF = (wordCountInDocument / documentWordsCount);
}
return TF;
}
private void sendDocumentTermsInfoToLeader(Socket socket, List<DocumentTermsInfo> documentTermsInfo) {
try {
// Create an ObjectOutputStream for sending the document scores
ObjectOutputStream objectStream = new ObjectOutputStream(socket.getOutputStream());
// Send the document scores to the leader
objectStream.writeObject(documentTermsInfo);
// Flush and close the object stream
objectStream.flush();
objectStream.close();
} catch (IOException e) {
// Handle communication error
e.printStackTrace();
logger.error("An error occurred while sending results to leader", e);
}
}
}
registration-discovery-leader-reelection-cordinator-workers/src/main/resources/META-INF/MANIFEST.MF 0 → 100644
View file @ 58cc723c
Manifest-Version: 1.0
Main-Class: Registration_Discovery.Application
registration-discovery-leader-reelection-cordinator-workers/src/main/resources/logback.xml 0 → 100644
View file @ 58cc723c
<?xml version="1.0" encoding="UTF-8"?>
<configuration>
<property name="HOME_LOG" value="../../../logs/leader.log"/>
<property name="HOME_LOG_W" value="../../../logs/worker.log"/>
<property name="HOME_LOG_P" value="../../../logs/project.log"/>
<appender name="CONSOLE" class="ch.qos.logback.core.ConsoleAppender">
<layout class="ch.qos.logback.classic.PatternLayout">
<Pattern>
%d{HH:mm:ss.SSS} [%t] %-5level %logger{36} - %msg%n
</Pattern>
</layout>
</appender>
<appender name="FILE" class="ch.qos.logback.core.FileAppender">
<file>${HOME_LOG}</file>
<append>true</append>
<immediateFlush>true</immediateFlush>
<encoder>
<pattern>%d %p %c{1.} [%t] %m%n</pattern>
</encoder>
</appender>
<appender name="FILE1" class="ch.qos.logback.core.FileAppender">
<file>${HOME_LOG_W}</file>
<append>true</append>
<immediateFlush>true</immediateFlush>
<encoder>
<pattern>%d %p %c{1.} [%t] %m%n</pattern>
</encoder>
</appender>
<appender name="FILE2" class="ch.qos.logback.core.FileAppender">
<file>${HOME_LOG_P}</file>
<append>true</append>
<immediateFlush>true</immediateFlush>
<encoder>
<pattern>%d %p %c{1.} [%t] %m%n</pattern>
</encoder>
</appender>
<!-- Log Level: ERROR, WARN, INFO, DEBUG, TRACE-->
<logger name="Registration_Discovery.Leader" level="DEBUG" additivity="false">
<appender-ref ref="FILE"/>
</logger>
<logger name="Registration_Discovery.Worker" level="DEBUG" additivity="false">
<appender-ref ref="FILE1"/>
</logger>
<logger name="Registration_Discovery" level="DEBUG" additivity="false">
<appender-ref ref="CONSOLE"/>
<appender-ref ref="FILE2"/>
</logger>
<root level="error">
<appender-ref ref="FILE"/>
</root>
</configuration>
registration-discovery-leader-reelection-cordinator-workers/target/classes/META-INF/MANIFEST.MF 0 → 100644
View file @ 58cc723c
Manifest-Version: 1.0
Main-Class: Registration_Discovery.Application
registration-discovery-leader-reelection-cordinator-workers/target/classes/logback.xml 0 → 100644
View file @ 58cc723c
<?xml version="1.0" encoding="UTF-8"?>
<configuration>
<property name="HOME_LOG" value="../../../logs/leader.log"/>
<property name="HOME_LOG_W" value="../../../logs/worker.log"/>
<property name="HOME_LOG_P" value="../../../logs/project.log"/>
<appender name="CONSOLE" class="ch.qos.logback.core.ConsoleAppender">
<layout class="ch.qos.logback.classic.PatternLayout">
<Pattern>
%d{HH:mm:ss.SSS} [%t] %-5level %logger{36} - %msg%n
</Pattern>
</layout>
</appender>
<appender name="FILE" class="ch.qos.logback.core.FileAppender">
<file>${HOME_LOG}</file>
<append>true</append>
<immediateFlush>true</immediateFlush>
<encoder>
<pattern>%d %p %c{1.} [%t] %m%n</pattern>
</encoder>
</appender>
<appender name="FILE1" class="ch.qos.logback.core.FileAppender">
<file>${HOME_LOG_W}</file>
<append>true</append>
<immediateFlush>true</immediateFlush>
<encoder>
<pattern>%d %p %c{1.} [%t] %m%n</pattern>
</encoder>
</appender>
<appender name="FILE2" class="ch.qos.logback.core.FileAppender">
<file>${HOME_LOG_P}</file>
<append>true</append>
<immediateFlush>true</immediateFlush>
<encoder>
<pattern>%d %p %c{1.} [%t] %m%n</pattern>
</encoder>
</appender>
<!-- Log Level: ERROR, WARN, INFO, DEBUG, TRACE-->
<logger name="Registration_Discovery.Leader" level="DEBUG" additivity="false">
<appender-ref ref="FILE"/>
</logger>
<logger name="Registration_Discovery.Worker" level="DEBUG" additivity="false">
<appender-ref ref="FILE1"/>
</logger>
<logger name="Registration_Discovery" level="DEBUG" additivity="false">
<appender-ref ref="CONSOLE"/>
<appender-ref ref="FILE2"/>
</logger>
<root level="error">
<appender-ref ref="FILE"/>
</root>
</configuration>
registration-discovery-leader-reelection-cordinator-workers/target/maven-archiver/pom.properties 0 → 100644
View file @ 58cc723c
artifactId=Service-Registration-and-Discovery
groupId=org.example
version=1.0-SNAPSHOT
registration-discovery-leader-reelection-cordinator-workers/target/maven-status/maven-compiler-plugin/compile/default-compile/createdFiles.lst 0 → 100644
View file @ 58cc723c
Registration_Discovery\DocumentTermsInfo.class
Registration_Discovery\LeaderElection.class
Registration_Discovery\Application.class
Registration_Discovery\LeaderElection$1.class
Registration_Discovery\Application$1.class
Registration_Discovery\Leader.class
Registration_Discovery\ServiceRegistry.class
Registration_Discovery\Worker.class
Registration_Discovery\DataForSearch.class
Registration_Discovery\TermFrequencyAndCount.class
Registration_Discovery\Leader$1.class
Registration_Discovery\OnElectionAction.class
Registration_Discovery\OnElectionCallback.class
Registration_Discovery\DocumentScore.class
Registration_Discovery\Document.class
registration-discovery-leader-reelection-cordinator-workers/target/maven-status/maven-compiler-plugin/compile/default-compile/inputFiles.lst 0 → 100644
View file @ 58cc723c
D:\DS_Project\registration-and-discovery-zookeeper\src\main\java\Registration_Discovery\Application.java
D:\DS_Project\registration-and-discovery-zookeeper\src\main\java\Registration_Discovery\DataForSearch.java
D:\DS_Project\registration-and-discovery-zookeeper\src\main\java\Registration_Discovery\Document.java
D:\DS_Project\registration-and-discovery-zookeeper\src\main\java\Registration_Discovery\DocumentScore.java
D:\DS_Project\registration-and-discovery-zookeeper\src\main\java\Registration_Discovery\DocumentTermsInfo.java
D:\DS_Project\registration-and-discovery-zookeeper\src\main\java\Registration_Discovery\Leader.java
D:\DS_Project\registration-and-discovery-zookeeper\src\main\java\Registration_Discovery\LeaderElection.java
D:\DS_Project\registration-and-discovery-zookeeper\src\main\java\Registration_Discovery\OnElectionAction.java
D:\DS_Project\registration-and-discovery-zookeeper\src\main\java\Registration_Discovery\OnElectionCallback.java
D:\DS_Project\registration-and-discovery-zookeeper\src\main\java\Registration_Discovery\ServiceRegistry.java
D:\DS_Project\registration-and-discovery-zookeeper\src\main\java\Registration_Discovery\TermFrequencyAndCount.java
D:\DS_Project\registration-and-discovery-zookeeper\src\main\java\Registration_Discovery\Worker.java
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment

HIAST - GitLab