io.delta.kernel.engine

Interface Engine

All Known Implementing Classes:

DefaultEngine

@Evolving
public interface Engine

Interface encapsulating all clients needed by the Delta Kernel in order to read the Delta table. Connectors are expected to pass an implementation of this interface when reading a Delta table.

Since:

3.0.0

Method Summary

Modifier and Type	Method and Description
CommitCoordinatorClientHandler	getCommitCoordinatorClientHandler(String name, java.util.Map<String,String> conf) Retrieves a CommitCoordinatorClientHandler for the specified commit coordinator client.
ExpressionHandler	getExpressionHandler() Get the connector provided ExpressionHandler.
FileSystemClient	getFileSystemClient() Get the connector provided FileSystemClient.
JsonHandler	getJsonHandler() Get the connector provided JsonHandler.
ParquetHandler	getParquetHandler() Get the connector provided ParquetHandler.

Method Detail

getExpressionHandler

ExpressionHandler getExpressionHandler()

Get the connector provided ExpressionHandler.

Returns:

An implementation of ExpressionHandler.

getJsonHandler

JsonHandler getJsonHandler()

Get the connector provided JsonHandler.

Returns:

An implementation of JsonHandler.

getFileSystemClient

FileSystemClient getFileSystemClient()

Get the connector provided FileSystemClient.

Returns:

An implementation of FileSystemClient.

getParquetHandler

ParquetHandler getParquetHandler()

Get the connector provided ParquetHandler.

Returns:

An implementation of ParquetHandler.

getCommitCoordinatorClientHandler

CommitCoordinatorClientHandler getCommitCoordinatorClientHandler(String name,
                                                                 java.util.Map<String,String> conf)

Retrieves a CommitCoordinatorClientHandler for the specified commit coordinator client.

CommitCoordinatorClientHandler helps Kernel perform commits to a table which is owned by a commit coordinator.

Parameters:

name - The identifier or name of the underlying commit coordinator client

conf - The configuration settings for the underlying commit coordinator client

Returns:

An implementation of CommitCoordinatorClientHandler configured for the specified client

Since:

3.3.0

See Also:

Coordinated commit protocol table feature.

This method creates and returns an implementation of {@link CommitCoordinatorClientHandler} based on the provided name and configuration of the underlying commit coordinator client.