String getDirPath ( Date date , Record record ) throws StageException { if ( dirPathTemplateInHeader ) { // We're not validating if the header exists as that job is already done return record . getHeader ( ) . getAttribute ( HdfsTarget . TARGET_DIRECTORY_HEADER ) ; } return pathResolver . resolvePath ( date , record ) ; }
Returns directory path for given record and date .