Skip to content

Commit 81dd8ff

Browse files
committed
cleanup
1 parent 3d02375 commit 81dd8ff

5 files changed

Lines changed: 9 additions & 11 deletions

File tree

backend/src/main/java/com/bakdata/conquery/models/datasets/concepts/MatchingStats.java

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -54,7 +54,6 @@ public synchronized CDateRange spanEvents() {
5454
}
5555

5656
public synchronized void putEntry(String source, Entry entry) {
57-
5857
entries.put(source, entry);
5958
span = null;
6059
numberOfEntities = -1L;
@@ -66,8 +65,6 @@ public synchronized void putEntry(String source, Entry entry) {
6665
@NoArgsConstructor
6766
@AllArgsConstructor
6867
public static class Entry {
69-
70-
7168
@JsonIgnore
7269
private final Set<String> foundEntities = new HashSet<>();
7370
private long numberOfEvents;

backend/src/main/java/com/bakdata/conquery/models/datasets/concepts/conditions/ColumnEqualCondition.java

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,6 @@
11
package com.bakdata.conquery.models.datasets.concepts.conditions;
22

3+
import static org.jooq.impl.DSL.*;
34
import static org.jooq.impl.DSL.field;
45
import static org.jooq.impl.SQLDataType.VARCHAR;
56

@@ -51,13 +52,13 @@ public boolean matches(String value, CalculatedValue<Map<String, Object>> rowMap
5152

5253
@Override
5354
public WhereCondition convertToSqlCondition(CTConditionContext context) {
54-
Field<String> field = (Field<String>) (Field<?>) field(DSL.name(column));
55+
Field<String> field = field(name(column), String.class);
5556
return new MultiSelectCondition(field, values.toArray(String[]::new), context.getFunctionProvider());
5657
}
5758

5859
@Override
5960
public Expression buildExpression(CTConditionContext context, ConceptElement<?> id) {
60-
return new Expression(id, Map.of(field(DSL.name(getColumn()), VARCHAR).as("%s_equal".formatted(column)), values.stream().map(DSL::val).collect(Collectors.toSet())));
61+
return new Expression(id, Map.of(field(name(getColumn()), VARCHAR).as("%s_equal".formatted(column)), values.stream().map(DSL::val).collect(Collectors.toSet())));
6162

6263
}
6364
}

backend/src/main/java/com/bakdata/conquery/models/datasets/concepts/conditions/IsEmptyCondition.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -36,12 +36,12 @@ public boolean matches(String value, CalculatedValue<Map<String, Object>> rowMap
3636

3737
@Override
3838
public WhereCondition convertToSqlCondition(CTConditionContext context) {
39-
Condition condition = DSL.field(DSL.name(column)).isNull();
39+
Condition condition = field(name(column)).isNull();
4040
return new ConditionWrappingWhereCondition(condition);
4141
}
4242

4343
@Override
4444
public Expression buildExpression(CTConditionContext context, ConceptElement<?> id) {
45-
return new Expression(id, Map.of(DSL.field(DSL.name(column), BOOLEAN).isNull().as("%s_is_empty".formatted(column)), Set.of(val(true))));
45+
return new Expression(id, Map.of(field(name(column), BOOLEAN).isNull().as("%s_is_empty".formatted(column)), Set.of(val(true))));
4646
}
4747
}

backend/src/main/java/com/bakdata/conquery/models/datasets/concepts/conditions/IsPresentCondition.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -34,12 +34,12 @@ public boolean matches(String value, CalculatedValue<Map<String, Object>> rowMap
3434

3535
@Override
3636
public WhereCondition convertToSqlCondition(CTConditionContext context) {
37-
Condition condition = DSL.field(DSL.name(column)).isNotNull();
37+
Condition condition = field(name(column)).isNotNull();
3838
return new ConditionWrappingWhereCondition(condition);
3939
}
4040

4141
@Override
4242
public Expression buildExpression(CTConditionContext context, ConceptElement<?> id) {
43-
return new Expression(id, Map.of(DSL.field(DSL.name(column)).isNull().as("%s_is_empty".formatted(column)), Set.of(val(false))));
43+
return new Expression(id, Map.of(field(name(column)).isNull().as("%s_is_empty".formatted(column)), Set.of(val(false))));
4444
}
4545
}

backend/src/main/java/com/bakdata/conquery/models/datasets/concepts/conditions/PrefixRangeCondition.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -57,9 +57,9 @@ public boolean matches(String value, CalculatedValue<Map<String, Object>> rowMap
5757

5858
@Override
5959
public WhereCondition convertToSqlCondition(CTConditionContext context) {
60-
Field<?> field = context.getConnectorColumn();
60+
Field<String> field = context.getConnectorColumn();
6161
String pattern = buildSqlRegexPattern(context.getFunctionProvider());
62-
Condition regexCondition = context.getFunctionProvider().likeRegex((Field<String>) field, pattern);
62+
Condition regexCondition = context.getFunctionProvider().likeRegex(field, pattern);
6363
return new ConditionWrappingWhereCondition(regexCondition);
6464
}
6565

0 commit comments

Comments
 (0)