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);
  }
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.
@param taskState Task state
@param numBranches # of branches in the state
@param branch Branch to retrieve
@return Map of properties for compression