Package com.logicalclocks.hsfs.beam.engine

Class BeamEngine

java.lang.Object

com.logicalclocks.hsfs.engine.EngineBase

com.logicalclocks.hsfs.beam.engine.BeamEngine

public class BeamEngine
extends EngineBase

Field Summary

Fields inherited from class com.logicalclocks.hsfs.engine.EngineBase

LOGGER, storageConnectorApi

Method Summary

Modifier and Type	Method	Description
String	addFile(String filePath)
static BeamEngine	getInstance()
Map<String,String>	getKafkaConfig(FeatureGroupBase featureGroup, Map<String,String> writeOptions)
BeamProducer	insertStream(StreamFeatureGroup streamFeatureGroup, Map<String,String> writeOptions)

Methods inherited from class java.lang.Object

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

Method Details

getInstance

public static BeamEngine getInstance()
                              throws FeatureStoreException

Throws:

FeatureStoreException

insertStream

public BeamProducer insertStream(StreamFeatureGroup streamFeatureGroup,
 Map<String,String> writeOptions)
                          throws FeatureStoreException,
IOException

Throws:

FeatureStoreException

IOException

addFile

public String addFile(String filePath)
               throws IOException,
FeatureStoreException

Specified by:

addFile in class EngineBase

Throws:

IOException

FeatureStoreException

getKafkaConfig

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

Specified by:

getKafkaConfig in class EngineBase

Throws:

FeatureStoreException

IOException