@Evolving public interface Engine
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 . |
ExpressionHandler getExpressionHandler()
ExpressionHandler
.ExpressionHandler
.JsonHandler getJsonHandler()
JsonHandler
.JsonHandler
.FileSystemClient getFileSystemClient()
FileSystemClient
.FileSystemClient
.ParquetHandler getParquetHandler()
ParquetHandler
.ParquetHandler
.CommitCoordinatorClientHandler getCommitCoordinatorClientHandler(String name, java.util.Map<String,String> conf)
CommitCoordinatorClientHandler
for the specified commit coordinator client.
CommitCoordinatorClientHandler
helps Kernel perform commits to a table which is
owned by a commit coordinator.
name
- The identifier or name of the underlying commit coordinator clientconf
- The configuration settings for the underlying commit coordinator clientCommitCoordinatorClientHandler
configured for the
specified clientThis method creates and returns an implementation of {@link CommitCoordinatorClientHandler} based on the provided name and configuration of the underlying commit coordinator client.