| 783 | |
| 784 | static fs_ptr<DB::HDFSFileSystem> defaultHdfsFileSystem = nullptr; |
| 785 | void registerDefaultHdfsFileSystem( |
| 786 | const HDFSConnectionParams & hdfs_params, const int max_fd_num, const int skip_fd_num, const int io_error_num_to_reconnect) |
| 787 | { |
| 788 | // force ha mode. |
| 789 | HDFSConnectionParams ha_params = hdfs_params; |
| 790 | ha_params.setNNProxyHa(true); |
| 791 | defaultHdfsFileSystem = std::make_shared<DB::HDFSFileSystem>(ha_params, max_fd_num, skip_fd_num, io_error_num_to_reconnect); |
| 792 | } |
| 793 | |
| 794 | |
| 795 | fs_ptr<DB::HDFSFileSystem> & getDefaultHdfsFileSystem() |