-
Notifications
You must be signed in to change notification settings - Fork 12
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.
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
Feature/combine mapper filtersearch #2643
Conversation
backend/src/main/java/com/bakdata/conquery/apiv1/query/FilterConfig.java
Outdated
Show resolved
Hide resolved
backend/src/main/java/com/bakdata/conquery/models/datasets/concepts/Searchable.java
Show resolved
Hide resolved
...c/main/java/com/bakdata/conquery/models/datasets/concepts/filters/specific/SelectFilter.java
Show resolved
Hide resolved
backend/src/main/java/com/bakdata/conquery/models/index/AbstractIndexKey.java
Outdated
Show resolved
Hide resolved
backend/src/main/java/com/bakdata/conquery/models/index/FEValueIndex.java
Outdated
Show resolved
Hide resolved
backend/src/main/java/com/bakdata/conquery/models/index/FEValueIndex.java
Outdated
Show resolved
Hide resolved
backend/src/main/java/com/bakdata/conquery/models/index/IndexService.java
Show resolved
Hide resolved
backend/src/main/java/com/bakdata/conquery/models/index/IndexService.java
Outdated
Show resolved
Hide resolved
backend/src/main/java/com/bakdata/conquery/util/search/TrieSearch.java
Outdated
Show resolved
Hide resolved
backend/src/test/java/com/bakdata/conquery/integration/IntegrationTests.java
Show resolved
Hide resolved
# Conflicts: # backend/src/test/java/com/bakdata/conquery/integration/common/LoadingUtil.java
@@ -126,38 +125,28 @@ public void updateSearch() { | |||
for (Searchable searchable : collectedSearchables) { | |||
|
|||
service.submit(() -> { | |||
final Stream<FEValue> values = searchable.getSearchValues(getParserConfig(), storage); | |||
|
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Mir ist gestern aufgefallen, dass sich der Job nicht canceln lässt, kannst du das heir in einen separaten Job heben und dann eine cancel methode implementieren? Es reicht ein shutdownNow zu machen in der join-loop und dann zu exiten wenn der rest durchgelaufen ist (vlt auch ein clear?) das hätte mir gestern einiges an zeit gespart :D
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Der Kommentar ließ sich leider nicht weiter oben machen, ich meine für Zeile 92/93
// We inject the service as a non-final property so, jackson will never try to create a serializer for it (in contrast to constructor injection) | ||
@JsonIgnore | ||
@JacksonInject(useInput = OptBoolean.FALSE) | ||
@NonNull |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
NotNull oder NonNul?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
NonNull, auf einem Shard darf es null sein, es sollte aber nie explizit auf null gesetzt werden.
|
||
import java.util.Map; | ||
|
||
public interface Index<T extends IndexKey<? extends Index<T>>> { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
bisschen komisch, dass ein Index nur put hat?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Es hatte erst auch ein get, aber das brauchte ich letztendlich nicht
} | ||
} | ||
catch (IOException ioException) { | ||
log.warn("Failed to open {}", key.getCsv(), ioException); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
log.warn("Failed to open {}", key.getCsv(), ioException); | |
log.warn("Failed to open `{}`", key.getCsv(), ioException); |
Damit man sehen kann, ob es evtl Whitespace Error sind :)
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Ich benutze jetzt
String externalValueCleaned = CharMatcher.whitespace().trimAndCollapseFrom(externalValue, ' ');
final String externalValue = substitutor.replace(externalTemplate); | ||
|
||
// Clean up the substitution by removing repeated white spaces | ||
String externalValueCleaned = externalValue.replaceAll("\\s+", " "); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
kannst du das Regex schon woanders erzeugen? So wird das im HotLoop erzeugt
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Ich benutze jetzt
String externalValueCleaned = CharMatcher.whitespace().trimAndCollapseFrom(externalValue, ' ');
|
||
@Slf4j | ||
@Data | ||
public class FilterSearch { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Warum ist sie jetzt in query?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Nach api passt sie nicht so wirklich, nach dw müsste sie eigentlich in ein core
package
public class MatcherTest { | ||
@Test | ||
void test() { | ||
|
||
log.info("result {}", CharMatcher.whitespace().trimAndCollapseFrom("hekd dskf d dkfjdk", ' ')); | ||
} |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
💣
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
upps mache ich noch wieder raus
# Conflicts: # backend/src/test/resources/tests/endpoints/adminEndpointInfo.json # docs/Table JSONs.md
No description provided.