#create data_source kafka k1 = "kafka_config.json" for graph test_graph
CREATE DATA_SOURCE KAFKA k1 FOR GRAPH test_graph
SET k1 = "kafka_config.json"
# define the loading jobs
CREATE LOADING JOB load_person FOR GRAPH test_graph {
DEFINE FILENAME f1 = "$k1:topic_partition_config.json";
TO VERTEX Person VALUES ($2, $0, $1),
TO EDGE Person2Comp VALUES ($2, $2, $1)
RUN LOADING JOB load_person