Skip to content

Commit 57f88d1

Browse files
committed
reduce visibility more
1 parent 80b72c5 commit 57f88d1

3 files changed

Lines changed: 6 additions & 6 deletions

File tree

native/core/src/execution/shuffle/spark_unsafe/list.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -70,7 +70,7 @@ impl SparkUnsafeArray {
7070
}
7171
}
7272

73-
pub fn get_num_elements(&self) -> usize {
73+
pub(crate) fn get_num_elements(&self) -> usize {
7474
self.num_elements
7575
}
7676

@@ -82,7 +82,7 @@ impl SparkUnsafeArray {
8282

8383
/// Returns true if the null bit at the given index of the array is set.
8484
#[inline]
85-
pub fn is_null_at(&self, index: usize) -> bool {
85+
pub(crate) fn is_null_at(&self, index: usize) -> bool {
8686
unsafe {
8787
let mask: i64 = 1i64 << (index & 0x3f);
8888
let word_offset = (self.row_addr + 8 + (((index >> 6) as i64) << 3)) as *const i64;

native/core/src/execution/shuffle/spark_unsafe/map.rs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -23,13 +23,13 @@ use arrow::array::builder::{ArrayBuilder, MapBuilder, MapFieldNames};
2323
use arrow::datatypes::{DataType, FieldRef};
2424

2525
pub struct SparkUnsafeMap {
26-
pub keys: SparkUnsafeArray,
27-
pub values: SparkUnsafeArray,
26+
pub(crate) keys: SparkUnsafeArray,
27+
pub(crate) values: SparkUnsafeArray,
2828
}
2929

3030
impl SparkUnsafeMap {
3131
/// Creates a `SparkUnsafeMap` which points to the given address and size in bytes.
32-
pub fn new(addr: i64, size: i32) -> Self {
32+
pub(crate) fn new(addr: i64, size: i32) -> Self {
3333
// Read the number of bytes of key array from the first 8 bytes.
3434
let slice: &[u8] = unsafe { std::slice::from_raw_parts(addr as *const u8, 8) };
3535
let key_array_size = i64::from_le_bytes(slice.try_into().unwrap());

native/core/src/execution/shuffle/spark_unsafe/row.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -256,7 +256,7 @@ impl SparkUnsafeRow {
256256

257257
/// Returns true if the null bit at the given index of the row is set.
258258
#[inline]
259-
pub fn is_null_at(&self, index: usize) -> bool {
259+
pub(crate) fn is_null_at(&self, index: usize) -> bool {
260260
unsafe {
261261
let mask: i64 = 1i64 << (index & 0x3f);
262262
let word_offset = (self.row_addr + (((index >> 6) as i64) << 3)) as *const i64;

0 commit comments

Comments
 (0)