[CRUNCH-676] Declare createTempPath() in the Pipeline interface

• Type: New Feature
• Status: Open
• Priority: Minor
• Resolution: Unresolved
• Component/s: Core
• Assignee: Josh Wills
• Reporter: Ryan Kemp
• Created: 13/Feb/19 22:20
• Updated: 16/Feb/19 00:21

Description

DistributedPipeline declares public createTempPath(), but MemPipeline does not. Can createTempPath() be declared in Pipeline and implemented in MemPipeline?

The method in MemPipeline could be extremely similar to DistributedPipeline.

• conf.get("crunch.tmp.dir", "/tmp");
• Maintain a tempFileIndex