Skip to content

Commit 33dd804

Browse files
committed
renamed TestClientConfigurationConfigurable -> TestAwsClientConfiguration
1 parent 9ad7d37 commit 33dd804

File tree

4 files changed

+7
-7
lines changed

4 files changed

+7
-7
lines changed

embulk-input-s3/src/main/java/org/embulk/input/s3/AbstractS3FileInputPlugin.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -62,7 +62,7 @@ public interface PluginTask
6262

6363
@Config("client_config")
6464
@ConfigDefault("{}")
65-
public AwsClientConfigurationsTask getClientConfig();
65+
public AwsClientConfigurationTask getClientConfig();
6666

6767
public FileList getFiles();
6868
public void setFiles(FileList files);

embulk-input-s3/src/main/java/org/embulk/input/s3/AwsClientConfigurationsTask.java renamed to embulk-input-s3/src/main/java/org/embulk/input/s3/AwsClientConfigurationTask.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,7 @@
77
import org.embulk.config.Task;
88
import org.embulk.spi.unit.ByteSize;
99

10-
public interface AwsClientConfigurationsTask
10+
public interface AwsClientConfigurationTask
1111
extends Task
1212
{
1313
// NOTE: Can use `client_execution_timeout` from v1.10.65

embulk-input-s3/src/main/java/org/embulk/input/s3/AwsClientConfigurations.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -12,7 +12,7 @@
1212

1313
public class AwsClientConfigurations
1414
{
15-
public static ClientConfiguration getClientConfiguration(AwsClientConfigurationsTask task)
15+
public static ClientConfiguration getClientConfiguration(AwsClientConfigurationTask task)
1616
{
1717
ClientConfiguration c = new ClientConfiguration();
1818

@@ -100,7 +100,7 @@ public static ClientConfiguration getClientConfiguration(AwsClientConfigurations
100100

101101
if (task.getSecureRandom().isPresent()) {
102102
try {
103-
AwsClientConfigurationsTask.SecureRandomTask secureRandomTask = task.getSecureRandom().get();
103+
AwsClientConfigurationTask.SecureRandomTask secureRandomTask = task.getSecureRandom().get();
104104
SecureRandom rand =
105105
secureRandomTask.getProvider().isPresent()
106106
? SecureRandom.getInstance(secureRandomTask.getAlgorithm(), secureRandomTask.getProvider().get())

embulk-input-s3/src/test/java/org/embulk/input/s3/TestClientConfigurationConfigurable.java renamed to embulk-input-s3/src/test/java/org/embulk/input/s3/TestAwsClientConfiguration.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,7 @@
1717
import static org.embulk.input.s3.TestS3FileInputPlugin.schemaConfig;
1818
import static org.junit.Assert.assertEquals;
1919

20-
public class TestClientConfigurationConfigurable
20+
public class TestAwsClientConfiguration
2121
{
2222
@Rule
2323
public EmbulkTestRuntime runtime = new EmbulkTestRuntime();
@@ -54,13 +54,13 @@ public void setTwoParam()
5454
{
5555
config.setNested("client_config", Exec.newConfigSource()
5656
.set("socket_send_buffer_size_hint", "1MB")
57-
.set("socket_receive_buffer_size_hint", "1MB"));
57+
.set("socket_receive_buffer_size_hint", "2MB"));
5858

5959
ClientConfiguration clientConfiguration = getClientConfiguration();
6060

6161
int[] socketBufferSizeHints = clientConfiguration.getSocketBufferSizeHints();
6262
assertEquals(1 << 20, socketBufferSizeHints[0]);
63-
assertEquals(1 << 20, socketBufferSizeHints[1]);
63+
assertEquals(2 << 20, socketBufferSizeHints[1]);
6464
}
6565

6666
@Test

0 commit comments

Comments
 (0)