Skip to content

Commit

Permalink
Fix the code style.
Browse files Browse the repository at this point in the history
  • Loading branch information
xianrenzw committed Feb 10, 2025
1 parent e07e8a9 commit faed8b9
Showing 1 changed file with 20 additions and 11 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -18,6 +18,7 @@
*/
package org.apache.bigtop.manager.stack.extra.v1_0_0.seatunnel;

import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;

import static org.junit.jupiter.api.Assertions.assertEquals;
Expand All @@ -26,33 +27,41 @@

public class SeaTunnelParamsTest {

private SeaTunnelParams seaTunnelParams;

@BeforeEach
public void setUp() {
seaTunnelParams = mock(SeaTunnelParams.class);
when(seaTunnelParams.stackHome()).thenReturn("/stack");
when(seaTunnelParams.getServiceName()).thenCallRealMethod();
when(seaTunnelParams.serviceHome()).thenCallRealMethod();
when(seaTunnelParams.sparkHome()).thenCallRealMethod();
when(seaTunnelParams.flinkHome()).thenCallRealMethod();
when(seaTunnelParams.confDir()).thenCallRealMethod();
}

@Test
public void testServiceHome() {
assertEquals("/stack/seatunnel", seaTunnelParams.serviceHome());
}

@Test
public void testConfDir() {
SeaTunnelParams seaTunnelParams = mock(SeaTunnelParams.class);
when(seaTunnelParams.serviceHome()).thenReturn("/bigtop/seatunnel");
when(seaTunnelParams.confDir()).thenCallRealMethod();
assertEquals("/bigtop/seatunnel/config", seaTunnelParams.confDir());
assertEquals("/stack/seatunnel/config", seaTunnelParams.confDir());
}

@Test
public void testSparkHome() {
SeaTunnelParams seaTunnelParams = mock(SeaTunnelParams.class);
when(seaTunnelParams.stackHome()).thenReturn("/stack");
when(seaTunnelParams.sparkHome()).thenCallRealMethod();
assertEquals("/stack/spark", seaTunnelParams.sparkHome());
}

@Test
public void testFlinkHome() {
SeaTunnelParams seaTunnelParams = mock(SeaTunnelParams.class);
when(seaTunnelParams.stackHome()).thenReturn("/stack");
when(seaTunnelParams.flinkHome()).thenCallRealMethod();
assertEquals("/stack/flink", seaTunnelParams.flinkHome());
}

@Test
public void testGetServiceName() {
SeaTunnelParams seaTunnelParams = new SeaTunnelParams();
assertEquals("seatunnel", seaTunnelParams.getServiceName());
}
}

0 comments on commit faed8b9

Please sign in to comment.