Package org.apache.beam.sdk.io.delta

Class BeamEngine

java.lang.Object

org.apache.beam.sdk.io.delta.BeamEngine

All Implemented Interfaces:

Engine

public class BeamEngine
extends Object
implements Engine

A Beam specific Engine wrapper that provides a custom ParquetHandler.

Constructor Summary

Constructors

Constructor	Description
BeamEngine(Engine delegate, ParquetHandler parquetHandler)

Method Summary

Modifier and Type	Method	Description
ExpressionHandler	getExpressionHandler()
FileSystemClient	getFileSystemClient()
JsonHandler	getJsonHandler()
ParquetHandler	getParquetHandler()

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.delta.kernel.engine.Engine

getMetricsReporters

Constructor Details

BeamEngine

public BeamEngine(Engine delegate,
 ParquetHandler parquetHandler)

Method Details

getExpressionHandler

public ExpressionHandler getExpressionHandler()

Specified by:

getExpressionHandler in interface Engine

getJsonHandler

public JsonHandler getJsonHandler()

Specified by:

getJsonHandler in interface Engine

getFileSystemClient

public FileSystemClient getFileSystemClient()

Specified by:

getFileSystemClient in interface Engine

getParquetHandler

public ParquetHandler getParquetHandler()

Specified by:

getParquetHandler in interface Engine