public static Map < String , Object > getConfigForBranch ( State taskState , int numBranches , int branch ) { String typePropertyName = ForkOperatorUtils . getPropertyNameForBranch ( ConfigurationKeys . WRITER_CODEC_TYPE , numBranches , branch ) ; String compressionType = taskState . getProp ( typePropertyName ) ; if ( compressionType == null ) { return null ; } return ImmutableMap . < String , Object > of ( COMPRESSION_TYPE_KEY , compressionType ) ; }
Retrieve configuration settings for a given branch .