Implement TPC-H data loader

configs/tpch_replay_dsched.conf

@@ -0,0 +1,38 @@
+# Output configs.
+--log=./tpch_replay_dsched.log
+--log_level=debug
+--csv=./tpch_replay_dsched.csv
+
+# Task configs.
+--runtime_variance=0
+
+# Scheduler configs.
+
+# DSched
+--scheduler=TetriSched
+--scheduler_runtime=0
+--enforce_deadlines
+--retract_schedules
+--release_taskgraphs
+--drop_skipped_tasks
+--scheduler_time_discretization=1
+
+# Deadline variance
+--min_deadline_variance=10
+--max_deadline_variance=25
+
+# Execution mode configs.
+--execution_mode=replay
+--replay_trace=tpch
+
+# Release time config.
+--override_release_policy=gamma
+--override_gamma_coefficient=1
+--override_poisson_arrival_rate=1
+--override_num_invocation=10
+
+# TPCH flags
+--random_seed=1234
+--tpch_query_dag_spec=profiles/workload/tpch/queries.yaml
+--tpch_dataset_size=50
+--worker_profile_path=profiles/workers/tpch_cluster.yaml

configs/tpch_replay_edf.conf

@@ -0,0 +1,47 @@
+# Output configs.
+# --log=./tpch_replay_dsched.log
+# --log_level=debug
+# --csv=./tpch_replay_dsched.csv
+
+--log=./tpch_replay_edf.log
+--log_level=debug
+--csv=./tpch_replay_edf.csv
+
+# Task configs.
+--runtime_variance=0
+
+# Scheduler configs.
+
+# EDF
+--scheduler=EDF
+--scheduler_runtime=0
+--enforce_deadlines
+
+# DSched
+# --scheduler=TetriSched
+# --scheduler_runtime=0
+# --enforce_deadlines
+# --retract_schedules
+# --release_taskgraphs
+# --drop_skipped_tasks
+# --scheduler_time_discretization=1
+
+# Deadline variance
+--min_deadline_variance=10
+--max_deadline_variance=25
+
+# Execution mode configs.
+--execution_mode=replay
+--replay_trace=tpch
+
+# Release time config.
+--override_release_policy=gamma
+--override_gamma_coefficient=1
+--override_poisson_arrival_rate=1
+--override_num_invocation=10
+
+# TPCH flags
+--random_seed=1234
+--tpch_query_dag_spec=profiles/workload/tpch/queries.yaml
+--tpch_dataset_size=50
+--worker_profile_path=profiles/workers/tpch_cluster.yaml

data/__init__.py

@@ -7,6 +7,7 @@
 from .task_loader_benchmark import TaskLoaderBenchmark
 from .task_loader_pylot import TaskLoaderPylot
 from .task_loader_synthetic import TaskLoaderSynthetic
+from .tpch_loader import TpchLoader
 from .worker_loader import WorkerLoader
 from .worker_loader_benchmark import WorkerLoaderBenchmark
 from .workload_loader import WorkloadLoader