Skip to content

feat(meos): converge the Kafka facade onto the unified JMEOS jar + post-#1137 trgeometry (stacks on #4) #5

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

Closed
estebanzimanyi wants to merge 1 commit into from
Closed

feat(meos): converge the Kafka facade onto the unified JMEOS jar + post-#1137 trgeometry (stacks on #4) #5

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
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
Binary file modified kafka-streams-app/jar/JMEOS.jar
View file
Open in desktop
Binary file not shown.
34 changes: 17 additions & 17 deletions kafka-streams-app/src/main/java/org/mobilitydb/kafka/meos/MeosOpsBigintSet.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -21,10 +21,10 @@ private MeosOpsBigintSet() { /* utility */ }
* <p>Object-model role: {@code constructor}.</p>
* <p>Classification: constructor of instant/scalar</p>
*/
public static Pointer bigintset_make(Pointer arg0, int arg1) {
public static jnr.ffi.Pointer bigintset_make(jnr.ffi.Pointer arg0, int arg1) {
if (!MEOS_AVAILABLE) {
throw new UnsupportedOperationException(
"bigintset_make requires libmeos — set -Dmobilityflink.meos.enabled=true");
"bigintset_make requires libmeos — set -Dmobilitykafka.meos.enabled=true");
}
return GeneratedFunctions.bigintset_make(arg0, arg1);
}
Expand All @@ -35,10 +35,10 @@ public static Pointer bigintset_make(Pointer arg0, int arg1) {
* <p>Object-model role: {@code accessor}.</p>
* <p>Classification: role=accessor</p>
*/
public static int bigintset_end_value(Pointer arg0) {
public static long bigintset_end_value(jnr.ffi.Pointer arg0) {
if (!MEOS_AVAILABLE) {
throw new UnsupportedOperationException(
"bigintset_end_value requires libmeos — set -Dmobilityflink.meos.enabled=true");
"bigintset_end_value requires libmeos — set -Dmobilitykafka.meos.enabled=true");
}
return GeneratedFunctions.bigintset_end_value(arg0);
}
Expand All @@ -49,10 +49,10 @@ public static int bigintset_end_value(Pointer arg0) {
* <p>Object-model role: {@code accessor}.</p>
* <p>Classification: role=accessor</p>
*/
public static Pointer bigintset_shift_scale(Pointer arg0, int arg1, int arg2, int arg3, int arg4) {
public static jnr.ffi.Pointer bigintset_shift_scale(jnr.ffi.Pointer arg0, long arg1, long arg2, boolean arg3, boolean arg4) {
if (!MEOS_AVAILABLE) {
throw new UnsupportedOperationException(
"bigintset_shift_scale requires libmeos — set -Dmobilityflink.meos.enabled=true");
"bigintset_shift_scale requires libmeos — set -Dmobilitykafka.meos.enabled=true");
}
return GeneratedFunctions.bigintset_shift_scale(arg0, arg1, arg2, arg3, arg4);
}
Expand All @@ -63,10 +63,10 @@ public static Pointer bigintset_shift_scale(Pointer arg0, int arg1, int arg2, in
* <p>Object-model role: {@code accessor}.</p>
* <p>Classification: role=accessor</p>
*/
public static int bigintset_start_value(Pointer arg0) {
public static long bigintset_start_value(jnr.ffi.Pointer arg0) {
if (!MEOS_AVAILABLE) {
throw new UnsupportedOperationException(
"bigintset_start_value requires libmeos — set -Dmobilityflink.meos.enabled=true");
"bigintset_start_value requires libmeos — set -Dmobilitykafka.meos.enabled=true");
}
return GeneratedFunctions.bigintset_start_value(arg0);
}
Expand All @@ -77,12 +77,12 @@ public static int bigintset_start_value(Pointer arg0) {
* <p>Object-model role: {@code accessor}.</p>
* <p>Classification: role=accessor</p>
*/
public static int bigintset_value_n(Pointer arg0, int arg1, Pointer arg2) {
public static jnr.ffi.Pointer bigintset_value_n(jnr.ffi.Pointer arg0, int arg1) {
if (!MEOS_AVAILABLE) {
throw new UnsupportedOperationException(
"bigintset_value_n requires libmeos — set -Dmobilityflink.meos.enabled=true");
"bigintset_value_n requires libmeos — set -Dmobilitykafka.meos.enabled=true");
}
return GeneratedFunctions.bigintset_value_n(arg0, arg1, arg2);
return GeneratedFunctions.bigintset_value_n(arg0, arg1);
}

/**
Expand All @@ -91,10 +91,10 @@ public static int bigintset_value_n(Pointer arg0, int arg1, Pointer arg2) {
* <p>Object-model role: {@code accessor}.</p>
* <p>Classification: role=accessor</p>
*/
public static Pointer bigintset_values(Pointer arg0) {
public static jnr.ffi.Pointer bigintset_values(jnr.ffi.Pointer arg0) {
if (!MEOS_AVAILABLE) {
throw new UnsupportedOperationException(
"bigintset_values requires libmeos — set -Dmobilityflink.meos.enabled=true");
"bigintset_values requires libmeos — set -Dmobilitykafka.meos.enabled=true");
}
return GeneratedFunctions.bigintset_values(arg0);
}
Expand All @@ -105,10 +105,10 @@ public static Pointer bigintset_values(Pointer arg0) {
* <p>Object-model role: {@code constructor}.</p>
* <p>Classification: IO/serialization</p>
*/
public static Pointer bigintset_in(String arg0) {
public static jnr.ffi.Pointer bigintset_in(java.lang.String arg0) {
if (!MEOS_AVAILABLE) {
throw new UnsupportedOperationException(
"bigintset_in requires libmeos — set -Dmobilityflink.meos.enabled=true");
"bigintset_in requires libmeos — set -Dmobilitykafka.meos.enabled=true");
}
return GeneratedFunctions.bigintset_in(arg0);
}
Expand All @@ -119,10 +119,10 @@ public static Pointer bigintset_in(String arg0) {
* <p>Object-model role: {@code output}.</p>
* <p>Classification: IO/serialization</p>
*/
public static String bigintset_out(Pointer arg0) {
public static java.lang.String bigintset_out(jnr.ffi.Pointer arg0) {
if (!MEOS_AVAILABLE) {
throw new UnsupportedOperationException(
"bigintset_out requires libmeos — set -Dmobilityflink.meos.enabled=true");
"bigintset_out requires libmeos — set -Dmobilitykafka.meos.enabled=true");
}
return GeneratedFunctions.bigintset_out(arg0);
}
Expand Down
36 changes: 18 additions & 18 deletions kafka-streams-app/src/main/java/org/mobilitydb/kafka/meos/MeosOpsBigintSpan.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -21,10 +21,10 @@ private MeosOpsBigintSpan() { /* utility */ }
* <p>Object-model role: {@code constructor}.</p>
* <p>Classification: constructor of instant/scalar</p>
*/
public static Pointer bigintspan_make(int arg0, int arg1, int arg2, int arg3) {
public static jnr.ffi.Pointer bigintspan_make(long arg0, long arg1, boolean arg2, boolean arg3) {
if (!MEOS_AVAILABLE) {
throw new UnsupportedOperationException(
"bigintspan_make requires libmeos — set -Dmobilityflink.meos.enabled=true");
"bigintspan_make requires libmeos — set -Dmobilitykafka.meos.enabled=true");
}
return GeneratedFunctions.bigintspan_make(arg0, arg1, arg2, arg3);
}
Expand All @@ -35,10 +35,10 @@ public static Pointer bigintspan_make(int arg0, int arg1, int arg2, int arg3) {
* <p>Object-model role: {@code accessor}.</p>
* <p>Classification: role=accessor</p>
*/
public static Pointer bigintspan_bins(Pointer arg0, int arg1, int arg2, Pointer arg3) {
public static jnr.ffi.Pointer bigintspan_bins(jnr.ffi.Pointer arg0, long arg1, long arg2, jnr.ffi.Pointer arg3) {
if (!MEOS_AVAILABLE) {
throw new UnsupportedOperationException(
"bigintspan_bins requires libmeos — set -Dmobilityflink.meos.enabled=true");
"bigintspan_bins requires libmeos — set -Dmobilitykafka.meos.enabled=true");
}
return GeneratedFunctions.bigintspan_bins(arg0, arg1, arg2, arg3);
}
Expand All @@ -49,10 +49,10 @@ public static Pointer bigintspan_bins(Pointer arg0, int arg1, int arg2, Pointer
* <p>Object-model role: {@code accessor}.</p>
* <p>Classification: role=accessor</p>
*/
public static Pointer bigintspan_expand(Pointer arg0, int arg1) {
public static jnr.ffi.Pointer bigintspan_expand(jnr.ffi.Pointer arg0, long arg1) {
if (!MEOS_AVAILABLE) {
throw new UnsupportedOperationException(
"bigintspan_expand requires libmeos — set -Dmobilityflink.meos.enabled=true");
"bigintspan_expand requires libmeos — set -Dmobilitykafka.meos.enabled=true");
}
return GeneratedFunctions.bigintspan_expand(arg0, arg1);
}
Expand All @@ -63,10 +63,10 @@ public static Pointer bigintspan_expand(Pointer arg0, int arg1) {
* <p>Object-model role: {@code accessor}.</p>
* <p>Classification: role=accessor</p>
*/
public static int bigintspan_lower(Pointer arg0) {
public static long bigintspan_lower(jnr.ffi.Pointer arg0) {
if (!MEOS_AVAILABLE) {
throw new UnsupportedOperationException(
"bigintspan_lower requires libmeos — set -Dmobilityflink.meos.enabled=true");
"bigintspan_lower requires libmeos — set -Dmobilitykafka.meos.enabled=true");
}
return GeneratedFunctions.bigintspan_lower(arg0);
}
Expand All @@ -77,10 +77,10 @@ public static int bigintspan_lower(Pointer arg0) {
* <p>Object-model role: {@code accessor}.</p>
* <p>Classification: role=accessor</p>
*/
public static Pointer bigintspan_shift_scale(Pointer arg0, int arg1, int arg2, int arg3, int arg4) {
public static jnr.ffi.Pointer bigintspan_shift_scale(jnr.ffi.Pointer arg0, long arg1, long arg2, boolean arg3, boolean arg4) {
if (!MEOS_AVAILABLE) {
throw new UnsupportedOperationException(
"bigintspan_shift_scale requires libmeos — set -Dmobilityflink.meos.enabled=true");
"bigintspan_shift_scale requires libmeos — set -Dmobilitykafka.meos.enabled=true");
}
return GeneratedFunctions.bigintspan_shift_scale(arg0, arg1, arg2, arg3, arg4);
}
Expand All @@ -91,10 +91,10 @@ public static Pointer bigintspan_shift_scale(Pointer arg0, int arg1, int arg2, i
* <p>Object-model role: {@code accessor}.</p>
* <p>Classification: role=accessor</p>
*/
public static int bigintspan_upper(Pointer arg0) {
public static long bigintspan_upper(jnr.ffi.Pointer arg0) {
if (!MEOS_AVAILABLE) {
throw new UnsupportedOperationException(
"bigintspan_upper requires libmeos — set -Dmobilityflink.meos.enabled=true");
"bigintspan_upper requires libmeos — set -Dmobilitykafka.meos.enabled=true");
}
return GeneratedFunctions.bigintspan_upper(arg0);
}
Expand All @@ -105,10 +105,10 @@ public static int bigintspan_upper(Pointer arg0) {
* <p>Object-model role: {@code accessor}.</p>
* <p>Classification: role=accessor</p>
*/
public static int bigintspan_width(Pointer arg0) {
public static long bigintspan_width(jnr.ffi.Pointer arg0) {
if (!MEOS_AVAILABLE) {
throw new UnsupportedOperationException(
"bigintspan_width requires libmeos — set -Dmobilityflink.meos.enabled=true");
"bigintspan_width requires libmeos — set -Dmobilitykafka.meos.enabled=true");
}
return GeneratedFunctions.bigintspan_width(arg0);
}
Expand All @@ -119,10 +119,10 @@ public static int bigintspan_width(Pointer arg0) {
* <p>Object-model role: {@code constructor}.</p>
* <p>Classification: IO/serialization</p>
*/
public static Pointer bigintspan_in(String arg0) {
public static jnr.ffi.Pointer bigintspan_in(java.lang.String arg0) {
if (!MEOS_AVAILABLE) {
throw new UnsupportedOperationException(
"bigintspan_in requires libmeos — set -Dmobilityflink.meos.enabled=true");
"bigintspan_in requires libmeos — set -Dmobilitykafka.meos.enabled=true");
}
return GeneratedFunctions.bigintspan_in(arg0);
}
Expand All @@ -133,10 +133,10 @@ public static Pointer bigintspan_in(String arg0) {
* <p>Object-model role: {@code output}.</p>
* <p>Classification: IO/serialization</p>
*/
public static String bigintspan_out(Pointer arg0) {
public static java.lang.String bigintspan_out(jnr.ffi.Pointer arg0) {
if (!MEOS_AVAILABLE) {
throw new UnsupportedOperationException(
"bigintspan_out requires libmeos — set -Dmobilityflink.meos.enabled=true");
"bigintspan_out requires libmeos — set -Dmobilitykafka.meos.enabled=true");
}
return GeneratedFunctions.bigintspan_out(arg0);
}
Expand Down
28 changes: 14 additions & 14 deletions kafka-streams-app/src/main/java/org/mobilitydb/kafka/meos/MeosOpsBigintSpanSet.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -21,10 +21,10 @@ private MeosOpsBigintSpanSet() { /* utility */ }
* <p>Object-model role: {@code accessor}.</p>
* <p>Classification: role=accessor</p>
*/
public static Pointer bigintspanset_bins(Pointer arg0, int arg1, int arg2, Pointer arg3) {
public static jnr.ffi.Pointer bigintspanset_bins(jnr.ffi.Pointer arg0, long arg1, long arg2, jnr.ffi.Pointer arg3) {
if (!MEOS_AVAILABLE) {
throw new UnsupportedOperationException(
"bigintspanset_bins requires libmeos — set -Dmobilityflink.meos.enabled=true");
"bigintspanset_bins requires libmeos — set -Dmobilitykafka.meos.enabled=true");
}
return GeneratedFunctions.bigintspanset_bins(arg0, arg1, arg2, arg3);
}
Expand All @@ -35,10 +35,10 @@ public static Pointer bigintspanset_bins(Pointer arg0, int arg1, int arg2, Point
* <p>Object-model role: {@code accessor}.</p>
* <p>Classification: role=accessor</p>
*/
public static int bigintspanset_lower(Pointer arg0) {
public static long bigintspanset_lower(jnr.ffi.Pointer arg0) {
if (!MEOS_AVAILABLE) {
throw new UnsupportedOperationException(
"bigintspanset_lower requires libmeos — set -Dmobilityflink.meos.enabled=true");
"bigintspanset_lower requires libmeos — set -Dmobilitykafka.meos.enabled=true");
}
return GeneratedFunctions.bigintspanset_lower(arg0);
}
Expand All @@ -49,10 +49,10 @@ public static int bigintspanset_lower(Pointer arg0) {
* <p>Object-model role: {@code accessor}.</p>
* <p>Classification: role=accessor</p>
*/
public static Pointer bigintspanset_shift_scale(Pointer arg0, int arg1, int arg2, int arg3, int arg4) {
public static jnr.ffi.Pointer bigintspanset_shift_scale(jnr.ffi.Pointer arg0, long arg1, long arg2, boolean arg3, boolean arg4) {
if (!MEOS_AVAILABLE) {
throw new UnsupportedOperationException(
"bigintspanset_shift_scale requires libmeos — set -Dmobilityflink.meos.enabled=true");
"bigintspanset_shift_scale requires libmeos — set -Dmobilitykafka.meos.enabled=true");
}
return GeneratedFunctions.bigintspanset_shift_scale(arg0, arg1, arg2, arg3, arg4);
}
Expand All @@ -63,10 +63,10 @@ public static Pointer bigintspanset_shift_scale(Pointer arg0, int arg1, int arg2
* <p>Object-model role: {@code accessor}.</p>
* <p>Classification: role=accessor</p>
*/
public static int bigintspanset_upper(Pointer arg0) {
public static long bigintspanset_upper(jnr.ffi.Pointer arg0) {
if (!MEOS_AVAILABLE) {
throw new UnsupportedOperationException(
"bigintspanset_upper requires libmeos — set -Dmobilityflink.meos.enabled=true");
"bigintspanset_upper requires libmeos — set -Dmobilitykafka.meos.enabled=true");
}
return GeneratedFunctions.bigintspanset_upper(arg0);
}
Expand All @@ -77,10 +77,10 @@ public static int bigintspanset_upper(Pointer arg0) {
* <p>Object-model role: {@code accessor}.</p>
* <p>Classification: role=accessor</p>
*/
public static int bigintspanset_width(Pointer arg0, int arg1) {
public static long bigintspanset_width(jnr.ffi.Pointer arg0, boolean arg1) {
if (!MEOS_AVAILABLE) {
throw new UnsupportedOperationException(
"bigintspanset_width requires libmeos — set -Dmobilityflink.meos.enabled=true");
"bigintspanset_width requires libmeos — set -Dmobilitykafka.meos.enabled=true");
}
return GeneratedFunctions.bigintspanset_width(arg0, arg1);
}
Expand All @@ -91,10 +91,10 @@ public static int bigintspanset_width(Pointer arg0, int arg1) {
* <p>Object-model role: {@code constructor}.</p>
* <p>Classification: IO/serialization</p>
*/
public static Pointer bigintspanset_in(String arg0) {
public static jnr.ffi.Pointer bigintspanset_in(java.lang.String arg0) {
if (!MEOS_AVAILABLE) {
throw new UnsupportedOperationException(
"bigintspanset_in requires libmeos — set -Dmobilityflink.meos.enabled=true");
"bigintspanset_in requires libmeos — set -Dmobilitykafka.meos.enabled=true");
}
return GeneratedFunctions.bigintspanset_in(arg0);
}
Expand All @@ -105,10 +105,10 @@ public static Pointer bigintspanset_in(String arg0) {
* <p>Object-model role: {@code output}.</p>
* <p>Classification: IO/serialization</p>
*/
public static String bigintspanset_out(Pointer arg0) {
public static java.lang.String bigintspanset_out(jnr.ffi.Pointer arg0) {
if (!MEOS_AVAILABLE) {
throw new UnsupportedOperationException(
"bigintspanset_out requires libmeos — set -Dmobilityflink.meos.enabled=true");
"bigintspanset_out requires libmeos — set -Dmobilitykafka.meos.enabled=true");
}
return GeneratedFunctions.bigintspanset_out(arg0);
}
Expand Down
Loading