Struct InMemoryDataProvider 

pub struct InMemoryDataProvider { /* private fields */ }

Implementations

impl InMemoryDataProvider

pub fn new(owner_controller: ControllerId) -> InMemoryDataProvider

pub fn with_envelope( owner_controller: ControllerId, envelope: ExternalDataPlanEnvelope, ) -> Result<InMemoryDataProvider, DagMlError>

pub fn register_envelope( &mut self, envelope: ExternalDataPlanEnvelope, ) -> Result<(), DagMlError>

pub fn handle_record(&self, handle: u64) -> Option<DataHandleRecord>

pub fn handle_records(&self) -> Vec<DataHandleRecord>

pub fn view_record(&self, handle: u64) -> Option<DataViewHandleRecord>

pub fn view_records(&self) -> Vec<DataViewHandleRecord>

Trait Implementations

impl Debug for InMemoryDataProvider

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl RuntimeDataProvider for InMemoryDataProvider

fn materialize( &self, request: &DataMaterializationRequest, ) -> Result<HandleRef, DagMlError>

fn make_view(&self, request: &DataViewRequest) -> Result<HandleRef, DagMlError>

fn coordinator_relations( &self, binding: &DataBinding, ) -> Result<Option<SampleRelationSet>, DagMlError>