(&mut self, tape: &Tape<'_>, pos: &[u32])
| 37 | |
| 38 | impl ArrayDecoder for NullArrayDecoder { |
| 39 | fn decode(&mut self, tape: &Tape<'_>, pos: &[u32]) -> Result<ArrayRef, ArrowError> { |
| 40 | if !self.ignore_type_conflicts { |
| 41 | for p in pos { |
| 42 | if !matches!(tape.get(*p), TapeElement::Null) { |
| 43 | return Err(tape.error(*p, "null")); |
| 44 | } |
| 45 | } |
| 46 | } |
| 47 | Ok(Arc::new(NullArray::new(pos.len()))) |
| 48 | } |
| 49 | } |