Trait amadeus::Source[−][src]

pub trait Source: Clone + Debug {
    type Item: Data;
    type Error: Error;
    type ParStream: ParallelStream<Item = Result<Self::Item, Self::Error>>;
    type DistStream: DistributedStream<Item = Result<Self::Item, Self::Error>>;
    fn par_stream(self) -> Self::ParStream;
    fn dist_stream(self) -> Self::DistStream;
}

Associated Types

`type Item: Data`[src]

`type Error: Error`[src]

`type ParStream: ParallelStream<Item = Result<Self::Item, Self::Error>>`[src]

`type DistStream: DistributedStream<Item = Result<Self::Item, Self::Error>>`[src]

Required methods

`fn par_stream(self) -> Self::ParStream`[src]

`fn dist_stream(self) -> Self::DistStream`[src]

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]

`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]

`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]

`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]

`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]