gistfile1.txt

require 'hdfs/classpath'

fs   = Hadoop::DFS::FileSystem.new local: true
dfs  = Hadoop::DFS::FileSystem.new host: 'nn-beta-1263dd15.ewr01.tumblr.net'
binlog_path = '/db-binlog'
binlogs     = Dir.glob(File.join(binlog_path, '*')).select {|entry| entry.start_with? File.join binlog_path, 'binlog.0'}.sort.tap(&:pop)

binlogs.each {|binlog| fs.copy(binlog, File.join('/blog_shard_merge_binlogs', '7e707b78_master', File.basename(binlog)), dfs)}