Package com.logicalclocks.hsfs.engine

Class EngineBase

java.lang.Object

com.logicalclocks.hsfs.engine.EngineBase

Direct Known Subclasses:

BeamEngine, Engine, FlinkEngine, SparkEngine

public abstract class EngineBase
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
protected static final org.slf4j.Logger	LOGGER
StorageConnectorApi	storageConnectorApi

Constructor Summary

Constructors

Constructor	Description
EngineBase()

Method Summary

Modifier and Type	Method	Description
abstract String	addFile(String filePath)
abstract Map<String,String>	getKafkaConfig(FeatureGroupBase featureGroup, Map<String,String> writeOptions)

Methods inherited from class java.lang.Object

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

Field Details

LOGGER

protected static final org.slf4j.Logger LOGGER

storageConnectorApi

public StorageConnectorApi storageConnectorApi

Constructor Details

EngineBase

public EngineBase()

Method Details

addFile

public abstract String addFile(String filePath)
                        throws IOException,
FeatureStoreException

Throws:

IOException

FeatureStoreException

getKafkaConfig

public abstract Map<String,String> getKafkaConfig(FeatureGroupBase featureGroup,
 Map<String,String> writeOptions)
                                           throws FeatureStoreException,
IOException

Throws:

FeatureStoreException

IOException