Skip to content
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

update query params and results according to spec #19

Merged
merged 9 commits into from
May 6, 2023
Merged

update query params and results according to spec #19

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
9 commits
Select commit Hold shift + click to select a range
bd4f2ac
add query for query mix
BingTong0 Mar 28, 2023
6948193
update CR13 variate type & add Path type & delete useless file
BingTong0 Apr 20, 2023
e844649
remove useless code
BingTong0 Apr 20, 2023
cf0b553
Merge branch 'main' into dev
BingTong0 Apr 23, 2023
27aa15e
Merge branch 'main' into dev
BingTong0 Apr 23, 2023
57cdf9a
update query params and results according to spec
BingTong0 May 5, 2023
b451c69
Merge branch 'main' into dev
BingTong0 May 5, 2023
5efc676
remove params lowerbound & upperbound of complex read 9
BingTong0 May 5, 2023
6e05509
update var name
BingTong0 May 6, 2023
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
2 changes: 0 additions & 2 deletions src/main/java/org/ldbcouncil/finbench/driver/Operation.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -11,7 +11,6 @@
import org.ldbcouncil.finbench.driver.workloads.transaction.queries.ComplexRead10;
import org.ldbcouncil.finbench.driver.workloads.transaction.queries.ComplexRead11;
import org.ldbcouncil.finbench.driver.workloads.transaction.queries.ComplexRead12;
import org.ldbcouncil.finbench.driver.workloads.transaction.queries.ComplexRead13;
import org.ldbcouncil.finbench.driver.workloads.transaction.queries.ComplexRead2;
import org.ldbcouncil.finbench.driver.workloads.transaction.queries.ComplexRead3;
import org.ldbcouncil.finbench.driver.workloads.transaction.queries.ComplexRead4;
Expand Down Expand Up @@ -41,7 +40,6 @@
@JsonSubTypes.Type(ComplexRead10.class),
@JsonSubTypes.Type(ComplexRead11.class),
@JsonSubTypes.Type(ComplexRead12.class),
@JsonSubTypes.Type(ComplexRead13.class),
})
public abstract class Operation<RESULT_TYPE> {
private static final TemporalUtil temporalutil = new TemporalUtil();
Expand Down
223 changes: 29 additions & 194 deletions ...org/ldbcouncil/finbench/driver/workloads/transaction/LdbcFinBenchSimpleReadGenerator.java
View file
Open in desktop

Large diffs are not rendered by default.

4 changes: 0 additions & 4 deletions ...org/ldbcouncil/finbench/driver/workloads/transaction/LdbcFinBenchTransactionWorkload.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -47,7 +47,6 @@
import org.ldbcouncil.finbench.driver.workloads.transaction.queries.ComplexRead10;
import org.ldbcouncil.finbench.driver.workloads.transaction.queries.ComplexRead11;
import org.ldbcouncil.finbench.driver.workloads.transaction.queries.ComplexRead12;
import org.ldbcouncil.finbench.driver.workloads.transaction.queries.ComplexRead13;
import org.ldbcouncil.finbench.driver.workloads.transaction.queries.ComplexRead2;
import org.ldbcouncil.finbench.driver.workloads.transaction.queries.ComplexRead3;
import org.ldbcouncil.finbench.driver.workloads.transaction.queries.ComplexRead4;
Expand Down Expand Up @@ -291,9 +290,6 @@ public void onInit(Map<String, String> params) throws WorkloadException {
longReadInterleavesAsMilli.put(ComplexRead12.TYPE, Long.parseLong(
params.get(LdbcFinBenchTransactionWorkloadConfiguration.COMPLEX_READ_OPERATION_12_INTERLEAVE_KEY)
.trim()));
longReadInterleavesAsMilli.put(ComplexRead13.TYPE, Long.parseLong(
params.get(LdbcFinBenchTransactionWorkloadConfiguration.COMPLEX_READ_OPERATION_13_INTERLEAVE_KEY)
.trim()));

} catch (NumberFormatException e) {
throw new WorkloadException("Unable to parse one of the read operation interleave values", e);
Expand Down
48 changes: 6 additions & 42 deletions ...l/finbench/driver/workloads/transaction/LdbcFinBenchTransactionWorkloadConfiguration.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -24,7 +24,6 @@
import org.ldbcouncil.finbench.driver.workloads.transaction.queries.ComplexRead10;
import org.ldbcouncil.finbench.driver.workloads.transaction.queries.ComplexRead11;
import org.ldbcouncil.finbench.driver.workloads.transaction.queries.ComplexRead12;
import org.ldbcouncil.finbench.driver.workloads.transaction.queries.ComplexRead13;
import org.ldbcouncil.finbench.driver.workloads.transaction.queries.ComplexRead2;
import org.ldbcouncil.finbench.driver.workloads.transaction.queries.ComplexRead3;
import org.ldbcouncil.finbench.driver.workloads.transaction.queries.ComplexRead4;
Expand All @@ -42,15 +41,11 @@
import org.ldbcouncil.finbench.driver.workloads.transaction.queries.SimpleRead4;
import org.ldbcouncil.finbench.driver.workloads.transaction.queries.SimpleRead5;
import org.ldbcouncil.finbench.driver.workloads.transaction.queries.SimpleRead6;
import org.ldbcouncil.finbench.driver.workloads.transaction.queries.SimpleRead7;
import org.ldbcouncil.finbench.driver.workloads.transaction.queries.SimpleRead8;
import org.ldbcouncil.finbench.driver.workloads.transaction.queries.Write1;
import org.ldbcouncil.finbench.driver.workloads.transaction.queries.Write10;
import org.ldbcouncil.finbench.driver.workloads.transaction.queries.Write11;
import org.ldbcouncil.finbench.driver.workloads.transaction.queries.Write12;
import org.ldbcouncil.finbench.driver.workloads.transaction.queries.Write13;
import org.ldbcouncil.finbench.driver.workloads.transaction.queries.Write14;
import org.ldbcouncil.finbench.driver.workloads.transaction.queries.Write15;
import org.ldbcouncil.finbench.driver.workloads.transaction.queries.Write2;
import org.ldbcouncil.finbench.driver.workloads.transaction.queries.Write3;
import org.ldbcouncil.finbench.driver.workloads.transaction.queries.Write4;
Expand Down Expand Up @@ -122,8 +117,6 @@ public abstract class LdbcFinBenchTransactionWorkloadConfiguration {
LDBC_FINBENCH_TRANSACTION_PARAM_NAME_PREFIX + ComplexRead11.class.getSimpleName() + INTERLEAVE_SUFFIX;
public static final String COMPLEX_READ_OPERATION_12_INTERLEAVE_KEY =
LDBC_FINBENCH_TRANSACTION_PARAM_NAME_PREFIX + ComplexRead12.class.getSimpleName() + INTERLEAVE_SUFFIX;
public static final String COMPLEX_READ_OPERATION_13_INTERLEAVE_KEY =
LDBC_FINBENCH_TRANSACTION_PARAM_NAME_PREFIX + ComplexRead13.class.getSimpleName() + INTERLEAVE_SUFFIX;
public static final List<String> COMPLEX_READ_OPERATION_INTERLEAVE_KEYS = Lists.newArrayList(
COMPLEX_READ_OPERATION_1_INTERLEAVE_KEY,
COMPLEX_READ_OPERATION_2_INTERLEAVE_KEY,
Expand All @@ -136,8 +129,7 @@ public abstract class LdbcFinBenchTransactionWorkloadConfiguration {
COMPLEX_READ_OPERATION_9_INTERLEAVE_KEY,
COMPLEX_READ_OPERATION_10_INTERLEAVE_KEY,
COMPLEX_READ_OPERATION_11_INTERLEAVE_KEY,
COMPLEX_READ_OPERATION_12_INTERLEAVE_KEY,
COMPLEX_READ_OPERATION_13_INTERLEAVE_KEY);
COMPLEX_READ_OPERATION_12_INTERLEAVE_KEY);
public static final Map<Integer, String> OPERATION_TYPE_TO_INTERLEAVE_KEY_MAPPING = typeToInterleaveKeyMapping();
/*
* Operation frequency
Expand Down Expand Up @@ -167,8 +159,6 @@ public abstract class LdbcFinBenchTransactionWorkloadConfiguration {
LDBC_FINBENCH_TRANSACTION_PARAM_NAME_PREFIX + ComplexRead11.class.getSimpleName() + FREQUENCY_SUFFIX;
public static final String COMPLEX_READ_OPERATION_12_FREQUENCY_KEY =
LDBC_FINBENCH_TRANSACTION_PARAM_NAME_PREFIX + ComplexRead12.class.getSimpleName() + FREQUENCY_SUFFIX;
public static final String COMPLEX_READ_OPERATION_13_FREQUENCY_KEY =
LDBC_FINBENCH_TRANSACTION_PARAM_NAME_PREFIX + ComplexRead13.class.getSimpleName() + FREQUENCY_SUFFIX;
public static final List<String> COMPLEX_READ_OPERATION_FREQUENCY_KEYS = Lists.newArrayList(
COMPLEX_READ_OPERATION_1_FREQUENCY_KEY,
COMPLEX_READ_OPERATION_2_FREQUENCY_KEY,
Expand All @@ -181,8 +171,7 @@ public abstract class LdbcFinBenchTransactionWorkloadConfiguration {
COMPLEX_READ_OPERATION_9_FREQUENCY_KEY,
COMPLEX_READ_OPERATION_10_FREQUENCY_KEY,
COMPLEX_READ_OPERATION_11_FREQUENCY_KEY,
COMPLEX_READ_OPERATION_12_FREQUENCY_KEY,
COMPLEX_READ_OPERATION_13_FREQUENCY_KEY
COMPLEX_READ_OPERATION_12_FREQUENCY_KEY
);
// Default value in case there is no update stream
public static final String DEFAULT_UPDATE_INTERLEAVE = "1";
Expand All @@ -202,7 +191,6 @@ public abstract class LdbcFinBenchTransactionWorkloadConfiguration {
public static final String COMPLEX_READ_OPERATION_10_ENABLE_KEY = asEnableKey(ComplexRead10.class);
public static final String COMPLEX_READ_OPERATION_11_ENABLE_KEY = asEnableKey(ComplexRead11.class);
public static final String COMPLEX_READ_OPERATION_12_ENABLE_KEY = asEnableKey(ComplexRead12.class);
public static final String COMPLEX_READ_OPERATION_13_ENABLE_KEY = asEnableKey(ComplexRead13.class);
public static final List<String> COMPLEX_READ_OPERATION_ENABLE_KEYS = Lists.newArrayList(
COMPLEX_READ_OPERATION_1_ENABLE_KEY,
COMPLEX_READ_OPERATION_2_ENABLE_KEY,
Expand All @@ -215,26 +203,21 @@ public abstract class LdbcFinBenchTransactionWorkloadConfiguration {
COMPLEX_READ_OPERATION_9_ENABLE_KEY,
COMPLEX_READ_OPERATION_10_ENABLE_KEY,
COMPLEX_READ_OPERATION_11_ENABLE_KEY,
COMPLEX_READ_OPERATION_12_ENABLE_KEY,
COMPLEX_READ_OPERATION_13_ENABLE_KEY
COMPLEX_READ_OPERATION_12_ENABLE_KEY
);
public static final String SIMPLE_READ_OPERATION_1_ENABLE_KEY = asEnableKey(SimpleRead1.class);
public static final String SIMPLE_READ_OPERATION_2_ENABLE_KEY = asEnableKey(SimpleRead2.class);
public static final String SIMPLE_READ_OPERATION_3_ENABLE_KEY = asEnableKey(SimpleRead3.class);
public static final String SIMPLE_READ_OPERATION_4_ENABLE_KEY = asEnableKey(SimpleRead4.class);
public static final String SIMPLE_READ_OPERATION_5_ENABLE_KEY = asEnableKey(SimpleRead5.class);
public static final String SIMPLE_READ_OPERATION_6_ENABLE_KEY = asEnableKey(SimpleRead6.class);
public static final String SIMPLE_READ_OPERATION_7_ENABLE_KEY = asEnableKey(SimpleRead7.class);
public static final String SIMPLE_READ_OPERATION_8_ENABLE_KEY = asEnableKey(SimpleRead8.class);
public static final List<String> SIMPLE_READ_OPERATION_ENABLE_KEYS = Lists.newArrayList(
SIMPLE_READ_OPERATION_1_ENABLE_KEY,
SIMPLE_READ_OPERATION_2_ENABLE_KEY,
SIMPLE_READ_OPERATION_3_ENABLE_KEY,
SIMPLE_READ_OPERATION_4_ENABLE_KEY,
SIMPLE_READ_OPERATION_5_ENABLE_KEY,
SIMPLE_READ_OPERATION_6_ENABLE_KEY,
SIMPLE_READ_OPERATION_7_ENABLE_KEY,
SIMPLE_READ_OPERATION_8_ENABLE_KEY
SIMPLE_READ_OPERATION_6_ENABLE_KEY
);
public static final String WRITE_OPERATION_1_ENABLE_KEY = asEnableKey(Write1.class);
public static final String WRITE_OPERATION_2_ENABLE_KEY = asEnableKey(Write2.class);
Expand All @@ -249,7 +232,6 @@ public abstract class LdbcFinBenchTransactionWorkloadConfiguration {
public static final String WRITE_OPERATION_11_ENABLE_KEY = asEnableKey(Write11.class);
public static final String WRITE_OPERATION_12_ENABLE_KEY = asEnableKey(Write12.class);
public static final String WRITE_OPERATION_13_ENABLE_KEY = asEnableKey(Write13.class);
public static final String WRITE_OPERATION_14_ENABLE_KEY = asEnableKey(Write14.class);
public static final List<String> WRITE_OPERATION_ENABLE_KEYS = Lists.newArrayList(
WRITE_OPERATION_1_ENABLE_KEY,
WRITE_OPERATION_2_ENABLE_KEY,
Expand All @@ -263,8 +245,7 @@ public abstract class LdbcFinBenchTransactionWorkloadConfiguration {
WRITE_OPERATION_10_ENABLE_KEY,
WRITE_OPERATION_11_ENABLE_KEY,
WRITE_OPERATION_12_ENABLE_KEY,
WRITE_OPERATION_13_ENABLE_KEY,
WRITE_OPERATION_14_ENABLE_KEY
WRITE_OPERATION_13_ENABLE_KEY
);
/*
* Read Operation Parameters
Expand Down Expand Up @@ -303,7 +284,6 @@ private static Map<Integer, String> typeToOperationParameterFilename() {
mapping.put(ComplexRead10.TYPE, COMPLEX_READ_OPERATION_10_PARAMS_FILENAME);
mapping.put(ComplexRead11.TYPE, COMPLEX_READ_OPERATION_11_PARAMS_FILENAME);
mapping.put(ComplexRead12.TYPE, COMPLEX_READ_OPERATION_12_PARAMS_FILENAME);
mapping.put(ComplexRead13.TYPE, COMPLEX_READ_OPERATION_13_PARAMS_FILENAME);
return mapping;
}

Expand All @@ -321,7 +301,6 @@ private static Map<Integer, String> typeToInterleaveKeyMapping() {
mapping.put(ComplexRead10.TYPE, COMPLEX_READ_OPERATION_10_INTERLEAVE_KEY);
mapping.put(ComplexRead11.TYPE, COMPLEX_READ_OPERATION_11_INTERLEAVE_KEY);
mapping.put(ComplexRead12.TYPE, COMPLEX_READ_OPERATION_12_INTERLEAVE_KEY);
mapping.put(ComplexRead13.TYPE, COMPLEX_READ_OPERATION_13_INTERLEAVE_KEY);
return mapping;
}

Expand Down Expand Up @@ -368,9 +347,6 @@ public static Map<String, String> convertFrequenciesToInterleaves(Map<String, St
interleave = Integer.parseInt(params.get(COMPLEX_READ_OPERATION_12_FREQUENCY_KEY)) * updateDistance;
params.put(COMPLEX_READ_OPERATION_12_INTERLEAVE_KEY, interleave.toString());

interleave = Integer.parseInt(params.get(COMPLEX_READ_OPERATION_13_FREQUENCY_KEY)) * updateDistance;
params.put(COMPLEX_READ_OPERATION_13_INTERLEAVE_KEY, interleave.toString());

return params;
}

Expand Down Expand Up @@ -423,8 +399,7 @@ public static boolean hasReads(Map<String, String> params) {
COMPLEX_READ_OPERATION_9_ENABLE_KEY,
COMPLEX_READ_OPERATION_10_ENABLE_KEY,
COMPLEX_READ_OPERATION_11_ENABLE_KEY,
COMPLEX_READ_OPERATION_12_ENABLE_KEY,
COMPLEX_READ_OPERATION_13_ENABLE_KEY).stream().anyMatch(key -> isSet(params, key));
COMPLEX_READ_OPERATION_12_ENABLE_KEY).stream().anyMatch(key -> isSet(params, key));
}

public static boolean hasWrites(Map<String, String> params) {
Expand Down Expand Up @@ -452,7 +427,6 @@ public static Map<String, String> withoutSimpleReads(Map<String, String> origina
params.put(SIMPLE_READ_OPERATION_4_ENABLE_KEY, "false");
params.put(SIMPLE_READ_OPERATION_5_ENABLE_KEY, "false");
params.put(SIMPLE_READ_OPERATION_6_ENABLE_KEY, "false");
params.put(SIMPLE_READ_OPERATION_7_ENABLE_KEY, "false");
return ConsoleAndFileDriverConfiguration.convertComplexKeysToSimpleKeys(params);
}

Expand Down Expand Up @@ -485,14 +459,12 @@ public static Map<String, String> withoutLongReads(Map<String, String> originalP
params.put(COMPLEX_READ_OPERATION_10_ENABLE_KEY, "false");
params.put(COMPLEX_READ_OPERATION_11_ENABLE_KEY, "false");
params.put(COMPLEX_READ_OPERATION_12_ENABLE_KEY, "false");
params.put(COMPLEX_READ_OPERATION_13_ENABLE_KEY, "false");
params.put(SIMPLE_READ_OPERATION_1_ENABLE_KEY, "false");
params.put(SIMPLE_READ_OPERATION_2_ENABLE_KEY, "false");
params.put(SIMPLE_READ_OPERATION_3_ENABLE_KEY, "false");
params.put(SIMPLE_READ_OPERATION_4_ENABLE_KEY, "false");
params.put(SIMPLE_READ_OPERATION_5_ENABLE_KEY, "false");
params.put(SIMPLE_READ_OPERATION_6_ENABLE_KEY, "false");
params.put(SIMPLE_READ_OPERATION_7_ENABLE_KEY, "false");
return ConsoleAndFileDriverConfiguration.convertComplexKeysToSimpleKeys(params);
}

Expand All @@ -510,15 +482,12 @@ public static Map<Integer, Class<? extends Operation>> operationTypeToClassMappi
operationTypeToClassMapping.put(ComplexRead10.TYPE, ComplexRead10.class);
operationTypeToClassMapping.put(ComplexRead11.TYPE, ComplexRead11.class);
operationTypeToClassMapping.put(ComplexRead12.TYPE, ComplexRead12.class);
operationTypeToClassMapping.put(ComplexRead13.TYPE, ComplexRead13.class);
operationTypeToClassMapping.put(SimpleRead1.TYPE, SimpleRead1.class);
operationTypeToClassMapping.put(SimpleRead2.TYPE, SimpleRead2.class);
operationTypeToClassMapping.put(SimpleRead3.TYPE, SimpleRead3.class);
operationTypeToClassMapping.put(SimpleRead4.TYPE, SimpleRead4.class);
operationTypeToClassMapping.put(SimpleRead5.TYPE, SimpleRead5.class);
operationTypeToClassMapping.put(SimpleRead6.TYPE, SimpleRead6.class);
operationTypeToClassMapping.put(SimpleRead7.TYPE, SimpleRead7.class);
operationTypeToClassMapping.put(SimpleRead8.TYPE, SimpleRead8.class);
operationTypeToClassMapping.put(Write1.TYPE, Write1.class);
operationTypeToClassMapping.put(Write2.TYPE, Write2.class);
operationTypeToClassMapping.put(Write3.TYPE, Write3.class);
Expand All @@ -532,7 +501,6 @@ public static Map<Integer, Class<? extends Operation>> operationTypeToClassMappi
operationTypeToClassMapping.put(Write11.TYPE, Write11.class);
operationTypeToClassMapping.put(Write12.TYPE, Write12.class);
operationTypeToClassMapping.put(Write13.TYPE, Write13.class);
operationTypeToClassMapping.put(Write14.TYPE, Write14.class);
return operationTypeToClassMapping;
}

Expand Down Expand Up @@ -593,8 +561,6 @@ public static Map<Class<? extends Operation>, String> getUpdateStreamClassToPath
classToFileNameMapping.put(Write11.class, INSERTS_DIRECTORY + "/Person.parquet");
classToFileNameMapping.put(Write12.class, INSERTS_DIRECTORY + "/Person.parquet");
classToFileNameMapping.put(Write13.class, INSERTS_DIRECTORY + "/Person.parquet");
classToFileNameMapping.put(Write14.class, INSERTS_DIRECTORY + "/Person.parquet");
classToFileNameMapping.put(Write15.class, INSERTS_DIRECTORY + "/Person.parquet");
classToFileNameMapping.put(ReadWrite1.class, INSERTS_DIRECTORY + "/Person.parquet");
classToFileNameMapping.put(ReadWrite2.class, INSERTS_DIRECTORY + "/Person.parquet");
classToFileNameMapping.put(ReadWrite3.class, INSERTS_DIRECTORY + "/Person.parquet");
Expand All @@ -619,8 +585,6 @@ public static Map<Class<? extends Operation>, String> getUpdateStreamClassToDate
classToDateColumnNameMapping.put(Write11.class, INSERTS_DATE_COLUMN);
classToDateColumnNameMapping.put(Write12.class, INSERTS_DATE_COLUMN);
classToDateColumnNameMapping.put(Write13.class, INSERTS_DATE_COLUMN);
classToDateColumnNameMapping.put(Write14.class, INSERTS_DATE_COLUMN);
classToDateColumnNameMapping.put(Write15.class, INSERTS_DATE_COLUMN);
classToDateColumnNameMapping.put(ReadWrite1.class, INSERTS_DATE_COLUMN);
classToDateColumnNameMapping.put(ReadWrite2.class, INSERTS_DATE_COLUMN);
classToDateColumnNameMapping.put(ReadWrite3.class, INSERTS_DATE_COLUMN);
Expand Down
10 changes: 0 additions & 10 deletions src/main/java/org/ldbcouncil/finbench/driver/workloads/transaction/LdbcOperation.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -10,7 +10,6 @@
import org.ldbcouncil.finbench.driver.workloads.transaction.queries.ComplexRead10;
import org.ldbcouncil.finbench.driver.workloads.transaction.queries.ComplexRead11;
import org.ldbcouncil.finbench.driver.workloads.transaction.queries.ComplexRead12;
import org.ldbcouncil.finbench.driver.workloads.transaction.queries.ComplexRead13;
import org.ldbcouncil.finbench.driver.workloads.transaction.queries.ComplexRead2;
import org.ldbcouncil.finbench.driver.workloads.transaction.queries.ComplexRead3;
import org.ldbcouncil.finbench.driver.workloads.transaction.queries.ComplexRead4;
Expand All @@ -28,15 +27,11 @@
import org.ldbcouncil.finbench.driver.workloads.transaction.queries.SimpleRead4;
import org.ldbcouncil.finbench.driver.workloads.transaction.queries.SimpleRead5;
import org.ldbcouncil.finbench.driver.workloads.transaction.queries.SimpleRead6;
import org.ldbcouncil.finbench.driver.workloads.transaction.queries.SimpleRead7;
import org.ldbcouncil.finbench.driver.workloads.transaction.queries.SimpleRead8;
import org.ldbcouncil.finbench.driver.workloads.transaction.queries.Write1;
import org.ldbcouncil.finbench.driver.workloads.transaction.queries.Write10;
import org.ldbcouncil.finbench.driver.workloads.transaction.queries.Write11;
import org.ldbcouncil.finbench.driver.workloads.transaction.queries.Write12;
import org.ldbcouncil.finbench.driver.workloads.transaction.queries.Write13;
import org.ldbcouncil.finbench.driver.workloads.transaction.queries.Write14;
import org.ldbcouncil.finbench.driver.workloads.transaction.queries.Write15;
import org.ldbcouncil.finbench.driver.workloads.transaction.queries.Write2;
import org.ldbcouncil.finbench.driver.workloads.transaction.queries.Write3;
import org.ldbcouncil.finbench.driver.workloads.transaction.queries.Write4;
Expand Down Expand Up @@ -66,15 +61,12 @@
@JsonSubTypes.Type(ComplexRead10.class),
@JsonSubTypes.Type(ComplexRead11.class),
@JsonSubTypes.Type(ComplexRead12.class),
@JsonSubTypes.Type(ComplexRead13.class),
@JsonSubTypes.Type(SimpleRead1.class),
@JsonSubTypes.Type(SimpleRead2.class),
@JsonSubTypes.Type(SimpleRead3.class),
@JsonSubTypes.Type(SimpleRead4.class),
@JsonSubTypes.Type(SimpleRead5.class),
@JsonSubTypes.Type(SimpleRead6.class),
@JsonSubTypes.Type(SimpleRead7.class),
@JsonSubTypes.Type(SimpleRead8.class),
@JsonSubTypes.Type(Write1.class),
@JsonSubTypes.Type(Write2.class),
@JsonSubTypes.Type(Write3.class),
Expand All @@ -88,8 +80,6 @@
@JsonSubTypes.Type(Write11.class),
@JsonSubTypes.Type(Write12.class),
@JsonSubTypes.Type(Write13.class),
@JsonSubTypes.Type(Write14.class),
@JsonSubTypes.Type(Write15.class),
@JsonSubTypes.Type(ReadWrite1.class),
@JsonSubTypes.Type(ReadWrite2.class),
@JsonSubTypes.Type(ReadWrite3.class)
Expand Down
Loading