Project

General

Profile

« Previous | Next » 

Revision 48589

Need to pass some parameters to the M/R job of OpenAIRE: adding a couple of params in the PrepareOAIJobNode (skip duplicate and xpath)

View differences:

modules/dnet-oai-common-workflows/trunk/src/main/java/eu/dnetlib/msro/oai/workflows/nodes/PrepareOaiDataJobNode.java
31 31
	private String oaiInterpretation;
32 32
	private String oaiSource;
33 33

  
34
	private boolean skipDuplicates = false;
35
	private String duplicateXPath;
36

  
34 37
	/*
35 38
	 * (non-Javadoc)
36 39
	 * 
......
48 51

  
49 52
		String configurationProfile = getConfigurationProfile();
50 53
		setIfNotBlank(OAIParameterNames.OAI_CONFIGURATION_PROFILE, configurationProfile, token);
54
		token.getEnv().setAttribute(OAIParameterNames.OAI_SKIP_DUPLICATES, String.valueOf(skipDuplicates));
55
		if(skipDuplicates) token.getEnv().setAttribute(OAIParameterNames.OAI_DUPLICATE_XPATH, duplicateXPath);
51 56
		return Arc.DEFAULT_ARC;
52 57
	}
53 58

  
......
112 117
		this.oaiSource = oaiSource;
113 118
	}
114 119

  
120
	public boolean isSkipDuplicates() {
121
		return skipDuplicates;
122
	}
115 123

  
124
	public void setSkipDuplicates(final boolean skipDuplicates) {
125
		this.skipDuplicates = skipDuplicates;
126
	}
127

  
128
	public String getDuplicateXPath() {
129
		return duplicateXPath;
130
	}
131

  
132
	public void setDuplicateXPath(final String duplicateXPath) {
133
		this.duplicateXPath = duplicateXPath;
134
	}
135

  
136

  
137

  
116 138
}

Also available in: Unified diff