Package io.deephaven.kafka.ingest
Class ChunkUtils
java.lang.Object
io.deephaven.kafka.ingest.ChunkUtils
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionstatic <T> voidapplyInto(ToByteFunction<? super T> byteFunction, ObjectChunk<? extends T, ?> src, int srcOffset, WritableByteChunk<?> dest, int destOffset, int length) static <T> voidapplyInto(ToCharFunction<? super T> charFunction, ObjectChunk<? extends T, ?> src, int srcOffset, WritableCharChunk<?> dest, int destOffset, int length) static <T> voidapplyInto(ToFloatFunction<? super T> floatFunction, ObjectChunk<? extends T, ?> src, int srcOffset, WritableFloatChunk<?> dest, int destOffset, int length) static <T> voidapplyInto(ToShortFunction<? super T> shortFunction, ObjectChunk<? extends T, ?> src, int srcOffset, WritableShortChunk<?> dest, int destOffset, int length) static <T,R> void applyInto(Function<? super T, ? extends R> objFunction, ObjectChunk<? extends T, ?> src, int srcOffset, WritableObjectChunk<R, ?> dest, int destOffset, int length) static <T> voidapplyInto(Predicate<? super T> booleanFunction, ObjectChunk<? extends T, ?> src, int srcOffset, WritableBooleanChunk<?> dest, int destOffset, int length) static <T> voidapplyInto(ToDoubleFunction<? super T> doubleFunction, ObjectChunk<? extends T, ?> src, int srcOffset, WritableDoubleChunk<?> dest, int destOffset, int length) static <T> voidapplyInto(ToIntFunction<? super T> intFunction, ObjectChunk<? extends T, ?> src, int srcOffset, WritableIntChunk<?> dest, int destOffset, int length) static <T> voidapplyInto(ToLongFunction<? super T> longFunction, ObjectChunk<? extends T, ?> src, int srcOffset, WritableLongChunk<?> dest, int destOffset, int length)
-
Constructor Details
-
ChunkUtils
public ChunkUtils()
-
-
Method Details
-
applyInto
public static <T> void applyInto(Predicate<? super T> booleanFunction, ObjectChunk<? extends T, ?> src, int srcOffset, WritableBooleanChunk<?> dest, int destOffset, int length) -
applyInto
public static <T> void applyInto(ToByteFunction<? super T> byteFunction, ObjectChunk<? extends T, ?> src, int srcOffset, WritableByteChunk<?> dest, int destOffset, int length) -
applyInto
public static <T> void applyInto(ToCharFunction<? super T> charFunction, ObjectChunk<? extends T, ?> src, int srcOffset, WritableCharChunk<?> dest, int destOffset, int length) -
applyInto
public static <T> void applyInto(ToShortFunction<? super T> shortFunction, ObjectChunk<? extends T, ?> src, int srcOffset, WritableShortChunk<?> dest, int destOffset, int length) -
applyInto
public static <T> void applyInto(ToIntFunction<? super T> intFunction, ObjectChunk<? extends T, ?> src, int srcOffset, WritableIntChunk<?> dest, int destOffset, int length) -
applyInto
public static <T> void applyInto(ToLongFunction<? super T> longFunction, ObjectChunk<? extends T, ?> src, int srcOffset, WritableLongChunk<?> dest, int destOffset, int length) -
applyInto
public static <T> void applyInto(ToFloatFunction<? super T> floatFunction, ObjectChunk<? extends T, ?> src, int srcOffset, WritableFloatChunk<?> dest, int destOffset, int length) -
applyInto
public static <T> void applyInto(ToDoubleFunction<? super T> doubleFunction, ObjectChunk<? extends T, ?> src, int srcOffset, WritableDoubleChunk<?> dest, int destOffset, int length) -
applyInto
public static <T,R> void applyInto(Function<? super T, ? extends R> objFunction, ObjectChunk<? extends T, ?> src, int srcOffset, WritableObjectChunk<R, ?> dest, int destOffset, int length)
-