Package io.delta.kernel.defaults.engine

Class DefaultEngine

Object

io.delta.kernel.defaults.engine.DefaultEngine

All Implemented Interfaces:

Engine

public class DefaultEngine
extends Object
implements Engine

Default implementation of Engine based on Hadoop APIs.

Method Summary

Modifier and Type	Method	Description
static DefaultEngine	create(FileIO fileIO)	Create an instance of DefaultEngine.
static DefaultEngine	create(org.apache.hadoop.conf.Configuration hadoopConf)	Create an instance of DefaultEngine.
ExpressionHandler	getExpressionHandler()	Get the connector provided ExpressionHandler.
FileSystemClient	getFileSystemClient()	Get the connector provided FileSystemClient.
JsonHandler	getJsonHandler()	Get the connector provided JsonHandler.
List<MetricsReporter>	getMetricsReporters()	Get the engine's MetricsReporter instances to push reports to.
ParquetHandler	getParquetHandler()	Get the connector provided ParquetHandler.

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

getExpressionHandler

public ExpressionHandler getExpressionHandler()

Description copied from interface: Engine

Get the connector provided ExpressionHandler.

Specified by:

getExpressionHandler in interface Engine

Returns:

An implementation of ExpressionHandler.

getJsonHandler

public JsonHandler getJsonHandler()

Description copied from interface: Engine

Get the connector provided JsonHandler.

Specified by:

getJsonHandler in interface Engine

Returns:

An implementation of JsonHandler.

getFileSystemClient

public FileSystemClient getFileSystemClient()

Description copied from interface: Engine

Get the connector provided FileSystemClient.

Specified by:

getFileSystemClient in interface Engine

Returns:

An implementation of FileSystemClient.

getParquetHandler

public ParquetHandler getParquetHandler()

Description copied from interface: Engine

Get the connector provided ParquetHandler.

Specified by:

getParquetHandler in interface Engine

Returns:

An implementation of ParquetHandler.

getMetricsReporters

public List<MetricsReporter> getMetricsReporters()

Description copied from interface: Engine

Get the engine's MetricsReporter instances to push reports to.

Specified by:

getMetricsReporters in interface 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.