com.logicalclocks.hsfs.flink.engine

Class FeatureGroupEngine

java.lang.Object

com.logicalclocks.hsfs.engine.FeatureGroupEngineBase

com.logicalclocks.hsfs.flink.engine.FeatureGroupEngine

public class FeatureGroupEngine
extends FeatureGroupEngineBase

Field Summary

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

featureGroupApi, LOGGER, tagsApi, utils

Constructor Summary

Constructors

Constructor and Description
FeatureGroupEngine()

Method Summary

Modifier and Type	Method and Description
StreamFeatureGroup	getStreamFeatureGroup(FeatureStore featureStore, String fgName, Integer fgVersion)
List<StreamFeatureGroup>	getStreamFeatureGroups(FeatureStore featureStore, String fgName)
org.apache.flink.streaming.api.datastream.DataStreamSink<?>	insertStream(StreamFeatureGroup streamFeatureGroup, org.apache.flink.streaming.api.datastream.DataStream<?> featureData, Map<String,String> writeOptions)

Methods inherited from class com.logicalclocks.hsfs.engine.FeatureGroupEngineBase

addTag, delete, deleteTag, getTag, getTags, saveExtennalFeatureGroupMetaData, updateDescription, updateFeatures, updateStatisticsConfig

Methods inherited from class java.lang.Object

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

Constructor Detail

FeatureGroupEngine

public FeatureGroupEngine()

Method Detail

insertStream

public org.apache.flink.streaming.api.datastream.DataStreamSink<?> insertStream(StreamFeatureGroup streamFeatureGroup,
                                                                                org.apache.flink.streaming.api.datastream.DataStream<?> featureData,
                                                                                Map<String,String> writeOptions)

getStreamFeatureGroup

public StreamFeatureGroup getStreamFeatureGroup(FeatureStore featureStore,
                                                String fgName,
                                                Integer fgVersion)
                                         throws IOException,
                                                FeatureStoreException

Throws:

IOException

FeatureStoreException

getStreamFeatureGroups

public List<StreamFeatureGroup> getStreamFeatureGroups(FeatureStore featureStore,
                                                       String fgName)
                                                throws FeatureStoreException,
                                                       IOException

Throws:

FeatureStoreException

IOException