Skip to content

fix: gpstore query prefixes, file paths, and README clarifications #55

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
qishipengqsp merged 4 commits into from
Sep 23, 2025
Merged

fix: gpstore query prefixes, file paths, and README clarifications #55

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
4 commits
Select commit Hold shift + click to select a range
7692da3
doc: Clarify validation and build & load database steps in gpstore RE…
SoftlySpoken Sep 23, 2025
1f91919
fix: fix parameters_dir & updates_dir in gpstore properties files
SoftlySpoken Sep 23, 2025
b753545
fix: add plugin prefix to gpstore queries to adapt to docker
SoftlySpoken Sep 23, 2025
7c0f208
fix: upload correct validation_params.csv for gpstore
SoftlySpoken Sep 23, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
9 changes: 8 additions & 1 deletion gpstore/README.md
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -106,17 +106,24 @@ exit
docker restart gpstore-server
```

## 2.3 Load data
## 2.3 Build & load database

```bash
# Build database
curl -X POST -H 'Content-Type: application/json' -d '{"operation":"build","username":"root","password":"123456","db_name":"finbench-sf10"}' http://127.0.0.1:9009/grpc/api
# Load database
curl -X POST -H 'Content-Type: application/json' -d '{"operation":"load","username":"root","password":"123456","db_name":"finbench-sf10"}' http://127.0.0.1:9009/grpc/api
```

# 3. Benchmark

## 3.1 Validate

Please note that, typically, *either 3.1.1 or 3.1.2 will be executed across a run*, since they serve different purposes:

- "Create validation" is for generating a `validation_params.csv` file from gpstore's outputs, so as this CSV file can be used as the ground truth to validate other systems.
- "Validate" is for validating gpstore against an existing, correct `validation_params.csv` file, such as that provided under this directory.

### 3.1.1 Create validation

```shell
Expand Down
4 changes: 2 additions & 2 deletions gpstore/benchmark.properties
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -29,8 +29,8 @@ validation_parameters_size=100
validate_workload=true
validate_database=validation_params.csv
warmup=450000
ldbc.finbench.transaction.queries.parameters_dir=data/sf10/read_params
ldbc.finbench.transaction.queries.updates_dir=data/sf10/incremental
ldbc.finbench.transaction.queries.parameters_dir=data/finbench-sf10/read_params
ldbc.finbench.transaction.queries.updates_dir=data/finbench-sf10/incremental
# param and update files suffix, `csv` or `parquet`, default is `csv`
ldbc.finbench.transaction.queries.files_suffix=csv
ldbc.finbench.transaction.queries.simple_read_dissipation=0.2
Expand Down
4 changes: 2 additions & 2 deletions gpstore/create_validation.properties
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -29,8 +29,8 @@ validation_parameters_size=10000
validate_workload=true
validate_database=validation_params.csv
warmup=0
ldbc.finbench.transaction.queries.parameters_dir=data/sf10/read_params
ldbc.finbench.transaction.queries.updates_dir=data/sf10/incremental
ldbc.finbench.transaction.queries.parameters_dir=data/finbench-sf10/read_params
ldbc.finbench.transaction.queries.updates_dir=data/finbench-sf10/incremental
# param and update files suffix, `csv` or `parquet`, default is `csv`
ldbc.finbench.transaction.queries.files_suffix=csv
ldbc.finbench.transaction.queries.simple_read_dissipation=0.2
Expand Down
2 changes: 1 addition & 1 deletion gpstore/queries/transaction-complex-read-1.cypher
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,3 +1,3 @@
CALL tcr1($id, $startTime, $endTime, $truncationLimit, $truncationOrder)
CALL plugin.tcr1($id, $startTime, $endTime, $truncationLimit, $truncationOrder)
YIELD otherId, accountDistance, mediumId, mediumType
RETURN otherId, accountDistance, mediumId, mediumType
2 changes: 1 addition & 1 deletion gpstore/queries/transaction-complex-read-10.cypher
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,3 +1,3 @@
CALL tcr10($pid1, $pid2, $startTime, $endTime)
CALL plugin.tcr10($pid1, $pid2, $startTime, $endTime)
YIELD jaccardSimilarity
RETURN jaccardSimilarity
2 changes: 1 addition & 1 deletion gpstore/queries/transaction-complex-read-11.cypher
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,3 +1,3 @@
CALL tcr11($id, $startTime, $endTime, $truncationLimit, $truncationOrder)
CALL plugin.tcr11($id, $startTime, $endTime, $truncationLimit, $truncationOrder)
YIELD sumLoanAmount, numLoans
RETURN sumLoanAmount, numLoans
2 changes: 1 addition & 1 deletion gpstore/queries/transaction-complex-read-12.cypher
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,3 +1,3 @@
CALL tcr12($id, $startTime, $endTime, $truncationLimit, $truncationOrder)
CALL plugin.tcr12($id, $startTime, $endTime, $truncationLimit, $truncationOrder)
YIELD compAccountId, sumEdge2Amount
RETURN compAccountId, sumEdge2Amount
2 changes: 1 addition & 1 deletion gpstore/queries/transaction-complex-read-2.cypher
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,3 +1,3 @@
CALL tcr2($id, $startTime, $endTime, $truncationLimit, $truncationOrder)
CALL plugin.tcr2($id, $startTime, $endTime, $truncationLimit, $truncationOrder)
YIELD otherId, sumLoanAmount, sumLoanBalance
RETURN otherId, sumLoanAmount, sumLoanBalance
2 changes: 1 addition & 1 deletion gpstore/queries/transaction-complex-read-3.cypher
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,3 +1,3 @@
CALL tcr3($id1, $id2, $startTime, $endTime)
CALL plugin.tcr3($id1, $id2, $startTime, $endTime)
YIELD shortestPathLength
RETURN shortestPathLength
2 changes: 1 addition & 1 deletion gpstore/queries/transaction-complex-read-4.cypher
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,3 +1,3 @@
CALL tcr4($id1, $id2, $startTime, $endTime)
CALL plugin.tcr4($id1, $id2, $startTime, $endTime)
YIELD otherId, numEdge2, sumEdge2Amount, maxEdge2Amount, numEdge3, sumEdge3Amount, maxEdge3Amount
RETURN otherId, numEdge2, sumEdge2Amount, maxEdge2Amount, numEdge3, sumEdge3Amount, maxEdge3Amount
2 changes: 1 addition & 1 deletion gpstore/queries/transaction-complex-read-5.cypher
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,3 +1,3 @@
CALL tcr5($id, $startTime, $endTime, $truncationLimit, $truncationOrder)
CALL plugin.tcr5($id, $startTime, $endTime, $truncationLimit, $truncationOrder)
YIELD path
RETURN path
2 changes: 1 addition & 1 deletion gpstore/queries/transaction-complex-read-6.cypher
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,3 +1,3 @@
CALL tcr6($id, $threshold1, $threshold2, $startTime, $endTime, $truncationLimit, $truncationOrder)
CALL plugin.tcr6($id, $threshold1, $threshold2, $startTime, $endTime, $truncationLimit, $truncationOrder)
YIELD midId, sumEdge1Amount, sumEdge2Amount
RETURN midId, sumEdge1Amount, sumEdge2Amount
2 changes: 1 addition & 1 deletion gpstore/queries/transaction-complex-read-7.cypher
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,3 +1,3 @@
CALL tcr7($id, $threshold, $startTime, $endTime, $truncationLimit, $truncationOrder)
CALL plugin.tcr7($id, $threshold, $startTime, $endTime, $truncationLimit, $truncationOrder)
YIELD numSrc, numDst, inOutRatio
RETURN numSrc, numDst, inOutRatio
2 changes: 1 addition & 1 deletion gpstore/queries/transaction-complex-read-8.cypher
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,3 +1,3 @@
CALL tcr8($id, $threshold, $startTime, $endTime, $truncationLimit, $truncationOrder)
CALL plugin.tcr8($id, $threshold, $startTime, $endTime, $truncationLimit, $truncationOrder)
YIELD dstId, ratio, minDistanceFromLoan
RETURN dstId, ratio, minDistanceFromLoan
2 changes: 1 addition & 1 deletion gpstore/queries/transaction-complex-read-9.cypher
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,3 +1,3 @@
CALL tcr9($id, $threshold, $startTime, $endTime, $truncationLimit, $truncationOrder)
CALL plugin.tcr9($id, $threshold, $startTime, $endTime, $truncationLimit, $truncationOrder)
YIELD ratioRepay, ratioDeposit, ratioTransfer
RETURN ratioRepay, ratioDeposit, ratioTransfer
2 changes: 1 addition & 1 deletion gpstore/queries/transaction-read-write-1.cypher
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1 +1 @@
CALL trw1($srcId, $dstId, $time, $amount, $startTime, $endTime)
CALL plugin.trw1($srcId, $dstId, $time, $amount, $startTime, $endTime)
2 changes: 1 addition & 1 deletion gpstore/queries/transaction-read-write-2.cypher
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1 +1 @@
CALL trw2($srcId, $dstId, $time, $amount, $amountThreshold, $startTime, $endTime, $ratioThreshold, $truncationLimit, $truncationOrder)
CALL plugin.trw2($srcId, $dstId, $time, $amount, $amountThreshold, $startTime, $endTime, $ratioThreshold, $truncationLimit, $truncationOrder)
2 changes: 1 addition & 1 deletion gpstore/queries/transaction-read-write-3.cypher
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1 +1 @@
CALL trw3($srcId, $dstId, $time, $threshold, $startTime, $endTime, $truncationLimit, $truncationOrder)
CALL plugin.trw3($srcId, $dstId, $time, $threshold, $startTime, $endTime, $truncationLimit, $truncationOrder)
2 changes: 1 addition & 1 deletion gpstore/queries/transaction-simple-read-1.cypher
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,3 +1,3 @@
CALL tsr1($id)
CALL plugin.tsr1($id)
YIELD createTime, isBlocked, type
RETURN createTime, isBlocked, type
2 changes: 1 addition & 1 deletion gpstore/queries/transaction-simple-read-2.cypher
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,3 +1,3 @@
CALL tsr2($id, $startTime, $endTime)
CALL plugin.tsr2($id, $startTime, $endTime)
YIELD sumEdge1Amount, maxEdge1Amount, numEdge1, sumEdge2Amount, maxEdge2Amount, numEdge2
RETURN sumEdge1Amount, maxEdge1Amount, numEdge1, sumEdge2Amount, maxEdge2Amount, numEdge2
2 changes: 1 addition & 1 deletion gpstore/queries/transaction-simple-read-3.cypher
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,3 +1,3 @@
CALL tsr3($id, $threshold, $startTime, $endTime)
CALL plugin.tsr3($id, $threshold, $startTime, $endTime)
YIELD blockRatio
RETURN blockRatio
2 changes: 1 addition & 1 deletion gpstore/queries/transaction-simple-read-4.cypher
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,3 +1,3 @@
CALL tsr4($id, $threshold, $startTime, $endTime)
CALL plugin.tsr4($id, $threshold, $startTime, $endTime)
YIELD dstId, numEdges, sumAmount
RETURN dstId, numEdges, sumAmount
2 changes: 1 addition & 1 deletion gpstore/queries/transaction-simple-read-5.cypher
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,3 +1,3 @@
CALL tsr5($id, $threshold, $startTime, $endTime)
CALL plugin.tsr5($id, $threshold, $startTime, $endTime)
YIELD srcId, numEdges, sumAmount
RETURN srcId, numEdges, sumAmount
2 changes: 1 addition & 1 deletion gpstore/queries/transaction-simple-read-6.cypher
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,3 +1,3 @@
CALL tsr6($id, $startTime, $endTime)
CALL plugin.tsr6($id, $startTime, $endTime)
YIELD dstId
RETURN dstId
2 changes: 1 addition & 1 deletion gpstore/queries/transaction-write-1.cypher
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1 +1 @@
CALL tw1($personId, $personName, $isBlocked)
CALL plugin.tw1($personId, $personName, $isBlocked)
2 changes: 1 addition & 1 deletion gpstore/queries/transaction-write-10.cypher
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1 +1 @@
CALL tw10($personId1, $personId2, $time)
CALL plugin.tw10($personId1, $personId2, $time)
2 changes: 1 addition & 1 deletion gpstore/queries/transaction-write-11.cypher
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1 +1 @@
CALL tw11($companyId1, $companyId2, $time)
CALL plugin.tw11($companyId1, $companyId2, $time)
2 changes: 1 addition & 1 deletion gpstore/queries/transaction-write-12.cypher
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1 +1 @@
CALL tw12($accountId1, $accountId2, $time, $amount)
CALL plugin.tw12($accountId1, $accountId2, $time, $amount)
2 changes: 1 addition & 1 deletion gpstore/queries/transaction-write-13.cypher
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1 +1 @@
CALL tw13($accountId1, $accountId2, $time, $amount)
CALL plugin.tw13($accountId1, $accountId2, $time, $amount)
2 changes: 1 addition & 1 deletion gpstore/queries/transaction-write-14.cypher
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1 +1 @@
CALL tw14($accountId, $loanId, $time, $amount)
CALL plugin.tw14($accountId, $loanId, $time, $amount)
2 changes: 1 addition & 1 deletion gpstore/queries/transaction-write-15.cypher
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1 +1 @@
CALL tw15($loanId, $accountId, $time, $amount)
CALL plugin.tw15($loanId, $accountId, $time, $amount)
2 changes: 1 addition & 1 deletion gpstore/queries/transaction-write-16.cypher
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1 +1 @@
CALL tw16($mediumId, $accountId, $time)
CALL plugin.tw16($mediumId, $accountId, $time)
2 changes: 1 addition & 1 deletion gpstore/queries/transaction-write-17.cypher
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1 +1 @@
CALL tw17($accountId)
CALL plugin.tw17($accountId)
2 changes: 1 addition & 1 deletion gpstore/queries/transaction-write-18.cypher
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1 +1 @@
CALL tw18($accountId)
CALL plugin.tw18($accountId)
2 changes: 1 addition & 1 deletion gpstore/queries/transaction-write-19.cypher
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1 +1 @@
CALL tw19($personId)
CALL plugin.tw19($personId)
2 changes: 1 addition & 1 deletion gpstore/queries/transaction-write-2.cypher
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1 +1 @@
CALL tw2($companyId, $companyName, $isBlocked)
CALL plugin.tw2($companyId, $companyName, $isBlocked)
2 changes: 1 addition & 1 deletion gpstore/queries/transaction-write-3.cypher
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1 +1 @@
CALL tw3($mediumId, $mediumType, $isBlocked)
CALL plugin.tw3($mediumId, $mediumType, $isBlocked)
2 changes: 1 addition & 1 deletion gpstore/queries/transaction-write-4.cypher
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1 +1 @@
CALL tw4($personId, $accountId, $time, $accountBlocked, $accountType)
CALL plugin.tw4($personId, $accountId, $time, $accountBlocked, $accountType)
2 changes: 1 addition & 1 deletion gpstore/queries/transaction-write-5.cypher
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1 +1 @@
CALL tw5($companyId, $accountId, $time, $accountBlocked, $accountType)
CALL plugin.tw5($companyId, $accountId, $time, $accountBlocked, $accountType)
2 changes: 1 addition & 1 deletion gpstore/queries/transaction-write-6.cypher
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1 +1 @@
CALL tw6($personId, $loanId, $loanAmount, $balance, $time)
CALL plugin.tw6($personId, $loanId, $loanAmount, $balance, $time)
2 changes: 1 addition & 1 deletion gpstore/queries/transaction-write-7.cypher
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1 +1 @@
CALL tw7($companyId, $loanId, $loanAmount, $balance, $time)
CALL plugin.tw7($companyId, $loanId, $loanAmount, $balance, $time)
2 changes: 1 addition & 1 deletion gpstore/queries/transaction-write-8.cypher
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1 +1 @@
CALL tw8($personId, $companyId, $time, $ratio)
CALL plugin.tw8($personId, $companyId, $time, $ratio)
2 changes: 1 addition & 1 deletion gpstore/queries/transaction-write-9.cypher
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1 +1 @@
CALL tw9($companyId1, $companyId2, $time, $ratio)
CALL plugin.tw9($companyId1, $companyId2, $time, $ratio)
4 changes: 2 additions & 2 deletions gpstore/validate_database.properties
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -29,8 +29,8 @@ validation_parameters_size=10000
validate_workload=true
validate_database=validation_params.csv
warmup=0
ldbc.finbench.transaction.queries.parameters_dir=data/sf10/read_params
ldbc.finbench.transaction.queries.updates_dir=data/sf10/incremental
ldbc.finbench.transaction.queries.parameters_dir=data/finbench-sf10/read_params
ldbc.finbench.transaction.queries.updates_dir=data/finbench-sf10/incremental
# param and update files suffix, `csv` or `parquet`, default is `csv`
ldbc.finbench.transaction.queries.files_suffix=csv
ldbc.finbench.transaction.queries.simple_read_dissipation=0.2
Expand Down
Loading