Package org.apache.arrow.datafusion

Interface ExecutionContext

  • All Superinterfaces:
    java.lang.AutoCloseable
    public interface ExecutionContext
extends java.lang.AutoCloseable
    An execution context holds resources and is the entrance for obtaining DataFrame

    • Method Summary

      All Methods Instance Methods Abstract Methods 
      Modifier and Type Method Description
      long getPointer()  
      Runtime getRuntime()
      Get the runtime associated with this context
      java.util.concurrent.CompletableFuture<java.lang.Void> registerCsv​(java.lang.String name, java.nio.file.Path path)
      Registering a csv file with the context
      java.util.concurrent.CompletableFuture<java.lang.Void> registerParquet​(java.lang.String name, java.nio.file.Path path)
      Registering a parquet file with the context
      java.util.concurrent.CompletableFuture<DataFrame> sql​(java.lang.String sql)
      Obtain the DataFrame by running the sql against the datafusion library

      • Methods inherited from interface java.lang.AutoCloseable

        close

    • Method Detail

      • sql

        java.util.concurrent.CompletableFuture<DataFrame> sql​(java.lang.String sql)
        Obtain the DataFrame by running the sql against the datafusion library

      • registerCsv

        java.util.concurrent.CompletableFuture<java.lang.Void> registerCsv​(java.lang.String name,
                                                                   java.nio.file.Path path)
        Registering a csv file with the context

      • registerParquet

        java.util.concurrent.CompletableFuture<java.lang.Void> registerParquet​(java.lang.String name,
                                                                       java.nio.file.Path path)
        Registering a parquet file with the context

      • getRuntime

        Runtime getRuntime()
        Get the runtime associated with this context

      • getPointer

        long getPointer()