Package io.delta.kernel.defaults.engine

Class DefaultEngine

Object
io.delta.kernel.defaults.engine.DefaultEngine
All Implemented Interfaces:
io.delta.kernel.engine.Engine
public class DefaultEngine extends Object implements io.delta.kernel.engine.Engine
Default implementation of Engine based on Hadoop APIs.

  • Method Details

    • getExpressionHandler

      public io.delta.kernel.engine.ExpressionHandler getExpressionHandler()
      Specified by:
      getExpressionHandler in interface io.delta.kernel.engine.Engine

    • getJsonHandler

      public io.delta.kernel.engine.JsonHandler getJsonHandler()
      Specified by:
      getJsonHandler in interface io.delta.kernel.engine.Engine

    • getFileSystemClient

      public io.delta.kernel.engine.FileSystemClient getFileSystemClient()
      Specified by:
      getFileSystemClient in interface io.delta.kernel.engine.Engine

    • getParquetHandler

      public io.delta.kernel.engine.ParquetHandler getParquetHandler()
      Specified by:
      getParquetHandler in interface io.delta.kernel.engine.Engine

    • getMetricsReporters

      public List<io.delta.kernel.engine.MetricsReporter> getMetricsReporters()
      Specified by:
      getMetricsReporters in interface io.delta.kernel.engine.Engine

    • create

      public static DefaultEngine create(org.apache.hadoop.conf.Configuration hadoopConf)
      Create an instance of DefaultEngine.
      Parameters:
      hadoopConf - Hadoop configuration to use.
      Returns:
      an instance of DefaultEngine.

    • create

      public static DefaultEngine create(FileIO fileIO)
      Create an instance of DefaultEngine. It takes FileIO as an argument which is used for I/O related operations.
      Parameters:
      fileIO - File IO implementation to use for reading and writing files.
      Returns:
      an instance of DefaultEngine.