code: @Override
    protected void movePath(ParallelRunner parallelRunner, State state, Path src, Path dst, int branchId)
        throws IOException {
  
      String outputDir = dst.getParent().toString();
      String schemaName = dst.getName();
      Path newDst = new Path(new Path(outputDir, getDbTableName(schemaName)), timestamp);
  
      if (!this.publisherFileSystemByBranches.get(branchId).exists(newDst)) {
        WriterUtils.mkdirsWithRecursivePermissionWithRetry(this.publisherFileSystemByBranches.get(branchId),
            newDst.getParent(), this.permissions.get(branchId), this.retrierConfig);
      }
  
      super.movePath(parallelRunner, state, src, newDst, branchId);
    }
docs: Update destination path to put db and table name in format "dbname.tablename" using {@link #getDbTableName(String)}
  and include timestamp
  
  Input dst format: {finaldir}/{schemaName}
  Output dst format: {finaldir}/{dbname.tablename}/{currenttimestamp}