apache/celeborn
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

[CELEBORN-1273] Move java classes under scala src to java

Browse Source 
### What changes were proposed in this pull request?
Just fix minor typo:
```
ls **/scala/**/*.java
common/src/main/scala/org/apache/celeborn/common/meta/WorkerEventInfo.java common/src/main/scala/org/apache/celeborn/common/meta/WorkerStatus.java
```

After this:
```
ls **/scala/**/*.java
zsh: no matches found: **/scala/**/*.java

ls **/java/**/*.scala
zsh: no matches found: **/java/**/*.scala
```
### Why are the changes needed?
Fix code format.

### Does this PR introduce _any_ user-facing change?
No.

### How was this patch tested?
Existing UT.

Closes #2310 from turboFei/scala_java.

Authored-by: Fei Wang <fwang12@ebay.com>
Signed-off-by: SteNicholas <programgeek@163.com>
This commit is contained in:
Fei Wang 2024-02-20 15:34:18 +08:00 committed by SteNicholas
parent 93818d96d5
commit 4f23af49c9
2 changed files with 6 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
common/src/main/scala/org/apache/celeborn/common/meta/WorkerEventInfo.java → common/src/main/java/org/apache/celeborn/common/meta/WorkerEventInfo.java
View File

@ -17,11 +17,11 @@
package org.apache.celeborn.common.meta;
import org.apache.celeborn.common.protocol.WorkerEventType;
import java.io.Serializable;
import java.util.Objects;
import org.apache.celeborn.common.protocol.WorkerEventType;
public class WorkerEventInfo implements Serializable {
private static final long serialVersionUID = 5681914909039445235L;
private int eventTypeValue;

7
common/src/main/scala/org/apache/celeborn/common/meta/WorkerStatus.java → common/src/main/java/org/apache/celeborn/common/meta/WorkerStatus.java
View File

@ -17,10 +17,10 @@
package org.apache.celeborn.common.meta;
import org.apache.celeborn.common.protocol.PbWorkerStatus;
import java.util.Objects;
import org.apache.celeborn.common.protocol.PbWorkerStatus;
public class WorkerStatus {
private int stateValue;
private long stateStartTime;
@ -55,7 +55,8 @@ public class WorkerStatus {
return false;
}
WorkerStatus that = (WorkerStatus) o;
return getStateValue() == that.getStateValue() && getStateStartTime() == that.getStateStartTime();
return getStateValue() == that.getStateValue()
&& getStateStartTime() == that.getStateStartTime();
}
@Override