IntenseFinance/nosqlbench
3
0
Fork 0
mirror of https://github.com/nosqlbench/nosqlbench.git synced 2025-02-25 18:55:28 -06:00
Code Issues Packages Projects Releases Wiki Activity

function adapter handles LongToIntFunction

Browse Source
This commit is contained in:
Jonathan Shook 2020-06-30 20:38:22 -05:00
parent b3eecb4d65
commit d083483f8d
1 changed files with 13 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
virtdata-api/src/main/java/io/nosqlbench/virtdata/api/bindings/VirtDataFunctions.java
View File

@ -10,6 +10,7 @@ public class VirtDataFunctions {
private enum FuncType { private enum FuncType {
LongToDoubleFunction(java.util.function.LongToDoubleFunction.class, double.class), LongToDoubleFunction(java.util.function.LongToDoubleFunction.class, double.class),
LongToIntFunction(java.util.function.LongToIntFunction.class, int.class),
LongFunction(LongFunction.class, long.class), LongFunction(LongFunction.class, long.class),
LongUnaryOperator(java.util.function.LongUnaryOperator.class, long.class), LongUnaryOperator(java.util.function.LongUnaryOperator.class, long.class),
IntFunction(java.util.function.IntFunction.class, int.class), IntFunction(java.util.function.IntFunction.class, int.class),
@ -61,6 +62,8 @@ public class VirtDataFunctions {
return truncate ? adaptDoubleFunction(func, output) : adaptDoubleFunctionStrict(func, output); return truncate ? adaptDoubleFunction(func, output) : adaptDoubleFunctionStrict(func, output);
case LongFunction: case LongFunction:
return truncate ? (F) adaptLongFunction(func, output) : (F) adaptLongFunctionStrict(func, output); return truncate ? (F) adaptLongFunction(func, output) : (F) adaptLongFunctionStrict(func, output);
case LongToIntFunction:
return truncate ? (F) adaptLongFunction(func, output) : (F) adaptLongFunctionStrict(func, output);
case IntFunction: case IntFunction:
return truncate ? adaptIntFunction(func, output) : adaptIntFunction(func, output); return truncate ? adaptIntFunction(func, output) : adaptIntFunction(func, output);
case Function: case Function:
@ -82,6 +85,9 @@ public class VirtDataFunctions {
case LongUnaryOperator: case LongUnaryOperator:
LongUnaryOperator f2 = assertTypesAssignable(func, LongUnaryOperator.class); LongUnaryOperator f2 = assertTypesAssignable(func, LongUnaryOperator.class);
return f2::applyAsLong; return f2::applyAsLong;
case LongToIntFunction:
LongToIntFunction f3 = assertTypesAssignable(func, LongToIntFunction.class);
return f3::applyAsInt;
case Function: case Function:
Function<Long, Long> f7 = assertTypesAssignable(func, Function.class, Long.class); Function<Long, Long> f7 = assertTypesAssignable(func, Function.class, Long.class);
return (long l) -> f7.apply(l); return (long l) -> f7.apply(l);
@ -119,6 +125,9 @@ public class VirtDataFunctions {
DoubleUnaryOperator f6 = (DoubleUnaryOperator)func; DoubleUnaryOperator f6 = (DoubleUnaryOperator)func;
Function<Double,?> rf6 = f6::applyAsDouble; Function<Double,?> rf6 = f6::applyAsDouble;
return rf6; return rf6;
case LongToIntFunction:
LongToIntFunction f7 = (LongToIntFunction)func;
Function<Long,Integer> rf7 = f7::applyAsInt;
case Function: case Function:
return (Function<?,?>) func; return (Function<?,?>) func;
default: default:
@ -190,6 +199,10 @@ public class VirtDataFunctions {
Function<Long, Object> f7 = assertTypesAssignable(func, Function.class); Function<Long, Object> f7 = assertTypesAssignable(func, Function.class);
assertOutputAssignable(f7.apply(1L),output); assertOutputAssignable(f7.apply(1L),output);
return (long l) -> f7.apply(l); return (long l) -> f7.apply(l);
case LongToIntFunction:
LongToIntFunction f8 = assertTypesAssignable(func, LongToIntFunction.class);
assertOutputAssignable(f8.applyAsInt(1L),output);
return (long l) -> f8.applyAsInt(l);
default: default:
throw new RuntimeException("Unable to convert " + func.getClass().getCanonicalName() + " to a " + throw new RuntimeException("Unable to convert " + func.getClass().getCanonicalName() + " to a " +
LongUnaryOperator.class.getCanonicalName()); LongUnaryOperator.class.getCanonicalName());