Skip to content

Commit

Permalink
Add first implementation of clpMatch that doesn't explicitly use inde…
Browse files Browse the repository at this point in the history
…xes. (apache#12291)

* Rename CLPDecodeRewriter to ClpRewriter in preparation for adding CLP_MATCH function.

* Add version of clpMatch that doesn't rely on indexing.

* Rename CLP transform functions test file.

* Add unit tests for clpEncodedVarsMatch.

* Minor logging improvements for clpEncodedVarsMatch.

* Don't try to flatten filter expression for expression without filters.

* Add clpencodedvarsmatch to list of functions without a scalar counterpart.
  • Loading branch information
kirkrodrigues authored Jan 30, 2024
1 parent 1a82ba6 commit d501478
Show file tree
Hide file tree
Showing 13 changed files with 1,188 additions and 268 deletions.
2 changes: 1 addition & 1 deletion LICENSE-binary
Original file line number Diff line number Diff line change
Expand Up @@ -280,7 +280,7 @@ com.uber:h3:4.1.1
com.yahoo.datasketches:memory:0.8.3
com.yahoo.datasketches:sketches-core:0.8.3
com.yammer.metrics:metrics-core:2.2.0
com.yscope.clp:clp-ffi:0.4.3
com.yscope.clp:clp-ffi:0.4.4
com.zaxxer:HikariCP-java7:2.4.13
commons-beanutils:commons-beanutils:1.9.4
commons-cli:commons-cli:1.5.0
Expand Down
4 changes: 4 additions & 0 deletions pinot-common/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -397,6 +397,10 @@
<groupId>com.github.seancfoley</groupId>
<artifactId>ipaddress</artifactId>
</dependency>
<dependency>
<groupId>com.yscope.clp</groupId>
<artifactId>clp-ffi</artifactId>
</dependency>
<dependency>
<groupId>io.github.hakky54</groupId>
<artifactId>sslcontext-kickstart-for-netty</artifactId>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -207,6 +207,9 @@ public enum TransformFunctionType {
CLP_DECODE("clpDecode", ReturnTypes.VARCHAR_2000_NULLABLE, OperandTypes.family(
ImmutableList.of(SqlTypeFamily.ANY, SqlTypeFamily.ANY, SqlTypeFamily.ANY, SqlTypeFamily.CHARACTER),
ordinal -> ordinal > 2), "clp_decode"),
CLP_ENCODED_VARS_MATCH("clpEncodedVarsMatch", ReturnTypes.BOOLEAN_NOT_NULL, OperandTypes.family(
ImmutableList.of(SqlTypeFamily.ANY, SqlTypeFamily.ANY, SqlTypeFamily.CHARACTER),
ordinal -> ordinal > 2), "clp_encoded_vars_match"),

// Regexp functions
REGEXP_EXTRACT("regexpExtract", "regexp_extract"),
Expand Down

This file was deleted.

Loading

0 comments on commit d501478

Please sign in to comment.