TigerGraph FARS 2020-2022 Implementation

Schema Diagram and Graph Statistics

Every edge type is directed and also has a reverse edge reverse_<TYPE> for traversal in the opposite direction (not counted below).

Vertex Statistics

Vertex Type	Count
Accident	115,142
Vehicle	182,055
Person	280,093
Event	329,040
VPICDecode	173,667
Trailer	4,742
DrugEvent	349,255
Weather	13
CrashRF	29
Damage	16
Distract	22
DrImpair	15
DriverRF	67
Factor	20
Maneuver	10
VehicleSF	13
Violatn	76
Vision	19
Race	20
PersonRF	44
NMCrash	24
NMDistract	18
NMImpair	14
NMPrior	15
DrugTest	12
Drug	422

Edge Statistics

Relationship	Count
(:Accident)-[:INVOLVES]->(:Vehicle)	182,055
(:Accident)-[:HAS_VICTIM]->(:Person)	280,093
(:Accident)-[:RESULTED_IN]->(:Event)	329,040
(:Vehicle)-[:HAS_OCCUPANT]->(:Person)	252,980
(:Vehicle)-[:SUBJECT_OF]->(:Event)	329,040
(:Vehicle)-[:OBJECT_OF]->(:Event)	66,079
(:Vehicle)-[:HAS_VEVENT]->(:Event)	395,119
(:Vehicle)-[:HAS_VPIC]->(:VPICDecode)	173,667
(:Vehicle)-[:HAS_TRAILER]->(:Trailer)	4,742
(:DrugEvent)-[:DRUG_EVENT_OF]->(:Person)	349,255
(:DrugTest)-[:DRUG_TEST_OF]->(:DrugEvent)	349,255
(:Drug)-[:RESULT_OF]->(:DrugEvent)	349,255
(:Accident)-[:OCCURRED_IN]->(:Weather)	116,337
(:CrashRF)-[:CRASH_FACTOR_OF]->(:Accident)	116,019
(:Damage)-[:POSITION_OF]->(:Vehicle)	761,383
(:Distract)-[:DISTRACTION_OF]->(:Vehicle)	177,181
(:DrImpair)-[:IMPAIRMENT_OF]->(:Vehicle)	177,703
(:DriverRF)-[:DRIVER_RF_OF]->(:Vehicle)	195,590
(:Factor)-[:FACTOR_OF]->(:Vehicle)	177,351
(:Maneuver)-[:MANEUVER_OF]->(:Vehicle)	177,145
(:VehicleSF)-[:VEHICLE_SF_OF]->(:Vehicle)	182,057
(:Violatn)-[:COMMITTED_BY]->(:Vehicle)	190,012
(:Vision)-[:VISION_OF]->(:Vehicle)	177,246
(:Race)-[:RACE_OF]->(:Person)	280,633
(:PersonRF)-[:PERSON_RF_OF]->(:Person)	280,134
(:NMCrash)-[:NMCRASH_OF]->(:Person)	37,908
(:NMDistract)-[:NMDISTRACT_OF]->(:Person)	27,125
(:NMImpair)-[:NMIMPAIR_OF]->(:Person)	27,182
(:NMPrior)-[:NMPRIOR_OF]->(:Person)	28,191

Total import time: 83.05 Seconds (schema 38.59 s + job creation 4.73 s + loading 32.87 s + rebuild 6.86 s)

Data Loading

Select a button below to jump to that part of the code. The schema and the two loading jobs are each shown as one complete GSQL script, exactly as run; the buttons jump to the line for each type.

Preparation

Vertex Types

Edge Types

Loading Jobs

Vertex Loading

Edge Loading

Overview

This workload covers only the 2020–2022 FARS releases, whose table layouts are nearly identical, unlike the full 1975–2022 import. All 33 tables of the three years are first cleaned into one tab-separated file per node label and one per (source label, relationship, target label) triple: 26 node files and 29 relationship files, 1.2 GB in total. The same files are loaded into neo4j and uploaded to hdfs, so every platform holds exactly the same graph.

The cleaning is the only Python step. Loading itself uses only GSQL: no data passes through Python.

Data Preparation (Python)

build_csv.py reads <year>/National/*.csv for 2020–2022 and applies the following rules:

Encoding: each source file is decoded as UTF-8, falling back to cp1252 (both occur). Output is UTF-8 with LF line endings. Non-breaking spaces become spaces, \x1a and en/em dashes become -, curly quotes become straight quotes, and tabs and newlines inside values become spaces.
Columns: names are upper-cased (2020 vpicdecode is camel-cased) and the three years are merged by column union; a column missing in a year is left empty. ORDER and TRIM are renamed to RACE_ORDER and TRIM1 because they are GSQL keywords.
Keys: accident_id = <year>_<ST_CASE>, vehicle_id = <accident_id>_<VEH_NO>, person_id = <vehicle_id>_<PER_NO>, event_id = <accident_id>_<EVENTNUM>. Keys are unique within a label.
Parked and working vehicles (parkwork) are merged into Vehicle: their P-prefixed columns are mapped to the matching vehicle columns (for example PMAKE → MAKE, PVEH_SEV → DEFORMED; all 113 map), and source_table records vehicle or parkwork. Both tables share the VEH_NO numbering and never overlap; pvehiclesf is merged into vehiclesf the same way.
1:1 tables are folded into their parent node; vsoe is fully derivable from vevent (checked row by row) and is stored as the AOI property of HAS_VEVENT.
Code nodes {id, name} are built from each table's code/NAME column pair; if a code's wording differs between years, the 2022 wording is used.
Types are inferred per column: INT if every value is an integer without leading zeros, DOUBLE if numeric with decimals, otherwise STRING (VINs, for example).
Integrity: every relationship file is checked for missing endpoints and duplicate (source, target) pairs. None were found.
Format: tab-separated with no quoting. Many values contain a literal " (inch marks such as 126" Day cab), and the TigerGraph loader does not accept the CSV "" escape. Tabs never occur in the cleaned values, and Neo4j only treats " as a quote at the start of a field. The single value that started with " was rewritten with single quotes.

The script also writes schema.json (columns, inferred types, row counts), expected-counts.tsv (used to verify each platform after loading), and the Cypher and GSQL shown on this page, so the property lists always match the files. It runs in about six minutes. The full script, build_csv.py, is available on the Download page.

Create Graph Schema (38.594s)

The graph is created empty and its types are added with one graph-level schema change job, so the type names belong to fars20_22 only and DROP GRAPH fars20_22 removes exactly these types. Every vertex keeps its key as an attribute (primary_id_as_attribute="true"). Code vertices use the INT code as primary id; all other vertices use STRING ids.

Every edge type connects exactly one pair of vertex types. TigerGraph has no null: an empty field is stored as 0 for INT/DOUBLE and as an empty string for STRING. FARS often uses 0 as a real code, so filters on columns that are missing for some years or rows should also check DATA_YEAR or the folded table's key columns.

gsql

CREATE GRAPH fars20_22()

USE GRAPH fars20_22
CREATE SCHEMA_CHANGE JOB fars20_22_schema FOR GRAPH fars20_22 {
  ADD VERTEX Accident (
    PRIMARY_ID accident_id STRING,
    DATA_YEAR INT,
    STATE INT,
    STATENAME STRING,
    ST_CASE INT,
    VE_TOTAL INT,
    VE_FORMS INT,
    PVH_INVL INT,
    PEDS INT,
    PERNOTMVIT INT,
    PERMVIT INT,
    PERSONS INT,
    COUNTY INT,
    COUNTYNAME STRING,
    CITY INT,
    CITYNAME STRING,
    DAY INT,
    DAYNAME INT,
    MONTH INT,
    MONTHNAME STRING,
    YEAR INT,
    DAY_WEEK INT,
    DAY_WEEKNAME STRING,
    HOUR INT,
    HOURNAME STRING,
    MINUTE INT,
    MINUTENAME STRING,
    NHS INT,
    NHSNAME STRING,
    ROUTE INT,
    ROUTENAME STRING,
    TWAY_ID STRING,
    TWAY_ID2 STRING,
    RUR_URB INT,
    RUR_URBNAME STRING,
    FUNC_SYS INT,
    FUNC_SYSNAME STRING,
    RD_OWNER INT,
    RD_OWNERNAME STRING,
    MILEPT INT,
    MILEPTNAME STRING,
    LATITUDE DOUBLE,
    LATITUDENAME DOUBLE,
    LONGITUD DOUBLE,
    LONGITUDNAME DOUBLE,
    SP_JUR INT,
    SP_JURNAME STRING,
    HARM_EV INT,
    HARM_EVNAME STRING,
    MAN_COLL INT,
    MAN_COLLNAME STRING,
    RELJCT1 INT,
    RELJCT1NAME STRING,
    RELJCT2 INT,
    RELJCT2NAME STRING,
    TYP_INT INT,
    TYP_INTNAME STRING,
    WRK_ZONE INT,
    WRK_ZONENAME STRING,
    REL_ROAD INT,
    REL_ROADNAME STRING,
    LGT_COND INT,
    LGT_CONDNAME STRING,
    WEATHER INT,
    WEATHERNAME STRING,
    SCH_BUS INT,
    SCH_BUSNAME STRING,
    RAIL STRING,
    RAILNAME STRING,
    NOT_HOUR INT,
    NOT_HOURNAME STRING,
    NOT_MIN INT,
    NOT_MINNAME STRING,
    ARR_HOUR INT,
    ARR_HOURNAME STRING,
    ARR_MIN INT,
    ARR_MINNAME STRING,
    HOSP_HR INT,
    HOSP_HRNAME STRING,
    HOSP_MN INT,
    HOSP_MNNAME STRING,
    FATALS INT,
    DRUNK_DR INT,
    MIACC_A1 INT,
    MIACC_A2 INT,
    MIACC_A3 INT,
    MIACC_A4 INT,
    MIACC_A5 INT,
    MIACC_A6 INT,
    MIACC_A7 INT,
    MIACC_A8 INT,
    MIACC_A9 INT,
    MIACC_A10 INT,
    MIDRVACC_A1 INT,
    MIDRVACC_A2 INT,
    MIDRVACC_A3 INT,
    MIDRVACC_A4 INT,
    MIDRVACC_A5 INT,
    MIDRVACC_A6 INT,
    MIDRVACC_A7 INT,
    MIDRVACC_A8 INT,
    MIDRVACC_A9 INT,
    MIDRVACC_A10 INT
  ) WITH primary_id_as_attribute="true";
  ADD VERTEX Vehicle (
    PRIMARY_ID vehicle_id STRING,
    accident_id STRING,
    source_table STRING,
    DATA_YEAR INT,
    STATE INT,
    STATENAME STRING,
    ST_CASE INT,
    VEH_NO INT,
    VE_FORMS INT,
    NUMOCCS INT,
    NUMOCCSNAME STRING,
    DAY INT,
    DAYNAME INT,
    MONTH INT,
    MONTHNAME STRING,
    HOUR INT,
    HOURNAME STRING,
    MINUTE INT,
    MINUTENAME STRING,
    HARM_EV INT,
    HARM_EVNAME STRING,
    MAN_COLL INT,
    MAN_COLLNAME STRING,
    UNITTYPE INT,
    UNITTYPENAME STRING,
    HIT_RUN INT,
    HIT_RUNNAME STRING,
    REG_STAT INT,
    REG_STATNAME STRING,
    OWNER INT,
    OWNERNAME STRING,
    MAKE INT,
    MAKENAME STRING,
    MODEL INT,
    MAK_MOD INT,
    MAK_MODNAME STRING,
    BODY_TYP INT,
    BODY_TYPNAME STRING,
    MOD_YEAR INT,
    MOD_YEARNAME STRING,
    VIN STRING,
    VINNAME STRING,
    VIN_1 STRING,
    VIN_2 STRING,
    VIN_3 STRING,
    VIN_4 STRING,
    VIN_5 STRING,
    VIN_6 STRING,
    VIN_7 STRING,
    VIN_8 STRING,
    VIN_9 STRING,
    VIN_10 STRING,
    VIN_11 STRING,
    VIN_12 STRING,
    TOW_VEH INT,
    TOW_VEHNAME STRING,
    J_KNIFE INT,
    J_KNIFENAME STRING,
    MCARR_I1 INT,
    MCARR_I1NAME STRING,
    MCARR_I2 STRING,
    MCARR_I2NAME STRING,
    MCARR_ID STRING,
    MCARR_IDNAME STRING,
    V_CONFIG INT,
    V_CONFIGNAME STRING,
    CARGO_BT INT,
    CARGO_BTNAME STRING,
    HAZ_INV INT,
    HAZ_INVNAME STRING,
    HAZ_PLAC INT,
    HAZ_PLACNAME STRING,
    HAZ_ID INT,
    HAZ_IDNAME STRING,
    HAZ_CNO INT,
    HAZ_CNONAME STRING,
    HAZ_REL INT,
    HAZ_RELNAME STRING,
    BUS_USE INT,
    BUS_USENAME STRING,
    SPEC_USE INT,
    SPEC_USENAME STRING,
    EMER_USE INT,
    EMER_USENAME STRING,
    TRAV_SP INT,
    TRAV_SPNAME STRING,
    UNDERIDE INT,
    UNDERIDENAME STRING,
    ROLLOVER INT,
    ROLLOVERNAME STRING,
    ROLINLOC INT,
    ROLINLOCNAME STRING,
    IMPACT1 INT,
    IMPACT1NAME STRING,
    DEFORMED INT,
    DEFORMEDNAME STRING,
    TOWED INT,
    TOWEDNAME STRING,
    M_HARM INT,
    M_HARMNAME STRING,
    FIRE_EXP INT,
    FIRE_EXPNAME STRING,
    DR_PRES INT,
    DR_PRESNAME STRING,
    L_STATE INT,
    L_STATENAME STRING,
    DR_ZIP INT,
    DR_ZIPNAME STRING,
    L_STATUS INT,
    L_STATUSNAME STRING,
    L_TYPE INT,
    L_TYPENAME STRING,
    CDL_STAT INT,
    CDL_STATNAME STRING,
    L_ENDORS INT,
    L_ENDORSNAME STRING,
    L_COMPL INT,
    L_COMPLNAME STRING,
    L_RESTRI INT,
    L_RESTRINAME STRING,
    DR_HGT INT,
    DR_HGTNAME STRING,
    DR_WGT INT,
    DR_WGTNAME STRING,
    PREV_ACC INT,
    PREV_ACCNAME STRING,
    PREV_SUS1 INT,
    PREV_SUS1NAME STRING,
    PREV_SUS2 INT,
    PREV_SUS2NAME STRING,
    PREV_SUS3 INT,
    PREV_SUS3NAME STRING,
    PREV_DWI INT,
    PREV_DWINAME STRING,
    PREV_SPD INT,
    PREV_SPDNAME STRING,
    PREV_OTH INT,
    PREV_OTHNAME STRING,
    FIRST_MO INT,
    FIRST_MONAME STRING,
    FIRST_YR INT,
    FIRST_YRNAME STRING,
    LAST_MO INT,
    LAST_MONAME STRING,
    LAST_YR INT,
    LAST_YRNAME STRING,
    SPEEDREL INT,
    SPEEDRELNAME STRING,
    VTRAFWAY INT,
    VTRAFWAYNAME STRING,
    VNUM_LAN INT,
    VNUM_LANNAME STRING,
    VSPD_LIM INT,
    VSPD_LIMNAME STRING,
    VALIGN INT,
    VALIGNNAME STRING,
    VPROFILE INT,
    VPROFILENAME STRING,
    VPAVETYP INT,
    VPAVETYPNAME STRING,
    VSURCOND INT,
    VSURCONDNAME STRING,
    VTRAFCON INT,
    VTRAFCONNAME STRING,
    VTCONT_F INT,
    VTCONT_FNAME STRING,
    P_CRASH1 INT,
    P_CRASH1NAME STRING,
    P_CRASH2 INT,
    P_CRASH2NAME STRING,
    P_CRASH3 INT,
    P_CRASH3NAME STRING,
    PCRASH4 INT,
    PCRASH4NAME STRING,
    PCRASH5 INT,
    PCRASH5NAME STRING,
    ACC_TYPE INT,
    ACC_TYPENAME STRING,
    TRLR1VIN STRING,
    TRLR1VINNAME STRING,
    TRLR2VIN STRING,
    TRLR2VINNAME STRING,
    TRLR3VIN STRING,
    TRLR3VINNAME STRING,
    DEATHS INT,
    DR_DRINK INT,
    DR_DRINKNAME STRING,
    VPICMAKE INT,
    VPICMAKENAME STRING,
    VPICMODEL INT,
    VPICMODELNAME STRING,
    VPICBODYCLASS INT,
    VPICBODYCLASSNAME STRING,
    ICFINALBODY INT,
    ICFINALBODYNAME STRING,
    GVWR_FROM INT,
    GVWR_FROMNAME STRING,
    GVWR_TO INT,
    GVWR_TONAME STRING,
    TRLR1GVWR INT,
    TRLR1GVWRNAME STRING,
    TRLR2GVWR INT,
    TRLR2GVWRNAME STRING,
    TRLR3GVWR INT,
    TRLR3GVWRNAME STRING,
    UNDEROVERRIDE INT,
    UNDEROVERRIDENAME STRING
  ) WITH primary_id_as_attribute="true";
  ADD VERTEX Person (
    PRIMARY_ID person_id STRING,
    accident_id STRING,
    vehicle_id STRING,
    DATA_YEAR INT,
    STATE INT,
    STATENAME STRING,
    ST_CASE INT,
    VE_FORMS INT,
    VEH_NO INT,
    PER_NO INT,
    STR_VEH INT,
    COUNTY INT,
    DAY INT,
    DAYNAME INT,
    MONTH INT,
    MONTHNAME STRING,
    HOUR INT,
    HOURNAME STRING,
    MINUTE INT,
    MINUTENAME STRING,
    RUR_URB INT,
    RUR_URBNAME STRING,
    FUNC_SYS INT,
    FUNC_SYSNAME STRING,
    HARM_EV INT,
    HARM_EVNAME STRING,
    MAN_COLL INT,
    MAN_COLLNAME STRING,
    SCH_BUS INT,
    SCH_BUSNAME STRING,
    MAKE INT,
    MAKENAME STRING,
    MAK_MOD INT,
    MAK_MODNAME STRING,
    BODY_TYP INT,
    BODY_TYPNAME STRING,
    MOD_YEAR INT,
    MOD_YEARNAME STRING,
    TOW_VEH INT,
    TOW_VEHNAME STRING,
    SPEC_USE INT,
    SPEC_USENAME STRING,
    EMER_USE INT,
    EMER_USENAME STRING,
    ROLLOVER INT,
    ROLLOVERNAME STRING,
    IMPACT1 INT,
    IMPACT1NAME STRING,
    FIRE_EXP INT,
    FIRE_EXPNAME STRING,
    AGE INT,
    AGENAME STRING,
    SEX INT,
    SEXNAME STRING,
    PER_TYP INT,
    PER_TYPNAME STRING,
    INJ_SEV INT,
    INJ_SEVNAME STRING,
    SEAT_POS INT,
    SEAT_POSNAME STRING,
    REST_USE INT,
    REST_USENAME STRING,
    REST_MIS INT,
    REST_MISNAME STRING,
    AIR_BAG INT,
    AIR_BAGNAME STRING,
    EJECTION INT,
    EJECTIONNAME STRING,
    EJ_PATH INT,
    EJ_PATHNAME STRING,
    EXTRICAT INT,
    EXTRICATNAME STRING,
    DRINKING INT,
    DRINKINGNAME STRING,
    ALC_DET INT,
    ALC_DETNAME STRING,
    ALC_STATUS INT,
    ALC_STATUSNAME STRING,
    ATST_TYP INT,
    ATST_TYPNAME STRING,
    ALC_RES INT,
    ALC_RESNAME STRING,
    DRUGS INT,
    DRUGSNAME STRING,
    DRUG_DET INT,
    DRUG_DETNAME STRING,
    DSTATUS INT,
    DSTATUSNAME STRING,
    HOSPITAL INT,
    HOSPITALNAME STRING,
    DOA INT,
    DOANAME STRING,
    DEATH_DA INT,
    DEATH_DANAME STRING,
    DEATH_MO INT,
    DEATH_MONAME STRING,
    DEATH_YR INT,
    DEATH_YRNAME STRING,
    DEATH_HR INT,
    DEATH_HRNAME STRING,
    DEATH_MN INT,
    DEATH_MNNAME STRING,
    DEATH_TM INT,
    DEATH_TMNAME STRING,
    LAG_HRS INT,
    LAG_HRSNAME STRING,
    LAG_MINS INT,
    LAG_MINSNAME STRING,
    WORK_INJ INT,
    WORK_INJNAME STRING,
    HISPANIC INT,
    HISPANICNAME STRING,
    LOCATION INT,
    LOCATIONNAME STRING,
    HELM_USE INT,
    HELM_USENAME STRING,
    HELM_MIS INT,
    HELM_MISNAME STRING,
    VPICMAKE INT,
    VPICMAKENAME STRING,
    VPICMODEL INT,
    VPICMODELNAME STRING,
    VPICBODYCLASS INT,
    VPICBODYCLASSNAME STRING,
    ICFINALBODY INT,
    ICFINALBODYNAME STRING,
    GVWR_FROM INT,
    GVWR_FROMNAME STRING,
    GVWR_TO INT,
    GVWR_TONAME STRING,
    DEVTYPENAME STRING,
    DEVMOTORNAME STRING,
    DEVTYPE INT,
    DEVMOTOR INT,
    PBPTYPE INT,
    PBPTYPENAME STRING,
    PBAGE INT,
    PBAGENAME STRING,
    PBSEX INT,
    PBSEXNAME STRING,
    PBCWALK INT,
    PBCWALKNAME STRING,
    PBSWALK INT,
    PBSWALKNAME STRING,
    PBSZONE INT,
    PBSZONENAME STRING,
    PEDCTYPE INT,
    PEDCTYPENAME STRING,
    BIKECTYPE INT,
    BIKECTYPENAME STRING,
    PEDLOC INT,
    PEDLOCNAME STRING,
    BIKELOC INT,
    BIKELOCNAME STRING,
    PEDPOS INT,
    PEDPOSNAME STRING,
    BIKEPOS INT,
    BIKEPOSNAME STRING,
    PEDDIR INT,
    PEDDIRNAME STRING,
    BIKEDIR INT,
    BIKEDIRNAME STRING,
    MOTDIR INT,
    MOTDIRNAME STRING,
    MOTMAN INT,
    MOTMANNAME STRING,
    PEDLEG INT,
    PEDLEGNAME STRING,
    PEDSNR STRING,
    PEDSNRNAME STRING,
    PEDCGP INT,
    PEDCGPNAME STRING,
    BIKECGP INT,
    BIKECGPNAME STRING,
    NMHELMET INT,
    NMHELMETNAME STRING,
    NMPROPAD INT,
    NMPROPADNAME STRING,
    NMOTHPRO INT,
    NMOTHPRONAME STRING,
    NMREFCLO INT,
    NMREFCLONAME STRING,
    NMLIGHT INT,
    NMLIGHTNAME STRING,
    NMOTHPRE INT,
    NMOTHPRENAME STRING,
    MIPER_P1 INT,
    MIPER_P2 INT,
    MIPER_P3 INT,
    MIPER_P4 INT,
    MIPER_P5 INT,
    MIPER_P6 INT,
    MIPER_P7 INT,
    MIPER_P8 INT,
    MIPER_P9 INT,
    MIPER_P10 INT
  ) WITH primary_id_as_attribute="true";
  ADD VERTEX Event (
    PRIMARY_ID event_id STRING,
    accident_id STRING,
    DATA_YEAR INT,
    STATE INT,
    STATENAME STRING,
    ST_CASE INT,
    EVENTNUM INT,
    VNUMBER1 INT,
    AOI1 INT,
    AOI1NAME STRING,
    SOE INT,
    SOENAME STRING,
    VNUMBER2 INT,
    VNUMBER2NAME STRING,
    AOI2 INT,
    AOI2NAME STRING
  ) WITH primary_id_as_attribute="true";
  ADD VERTEX VPICDecode (
    PRIMARY_ID vpic_id STRING,
    vehicle_id STRING,
    accident_id STRING,
    DATA_YEAR INT,
    STATE INT,
    STATENAME STRING,
    ST_CASE INT,
    VEH_NO INT,
    VEHICLEDESCRIPTOR STRING,
    VINDECODEDON STRING,
    VINDECODEERROR STRING,
    VEHICLETYPEID INT,
    VEHICLETYPE STRING,
    MANUFACTURERFULLNAMEID INT,
    MANUFACTURERFULLNAME STRING,
    MAKEID INT,
    MAKE STRING,
    MODELID INT,
    MODEL STRING,
    MODELYEAR INT,
    SERIES STRING,
    TRIM1 STRING,
    SERIES2 STRING,
    TRIM2 STRING,
    PLANTCOUNTRYID INT,
    PLANTCOUNTRY STRING,
    PLANTSTATE STRING,
    PLANTCITY STRING,
    PLANTCOMPANYNAME STRING,
    DESTINATIONMARKETID INT,
    DESTINATIONMARKET STRING,
    BASEPRICE DOUBLE,
    NOTE STRING,
    BODYCLASSID INT,
    BODYCLASS STRING,
    DOORSCOUNT INT,
    WINDOWS INT,
    WHEELBASETYPEID INT,
    WHEELBASETYPE STRING,
    TRACKWIDTHIN DOUBLE,
    GROSSVEHICLEWEIGHTRATINGFROMID INT,
    GROSSVEHICLEWEIGHTRATINGFROM STRING,
    GROSSVEHICLEWEIGHTRATINGTOID INT,
    GROSSVEHICLEWEIGHTRATINGTO STRING,
    GROSSCOMBWEIGHTRATINGFROMID STRING,
    GROSSCOMBWEIGHTRATINGFROM STRING,
    GROSSCOMBWEIGHTRATINGTOID STRING,
    GROSSCOMBWEIGHTRATINGTO STRING,
    CURBWEIGHTLB INT,
    WHEELBASEIN_FROM DOUBLE,
    WHEELBASEIN_TO DOUBLE,
    WHEELSCOUNT INT,
    WHEELSIZEFRONTIN INT,
    WHEELSIZEREARIN INT,
    TRUCKBODYCABTYPEID INT,
    TRUCKBODYCABTYPE STRING,
    TRUCKBEDTYPEID INT,
    TRUCKBEDTYPE STRING,
    TRUCKBEDLENGTHIN INT,
    BUSTYPEID INT,
    BUSTYPE STRING,
    BUSFLOORCONFIGURATIONTYPEID INT,
    BUSFLOORCONFIGURATIONTYPE STRING,
    BUSLENGTHFT INT,
    OTHERBUSINFO STRING,
    CUSTOMMOTORCYCLETYPEID INT,
    CUSTOMMOTORCYCLETYPE STRING,
    MOTORCYCLESUSPENSIONTYPEID INT,
    MOTORCYCLESUSPENSIONTYPE STRING,
    MOTORCYCLECHASSISTYPEID INT,
    MOTORCYCLECHASSISTYPE STRING,
    OTHERMOTORCYCLEINFO STRING,
    STEERINGLOCATIONID INT,
    STEERINGLOCATION STRING,
    ENTERTAINMENTSYSTEMID INT,
    ENTERTAINMENTSYSTEM STRING,
    SEATSCOUNT INT,
    SEATROWSCOUNT INT,
    TRANSMISSIONSPEEDS INT,
    TRANSMISSIONSTYLEID INT,
    TRANSMISSIONSTYLE STRING,
    DRIVETYPEID INT,
    DRIVETYPE STRING,
    AXLESCOUNT INT,
    AXLECONFIGURATIONID INT,
    AXLECONFIGURATION STRING,
    BRAKESYSTEMTYPEID INT,
    BRAKESYSTEMTYPE STRING,
    BRAKESYSTEMDESC STRING,
    EVDRIVEUNITID INT,
    EVDRIVEUNIT STRING,
    BATTERYKWH_FROM DOUBLE,
    BATTERYKWH_TO DOUBLE,
    BATTERYV_FROM INT,
    BATTERYV_TO STRING,
    BATTERYA_FROM INT,
    BATTERYA_TO STRING,
    BATTERYPACKSPERVEHICLE INT,
    BATTERYMODULESPERPACK STRING,
    BATTERYCELLSPERMODULE STRING,
    BATTERYTYPEID INT,
    BATTERYTYPE STRING,
    OTHERBATTERYINFO STRING,
    CHARGERLEVELID INT,
    CHARGERLEVEL STRING,
    CHARGERPOWERKW INT,
    ENGINEMANUFACTURER STRING,
    ENGINEMODEL STRING,
    ENGINECONFIGURATIONID INT,
    ENGINECONFIGURATION STRING,
    ENGINEPOWERKW DOUBLE,
    ENGINESTROKECYCLES INT,
    ENGINECYLINDERSCOUNT INT,
    ENGINEBRAKEHP_FROM DOUBLE,
    ENGINEBRAKEHP_TO DOUBLE,
    ENGINECOOLINGTYPEID INT,
    ENGINECOOLINGTYPE STRING,
    DISPLACEMENTCI DOUBLE,
    DISPLACEMENTCC DOUBLE,
    DISPLACEMENTL DOUBLE,
    FUELTYPEPRIMARYID INT,
    FUELTYPEPRIMARY STRING,
    FUELTYPESECONDARYID INT,
    FUELTYPESECONDARY STRING,
    FUELDELIVERYINJECTIONTYPEID INT,
    FUELDELIVERYINJECTIONTYPE STRING,
    ENGINEVALVETRAINDESIGNID INT,
    ENGINEVALVETRAINDESIGN STRING,
    ENGINEELECTRIFICATIONLEVELID INT,
    ENGINEELECTRIFICATIONLEVEL STRING,
    ENGINETURBOID INT,
    ENGINETURBO STRING,
    TOPSPEEDMPH INT,
    OTHERENGINEINFO STRING,
    SEATBELTTYPEID INT,
    SEATBELTTYPE STRING,
    PRETENSIONERID INT,
    PRETENSIONER STRING,
    AIRBAGLOCFRONTID INT,
    AIRBAGLOCFRONT STRING,
    AIRBAGLOCKNEEID INT,
    AIRBAGLOCKNEE STRING,
    AIRBAGLOCSIDEID INT,
    AIRBAGLOCSIDE STRING,
    AIRBAGLOCCURTAINID INT,
    AIRBAGLOCCURTAIN STRING,
    AIRBAGLOCSEATCUSHIONID INT,
    AIRBAGLOCSEATCUSHION STRING,
    OTHERRESTRAINTSYSTEMINFO STRING,
    FORWARDCOLLISIONWARNINGID INT,
    FORWARDCOLLISIONWARNING STRING,
    DYNAMICBRAKESUPPORTID INT,
    DYNAMICBRAKESUPPORT STRING,
    CRASHIMMINENTBRAKINGID INT,
    CRASHIMMINENTBRAKING STRING,
    PEDESTRIANAUTOEMERGENCYBRAKINGID INT,
    PEDESTRIANAUTOEMERGENCYBRAKING STRING,
    BLINDSPOTWARNINGID INT,
    BLINDSPOTWARNING STRING,
    BLINDSPOTINTERVENTIONID INT,
    BLINDSPOTINTERVENTION STRING,
    LANEDEPARTUREWARNINGID INT,
    LANEDEPARTUREWARNING STRING,
    LANEKEEPINGASSISTANCEID INT,
    LANEKEEPINGASSISTANCE STRING,
    LANECENTERINGASSISTANCEID INT,
    LANECENTERINGASSISTANCE STRING,
    BACKUPCAMERAID INT,
    BACKUPCAMERA STRING,
    REARCROSSTRAFFICALERTID INT,
    REARCROSSTRAFFICALERT STRING,
    REARAUTOMATICEMERGENCYBRAKINGID INT,
    REARAUTOMATICEMERGENCYBRAKING STRING,
    PARKASSISTID INT,
    PARKASSIST STRING,
    DAYTIMERUNNINGLIGHTID INT,
    DAYTIMERUNNINGLIGHT STRING,
    HEADLAMPLIGHTSOURCEID INT,
    HEADLAMPLIGHTSOURCE STRING,
    SEMIAUTOHEADLAMPBEAMSWITCHINGID INT,
    SEMIAUTOHEADLAMPBEAMSWITCHING STRING,
    ADAPTIVEDRIVINGBEAMID INT,
    ADAPTIVEDRIVINGBEAM STRING,
    ADAPTIVECRUISECONTROLID INT,
    ADAPTIVECRUISECONTROL STRING,
    ANTILOCKBRAKESYSTEMID INT,
    ANTILOCKBRAKESYSTEM STRING,
    ELECTRONICSTABILITYCONTROLID INT,
    ELECTRONICSTABILITYCONTROL STRING,
    TPMSID INT,
    TPMS STRING,
    AUTOMATICCRASHNOTIFICATIONID INT,
    AUTOMATICCRASHNOTIFICATION STRING,
    EVENTDATARECORDERID INT,
    EVENTDATARECORDER STRING,
    TRACTIONCONTROLID INT,
    TRACTIONCONTROL STRING,
    AUTOPEDESTRIANALERTINGSOUNDID INT,
    AUTOPEDESTRIANALERTINGSOUND STRING,
    KEYLESSIGNITIONID INT,
    KEYLESSIGNITION STRING,
    SAEAUTOMATIONLEVEL_FROM INT,
    SAEAUTOMATIONLEVEL_TO STRING,
    AUTOREVERSESYSTEMID INT,
    AUTOREVERSESYSTEM STRING,
    ACTIVESAFETYSYSNOTE STRING,
    NONLANDUSEID STRING,
    NONLANDUSE STRING
  ) WITH primary_id_as_attribute="true";
  ADD VERTEX Trailer (
    PRIMARY_ID trailer_id STRING,
    vehicle_id STRING,
    accident_id STRING,
    DATA_YEAR INT,
    STATE INT,
    STATENAME STRING,
    ST_CASE INT,
    VEH_NO INT,
    TRAILER_NO INT,
    VEHICLEDESCRIPTOR STRING,
    VINDECODEDON STRING,
    VINDECODEERROR STRING,
    VEHICLETYPEID INT,
    VEHICLETYPE STRING,
    MANUFACTURERFULLNAMEID INT,
    MANUFACTURERFULLNAME STRING,
    MAKEID INT,
    MAKE STRING,
    MODELID INT,
    MODEL STRING,
    MODELYEAR INT,
    SERIES STRING,
    TRIM1 STRING,
    PLANTCOUNTRYID INT,
    PLANTCOUNTRY STRING,
    PLANTSTATE STRING,
    PLANTCITY STRING,
    PLANTCOMPANYNAME STRING,
    NOTE STRING,
    BODYCLASSID INT,
    BODYCLASS STRING,
    GROSSVEHICLEWEIGHTRATINGFROMID INT,
    GROSSVEHICLEWEIGHTRATINGFROM STRING,
    GROSSVEHICLEWEIGHTRATINGTOID INT,
    GROSSVEHICLEWEIGHTRATINGTO STRING,
    TRAILERBODYTYPEID INT,
    TRAILERBODYTYPE STRING,
    TRAILERTYPECONNECTIONID INT,
    TRAILERTYPECONNECTION STRING,
    TRAILERLENGTHFT DOUBLE,
    OTHERTRAILERINFO STRING,
    AXLESCOUNT INT,
    AXLECONFIGURATIONID INT,
    AXLECONFIGURATION STRING,
    NONLANDUSEID STRING,
    NONLANDUSE STRING
  ) WITH primary_id_as_attribute="true";
  ADD VERTEX DrugEvent (
    PRIMARY_ID drug_event_id STRING,
    person_id STRING,
    accident_id STRING,
    DATA_YEAR INT,
    STATE INT,
    STATENAME STRING,
    ST_CASE INT,
    VEH_NO INT,
    PER_NO INT,
    DRUGSPEC INT,
    DRUGSPECNAME STRING,
    DRUGRES INT,
    DRUGRESNAME STRING,
    vehicle_id STRING
  ) WITH primary_id_as_attribute="true";
  ADD VERTEX Weather (
    PRIMARY_ID id INT,
    name STRING
  ) WITH primary_id_as_attribute="true";
  ADD VERTEX CrashRF (
    PRIMARY_ID id INT,
    name STRING
  ) WITH primary_id_as_attribute="true";
  ADD VERTEX Damage (
    PRIMARY_ID id INT,
    name STRING
  ) WITH primary_id_as_attribute="true";
  ADD VERTEX Distract (
    PRIMARY_ID id INT,
    name STRING
  ) WITH primary_id_as_attribute="true";
  ADD VERTEX DrImpair (
    PRIMARY_ID id INT,
    name STRING
  ) WITH primary_id_as_attribute="true";
  ADD VERTEX DriverRF (
    PRIMARY_ID id INT,
    name STRING
  ) WITH primary_id_as_attribute="true";
  ADD VERTEX Factor (
    PRIMARY_ID id INT,
    name STRING
  ) WITH primary_id_as_attribute="true";
  ADD VERTEX Maneuver (
    PRIMARY_ID id INT,
    name STRING
  ) WITH primary_id_as_attribute="true";
  ADD VERTEX VehicleSF (
    PRIMARY_ID id INT,
    name STRING
  ) WITH primary_id_as_attribute="true";
  ADD VERTEX Violatn (
    PRIMARY_ID id INT,
    name STRING
  ) WITH primary_id_as_attribute="true";
  ADD VERTEX Vision (
    PRIMARY_ID id INT,
    name STRING
  ) WITH primary_id_as_attribute="true";
  ADD VERTEX Race (
    PRIMARY_ID id INT,
    name STRING
  ) WITH primary_id_as_attribute="true";
  ADD VERTEX PersonRF (
    PRIMARY_ID id INT,
    name STRING
  ) WITH primary_id_as_attribute="true";
  ADD VERTEX NMCrash (
    PRIMARY_ID id INT,
    name STRING
  ) WITH primary_id_as_attribute="true";
  ADD VERTEX NMDistract (
    PRIMARY_ID id INT,
    name STRING
  ) WITH primary_id_as_attribute="true";
  ADD VERTEX NMImpair (
    PRIMARY_ID id INT,
    name STRING
  ) WITH primary_id_as_attribute="true";
  ADD VERTEX NMPrior (
    PRIMARY_ID id INT,
    name STRING
  ) WITH primary_id_as_attribute="true";
  ADD VERTEX DrugTest (
    PRIMARY_ID id INT,
    name STRING
  ) WITH primary_id_as_attribute="true";
  ADD VERTEX Drug (
    PRIMARY_ID id INT,
    name STRING
  ) WITH primary_id_as_attribute="true";
  ADD DIRECTED EDGE INVOLVES (FROM Accident, TO Vehicle) WITH REVERSE_EDGE="reverse_INVOLVES";
  ADD DIRECTED EDGE HAS_VICTIM (FROM Accident, TO Person) WITH REVERSE_EDGE="reverse_HAS_VICTIM";
  ADD DIRECTED EDGE RESULTED_IN (FROM Accident, TO Event) WITH REVERSE_EDGE="reverse_RESULTED_IN";
  ADD DIRECTED EDGE HAS_OCCUPANT (FROM Vehicle, TO Person) WITH REVERSE_EDGE="reverse_HAS_OCCUPANT";
  ADD DIRECTED EDGE SUBJECT_OF (FROM Vehicle, TO Event, AOI INT, AOINAME STRING) WITH REVERSE_EDGE="reverse_SUBJECT_OF";
  ADD DIRECTED EDGE OBJECT_OF (FROM Vehicle, TO Event, AOI INT, AOINAME STRING) WITH REVERSE_EDGE="reverse_OBJECT_OF";
  ADD DIRECTED EDGE HAS_VEVENT (FROM Vehicle, TO Event, VEVENTNUM INT, AOI INT, AOINAME STRING) WITH REVERSE_EDGE="reverse_HAS_VEVENT";
  ADD DIRECTED EDGE HAS_VPIC (FROM Vehicle, TO VPICDecode) WITH REVERSE_EDGE="reverse_HAS_VPIC";
  ADD DIRECTED EDGE HAS_TRAILER (FROM Vehicle, TO Trailer, TRAILER_NO INT) WITH REVERSE_EDGE="reverse_HAS_TRAILER";
  ADD DIRECTED EDGE DRUG_EVENT_OF (FROM DrugEvent, TO Person) WITH REVERSE_EDGE="reverse_DRUG_EVENT_OF";
  ADD DIRECTED EDGE DRUG_TEST_OF (FROM DrugTest, TO DrugEvent) WITH REVERSE_EDGE="reverse_DRUG_TEST_OF";
  ADD DIRECTED EDGE RESULT_OF (FROM Drug, TO DrugEvent) WITH REVERSE_EDGE="reverse_RESULT_OF";
  ADD DIRECTED EDGE OCCURRED_IN (FROM Accident, TO Weather) WITH REVERSE_EDGE="reverse_OCCURRED_IN";
  ADD DIRECTED EDGE CRASH_FACTOR_OF (FROM CrashRF, TO Accident) WITH REVERSE_EDGE="reverse_CRASH_FACTOR_OF";
  ADD DIRECTED EDGE POSITION_OF (FROM Damage, TO Vehicle) WITH REVERSE_EDGE="reverse_POSITION_OF";
  ADD DIRECTED EDGE DISTRACTION_OF (FROM Distract, TO Vehicle) WITH REVERSE_EDGE="reverse_DISTRACTION_OF";
  ADD DIRECTED EDGE IMPAIRMENT_OF (FROM DrImpair, TO Vehicle) WITH REVERSE_EDGE="reverse_IMPAIRMENT_OF";
  ADD DIRECTED EDGE DRIVER_RF_OF (FROM DriverRF, TO Vehicle) WITH REVERSE_EDGE="reverse_DRIVER_RF_OF";
  ADD DIRECTED EDGE FACTOR_OF (FROM Factor, TO Vehicle) WITH REVERSE_EDGE="reverse_FACTOR_OF";
  ADD DIRECTED EDGE MANEUVER_OF (FROM Maneuver, TO Vehicle) WITH REVERSE_EDGE="reverse_MANEUVER_OF";
  ADD DIRECTED EDGE VEHICLE_SF_OF (FROM VehicleSF, TO Vehicle) WITH REVERSE_EDGE="reverse_VEHICLE_SF_OF";
  ADD DIRECTED EDGE COMMITTED_BY (FROM Violatn, TO Vehicle) WITH REVERSE_EDGE="reverse_COMMITTED_BY";
  ADD DIRECTED EDGE VISION_OF (FROM Vision, TO Vehicle) WITH REVERSE_EDGE="reverse_VISION_OF";
  ADD DIRECTED EDGE RACE_OF (FROM Race, TO Person, RACE_ORDER INT, MULTRACE INT) WITH REVERSE_EDGE="reverse_RACE_OF";
  ADD DIRECTED EDGE PERSON_RF_OF (FROM PersonRF, TO Person) WITH REVERSE_EDGE="reverse_PERSON_RF_OF";
  ADD DIRECTED EDGE NMCRASH_OF (FROM NMCrash, TO Person) WITH REVERSE_EDGE="reverse_NMCRASH_OF";
  ADD DIRECTED EDGE NMDISTRACT_OF (FROM NMDistract, TO Person) WITH REVERSE_EDGE="reverse_NMDISTRACT_OF";
  ADD DIRECTED EDGE NMIMPAIR_OF (FROM NMImpair, TO Person) WITH REVERSE_EDGE="reverse_NMIMPAIR_OF";
  ADD DIRECTED EDGE NMPRIOR_OF (FROM NMPrior, TO Person) WITH REVERSE_EDGE="reverse_NMPRIOR_OF";
}
RUN SCHEMA_CHANGE JOB fars20_22_schema
DROP JOB fars20_22_schema

Loading Jobs (job creation 4.728s)

Two loading jobs read the same tab-separated files as Neo4j: all vertices first, then all edges. The m1: prefix makes node m1 read the shared /datasets file system and distribute the data across the cluster. Edge statements set VERTEX_MUST_EXIST="true", so a row whose endpoint is missing is rejected and counted instead of creating an empty vertex.

load_vertices

gsql

USE GRAPH fars20_22

CREATE LOADING JOB load_vertices FOR GRAPH fars20_22 {
  DEFINE FILENAME f_Accident = "m1:/datasets/prop_datasets/fars/fars20-22/csv/nodes/Accident.tsv";
  DEFINE FILENAME f_Vehicle = "m1:/datasets/prop_datasets/fars/fars20-22/csv/nodes/Vehicle.tsv";
  DEFINE FILENAME f_Person = "m1:/datasets/prop_datasets/fars/fars20-22/csv/nodes/Person.tsv";
  DEFINE FILENAME f_Event = "m1:/datasets/prop_datasets/fars/fars20-22/csv/nodes/Event.tsv";
  DEFINE FILENAME f_VPICDecode = "m1:/datasets/prop_datasets/fars/fars20-22/csv/nodes/VPICDecode.tsv";
  DEFINE FILENAME f_Trailer = "m1:/datasets/prop_datasets/fars/fars20-22/csv/nodes/Trailer.tsv";
  DEFINE FILENAME f_DrugEvent = "m1:/datasets/prop_datasets/fars/fars20-22/csv/nodes/DrugEvent.tsv";
  DEFINE FILENAME f_Weather = "m1:/datasets/prop_datasets/fars/fars20-22/csv/nodes/Weather.tsv";
  DEFINE FILENAME f_CrashRF = "m1:/datasets/prop_datasets/fars/fars20-22/csv/nodes/CrashRF.tsv";
  DEFINE FILENAME f_Damage = "m1:/datasets/prop_datasets/fars/fars20-22/csv/nodes/Damage.tsv";
  DEFINE FILENAME f_Distract = "m1:/datasets/prop_datasets/fars/fars20-22/csv/nodes/Distract.tsv";
  DEFINE FILENAME f_DrImpair = "m1:/datasets/prop_datasets/fars/fars20-22/csv/nodes/DrImpair.tsv";
  DEFINE FILENAME f_DriverRF = "m1:/datasets/prop_datasets/fars/fars20-22/csv/nodes/DriverRF.tsv";
  DEFINE FILENAME f_Factor = "m1:/datasets/prop_datasets/fars/fars20-22/csv/nodes/Factor.tsv";
  DEFINE FILENAME f_Maneuver = "m1:/datasets/prop_datasets/fars/fars20-22/csv/nodes/Maneuver.tsv";
  DEFINE FILENAME f_VehicleSF = "m1:/datasets/prop_datasets/fars/fars20-22/csv/nodes/VehicleSF.tsv";
  DEFINE FILENAME f_Violatn = "m1:/datasets/prop_datasets/fars/fars20-22/csv/nodes/Violatn.tsv";
  DEFINE FILENAME f_Vision = "m1:/datasets/prop_datasets/fars/fars20-22/csv/nodes/Vision.tsv";
  DEFINE FILENAME f_Race = "m1:/datasets/prop_datasets/fars/fars20-22/csv/nodes/Race.tsv";
  DEFINE FILENAME f_PersonRF = "m1:/datasets/prop_datasets/fars/fars20-22/csv/nodes/PersonRF.tsv";
  DEFINE FILENAME f_NMCrash = "m1:/datasets/prop_datasets/fars/fars20-22/csv/nodes/NMCrash.tsv";
  DEFINE FILENAME f_NMDistract = "m1:/datasets/prop_datasets/fars/fars20-22/csv/nodes/NMDistract.tsv";
  DEFINE FILENAME f_NMImpair = "m1:/datasets/prop_datasets/fars/fars20-22/csv/nodes/NMImpair.tsv";
  DEFINE FILENAME f_NMPrior = "m1:/datasets/prop_datasets/fars/fars20-22/csv/nodes/NMPrior.tsv";
  DEFINE FILENAME f_DrugTest = "m1:/datasets/prop_datasets/fars/fars20-22/csv/nodes/DrugTest.tsv";
  DEFINE FILENAME f_Drug = "m1:/datasets/prop_datasets/fars/fars20-22/csv/nodes/Drug.tsv";
  LOAD f_Accident TO VERTEX Accident VALUES ($"accident_id", $"DATA_YEAR", $"STATE", $"STATENAME", $"ST_CASE", $"VE_TOTAL", $"VE_FORMS", $"PVH_INVL", $"PEDS", $"PERNOTMVIT", $"PERMVIT", $"PERSONS", $"COUNTY", $"COUNTYNAME", $"CITY", $"CITYNAME", $"DAY", $"DAYNAME", $"MONTH", $"MONTHNAME", $"YEAR", $"DAY_WEEK", $"DAY_WEEKNAME", $"HOUR", $"HOURNAME", $"MINUTE", $"MINUTENAME", $"NHS", $"NHSNAME", $"ROUTE", $"ROUTENAME", $"TWAY_ID", $"TWAY_ID2", $"RUR_URB", $"RUR_URBNAME", $"FUNC_SYS", $"FUNC_SYSNAME", $"RD_OWNER", $"RD_OWNERNAME", $"MILEPT", $"MILEPTNAME", $"LATITUDE", $"LATITUDENAME", $"LONGITUD", $"LONGITUDNAME", $"SP_JUR", $"SP_JURNAME", $"HARM_EV", $"HARM_EVNAME", $"MAN_COLL", $"MAN_COLLNAME", $"RELJCT1", $"RELJCT1NAME", $"RELJCT2", $"RELJCT2NAME", $"TYP_INT", $"TYP_INTNAME", $"WRK_ZONE", $"WRK_ZONENAME", $"REL_ROAD", $"REL_ROADNAME", $"LGT_COND", $"LGT_CONDNAME", $"WEATHER", $"WEATHERNAME", $"SCH_BUS", $"SCH_BUSNAME", $"RAIL", $"RAILNAME", $"NOT_HOUR", $"NOT_HOURNAME", $"NOT_MIN", $"NOT_MINNAME", $"ARR_HOUR", $"ARR_HOURNAME", $"ARR_MIN", $"ARR_MINNAME", $"HOSP_HR", $"HOSP_HRNAME", $"HOSP_MN", $"HOSP_MNNAME", $"FATALS", $"DRUNK_DR", $"MIACC_A1", $"MIACC_A2", $"MIACC_A3", $"MIACC_A4", $"MIACC_A5", $"MIACC_A6", $"MIACC_A7", $"MIACC_A8", $"MIACC_A9", $"MIACC_A10", $"MIDRVACC_A1", $"MIDRVACC_A2", $"MIDRVACC_A3", $"MIDRVACC_A4", $"MIDRVACC_A5", $"MIDRVACC_A6", $"MIDRVACC_A7", $"MIDRVACC_A8", $"MIDRVACC_A9", $"MIDRVACC_A10")
    USING HEADER="true", SEPARATOR="\t", EOL="\n";
  LOAD f_Vehicle TO VERTEX Vehicle VALUES ($"vehicle_id", $"accident_id", $"source_table", $"DATA_YEAR", $"STATE", $"STATENAME", $"ST_CASE", $"VEH_NO", $"VE_FORMS", $"NUMOCCS", $"NUMOCCSNAME", $"DAY", $"DAYNAME", $"MONTH", $"MONTHNAME", $"HOUR", $"HOURNAME", $"MINUTE", $"MINUTENAME", $"HARM_EV", $"HARM_EVNAME", $"MAN_COLL", $"MAN_COLLNAME", $"UNITTYPE", $"UNITTYPENAME", $"HIT_RUN", $"HIT_RUNNAME", $"REG_STAT", $"REG_STATNAME", $"OWNER", $"OWNERNAME", $"MAKE", $"MAKENAME", $"MODEL", $"MAK_MOD", $"MAK_MODNAME", $"BODY_TYP", $"BODY_TYPNAME", $"MOD_YEAR", $"MOD_YEARNAME", $"VIN", $"VINNAME", $"VIN_1", $"VIN_2", $"VIN_3", $"VIN_4", $"VIN_5", $"VIN_6", $"VIN_7", $"VIN_8", $"VIN_9", $"VIN_10", $"VIN_11", $"VIN_12", $"TOW_VEH", $"TOW_VEHNAME", $"J_KNIFE", $"J_KNIFENAME", $"MCARR_I1", $"MCARR_I1NAME", $"MCARR_I2", $"MCARR_I2NAME", $"MCARR_ID", $"MCARR_IDNAME", $"V_CONFIG", $"V_CONFIGNAME", $"CARGO_BT", $"CARGO_BTNAME", $"HAZ_INV", $"HAZ_INVNAME", $"HAZ_PLAC", $"HAZ_PLACNAME", $"HAZ_ID", $"HAZ_IDNAME", $"HAZ_CNO", $"HAZ_CNONAME", $"HAZ_REL", $"HAZ_RELNAME", $"BUS_USE", $"BUS_USENAME", $"SPEC_USE", $"SPEC_USENAME", $"EMER_USE", $"EMER_USENAME", $"TRAV_SP", $"TRAV_SPNAME", $"UNDERIDE", $"UNDERIDENAME", $"ROLLOVER", $"ROLLOVERNAME", $"ROLINLOC", $"ROLINLOCNAME", $"IMPACT1", $"IMPACT1NAME", $"DEFORMED", $"DEFORMEDNAME", $"TOWED", $"TOWEDNAME", $"M_HARM", $"M_HARMNAME", $"FIRE_EXP", $"FIRE_EXPNAME", $"DR_PRES", $"DR_PRESNAME", $"L_STATE", $"L_STATENAME", $"DR_ZIP", $"DR_ZIPNAME", $"L_STATUS", $"L_STATUSNAME", $"L_TYPE", $"L_TYPENAME", $"CDL_STAT", $"CDL_STATNAME", $"L_ENDORS", $"L_ENDORSNAME", $"L_COMPL", $"L_COMPLNAME", $"L_RESTRI", $"L_RESTRINAME", $"DR_HGT", $"DR_HGTNAME", $"DR_WGT", $"DR_WGTNAME", $"PREV_ACC", $"PREV_ACCNAME", $"PREV_SUS1", $"PREV_SUS1NAME", $"PREV_SUS2", $"PREV_SUS2NAME", $"PREV_SUS3", $"PREV_SUS3NAME", $"PREV_DWI", $"PREV_DWINAME", $"PREV_SPD", $"PREV_SPDNAME", $"PREV_OTH", $"PREV_OTHNAME", $"FIRST_MO", $"FIRST_MONAME", $"FIRST_YR", $"FIRST_YRNAME", $"LAST_MO", $"LAST_MONAME", $"LAST_YR", $"LAST_YRNAME", $"SPEEDREL", $"SPEEDRELNAME", $"VTRAFWAY", $"VTRAFWAYNAME", $"VNUM_LAN", $"VNUM_LANNAME", $"VSPD_LIM", $"VSPD_LIMNAME", $"VALIGN", $"VALIGNNAME", $"VPROFILE", $"VPROFILENAME", $"VPAVETYP", $"VPAVETYPNAME", $"VSURCOND", $"VSURCONDNAME", $"VTRAFCON", $"VTRAFCONNAME", $"VTCONT_F", $"VTCONT_FNAME", $"P_CRASH1", $"P_CRASH1NAME", $"P_CRASH2", $"P_CRASH2NAME", $"P_CRASH3", $"P_CRASH3NAME", $"PCRASH4", $"PCRASH4NAME", $"PCRASH5", $"PCRASH5NAME", $"ACC_TYPE", $"ACC_TYPENAME", $"TRLR1VIN", $"TRLR1VINNAME", $"TRLR2VIN", $"TRLR2VINNAME", $"TRLR3VIN", $"TRLR3VINNAME", $"DEATHS", $"DR_DRINK", $"DR_DRINKNAME", $"VPICMAKE", $"VPICMAKENAME", $"VPICMODEL", $"VPICMODELNAME", $"VPICBODYCLASS", $"VPICBODYCLASSNAME", $"ICFINALBODY", $"ICFINALBODYNAME", $"GVWR_FROM", $"GVWR_FROMNAME", $"GVWR_TO", $"GVWR_TONAME", $"TRLR1GVWR", $"TRLR1GVWRNAME", $"TRLR2GVWR", $"TRLR2GVWRNAME", $"TRLR3GVWR", $"TRLR3GVWRNAME", $"UNDEROVERRIDE", $"UNDEROVERRIDENAME")
    USING HEADER="true", SEPARATOR="\t", EOL="\n";
  LOAD f_Person TO VERTEX Person VALUES ($"person_id", $"accident_id", $"vehicle_id", $"DATA_YEAR", $"STATE", $"STATENAME", $"ST_CASE", $"VE_FORMS", $"VEH_NO", $"PER_NO", $"STR_VEH", $"COUNTY", $"DAY", $"DAYNAME", $"MONTH", $"MONTHNAME", $"HOUR", $"HOURNAME", $"MINUTE", $"MINUTENAME", $"RUR_URB", $"RUR_URBNAME", $"FUNC_SYS", $"FUNC_SYSNAME", $"HARM_EV", $"HARM_EVNAME", $"MAN_COLL", $"MAN_COLLNAME", $"SCH_BUS", $"SCH_BUSNAME", $"MAKE", $"MAKENAME", $"MAK_MOD", $"MAK_MODNAME", $"BODY_TYP", $"BODY_TYPNAME", $"MOD_YEAR", $"MOD_YEARNAME", $"TOW_VEH", $"TOW_VEHNAME", $"SPEC_USE", $"SPEC_USENAME", $"EMER_USE", $"EMER_USENAME", $"ROLLOVER", $"ROLLOVERNAME", $"IMPACT1", $"IMPACT1NAME", $"FIRE_EXP", $"FIRE_EXPNAME", $"AGE", $"AGENAME", $"SEX", $"SEXNAME", $"PER_TYP", $"PER_TYPNAME", $"INJ_SEV", $"INJ_SEVNAME", $"SEAT_POS", $"SEAT_POSNAME", $"REST_USE", $"REST_USENAME", $"REST_MIS", $"REST_MISNAME", $"AIR_BAG", $"AIR_BAGNAME", $"EJECTION", $"EJECTIONNAME", $"EJ_PATH", $"EJ_PATHNAME", $"EXTRICAT", $"EXTRICATNAME", $"DRINKING", $"DRINKINGNAME", $"ALC_DET", $"ALC_DETNAME", $"ALC_STATUS", $"ALC_STATUSNAME", $"ATST_TYP", $"ATST_TYPNAME", $"ALC_RES", $"ALC_RESNAME", $"DRUGS", $"DRUGSNAME", $"DRUG_DET", $"DRUG_DETNAME", $"DSTATUS", $"DSTATUSNAME", $"HOSPITAL", $"HOSPITALNAME", $"DOA", $"DOANAME", $"DEATH_DA", $"DEATH_DANAME", $"DEATH_MO", $"DEATH_MONAME", $"DEATH_YR", $"DEATH_YRNAME", $"DEATH_HR", $"DEATH_HRNAME", $"DEATH_MN", $"DEATH_MNNAME", $"DEATH_TM", $"DEATH_TMNAME", $"LAG_HRS", $"LAG_HRSNAME", $"LAG_MINS", $"LAG_MINSNAME", $"WORK_INJ", $"WORK_INJNAME", $"HISPANIC", $"HISPANICNAME", $"LOCATION", $"LOCATIONNAME", $"HELM_USE", $"HELM_USENAME", $"HELM_MIS", $"HELM_MISNAME", $"VPICMAKE", $"VPICMAKENAME", $"VPICMODEL", $"VPICMODELNAME", $"VPICBODYCLASS", $"VPICBODYCLASSNAME", $"ICFINALBODY", $"ICFINALBODYNAME", $"GVWR_FROM", $"GVWR_FROMNAME", $"GVWR_TO", $"GVWR_TONAME", $"DEVTYPENAME", $"DEVMOTORNAME", $"DEVTYPE", $"DEVMOTOR", $"PBPTYPE", $"PBPTYPENAME", $"PBAGE", $"PBAGENAME", $"PBSEX", $"PBSEXNAME", $"PBCWALK", $"PBCWALKNAME", $"PBSWALK", $"PBSWALKNAME", $"PBSZONE", $"PBSZONENAME", $"PEDCTYPE", $"PEDCTYPENAME", $"BIKECTYPE", $"BIKECTYPENAME", $"PEDLOC", $"PEDLOCNAME", $"BIKELOC", $"BIKELOCNAME", $"PEDPOS", $"PEDPOSNAME", $"BIKEPOS", $"BIKEPOSNAME", $"PEDDIR", $"PEDDIRNAME", $"BIKEDIR", $"BIKEDIRNAME", $"MOTDIR", $"MOTDIRNAME", $"MOTMAN", $"MOTMANNAME", $"PEDLEG", $"PEDLEGNAME", $"PEDSNR", $"PEDSNRNAME", $"PEDCGP", $"PEDCGPNAME", $"BIKECGP", $"BIKECGPNAME", $"NMHELMET", $"NMHELMETNAME", $"NMPROPAD", $"NMPROPADNAME", $"NMOTHPRO", $"NMOTHPRONAME", $"NMREFCLO", $"NMREFCLONAME", $"NMLIGHT", $"NMLIGHTNAME", $"NMOTHPRE", $"NMOTHPRENAME", $"MIPER_P1", $"MIPER_P2", $"MIPER_P3", $"MIPER_P4", $"MIPER_P5", $"MIPER_P6", $"MIPER_P7", $"MIPER_P8", $"MIPER_P9", $"MIPER_P10")
    USING HEADER="true", SEPARATOR="\t", EOL="\n";
  LOAD f_Event TO VERTEX Event VALUES ($"event_id", $"accident_id", $"DATA_YEAR", $"STATE", $"STATENAME", $"ST_CASE", $"EVENTNUM", $"VNUMBER1", $"AOI1", $"AOI1NAME", $"SOE", $"SOENAME", $"VNUMBER2", $"VNUMBER2NAME", $"AOI2", $"AOI2NAME")
    USING HEADER="true", SEPARATOR="\t", EOL="\n";
  LOAD f_VPICDecode TO VERTEX VPICDecode VALUES ($"vpic_id", $"vehicle_id", $"accident_id", $"DATA_YEAR", $"STATE", $"STATENAME", $"ST_CASE", $"VEH_NO", $"VEHICLEDESCRIPTOR", $"VINDECODEDON", $"VINDECODEERROR", $"VEHICLETYPEID", $"VEHICLETYPE", $"MANUFACTURERFULLNAMEID", $"MANUFACTURERFULLNAME", $"MAKEID", $"MAKE", $"MODELID", $"MODEL", $"MODELYEAR", $"SERIES", $"TRIM1", $"SERIES2", $"TRIM2", $"PLANTCOUNTRYID", $"PLANTCOUNTRY", $"PLANTSTATE", $"PLANTCITY", $"PLANTCOMPANYNAME", $"DESTINATIONMARKETID", $"DESTINATIONMARKET", $"BASEPRICE", $"NOTE", $"BODYCLASSID", $"BODYCLASS", $"DOORSCOUNT", $"WINDOWS", $"WHEELBASETYPEID", $"WHEELBASETYPE", $"TRACKWIDTHIN", $"GROSSVEHICLEWEIGHTRATINGFROMID", $"GROSSVEHICLEWEIGHTRATINGFROM", $"GROSSVEHICLEWEIGHTRATINGTOID", $"GROSSVEHICLEWEIGHTRATINGTO", $"GROSSCOMBWEIGHTRATINGFROMID", $"GROSSCOMBWEIGHTRATINGFROM", $"GROSSCOMBWEIGHTRATINGTOID", $"GROSSCOMBWEIGHTRATINGTO", $"CURBWEIGHTLB", $"WHEELBASEIN_FROM", $"WHEELBASEIN_TO", $"WHEELSCOUNT", $"WHEELSIZEFRONTIN", $"WHEELSIZEREARIN", $"TRUCKBODYCABTYPEID", $"TRUCKBODYCABTYPE", $"TRUCKBEDTYPEID", $"TRUCKBEDTYPE", $"TRUCKBEDLENGTHIN", $"BUSTYPEID", $"BUSTYPE", $"BUSFLOORCONFIGURATIONTYPEID", $"BUSFLOORCONFIGURATIONTYPE", $"BUSLENGTHFT", $"OTHERBUSINFO", $"CUSTOMMOTORCYCLETYPEID", $"CUSTOMMOTORCYCLETYPE", $"MOTORCYCLESUSPENSIONTYPEID", $"MOTORCYCLESUSPENSIONTYPE", $"MOTORCYCLECHASSISTYPEID", $"MOTORCYCLECHASSISTYPE", $"OTHERMOTORCYCLEINFO", $"STEERINGLOCATIONID", $"STEERINGLOCATION", $"ENTERTAINMENTSYSTEMID", $"ENTERTAINMENTSYSTEM", $"SEATSCOUNT", $"SEATROWSCOUNT", $"TRANSMISSIONSPEEDS", $"TRANSMISSIONSTYLEID", $"TRANSMISSIONSTYLE", $"DRIVETYPEID", $"DRIVETYPE", $"AXLESCOUNT", $"AXLECONFIGURATIONID", $"AXLECONFIGURATION", $"BRAKESYSTEMTYPEID", $"BRAKESYSTEMTYPE", $"BRAKESYSTEMDESC", $"EVDRIVEUNITID", $"EVDRIVEUNIT", $"BATTERYKWH_FROM", $"BATTERYKWH_TO", $"BATTERYV_FROM", $"BATTERYV_TO", $"BATTERYA_FROM", $"BATTERYA_TO", $"BATTERYPACKSPERVEHICLE", $"BATTERYMODULESPERPACK", $"BATTERYCELLSPERMODULE", $"BATTERYTYPEID", $"BATTERYTYPE", $"OTHERBATTERYINFO", $"CHARGERLEVELID", $"CHARGERLEVEL", $"CHARGERPOWERKW", $"ENGINEMANUFACTURER", $"ENGINEMODEL", $"ENGINECONFIGURATIONID", $"ENGINECONFIGURATION", $"ENGINEPOWERKW", $"ENGINESTROKECYCLES", $"ENGINECYLINDERSCOUNT", $"ENGINEBRAKEHP_FROM", $"ENGINEBRAKEHP_TO", $"ENGINECOOLINGTYPEID", $"ENGINECOOLINGTYPE", $"DISPLACEMENTCI", $"DISPLACEMENTCC", $"DISPLACEMENTL", $"FUELTYPEPRIMARYID", $"FUELTYPEPRIMARY", $"FUELTYPESECONDARYID", $"FUELTYPESECONDARY", $"FUELDELIVERYINJECTIONTYPEID", $"FUELDELIVERYINJECTIONTYPE", $"ENGINEVALVETRAINDESIGNID", $"ENGINEVALVETRAINDESIGN", $"ENGINEELECTRIFICATIONLEVELID", $"ENGINEELECTRIFICATIONLEVEL", $"ENGINETURBOID", $"ENGINETURBO", $"TOPSPEEDMPH", $"OTHERENGINEINFO", $"SEATBELTTYPEID", $"SEATBELTTYPE", $"PRETENSIONERID", $"PRETENSIONER", $"AIRBAGLOCFRONTID", $"AIRBAGLOCFRONT", $"AIRBAGLOCKNEEID", $"AIRBAGLOCKNEE", $"AIRBAGLOCSIDEID", $"AIRBAGLOCSIDE", $"AIRBAGLOCCURTAINID", $"AIRBAGLOCCURTAIN", $"AIRBAGLOCSEATCUSHIONID", $"AIRBAGLOCSEATCUSHION", $"OTHERRESTRAINTSYSTEMINFO", $"FORWARDCOLLISIONWARNINGID", $"FORWARDCOLLISIONWARNING", $"DYNAMICBRAKESUPPORTID", $"DYNAMICBRAKESUPPORT", $"CRASHIMMINENTBRAKINGID", $"CRASHIMMINENTBRAKING", $"PEDESTRIANAUTOEMERGENCYBRAKINGID", $"PEDESTRIANAUTOEMERGENCYBRAKING", $"BLINDSPOTWARNINGID", $"BLINDSPOTWARNING", $"BLINDSPOTINTERVENTIONID", $"BLINDSPOTINTERVENTION", $"LANEDEPARTUREWARNINGID", $"LANEDEPARTUREWARNING", $"LANEKEEPINGASSISTANCEID", $"LANEKEEPINGASSISTANCE", $"LANECENTERINGASSISTANCEID", $"LANECENTERINGASSISTANCE", $"BACKUPCAMERAID", $"BACKUPCAMERA", $"REARCROSSTRAFFICALERTID", $"REARCROSSTRAFFICALERT", $"REARAUTOMATICEMERGENCYBRAKINGID", $"REARAUTOMATICEMERGENCYBRAKING", $"PARKASSISTID", $"PARKASSIST", $"DAYTIMERUNNINGLIGHTID", $"DAYTIMERUNNINGLIGHT", $"HEADLAMPLIGHTSOURCEID", $"HEADLAMPLIGHTSOURCE", $"SEMIAUTOHEADLAMPBEAMSWITCHINGID", $"SEMIAUTOHEADLAMPBEAMSWITCHING", $"ADAPTIVEDRIVINGBEAMID", $"ADAPTIVEDRIVINGBEAM", $"ADAPTIVECRUISECONTROLID", $"ADAPTIVECRUISECONTROL", $"ANTILOCKBRAKESYSTEMID", $"ANTILOCKBRAKESYSTEM", $"ELECTRONICSTABILITYCONTROLID", $"ELECTRONICSTABILITYCONTROL", $"TPMSID", $"TPMS", $"AUTOMATICCRASHNOTIFICATIONID", $"AUTOMATICCRASHNOTIFICATION", $"EVENTDATARECORDERID", $"EVENTDATARECORDER", $"TRACTIONCONTROLID", $"TRACTIONCONTROL", $"AUTOPEDESTRIANALERTINGSOUNDID", $"AUTOPEDESTRIANALERTINGSOUND", $"KEYLESSIGNITIONID", $"KEYLESSIGNITION", $"SAEAUTOMATIONLEVEL_FROM", $"SAEAUTOMATIONLEVEL_TO", $"AUTOREVERSESYSTEMID", $"AUTOREVERSESYSTEM", $"ACTIVESAFETYSYSNOTE", $"NONLANDUSEID", $"NONLANDUSE")
    USING HEADER="true", SEPARATOR="\t", EOL="\n";
  LOAD f_Trailer TO VERTEX Trailer VALUES ($"trailer_id", $"vehicle_id", $"accident_id", $"DATA_YEAR", $"STATE", $"STATENAME", $"ST_CASE", $"VEH_NO", $"TRAILER_NO", $"VEHICLEDESCRIPTOR", $"VINDECODEDON", $"VINDECODEERROR", $"VEHICLETYPEID", $"VEHICLETYPE", $"MANUFACTURERFULLNAMEID", $"MANUFACTURERFULLNAME", $"MAKEID", $"MAKE", $"MODELID", $"MODEL", $"MODELYEAR", $"SERIES", $"TRIM1", $"PLANTCOUNTRYID", $"PLANTCOUNTRY", $"PLANTSTATE", $"PLANTCITY", $"PLANTCOMPANYNAME", $"NOTE", $"BODYCLASSID", $"BODYCLASS", $"GROSSVEHICLEWEIGHTRATINGFROMID", $"GROSSVEHICLEWEIGHTRATINGFROM", $"GROSSVEHICLEWEIGHTRATINGTOID", $"GROSSVEHICLEWEIGHTRATINGTO", $"TRAILERBODYTYPEID", $"TRAILERBODYTYPE", $"TRAILERTYPECONNECTIONID", $"TRAILERTYPECONNECTION", $"TRAILERLENGTHFT", $"OTHERTRAILERINFO", $"AXLESCOUNT", $"AXLECONFIGURATIONID", $"AXLECONFIGURATION", $"NONLANDUSEID", $"NONLANDUSE")
    USING HEADER="true", SEPARATOR="\t", EOL="\n";
  LOAD f_DrugEvent TO VERTEX DrugEvent VALUES ($"drug_event_id", $"person_id", $"accident_id", $"DATA_YEAR", $"STATE", $"STATENAME", $"ST_CASE", $"VEH_NO", $"PER_NO", $"DRUGSPEC", $"DRUGSPECNAME", $"DRUGRES", $"DRUGRESNAME", $"vehicle_id")
    USING HEADER="true", SEPARATOR="\t", EOL="\n";
  LOAD f_Weather TO VERTEX Weather VALUES ($"id", $"name")
    USING HEADER="true", SEPARATOR="\t", EOL="\n";
  LOAD f_CrashRF TO VERTEX CrashRF VALUES ($"id", $"name")
    USING HEADER="true", SEPARATOR="\t", EOL="\n";
  LOAD f_Damage TO VERTEX Damage VALUES ($"id", $"name")
    USING HEADER="true", SEPARATOR="\t", EOL="\n";
  LOAD f_Distract TO VERTEX Distract VALUES ($"id", $"name")
    USING HEADER="true", SEPARATOR="\t", EOL="\n";
  LOAD f_DrImpair TO VERTEX DrImpair VALUES ($"id", $"name")
    USING HEADER="true", SEPARATOR="\t", EOL="\n";
  LOAD f_DriverRF TO VERTEX DriverRF VALUES ($"id", $"name")
    USING HEADER="true", SEPARATOR="\t", EOL="\n";
  LOAD f_Factor TO VERTEX Factor VALUES ($"id", $"name")
    USING HEADER="true", SEPARATOR="\t", EOL="\n";
  LOAD f_Maneuver TO VERTEX Maneuver VALUES ($"id", $"name")
    USING HEADER="true", SEPARATOR="\t", EOL="\n";
  LOAD f_VehicleSF TO VERTEX VehicleSF VALUES ($"id", $"name")
    USING HEADER="true", SEPARATOR="\t", EOL="\n";
  LOAD f_Violatn TO VERTEX Violatn VALUES ($"id", $"name")
    USING HEADER="true", SEPARATOR="\t", EOL="\n";
  LOAD f_Vision TO VERTEX Vision VALUES ($"id", $"name")
    USING HEADER="true", SEPARATOR="\t", EOL="\n";
  LOAD f_Race TO VERTEX Race VALUES ($"id", $"name")
    USING HEADER="true", SEPARATOR="\t", EOL="\n";
  LOAD f_PersonRF TO VERTEX PersonRF VALUES ($"id", $"name")
    USING HEADER="true", SEPARATOR="\t", EOL="\n";
  LOAD f_NMCrash TO VERTEX NMCrash VALUES ($"id", $"name")
    USING HEADER="true", SEPARATOR="\t", EOL="\n";
  LOAD f_NMDistract TO VERTEX NMDistract VALUES ($"id", $"name")
    USING HEADER="true", SEPARATOR="\t", EOL="\n";
  LOAD f_NMImpair TO VERTEX NMImpair VALUES ($"id", $"name")
    USING HEADER="true", SEPARATOR="\t", EOL="\n";
  LOAD f_NMPrior TO VERTEX NMPrior VALUES ($"id", $"name")
    USING HEADER="true", SEPARATOR="\t", EOL="\n";
  LOAD f_DrugTest TO VERTEX DrugTest VALUES ($"id", $"name")
    USING HEADER="true", SEPARATOR="\t", EOL="\n";
  LOAD f_Drug TO VERTEX Drug VALUES ($"id", $"name")
    USING HEADER="true", SEPARATOR="\t", EOL="\n";
}

load_edges

gsql

CREATE LOADING JOB load_edges FOR GRAPH fars20_22 {
  DEFINE FILENAME f_Accident_INVOLVES_Vehicle = "m1:/datasets/prop_datasets/fars/fars20-22/csv/edges/Accident_INVOLVES_Vehicle.tsv";
  DEFINE FILENAME f_Accident_HAS_VICTIM_Person = "m1:/datasets/prop_datasets/fars/fars20-22/csv/edges/Accident_HAS_VICTIM_Person.tsv";
  DEFINE FILENAME f_Accident_RESULTED_IN_Event = "m1:/datasets/prop_datasets/fars/fars20-22/csv/edges/Accident_RESULTED_IN_Event.tsv";
  DEFINE FILENAME f_Vehicle_HAS_OCCUPANT_Person = "m1:/datasets/prop_datasets/fars/fars20-22/csv/edges/Vehicle_HAS_OCCUPANT_Person.tsv";
  DEFINE FILENAME f_Vehicle_SUBJECT_OF_Event = "m1:/datasets/prop_datasets/fars/fars20-22/csv/edges/Vehicle_SUBJECT_OF_Event.tsv";
  DEFINE FILENAME f_Vehicle_OBJECT_OF_Event = "m1:/datasets/prop_datasets/fars/fars20-22/csv/edges/Vehicle_OBJECT_OF_Event.tsv";
  DEFINE FILENAME f_Vehicle_HAS_VEVENT_Event = "m1:/datasets/prop_datasets/fars/fars20-22/csv/edges/Vehicle_HAS_VEVENT_Event.tsv";
  DEFINE FILENAME f_Vehicle_HAS_VPIC_VPICDecode = "m1:/datasets/prop_datasets/fars/fars20-22/csv/edges/Vehicle_HAS_VPIC_VPICDecode.tsv";
  DEFINE FILENAME f_Vehicle_HAS_TRAILER_Trailer = "m1:/datasets/prop_datasets/fars/fars20-22/csv/edges/Vehicle_HAS_TRAILER_Trailer.tsv";
  DEFINE FILENAME f_DrugEvent_DRUG_EVENT_OF_Person = "m1:/datasets/prop_datasets/fars/fars20-22/csv/edges/DrugEvent_DRUG_EVENT_OF_Person.tsv";
  DEFINE FILENAME f_DrugTest_DRUG_TEST_OF_DrugEvent = "m1:/datasets/prop_datasets/fars/fars20-22/csv/edges/DrugTest_DRUG_TEST_OF_DrugEvent.tsv";
  DEFINE FILENAME f_Drug_RESULT_OF_DrugEvent = "m1:/datasets/prop_datasets/fars/fars20-22/csv/edges/Drug_RESULT_OF_DrugEvent.tsv";
  DEFINE FILENAME f_Accident_OCCURRED_IN_Weather = "m1:/datasets/prop_datasets/fars/fars20-22/csv/edges/Accident_OCCURRED_IN_Weather.tsv";
  DEFINE FILENAME f_CrashRF_CRASH_FACTOR_OF_Accident = "m1:/datasets/prop_datasets/fars/fars20-22/csv/edges/CrashRF_CRASH_FACTOR_OF_Accident.tsv";
  DEFINE FILENAME f_Damage_POSITION_OF_Vehicle = "m1:/datasets/prop_datasets/fars/fars20-22/csv/edges/Damage_POSITION_OF_Vehicle.tsv";
  DEFINE FILENAME f_Distract_DISTRACTION_OF_Vehicle = "m1:/datasets/prop_datasets/fars/fars20-22/csv/edges/Distract_DISTRACTION_OF_Vehicle.tsv";
  DEFINE FILENAME f_DrImpair_IMPAIRMENT_OF_Vehicle = "m1:/datasets/prop_datasets/fars/fars20-22/csv/edges/DrImpair_IMPAIRMENT_OF_Vehicle.tsv";
  DEFINE FILENAME f_DriverRF_DRIVER_RF_OF_Vehicle = "m1:/datasets/prop_datasets/fars/fars20-22/csv/edges/DriverRF_DRIVER_RF_OF_Vehicle.tsv";
  DEFINE FILENAME f_Factor_FACTOR_OF_Vehicle = "m1:/datasets/prop_datasets/fars/fars20-22/csv/edges/Factor_FACTOR_OF_Vehicle.tsv";
  DEFINE FILENAME f_Maneuver_MANEUVER_OF_Vehicle = "m1:/datasets/prop_datasets/fars/fars20-22/csv/edges/Maneuver_MANEUVER_OF_Vehicle.tsv";
  DEFINE FILENAME f_VehicleSF_VEHICLE_SF_OF_Vehicle = "m1:/datasets/prop_datasets/fars/fars20-22/csv/edges/VehicleSF_VEHICLE_SF_OF_Vehicle.tsv";
  DEFINE FILENAME f_Violatn_COMMITTED_BY_Vehicle = "m1:/datasets/prop_datasets/fars/fars20-22/csv/edges/Violatn_COMMITTED_BY_Vehicle.tsv";
  DEFINE FILENAME f_Vision_VISION_OF_Vehicle = "m1:/datasets/prop_datasets/fars/fars20-22/csv/edges/Vision_VISION_OF_Vehicle.tsv";
  DEFINE FILENAME f_Race_RACE_OF_Person = "m1:/datasets/prop_datasets/fars/fars20-22/csv/edges/Race_RACE_OF_Person.tsv";
  DEFINE FILENAME f_PersonRF_PERSON_RF_OF_Person = "m1:/datasets/prop_datasets/fars/fars20-22/csv/edges/PersonRF_PERSON_RF_OF_Person.tsv";
  DEFINE FILENAME f_NMCrash_NMCRASH_OF_Person = "m1:/datasets/prop_datasets/fars/fars20-22/csv/edges/NMCrash_NMCRASH_OF_Person.tsv";
  DEFINE FILENAME f_NMDistract_NMDISTRACT_OF_Person = "m1:/datasets/prop_datasets/fars/fars20-22/csv/edges/NMDistract_NMDISTRACT_OF_Person.tsv";
  DEFINE FILENAME f_NMImpair_NMIMPAIR_OF_Person = "m1:/datasets/prop_datasets/fars/fars20-22/csv/edges/NMImpair_NMIMPAIR_OF_Person.tsv";
  DEFINE FILENAME f_NMPrior_NMPRIOR_OF_Person = "m1:/datasets/prop_datasets/fars/fars20-22/csv/edges/NMPrior_NMPRIOR_OF_Person.tsv";
  LOAD f_Accident_INVOLVES_Vehicle TO EDGE INVOLVES VALUES ($"src", $"dst")
    USING HEADER="true", SEPARATOR="\t", EOL="\n", VERTEX_MUST_EXIST="true";
  LOAD f_Accident_HAS_VICTIM_Person TO EDGE HAS_VICTIM VALUES ($"src", $"dst")
    USING HEADER="true", SEPARATOR="\t", EOL="\n", VERTEX_MUST_EXIST="true";
  LOAD f_Accident_RESULTED_IN_Event TO EDGE RESULTED_IN VALUES ($"src", $"dst")
    USING HEADER="true", SEPARATOR="\t", EOL="\n", VERTEX_MUST_EXIST="true";
  LOAD f_Vehicle_HAS_OCCUPANT_Person TO EDGE HAS_OCCUPANT VALUES ($"src", $"dst")
    USING HEADER="true", SEPARATOR="\t", EOL="\n", VERTEX_MUST_EXIST="true";
  LOAD f_Vehicle_SUBJECT_OF_Event TO EDGE SUBJECT_OF VALUES ($"src", $"dst", $"AOI", $"AOINAME")
    USING HEADER="true", SEPARATOR="\t", EOL="\n", VERTEX_MUST_EXIST="true";
  LOAD f_Vehicle_OBJECT_OF_Event TO EDGE OBJECT_OF VALUES ($"src", $"dst", $"AOI", $"AOINAME")
    USING HEADER="true", SEPARATOR="\t", EOL="\n", VERTEX_MUST_EXIST="true";
  LOAD f_Vehicle_HAS_VEVENT_Event TO EDGE HAS_VEVENT VALUES ($"src", $"dst", $"VEVENTNUM", $"AOI", $"AOINAME")
    USING HEADER="true", SEPARATOR="\t", EOL="\n", VERTEX_MUST_EXIST="true";
  LOAD f_Vehicle_HAS_VPIC_VPICDecode TO EDGE HAS_VPIC VALUES ($"src", $"dst")
    USING HEADER="true", SEPARATOR="\t", EOL="\n", VERTEX_MUST_EXIST="true";
  LOAD f_Vehicle_HAS_TRAILER_Trailer TO EDGE HAS_TRAILER VALUES ($"src", $"dst", $"TRAILER_NO")
    USING HEADER="true", SEPARATOR="\t", EOL="\n", VERTEX_MUST_EXIST="true";
  LOAD f_DrugEvent_DRUG_EVENT_OF_Person TO EDGE DRUG_EVENT_OF VALUES ($"src", $"dst")
    USING HEADER="true", SEPARATOR="\t", EOL="\n", VERTEX_MUST_EXIST="true";
  LOAD f_DrugTest_DRUG_TEST_OF_DrugEvent TO EDGE DRUG_TEST_OF VALUES ($"src", $"dst")
    USING HEADER="true", SEPARATOR="\t", EOL="\n", VERTEX_MUST_EXIST="true";
  LOAD f_Drug_RESULT_OF_DrugEvent TO EDGE RESULT_OF VALUES ($"src", $"dst")
    USING HEADER="true", SEPARATOR="\t", EOL="\n", VERTEX_MUST_EXIST="true";
  LOAD f_Accident_OCCURRED_IN_Weather TO EDGE OCCURRED_IN VALUES ($"src", $"dst")
    USING HEADER="true", SEPARATOR="\t", EOL="\n", VERTEX_MUST_EXIST="true";
  LOAD f_CrashRF_CRASH_FACTOR_OF_Accident TO EDGE CRASH_FACTOR_OF VALUES ($"src", $"dst")
    USING HEADER="true", SEPARATOR="\t", EOL="\n", VERTEX_MUST_EXIST="true";
  LOAD f_Damage_POSITION_OF_Vehicle TO EDGE POSITION_OF VALUES ($"src", $"dst")
    USING HEADER="true", SEPARATOR="\t", EOL="\n", VERTEX_MUST_EXIST="true";
  LOAD f_Distract_DISTRACTION_OF_Vehicle TO EDGE DISTRACTION_OF VALUES ($"src", $"dst")
    USING HEADER="true", SEPARATOR="\t", EOL="\n", VERTEX_MUST_EXIST="true";
  LOAD f_DrImpair_IMPAIRMENT_OF_Vehicle TO EDGE IMPAIRMENT_OF VALUES ($"src", $"dst")
    USING HEADER="true", SEPARATOR="\t", EOL="\n", VERTEX_MUST_EXIST="true";
  LOAD f_DriverRF_DRIVER_RF_OF_Vehicle TO EDGE DRIVER_RF_OF VALUES ($"src", $"dst")
    USING HEADER="true", SEPARATOR="\t", EOL="\n", VERTEX_MUST_EXIST="true";
  LOAD f_Factor_FACTOR_OF_Vehicle TO EDGE FACTOR_OF VALUES ($"src", $"dst")
    USING HEADER="true", SEPARATOR="\t", EOL="\n", VERTEX_MUST_EXIST="true";
  LOAD f_Maneuver_MANEUVER_OF_Vehicle TO EDGE MANEUVER_OF VALUES ($"src", $"dst")
    USING HEADER="true", SEPARATOR="\t", EOL="\n", VERTEX_MUST_EXIST="true";
  LOAD f_VehicleSF_VEHICLE_SF_OF_Vehicle TO EDGE VEHICLE_SF_OF VALUES ($"src", $"dst")
    USING HEADER="true", SEPARATOR="\t", EOL="\n", VERTEX_MUST_EXIST="true";
  LOAD f_Violatn_COMMITTED_BY_Vehicle TO EDGE COMMITTED_BY VALUES ($"src", $"dst")
    USING HEADER="true", SEPARATOR="\t", EOL="\n", VERTEX_MUST_EXIST="true";
  LOAD f_Vision_VISION_OF_Vehicle TO EDGE VISION_OF VALUES ($"src", $"dst")
    USING HEADER="true", SEPARATOR="\t", EOL="\n", VERTEX_MUST_EXIST="true";
  LOAD f_Race_RACE_OF_Person TO EDGE RACE_OF VALUES ($"src", $"dst", $"RACE_ORDER", $"MULTRACE")
    USING HEADER="true", SEPARATOR="\t", EOL="\n", VERTEX_MUST_EXIST="true";
  LOAD f_PersonRF_PERSON_RF_OF_Person TO EDGE PERSON_RF_OF VALUES ($"src", $"dst")
    USING HEADER="true", SEPARATOR="\t", EOL="\n", VERTEX_MUST_EXIST="true";
  LOAD f_NMCrash_NMCRASH_OF_Person TO EDGE NMCRASH_OF VALUES ($"src", $"dst")
    USING HEADER="true", SEPARATOR="\t", EOL="\n", VERTEX_MUST_EXIST="true";
  LOAD f_NMDistract_NMDISTRACT_OF_Person TO EDGE NMDISTRACT_OF VALUES ($"src", $"dst")
    USING HEADER="true", SEPARATOR="\t", EOL="\n", VERTEX_MUST_EXIST="true";
  LOAD f_NMImpair_NMIMPAIR_OF_Person TO EDGE NMIMPAIR_OF VALUES ($"src", $"dst")
    USING HEADER="true", SEPARATOR="\t", EOL="\n", VERTEX_MUST_EXIST="true";
  LOAD f_NMPrior_NMPRIOR_OF_Person TO EDGE NMPRIOR_OF VALUES ($"src", $"dst")
    USING HEADER="true", SEPARATOR="\t", EOL="\n", VERTEX_MUST_EXIST="true";
}

Run Jobs (32.869s)

The jobs run one after the other: load_vertices took 15.308s and load_edges took 15.291s. A delta rebuild (6.860s, through the RESTPP /rebuildnow endpoint) follows before counting.

gsql

USE GRAPH fars20_22
RUN LOADING JOB load_vertices
RUN LOADING JOB load_edges

Per-file Statistics

Lines, rejected lines and duration per file as reported by SHOW LOADING STATUS. Files inside a job are processed one after another; the job wall-clock time also includes job start-up. Rejected lines in total: 0.

load_vertices

File	Lines	Duration
Accident.tsv	115,142	0.40 s
Vehicle.tsv	182,055	1.10 s
Person.tsv	280,093	1.47 s
Event.tsv	329,040	0.33 s
VPICDecode.tsv	173,667	0.90 s
Trailer.tsv	4,742	0.21 s
DrugEvent.tsv	349,255	0.31 s
Weather.tsv	13	0.10 s
CrashRF.tsv	29	0.10 s
Damage.tsv	16	0.10 s
Distract.tsv	22	0.11 s
DrImpair.tsv	15	0.30 s
DriverRF.tsv	67	0.10 s
Factor.tsv	20	0.10 s
Maneuver.tsv	10	0.10 s
VehicleSF.tsv	13	0.20 s
Violatn.tsv	76	0.10 s
Vision.tsv	19	0.10 s
Race.tsv	20	0.10 s
PersonRF.tsv	44	0.70 s
NMCrash.tsv	24	0.10 s
NMDistract.tsv	18	0.10 s
NMImpair.tsv	14	0.10 s
NMPrior.tsv	15	0.10 s
DrugTest.tsv	12	0.40 s
Drug.tsv	422	0.10 s

load_edges

File	Lines	Duration
Accident_INVOLVES_Vehicle.tsv	182,055	0.31 s
Accident_HAS_VICTIM_Person.tsv	280,093	0.42 s
Accident_RESULTED_IN_Event.tsv	329,040	0.32 s
Vehicle_HAS_OCCUPANT_Person.tsv	252,980	0.32 s
Vehicle_SUBJECT_OF_Event.tsv	329,040	0.34 s
Vehicle_OBJECT_OF_Event.tsv	66,079	0.21 s
Vehicle_HAS_VEVENT_Event.tsv	395,119	0.35 s
Vehicle_HAS_VPIC_VPICDecode.tsv	173,667	0.22 s
Vehicle_HAS_TRAILER_Trailer.tsv	4,742	0.10 s
DrugEvent_DRUG_EVENT_OF_Person.tsv	349,255	0.33 s
DrugTest_DRUG_TEST_OF_DrugEvent.tsv	349,255	0.32 s
Drug_RESULT_OF_DrugEvent.tsv	349,255	0.42 s
Accident_OCCURRED_IN_Weather.tsv	116,337	0.31 s
CrashRF_CRASH_FACTOR_OF_Accident.tsv	116,019	0.51 s
Damage_POSITION_OF_Vehicle.tsv	761,383	0.34 s
Distract_DISTRACTION_OF_Vehicle.tsv	177,181	0.31 s
DrImpair_IMPAIRMENT_OF_Vehicle.tsv	177,703	0.21 s
DriverRF_DRIVER_RF_OF_Vehicle.tsv	195,590	0.21 s
Factor_FACTOR_OF_Vehicle.tsv	177,351	0.31 s
Maneuver_MANEUVER_OF_Vehicle.tsv	177,145	0.31 s
VehicleSF_VEHICLE_SF_OF_Vehicle.tsv	182,057	0.31 s
Violatn_COMMITTED_BY_Vehicle.tsv	190,012	0.31 s
Vision_VISION_OF_Vehicle.tsv	177,246	0.31 s
Race_RACE_OF_Person.tsv	280,633	0.32 s
PersonRF_PERSON_RF_OF_Person.tsv	280,134	0.32 s
NMCrash_NMCRASH_OF_Person.tsv	37,908	0.21 s
NMDistract_NMDISTRACT_OF_Person.tsv	27,125	0.10 s
NMImpair_NMIMPAIR_OF_Person.tsv	27,182	0.11 s
NMPrior_NMPRIOR_OF_Person.tsv	28,191	0.10 s

Count Check

Vertex and edge counts were read with the RESTPP built-in functions stat_vertex_number and stat_edge_number and compared with expected-counts.tsv, the same file used to check Neo4j. All 26 vertex types and 29 edge types match, so the TigerGraph and Neo4j graphs have identical counts.