|
|
|
@@ -1,11 +1,6 @@ |
|
|
|
use std::{ptr::NonNull, sync::Arc}; |
|
|
|
|
|
|
|
use aligned_vec::{AVec, ConstAlign}; |
|
|
|
use dora_arrow_convert::{ArrowData, IntoArrow}; |
|
|
|
use dora_arrow_convert::ArrowData; |
|
|
|
use dora_core::config::{DataId, OperatorId}; |
|
|
|
use dora_message::metadata::{ArrowTypeInfo, BufferOffset, Metadata}; |
|
|
|
use eyre::{Context, Result}; |
|
|
|
use shared_memory_extended::{Shmem, ShmemConf}; |
|
|
|
use dora_message::metadata::Metadata; |
|
|
|
|
|
|
|
/// Represents an incoming Dora event. |
|
|
|
/// |
|
|
|
|