(Tuple t)
| 84 | } |
| 85 | |
| 86 | @Override |
| 87 | public void putNext(Tuple t) throws IOException { |
| 88 | try { |
| 89 | recWriter.write(null, t); |
| 90 | } |
| 91 | catch (InterruptedException e) { |
| 92 | throw new IOException(e); |
| 93 | } |
| 94 | } |
| 95 | |
| 96 | public static class TFileInputFormat extends |
| 97 | PigFileInputFormat<Text, Tuple> { |