in src/main/java/software/amazon/neptune/csv2rdf/NeptuneCsvHeader.java [186:209]
public NeptuneCsvEdgeHeader(Integer id, Integer from, Integer to, Integer label,
@NonNull List<NeptuneCsvUserDefinedColumn> userDefinedTypes) {
super(id, label, userDefinedTypes);
this.from = from;
this.to = to;
if (this.from == null) {
throw new Csv2RdfException("An edge requires a " + FROM + " field.");
}
if (this.to == null) {
throw new Csv2RdfException("An edge requires a " + TO + " field.");
}
if (this.getLabel() == null) {
throw new Csv2RdfException("An edge requires a " + LABEL + " field.");
}
for (NeptuneCsvUserDefinedColumn userDefinedType : this.getUserDefinedTypes()) {
if (userDefinedType.isArray()) {
throw new Csv2RdfException("Array types are not allowed for edges: " + userDefinedType.getName());
}
if (userDefinedType.getCardinality() == Cardinality.SET) {
throw new Csv2RdfException(
"Set-valued types are not allowed for edges: " + userDefinedType.getName());
}
}
}