in timescaledb-connector/src/main/java/com/epam/deltix/timebase/connector/util/ConnectorUtils.java [29:52]
public static TimescaleColumn convert(DataField dataField, String parentFieldName, String descriptorName) {
if (dataField == null) {
throw new IllegalArgumentException("Timebase data field is not specified.");
}
DataType dataType = dataField.getType();
String name = dataField.getName();
String fieldName;
if (parentFieldName != null) {
fieldName = parentFieldName + "_" + name;
} else {
fieldName = name;
}
TimescaleColumn.TimescaleDataType timescaleDataType = getTimescaleDataType(dataType);
boolean isArray = isArray(dataType);
return TimescaleColumn.builder()
.name(fieldName)
.dataType(timescaleDataType)
.relatedDescriptors(descriptorName == null ? Collections.emptyList() : Collections.singletonList(descriptorName))
.isArray(isArray)
.build();
}