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 and Description
protected static org.slf4j.Logger	LOGGER
StorageConnectorApi	storageConnectorApi

Constructor Summary

Constructors

Constructor and Description
EngineBase()

Method Summary

Modifier and Type	Method and 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 Detail

LOGGER

protected static final org.slf4j.Logger LOGGER

storageConnectorApi

public StorageConnectorApi storageConnectorApi

Constructor Detail

EngineBase

public EngineBase()

Method Detail

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