Struct BigQuerySchemaLocator 

pub struct BigQuerySchemaLocator { /* private fields */ }

A JSON file containing BigQuery table schema.

Trait Implementations

impl Clone for BigQuerySchemaLocator

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for BigQuerySchemaLocator

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

Formats the value using the given formatter.

impl Display for BigQuerySchemaLocator

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

Formats the value using the given formatter.

impl FromStr for BigQuerySchemaLocator

type Err = Error

The associated error which can be returned from parsing.

fn from_str(s: &str) -> Result<Self>

Parses a string s to return a value of this type.

impl Locator for BigQuerySchemaLocator

fn as_any(&self) -> &dyn Any

Provide a mechanism for casting a dyn Locator back to the underlying, concrete locator type using Rust’s Any type.

fn schema(&self, _ctx: Context) -> BoxFuture<Option<Schema>>

Return a table schema, if available.

fn write_schema( &self, _ctx: Context, schema: Schema, if_exists: IfExists, ) -> BoxFuture<()>

Write a table schema to this locator, if that’s the sort of thing that we can do.

fn count( &self, _ctx: Context, _shared_args: SharedArguments<Unverified>, _source_args: SourceArguments<Unverified>, ) -> BoxFuture<usize>

Count the records specified by this locator.

fn local_data( &self, _ctx: Context, _shared_args: SharedArguments<Unverified>, _source_args: SourceArguments<Unverified>, ) -> BoxFuture<Option<BoxStream<CsvStream>>>

If this locator can be used as a local data source, return a stream of CSV streams. This function type is bit hairy:

fn display_output_locators(&self) -> DisplayOutputLocators

Should we display the individual output locations?

fn write_local_data( &self, _ctx: Context, _data: BoxStream<CsvStream>, _shared_args: SharedArguments<Unverified>, _dest_args: DestinationArguments<Unverified>, ) -> BoxFuture<BoxStream<BoxFuture<BoxLocator>>>

If this locator can be used as a local data sink, write data to it.

fn supports_write_remote_data(&self, _source: &dyn Locator) -> bool

Can we access the data at source directly using write_remote_data?

fn write_remote_data( &self, _ctx: Context, source: BoxLocator, _shared_args: SharedArguments<Unverified>, _source_args: SourceArguments<Unverified>, _dest_args: DestinationArguments<Unverified>, ) -> BoxFuture<Vec<BoxLocator>>

Take the data at source, and write to this locator directly, without passing it through the local system.