//获取配置

Configuration conf = getConf();
FileSystem fs = inputPath.getFileSystem(conf);

//在您的案例中指定筛选器、日期。

PathFilter pf = new FileFilter(conf, fs, new String[] { "txt" });

//递归地移动或复制

moveRecursivelytoTarget(target, fs, inputPath, pf);

protected void moveRecursivelytoTarget(String target, FileSystem fs, Path path, PathFilter inputFilter)
    throws IOException
  {
    for (FileStatus stat : fs.listStatus(path, inputFilter))
      if (stat.isDir())
        moveRecursivelytoTarget(target, fs, stat.getPath(), inputFilter);
      else
      {
        fs.copyFromLocalFile(stat.getPath(), target);
        //Or rename
        //rename(stat.getPath(), target) 
      }
 }

您也可以在shell中执行相同的过程。
为了创建动态分区，将上面收集的信息放入一个临时表中，将其称为tablea，然后用parttion从tablea读取并写入tablemain，您就可以清理这个表一天。

set hive.exec.dynamic.partition=true; 
INSERT OVERWRITE TABLE tableMain PARTITION (date) SELECT x,y,z 
FROM tableA t;