Struct HudiTableFactory

pub struct HudiTableFactory {}

HudiTableFactory is responsible for creating and configuring Hudi tables.

This factory handles the initialization of Hudi tables by creating configuration options from both session state and table creation commands.

Examples

Creating a new HudiTableFactory instance:

use datafusion::prelude::SessionContext;
use hudi_datafusion::HudiTableFactory;

// Initialize a new HudiTableFactory
let factory = HudiTableFactory::new();
     
// The factory can be used to create Hudi tables
let table = factory.create_table(...)?;


// Using `CREATE EXTERNAL TABLE` to register Hudi table:
let test_table =  factory.create_table(...)?; // Table with path + url
let ctx = SessionContext::new();

// Register table in session using `CREATE EXTERNAL TABLE` command
let create_table_sql = format!(
    "CREATE EXTERNAL TABLE {} STORED AS HUDI LOCATION '{}' {}",
    test_table.as_ref(),
    test_table.path(),
    concat_as_sql_options(options)
);
ctx.sql(create_table_sql.as_str()).await?; // Query against this table

Implementations

impl HudiTableFactory

pub fn new() -> Self

Trait Implementations

impl Debug for HudiTableFactory

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

Formats the value using the given formatter.

impl Default for HudiTableFactory

fn default() -> Self

Returns the “default value” for a type.

impl TableProviderFactory for HudiTableFactory

fn create<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, state: &'life1 dyn Session, cmd: &'life2 CreateExternalTable, ) -> Pin<Box<dyn Future<Output = Result<Arc<dyn TableProvider>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Create a TableProvider with the given url