| 512 | } |
| 513 | |
| 514 | public static InputStream getCompositeStream(InputStream in, Properties properties) { |
| 515 | //Load default ~/.pigbootup if not specified by user |
| 516 | final String bootupFile = properties.getProperty("pig.load.default.statements", System.getProperty("user.home") + "/.pigbootup"); |
| 517 | try { |
| 518 | final InputStream inputSteam = new FileInputStream(new File(bootupFile)); |
| 519 | return new SequenceInputStream(inputSteam, in); |
| 520 | } catch(FileNotFoundException fe) { |
| 521 | log.info("Default bootup file " +bootupFile+ " not found"); |
| 522 | return in; |
| 523 | } |
| 524 | } |
| 525 | |
| 526 | /** |
| 527 | * Method to apply pig properties to JobConf (replaces properties with |