MCPcopy Create free account
hub / github.com/apache/arrow / PutSpaced

Method PutSpaced

cpp/src/parquet/encoder.cc:1280–1293  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

1278
1279template <typename DType>
1280void DeltaBitPackEncoder<DType>::PutSpaced(const T* src, int num_values,
1281 const uint8_t* valid_bits,
1282 int64_t valid_bits_offset) {
1283 if (valid_bits != NULLPTR) {
1284 PARQUET_ASSIGN_OR_THROW(auto buffer, ::arrow::AllocateBuffer(num_values * sizeof(T),
1285 this->memory_pool()));
1286 T* data = buffer->template mutable_data_as<T>();
1287 int num_valid_values = ::arrow::util::internal::SpacedCompress<T>(
1288 src, num_values, valid_bits, valid_bits_offset, data);
1289 Put(data, num_valid_values);
1290 } else {
1291 Put(src, num_values);
1292 }
1293}
1294
1295// ----------------------------------------------------------------------
1296// DELTA_LENGTH_BYTE_ARRAY encoder

Callers 15

PutMethod · 0.45
CheckRoundtripSpacedMethod · 0.45
CheckRoundtripMethod · 0.45
SetupEncoderDecoderMethod · 0.45
SetupEncoderDecoderMethod · 0.45
SetupEncoderDecoderMethod · 0.45
CheckRoundtripMethod · 0.45
CheckRoundtripSpacedMethod · 0.45
CheckRoundtripSpacedMethod · 0.45
CheckRoundtripSpacedMethod · 0.45
CheckRoundtripSpacedMethod · 0.45
BM_EncodingSpacedFunction · 0.45

Calls

no outgoing calls

Tested by 10

CheckRoundtripSpacedMethod · 0.36
CheckRoundtripMethod · 0.36
SetupEncoderDecoderMethod · 0.36
SetupEncoderDecoderMethod · 0.36
SetupEncoderDecoderMethod · 0.36
CheckRoundtripMethod · 0.36
CheckRoundtripSpacedMethod · 0.36
CheckRoundtripSpacedMethod · 0.36
CheckRoundtripSpacedMethod · 0.36
CheckRoundtripSpacedMethod · 0.36