Package com.logicalclocks.hsfs.spark.constructor

Class FsQuery

java.lang.Object

com.logicalclocks.hsfs.constructor.FsQueryBase<StreamFeatureGroup,ExternalFeatureGroup>

com.logicalclocks.hsfs.spark.constructor.FsQuery

public class FsQuery
extends FsQueryBase<StreamFeatureGroup,ExternalFeatureGroup>

Constructor Summary

Constructors

Constructor	Description
FsQuery()

Method Summary

Modifier and Type	Method	Description
void	registerHudiFeatureGroups(Map<String,String> readOptions)
void	registerOnDemandFeatureGroups()

Methods inherited from class com.logicalclocks.hsfs.constructor.FsQueryBase

getStorageQuery, removeNewLines

Methods inherited from class java.lang.Object

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

Constructor Details

FsQuery

public FsQuery()

Method Details

registerOnDemandFeatureGroups

public void registerOnDemandFeatureGroups()
                                   throws FeatureStoreException,
IOException

Specified by:

registerOnDemandFeatureGroups in class FsQueryBase<StreamFeatureGroup,ExternalFeatureGroup>

Throws:

FeatureStoreException

IOException

registerHudiFeatureGroups

public void registerHudiFeatureGroups(Map<String,String> readOptions)
                               throws FeatureStoreException

Specified by:

registerHudiFeatureGroups in class FsQueryBase<StreamFeatureGroup,ExternalFeatureGroup>

Throws:

FeatureStoreException