{
  "pipeline": {
    "name": "reduce"
  },
  "transform": {
    "cmd": ["sh"],
    "stdin": [
        "find /pfs/map/ -name '*' | while read count; do cat $count | awk '{ sum+=$1} END {print sum}' >/tmp/count; mv /tmp/count /pfs/out/`basename $count`; echo `basename $count`; done"
    ]
  },
  "inputs": [
    {
      "repo": {
        "name": "map"
      },
      "glob": "/*"
    }
  ]
}


{
  "pipeline": {
    "name": "reduce"
  },
  "transform": {
    "cmd": ["sh"],
    "stdin": [
        "find /pfs/map/ -name '*' | while read count; do cat $count | awk '{ sum+=$1} END {print sum}' >/tmp/count; mv /tmp/count /pfs/out/`basename $count`; echo `basename $count`; done"
    ]
  },
  "inputs": [
    {
      "repo": {
        "name": "map"
      },
      "glob": "/"
    }
  ]
}


Use / for glob pattern to minimize the number of datums and thus improve performance
Use / for glob pattern to minimize the number of datums and thus improve performance
