arrow_flight::sql::metadata

Struct GetTablesBuilder

Source
pub struct GetTablesBuilder {
    catalog_filter: Option<String>,
    table_types_filter: Vec<String>,
    db_schema_filter_pattern: Option<String>,
    table_name_filter_pattern: Option<String>,
    catalog_name: StringBuilder,
    db_schema_name: StringBuilder,
    table_name: StringBuilder,
    table_type: StringBuilder,
    table_schema: Option<BinaryBuilder>,
}
Expand description

A builder for a CommandGetTables response.

Builds rows like this:

  • catalog_name: utf8,
  • db_schema_name: utf8,
  • table_name: utf8 not null,
  • table_type: utf8 not null,
  • (optional) table_schema: bytes not null (schema of the table as described in Schema.fbs::Schema it is serialized as an IPC message.)

Fields§

§catalog_filter: Option<String>§table_types_filter: Vec<String>§db_schema_filter_pattern: Option<String>§table_name_filter_pattern: Option<String>§catalog_name: StringBuilder§db_schema_name: StringBuilder§table_name: StringBuilder§table_type: StringBuilder§table_schema: Option<BinaryBuilder>

Implementations§

Source§

impl GetTablesBuilder

Source

pub fn new( catalog: Option<impl Into<String>>, db_schema_filter_pattern: Option<impl Into<String>>, table_name_filter_pattern: Option<impl Into<String>>, table_types: impl IntoIterator<Item = impl Into<String>>, include_schema: bool, ) -> Self

Create a new instance of GetTablesBuilder

§Parameters
  • catalog: Specifies the Catalog to search for the tables.
    • An empty string retrieves those without a catalog.
    • If omitted the catalog name is not used to narrow the search.
  • db_schema_filter_pattern: Specifies a filter pattern for schemas to search for. When no pattern is provided, the pattern will not be used to narrow the search. In the pattern string, two special characters can be used to denote matching rules:
    • “%” means to match any substring with 0 or more characters.
    • “_” means to match any one character.
  • table_name_filter_pattern: Specifies a filter pattern for tables to search for. When no pattern is provided, all tables matching other filters are searched. In the pattern string, two special characters can be used to denote matching rules:
    • “%” means to match any substring with 0 or more characters.
    • “_” means to match any one character.
  • table_types: Specifies a filter of table types which must match. An empy Vec matches all table types.
  • include_schema: Specifies if the Arrow schema should be returned for found tables.
Source

pub fn append( &mut self, catalog_name: impl AsRef<str>, schema_name: impl AsRef<str>, table_name: impl AsRef<str>, table_type: impl AsRef<str>, table_schema: &Schema, ) -> Result<()>

Append a row

Source

pub fn build(self) -> Result<RecordBatch>

builds a RecordBatch for CommandGetTables

Source

pub fn schema(&self) -> SchemaRef

Return the schema of the RecordBatch that will be returned from CommandGetTables

Note the schema differs based on the values of `include_schema

Source

pub fn include_schema(&self) -> bool

Should the “schema” column be included

Trait Implementations§

Source§

impl From<CommandGetTables> for GetTablesBuilder

Source§

fn from(value: CommandGetTables) -> Self

Converts to this type from the input type.

Auto Trait Implementations§

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

§

impl<T> Instrument for T

§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided [Span], returning an Instrumented wrapper. Read more
§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> IntoRequest<T> for T

Source§

fn into_request(self) -> Request<T>

Wrap the input message T in a tonic::Request
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
§

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

§

fn vzip(self) -> V

§

impl<T> WithSubscriber for T

§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a [WithDispatch] wrapper. Read more
§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a [WithDispatch] wrapper. Read more
§

impl<T> Allocation for T
where T: RefUnwindSafe + Send + Sync,