[−][src]Trait amadeus::Source
Associated Types
type Item: Data
type Error: Error
type ParStream: ParallelStream<Item = Result<Self::Item, Self::Error>>
type DistStream: DistributedStream<Item = Result<Self::Item, Self::Error>>
Required methods
fn par_stream(self) -> Self::ParStream
fn dist_stream(self) -> Self::DistStream
Implementors
impl Source for Cloudfront
[src]
type Item = CloudfrontRow
type Error = Self::Error
type ParStream = IntoStream<Self::ParStream, Self::Item>
type DistStream = IntoStream<Self::DistStream, Self::Item>
fn par_stream(self) -> Self::ParStream
[src]
fn dist_stream(self) -> Self::DistStream
[src]
impl Source for CommonCrawl
[src]
type Item = Webpage<'static>
type Error = Self::Error
type ParStream = IntoStream<Self::ParStream, Self::Item>
type DistStream = IntoStream<Self::DistStream, Self::Item>
fn par_stream(self) -> Self::ParStream
[src]
fn dist_stream(self) -> Self::DistStream
[src]
impl<File, Row> Source for Csv<File, Row> where
File: File,
Row: Data,
[src]
File: File,
Row: Data,
type Item = Self::Item
type Error = Self::Error
type ParStream = Self::ParStream
type DistStream = Self::DistStream
fn par_stream(self) -> Self::ParStream
[src]
fn dist_stream(self) -> Self::DistStream
[src]
impl<File, Row> Source for Json<File, Row> where
File: File,
Row: Data,
[src]
File: File,
Row: Data,
type Item = Self::Item
type Error = Self::Error
type ParStream = Self::ParStream
type DistStream = Self::DistStream
fn par_stream(self) -> Self::ParStream
[src]
fn dist_stream(self) -> Self::DistStream
[src]
impl<File, Row> Source for Parquet<File, Row> where
File: File,
Row: Data,
[src]
File: File,
Row: Data,
type Item = Self::Item
type Error = Self::Error
type ParStream = Self::ParStream
type DistStream = Self::DistStream
fn par_stream(self) -> Self::ParStream
[src]
fn dist_stream(self) -> Self::DistStream
[src]
impl<Row> Source for Postgres<Row> where
Row: Data,
[src]
Row: Data,