This is an automated email from the ASF dual-hosted git repository.
aloalt pushed a change to branch WAYANG-FL
in repository https://gitbox.apache.org/repos/asf/incubator-wayang.git
from 1d2217ee updated versions in pom file
add 91a7f7e9 Tests working with multiple clients
new b11afbda Merge pull request #516 from Akshit1235/WAYANG-FL
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
wayang-fl/src/main/java/org/client/Client.java | 18 ++++++
wayang-fl/src/main/java/org/client/FLClient.java | 44 +++++++++++---
.../src/main/java/org/client/FLClientApp.java | 20 ++++++-
wayang-fl/src/main/java/org/components/FLJob.java | 36 ++++++++++--
.../src/main/java/org/components/FLJobStatus.java | 18 ++++++
.../src/main/java/org/components/FLSystem.java | 18 ++++++
.../java/org/components/aggregator/Aggregator.java | 18 ++++++
.../java/org/components/criterion/Criterion.java | 18 ++++++
.../org/components/criterion/EpochsCriterion.java | 18 ++++++
.../java/org/functions/AggregatorFunction.java | 18 ++++++
.../src/main/java/org/functions/PlanFunction.java | 19 ++++++
.../org/messages/AggregateResponsesMessage.java | 18 ++++++
.../java/org/messages/CheckCriterionMessage.java | 18 ++++++
.../org/messages/ClientUpdateRequestMessage.java | 18 ++++++
.../org/messages/ClientUpdateResponseMessage.java | 18 ++++++
.../java/org/messages/FinalOperandMessage.java | 18 ++++++
.../java/org/messages/HandshakeAckMessage.java | 18 ++++++
.../main/java/org/messages/HandshakeMessage.java | 18 ++++++
.../org/messages/InitiateHandshakeMessage.java | 18 ++++++
wayang-fl/src/main/java/org/messages/Message.java | 18 ++++++
.../messages/PlanHyperparametersAckMessage.java | 8 +--
.../org/messages/PlanHyperparametersMessage.java | 18 ++++++
.../java/org/messages/RunIterationMessage.java | 18 ++++++
.../messages/SendPlanHyperparametersMessage.java | 18 ++++++
.../main/java/org/messages/UpdateStateMessage.java | 18 ++++++
wayang-fl/src/main/java/org/server/FLServer.java | 31 ++++++++++
wayang-fl/src/main/java/org/server/Server.java | 18 ++++++
.../src/test/java/org/test/FLClientTest1.java | 39 ++++++-------
.../src/test/java/org/test/FLClientTest2.java | 40 ++++++-------
.../src/test/java/org/test/FLClientTest3.java | 40 ++++++-------
.../src/test/java/org/test/FLIntegrationTest.java | 54 ++++++++++++++---
.../src/test/resources/client-application.conf | 20 -------
.../src/test/resources/client1-application.conf | 67 ++++++++++++----------
.../src/test/resources/client2-application.conf | 23 ++++++--
.../src/test/resources/client3-application.conf | 23 ++++++--
.../src/test/resources/server-application.conf | 17 ++++++
36 files changed, 703 insertions(+), 156 deletions(-)
copy
wayang-api/wayang-api-python/src/main/java/org/apache/wayang/api/python/PythonAPI.java
=> wayang-fl/src/main/java/org/messages/PlanHyperparametersAckMessage.java
(89%)
copy
wayang-platforms/wayang-giraph/src/main/java/org/apache/wayang/giraph/Giraph.java
=> wayang-fl/src/test/java/org/test/FLClientTest1.java (54%)
copy
wayang-platforms/wayang-giraph/src/main/java/org/apache/wayang/giraph/Giraph.java
=> wayang-fl/src/test/java/org/test/FLClientTest2.java (54%)
copy
wayang-platforms/wayang-giraph/src/main/java/org/apache/wayang/giraph/Giraph.java
=> wayang-fl/src/test/java/org/test/FLClientTest3.java (54%)
delete mode 100644 wayang-fl/src/test/resources/client-application.conf
copy conf/flink/default.properties =>
wayang-fl/src/test/resources/client1-application.conf (71%)
copy conf/spark/default.properties =>
wayang-fl/src/test/resources/client2-application.conf (73%)
copy conf/spark/default.properties =>
wayang-fl/src/test/resources/client3-application.conf (73%)
