Package io.deephaven.kafka.ingest

Class ChunkUtils

java.lang.Object

io.deephaven.kafka.ingest.ChunkUtils

public class ChunkUtils
extends Object

Constructor Summary

Constructors

Constructor	Description
ChunkUtils()

Method Summary

Modifier and Type	Method	Description
static <T> void	applyInto(ToByteFunction<? super T> byteFunction, ObjectChunk<? extends T,?> src, int srcOffset, WritableByteChunk<?> dest, int destOffset, int length)
static <T> void	applyInto(ToCharFunction<? super T> charFunction, ObjectChunk<? extends T,?> src, int srcOffset, WritableCharChunk<?> dest, int destOffset, int length)
static <T> void	applyInto(ToFloatFunction<? super T> floatFunction, ObjectChunk<? extends T,?> src, int srcOffset, WritableFloatChunk<?> dest, int destOffset, int length)
static <T> void	applyInto(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> void	applyInto(Predicate<? super T> booleanFunction, ObjectChunk<? extends T,?> src, int srcOffset, WritableBooleanChunk<?> dest, int destOffset, int length)
static <T> void	applyInto(ToDoubleFunction<? super T> doubleFunction, ObjectChunk<? extends T,?> src, int srcOffset, WritableDoubleChunk<?> dest, int destOffset, int length)
static <T> void	applyInto(ToIntFunction<? super T> intFunction, ObjectChunk<? extends T,?> src, int srcOffset, WritableIntChunk<?> dest, int destOffset, int length)
static <T> void	applyInto(ToLongFunction<? super T> longFunction, ObjectChunk<? extends T,?> src, int srcOffset, WritableLongChunk<?> dest, int destOffset, int length)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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)