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 and Description
FsQuery()

Method Summary

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

FsQuery

public FsQuery()

Method Detail

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