提交 caa11fe2 authored 作者: 王红亮's avatar 王红亮

更新ftp配置

上级 2863f25c
...@@ -34,7 +34,7 @@ public class FtpAConfiguration { ...@@ -34,7 +34,7 @@ public class FtpAConfiguration {
throw new IllegalArgumentException( throw new IllegalArgumentException(
"FtpRedshift datasource port is null, please check your config"); "FtpRedshift datasource port is null, please check your config");
} }
if (!ftpOption.containsKey(FtpOptionRule.USERNAME.key())) { if (!ftpOption.containsKey(FtpOptionRule.USER.key())) {
throw new IllegalArgumentException( throw new IllegalArgumentException(
"FtpRedshift datasource username is null, please check your config"); "FtpRedshift datasource username is null, please check your config");
} }
...@@ -53,7 +53,7 @@ public class FtpAConfiguration { ...@@ -53,7 +53,7 @@ public class FtpAConfiguration {
FtpConfiguration ftpConfiguration = new FtpConfiguration(); FtpConfiguration ftpConfiguration = new FtpConfiguration();
ftpConfiguration.setHost(ftpOption.get(FtpOptionRule.HOST.key())); ftpConfiguration.setHost(ftpOption.get(FtpOptionRule.HOST.key()));
ftpConfiguration.setPort(ftpOption.get(FtpOptionRule.PORT.key())); ftpConfiguration.setPort(ftpOption.get(FtpOptionRule.PORT.key()));
ftpConfiguration.setUser(ftpOption.get(FtpOptionRule.USERNAME.key())); ftpConfiguration.setUser(ftpOption.get(FtpOptionRule.USER.key()));
ftpConfiguration.setPassword(ftpOption.get(FtpOptionRule.PASSWORD.key())); ftpConfiguration.setPassword(ftpOption.get(FtpOptionRule.PASSWORD.key()));
ftpConfiguration.setPath(ftpOption.get(FtpOptionRule.PATH.key())); ftpConfiguration.setPath(ftpOption.get(FtpOptionRule.PATH.key()));
ftpConfiguration.setType(ftpOption.get(FtpOptionRule.FILE_FORMAT_TYPE.key())); ftpConfiguration.setType(ftpOption.get(FtpOptionRule.FILE_FORMAT_TYPE.key()));
......
...@@ -30,7 +30,7 @@ import java.util.Set; ...@@ -30,7 +30,7 @@ import java.util.Set;
@AutoService(DataSourceFactory.class) @AutoService(DataSourceFactory.class)
public class FtpDataSourceFactory implements DataSourceFactory { public class FtpDataSourceFactory implements DataSourceFactory {
private static final String PLUGIN_NAME = "Ftp"; private static final String PLUGIN_NAME = "FtpFile";
@Override @Override
public String factoryIdentifier() { public String factoryIdentifier() {
......
...@@ -34,7 +34,7 @@ public class FtpOptionRule { ...@@ -34,7 +34,7 @@ public class FtpOptionRule {
.intType() .intType()
.noDefaultValue() .noDefaultValue()
.withDescription("the default port to use for connections"); .withDescription("the default port to use for connections");
public static final Option<String> USERNAME = public static final Option<String> USER =
Options.key("username") Options.key("username")
.stringType() .stringType()
.noDefaultValue() .noDefaultValue()
...@@ -57,7 +57,7 @@ public class FtpOptionRule { ...@@ -57,7 +57,7 @@ public class FtpOptionRule {
Options.key("delimiter").stringType().noDefaultValue().withDescription("delimiter"); Options.key("delimiter").stringType().noDefaultValue().withDescription("delimiter");
public static OptionRule optionRule() { public static OptionRule optionRule() {
return OptionRule.builder().required(HOST, PORT).optional(USERNAME, PASSWORD, PATH).build(); return OptionRule.builder().required(HOST, PORT).optional(USER, PASSWORD, PATH).build();
} }
public static OptionRule metadataRule() { public static OptionRule metadataRule() {
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论