I've not tried this myself, but it looks like there is a "ROW_NUMBER" expression that you could add as a column (use a "function") https://docs.oracle.com/cd/B19306_01/server.102/b14200/functions137.htm If that works as hoped, your map stages could then simply look at that column value and do nothing if it's greater than 1000.