Function test_table_provider

datafusion/ffi/tests/ffi_integration.rs:39–62

It is important that this test is in the `tests` directory and not in the library directory so we can verify we are building a dynamic library and testing it via a different executable.

(synchronous: bool)

    /// library directory so we can verify we are building a dynamic library and
    /// testing it via a different executable.
    async fn test_table_provider(synchronous: bool) -> Result<()> {
        let table_provider_module = get_module()?;
        let (ctx, codec) = super::utils::ctx_and_codec();

        // By calling the code below, the table provided will be created within
        // the module's code.
        let ffi_table_provider = (table_provider_module.create_table)(synchronous, codec);

        // In order to access the table provider within this executable, we need to
        // turn it into a `TableProvider`.
        let foreign_table_provider: Arc<dyn TableProvider> = (&ffi_table_provider).into();

        // Display the data to show the full cycle works.
        ctx.register_table("external_table", foreign_table_provider)?;
        let df = ctx.table("external_table").await?;
        let results = df.collect().await?;

        assert_eq!(results.len(), 3);
        assert!(results.contains(&create_record_batch(1, 5)));
        assert!(results.contains(&create_record_batch(6, 1)));
        assert!(results.contains(&create_record_batch(7, 5)));

        Ok(())
    }

    #[tokio::test]
    async fn async_test_table_provider() -> Result<()> {