| 225 | } |
| 226 | |
| 227 | @Test |
| 228 | public void testNative() throws Exception { |
| 229 | String query = |
| 230 | "a = load 'file:///tmp/input' as (x:int, y:int);" + |
| 231 | "b = native 'hadoop-examples.jar' Store a into '/tmp/table_testNativeMRJobSimple_input' Load '/tmp/table_testNativeMRJobSimple_output' `wordcount /tmp/table_testNativeMRJobSimple_input /tmp/table_testNativeMRJobSimple_output`;" + |
| 232 | "store b into 'file:///tmp/pigoutput';"; |
| 233 | |
| 234 | run(query, "test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-Native-1.gld"); |
| 235 | } |
| 236 | |
| 237 | @Test |
| 238 | public void testFilter() throws Exception { |