protected DatasetDescriptor createDestinationDescriptor ( WorkUnitState state , int branchId ) { Path publisherOutputDir = getPublisherOutputDir ( state , branchId ) ; FileSystem fs = this . publisherFileSystemByBranches . get ( branchId ) ; DatasetDescriptor destination = new DatasetDescriptor ( fs . getScheme ( ) , publisherOutputDir . toString ( ) ) ; destination . addMetadata ( DatasetConstants . FS_URI , fs . getUri ( ) . toString ( ) ) ; destination . addMetadata ( DatasetConstants . BRANCH , String . valueOf ( branchId ) ) ; return destination ; }
Create destination dataset descriptor