pub trait BatchableTransformer:
Send
+ Sync
+ DynClone {
// Required method
fn batch_transform<'life0, 'async_trait>(
&'life0 self,
nodes: Vec<Node>,
) -> Pin<Box<dyn Future<Output = IndexingStream> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait;
// Provided methods
fn concurrency(&self) -> Option<usize> { ... }
fn name(&self) -> &'static str { ... }
fn batch_size(&self) -> Option<usize> { ... }
}
Expand description
Transforms batched single nodes into streams of nodes
Required Methods§
Sourcefn batch_transform<'life0, 'async_trait>(
&'life0 self,
nodes: Vec<Node>,
) -> Pin<Box<dyn Future<Output = IndexingStream> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn batch_transform<'life0, 'async_trait>(
&'life0 self,
nodes: Vec<Node>,
) -> Pin<Box<dyn Future<Output = IndexingStream> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Transforms a batch of nodes into a stream of nodes
Provided Methods§
Sourcefn concurrency(&self) -> Option<usize>
fn concurrency(&self) -> Option<usize>
Overrides the default concurrency of the pipeline
fn name(&self) -> &'static str
Sourcefn batch_size(&self) -> Option<usize>
fn batch_size(&self) -> Option<usize>
Overrides the default batch size of the pipeline
Trait Implementations§
Source§impl BatchableTransformer for &dyn BatchableTransformer
impl BatchableTransformer for &dyn BatchableTransformer
Source§fn batch_transform<'life0, 'async_trait>(
&'life0 self,
nodes: Vec<Node>,
) -> Pin<Box<dyn Future<Output = IndexingStream> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn batch_transform<'life0, 'async_trait>(
&'life0 self,
nodes: Vec<Node>,
) -> Pin<Box<dyn Future<Output = IndexingStream> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Transforms a batch of nodes into a stream of nodes
Source§fn concurrency(&self) -> Option<usize>
fn concurrency(&self) -> Option<usize>
Overrides the default concurrency of the pipeline
fn name(&self) -> &'static str
Source§fn batch_size(&self) -> Option<usize>
fn batch_size(&self) -> Option<usize>
Overrides the default batch size of the pipeline
Source§impl BatchableTransformer for Box<dyn BatchableTransformer>
impl BatchableTransformer for Box<dyn BatchableTransformer>
Source§fn batch_transform<'life0, 'async_trait>(
&'life0 self,
nodes: Vec<Node>,
) -> Pin<Box<dyn Future<Output = IndexingStream> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn batch_transform<'life0, 'async_trait>(
&'life0 self,
nodes: Vec<Node>,
) -> Pin<Box<dyn Future<Output = IndexingStream> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Transforms a batch of nodes into a stream of nodes
Source§fn concurrency(&self) -> Option<usize>
fn concurrency(&self) -> Option<usize>
Overrides the default concurrency of the pipeline
fn name(&self) -> &'static str
Source§fn batch_size(&self) -> Option<usize>
fn batch_size(&self) -> Option<usize>
Overrides the default batch size of the pipeline
Source§impl WithBatchIndexingDefaults for Box<dyn BatchableTransformer>
impl WithBatchIndexingDefaults for Box<dyn BatchableTransformer>
fn with_indexing_defaults(&mut self, indexing_defaults: IndexingDefaults)
Source§impl WithBatchIndexingDefaults for dyn BatchableTransformer
impl WithBatchIndexingDefaults for dyn BatchableTransformer
fn with_indexing_defaults(&mut self, _indexing_defaults: IndexingDefaults)
Implementations on Foreign Types§
Source§impl BatchableTransformer for Box<dyn BatchableTransformer>
impl BatchableTransformer for Box<dyn BatchableTransformer>
Implementors§
impl BatchableTransformer for &dyn BatchableTransformer
impl BatchableTransformer for Arc<dyn BatchableTransformer>
impl BatchableTransformer for MockBatchableTransformer
impl<F> BatchableTransformer for F
Use a closure as a batchable transformer