33 result->
length =
sizeof(int16_t);
38 datum->
smallintval = (int16_t) * (int8_t*)compressed;
50 result->
length =
sizeof(int32_t);
56 datum->
intval = (int32_t) * (int8_t*)compressed;
59 datum->
intval = (int32_t) * (int16_t*)compressed;
77 result->
length =
sizeof(int64_t);
83 datum->
bigintval = (int64_t) * (int8_t*)compressed;
86 datum->
bigintval = (int64_t) * (int16_t*)compressed;
89 datum->
bigintval = (int64_t) * (int32_t*)compressed;
109 datum->
bigintval = (int64_t) * (int32_t*)compressed;
115 datum->
bigintval = (int64_t) * (int32_t*)compressed;
118 datum->
bigintval = (int64_t) * (int16_t*)compressed;
135 result->
length =
sizeof(int64_t);
187 if (static_cast<size_t>(n) >= it->
num_elems || n < 0) {
222 if (static_cast<size_t>(n) >= it->
num_elems || n < 0) {
225 result->pointer = NULL;
226 result->is_null =
true;
234 result->length =
static_cast<size_t>(it->
skip_size);
235 result->pointer = current_pos;
247 if (next_offset < 0) {
249 result->pointer = NULL;
250 result->is_null =
true;
255 result->length =
static_cast<size_t>(next_offset - offset);
257 result->is_null =
false;
271 *is_end = (
static_cast<size_t>(
n) >= it->
num_elems || n < 0);
279 if (next_offset >= 0) {
284 result->length =
static_cast<size_t>(next_offset - offset);
286 result->is_null =
false;
292 result->pointer = NULL;
293 result->is_null =
true;
301 *is_end = (
static_cast<size_t>(
n) >= it->
num_elems || n < 0);
308 result->length =
static_cast<size_t>(next_offset - offset);
310 result->is_null =
false;
321 if (static_cast<size_t>(n) >= it->
num_elems || n < 0) {
324 result->pointer = NULL;
325 result->is_null =
true;
332 result->length =
static_cast<size_t>(it->
skip_size);
333 result->pointer = current_pos;
static DEVICE void decompress(const SQLTypeInfo &ti, int8_t *compressed, VarlenDatum *result, Datum *datum)
DEVICE void ChunkIter_get_nth_point_coords(ChunkIter *it, int n, ArrayDatum *result, bool *is_end)
HOST DEVICE bool is_null_fixlen_array(const int8_t *val, int array_size) const
HOST DEVICE SQLTypes get_type() const
DEVICE void ChunkIter_get_nth(ChunkIter *it, int n, bool uncompress, VarlenDatum *result, bool *is_end)
std::conditional_t< is_cuda_compiler(), DeviceArrayDatum, HostArrayDatum > ArrayDatum
CONSTEXPR DEVICE bool is_null(const T &value)
DEVICE void ChunkIter_get_nth_varlen(ChunkIter *it, int n, ArrayDatum *result, bool *is_end)
HOST DEVICE bool is_null(const Datum &d) const
HOST DEVICE EncodingType get_compression() const
void ChunkIter_reset(ChunkIter *it)
HOST DEVICE int get_comp_param() const
DEVICE void ChunkIter_get_next(ChunkIter *it, bool uncompress, VarlenDatum *result, bool *is_end)
HOST DEVICE bool get_notnull() const
HOST static DEVICE bool isFlatBuffer(const void *buffer)
DEVICE void ChunkIter_get_nth_varlen_notnull(ChunkIter *it, int n, ArrayDatum *result, bool *is_end)
HOST DEVICE bool is_null_point_coord_array(const int8_t *val, int array_size) const
DEVICE void VarlenArray_get_nth(int8_t *buf, int n, ArrayDatum *result, bool *is_end)