add parameter: timeout

Author: civitaspo

README.md

@@ -18,6 +18,7 @@ Stores files on a SFTP Server
 - **secret_key_file**: (string, default: `null`)
 - **secret_key_passphrase**: (string, default: `""`)
 - **user_directory_is_root**: (boolean, default: `true`)
+- **timeout**: sftp connection timeout seconds (integer, default: `600`)
 - **path_prefix**: Prefix of output paths (string, required)
 - **file_ext**: Extension of output files (string, required)
 - **sequence_format**: Format for sequence part of output files (string, default: `".%03d.%02d"`)
@@ -33,6 +34,7 @@ out:
   secret_key_file: /Users/civitaspo/.ssh/id_rsa
   secret_key_passphrase: secret_pass
   user_directory_is_root: false
+  timeout: 600
   path_prefix: /data/sftp
   file_ext: _20151020.tsv
   sequence_format: ".%01d%01d"

src/main/java/org/embulk/output/sftp/SftpFileOutput.java

@@ -76,6 +76,7 @@ private FileSystemOptions initializeFsOptions(PluginTask task)
 
         try {
             SftpFileSystemConfigBuilder.getInstance().setUserDirIsRoot(fsOptions, task.getUserDirIsRoot());
+            SftpFileSystemConfigBuilder.getInstance().setTimeout(fsOptions, task.getSftpConnectionTimeout());
             SftpFileSystemConfigBuilder.getInstance().setStrictHostKeyChecking(fsOptions, "no");
             if (task.getSecretKeyFilePath().isPresent()) {
                 IdentityInfo identityInfo = new IdentityInfo(new File((task.getSecretKeyFilePath().get())), task.getSecretKeyPassphrase().getBytes());

src/main/java/org/embulk/output/sftp/SftpFileOutputPlugin.java

@@ -49,6 +49,10 @@ public interface PluginTask
         @ConfigDefault("true")
         public Boolean getUserDirIsRoot();
 
+        @Config("timeout")
+        @ConfigDefault("600") // 10 munites
+        public int getSftpConnectionTimeout();
+
         @Config("path_prefix")
         public String getPathPrefix();