forked from D-Net/dnet-hadoop
code formatting
This commit is contained in:
parent
0393cdce42
commit
d0d477cca3
|
@ -142,15 +142,14 @@ public class ModelConstants {
|
||||||
public static final Qualifier MAIN_TITLE_QUALIFIER = qualifier(
|
public static final Qualifier MAIN_TITLE_QUALIFIER = qualifier(
|
||||||
"main title", "main title", DNET_DATACITE_TITLE, DNET_DATACITE_TITLE);
|
"main title", "main title", DNET_DATACITE_TITLE, DNET_DATACITE_TITLE);
|
||||||
|
|
||||||
|
public static final AccessRight OPEN_ACCESS_RIGHT() {
|
||||||
public static final AccessRight OPEN_ACCESS_RIGHT () {
|
|
||||||
|
|
||||||
final AccessRight result = new AccessRight();
|
final AccessRight result = new AccessRight();
|
||||||
result.setClassid(ACCESS_RIGHT_OPEN);
|
result.setClassid(ACCESS_RIGHT_OPEN);
|
||||||
result.setClassid(ACCESS_RIGHT_OPEN);
|
result.setClassid(ACCESS_RIGHT_OPEN);
|
||||||
result.setSchemeid(ModelConstants.DNET_ACCESS_MODES);
|
result.setSchemeid(ModelConstants.DNET_ACCESS_MODES);
|
||||||
result.setSchemename(ModelConstants.DNET_ACCESS_MODES);
|
result.setSchemename(ModelConstants.DNET_ACCESS_MODES);
|
||||||
return result;
|
return result;
|
||||||
}
|
}
|
||||||
|
|
||||||
private static Qualifier qualifier(
|
private static Qualifier qualifier(
|
||||||
|
|
|
@ -111,7 +111,7 @@ public class TransformSparkJobNode {
|
||||||
log.info("workflowId is {}", workflowId);
|
log.info("workflowId is {}", workflowId);
|
||||||
|
|
||||||
MapFunction<MetadataRecord, MetadataRecord> x = TransformationFactory
|
MapFunction<MetadataRecord, MetadataRecord> x = TransformationFactory
|
||||||
.getTransformationPlugin(args, ct, isLookUpService);
|
.getTransformationPlugin(args, ct, isLookUpService);
|
||||||
|
|
||||||
final Dataset<MetadataRecord> inputMDStore = spark
|
final Dataset<MetadataRecord> inputMDStore = spark
|
||||||
.read()
|
.read()
|
||||||
|
|
|
@ -15,7 +15,6 @@ import java.sql.SQLException;
|
||||||
import java.util.List;
|
import java.util.List;
|
||||||
import java.util.Objects;
|
import java.util.Objects;
|
||||||
|
|
||||||
import com.google.common.collect.Lists;
|
|
||||||
import org.apache.commons.io.IOUtils;
|
import org.apache.commons.io.IOUtils;
|
||||||
import org.apache.commons.lang3.StringUtils;
|
import org.apache.commons.lang3.StringUtils;
|
||||||
import org.junit.jupiter.api.BeforeEach;
|
import org.junit.jupiter.api.BeforeEach;
|
||||||
|
@ -27,6 +26,7 @@ import org.mockito.junit.jupiter.MockitoExtension;
|
||||||
|
|
||||||
import com.fasterxml.jackson.core.type.TypeReference;
|
import com.fasterxml.jackson.core.type.TypeReference;
|
||||||
import com.fasterxml.jackson.databind.ObjectMapper;
|
import com.fasterxml.jackson.databind.ObjectMapper;
|
||||||
|
import com.google.common.collect.Lists;
|
||||||
|
|
||||||
import eu.dnetlib.dhp.common.vocabulary.VocabularyGroup;
|
import eu.dnetlib.dhp.common.vocabulary.VocabularyGroup;
|
||||||
import eu.dnetlib.dhp.schema.oaf.*;
|
import eu.dnetlib.dhp.schema.oaf.*;
|
||||||
|
|
Loading…
Reference in New Issue