com.logicalclocks.hsfs.metadata

Class FeatureGroupApi

java.lang.Object

com.logicalclocks.hsfs.metadata.FeatureGroupApi

public class FeatureGroupApi
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
static String	FEATURE_GROUP_CLEAR_PATH
static String	FEATURE_GROUP_COMMIT_PATH
static String	FEATURE_GROUP_ID_PATH
static String	FEATURE_GROUP_PATH
static String	FEATURE_GROUP_ROOT_PATH

Constructor Summary

Constructors

Constructor and Description
FeatureGroupApi()

Method Summary

Modifier and Type	Method and Description
void	delete(FeatureGroupBase featureGroupBase)
void	deleteContent(FeatureGroupBase featureGroup)
FeatureGroupCommit	featureGroupCommit(FeatureGroupBase featureGroup, FeatureGroupCommit featureGroupCommit)
List<FeatureGroupCommit>	getCommitDetails(FeatureGroupBase featureGroupBase, Long wallclockTimestamp, Integer limit)
<T> T	getInternal(FeatureStoreBase featureStoreBase, String fgName, Integer fgVersion, Class<T> fgType)
<U extends FeatureGroupBase> FeatureGroupBase	save(FeatureGroupBase featureGroup, Class<U> fgType)
<U extends FeatureGroupBase> FeatureGroupBase	saveFeatureGroupMetaData(FeatureGroupBase featureGroup, List<String> partitionKeys, String hudiPrecombineKey, Map<String,String> writeOptions, JobConfiguration jobConfiguration, Class<U> fgType)
<U extends FeatureGroupBase> FeatureGroupBase	saveInternal(FeatureGroupBase featureGroupBase, org.apache.http.entity.StringEntity entity, Class<U> fgType)
<T extends FeatureGroupBase> T	updateMetadata(FeatureGroupBase featureGroup, String queryParameter, Class<T> fgType)
<T extends FeatureGroupBase> T	updateMetadata(FeatureGroupBase featureGroup, String queryParameter, Object value, Class<T> fgType)

Methods inherited from class java.lang.Object

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

Field Detail

FEATURE_GROUP_ROOT_PATH

public static final String FEATURE_GROUP_ROOT_PATH

See Also:

Constant Field Values

FEATURE_GROUP_PATH

public static final String FEATURE_GROUP_PATH

See Also:

Constant Field Values

FEATURE_GROUP_ID_PATH

public static final String FEATURE_GROUP_ID_PATH

See Also:

Constant Field Values

FEATURE_GROUP_COMMIT_PATH

public static final String FEATURE_GROUP_COMMIT_PATH

See Also:

Constant Field Values

FEATURE_GROUP_CLEAR_PATH

public static final String FEATURE_GROUP_CLEAR_PATH

See Also:

Constant Field Values

Constructor Detail

FeatureGroupApi

public FeatureGroupApi()

Method Detail

getInternal

public <T> T getInternal(FeatureStoreBase featureStoreBase,
                         String fgName,
                         Integer fgVersion,
                         Class<T> fgType)
                  throws FeatureStoreException,
                         IOException

Throws:

FeatureStoreException

IOException

save

public <U extends FeatureGroupBase> FeatureGroupBase save(FeatureGroupBase featureGroup,
                                                          Class<U> fgType)
                                                   throws FeatureStoreException,
                                                          IOException

Throws:

FeatureStoreException

IOException

saveInternal

public <U extends FeatureGroupBase> FeatureGroupBase saveInternal(FeatureGroupBase featureGroupBase,
                                                                  org.apache.http.entity.StringEntity entity,
                                                                  Class<U> fgType)
                                                           throws FeatureStoreException,
                                                                  IOException

Throws:

FeatureStoreException

IOException

delete

public void delete(FeatureGroupBase featureGroupBase)
            throws FeatureStoreException,
                   IOException

Throws:

FeatureStoreException

IOException

deleteContent

public void deleteContent(FeatureGroupBase featureGroup)
                   throws FeatureStoreException,
                          IOException

Throws:

FeatureStoreException

IOException

updateMetadata

public <T extends FeatureGroupBase> T updateMetadata(FeatureGroupBase featureGroup,
                                                     String queryParameter,
                                                     Class<T> fgType)
                                              throws FeatureStoreException,
                                                     IOException

Throws:

FeatureStoreException

IOException

updateMetadata

public <T extends FeatureGroupBase> T updateMetadata(FeatureGroupBase featureGroup,
                                                     String queryParameter,
                                                     Object value,
                                                     Class<T> fgType)
                                              throws FeatureStoreException,
                                                     IOException

Throws:

FeatureStoreException

IOException

featureGroupCommit

public FeatureGroupCommit featureGroupCommit(FeatureGroupBase featureGroup,
                                             FeatureGroupCommit featureGroupCommit)
                                      throws FeatureStoreException,
                                             IOException

Throws:

FeatureStoreException

IOException

getCommitDetails

public List<FeatureGroupCommit> getCommitDetails(FeatureGroupBase featureGroupBase,
                                                 Long wallclockTimestamp,
                                                 Integer limit)
                                          throws IOException,
                                                 FeatureStoreException

Throws:

IOException

FeatureStoreException

saveFeatureGroupMetaData

public <U extends FeatureGroupBase> FeatureGroupBase saveFeatureGroupMetaData(FeatureGroupBase featureGroup,
                                                                              List<String> partitionKeys,
                                                                              String hudiPrecombineKey,
                                                                              Map<String,String> writeOptions,
                                                                              JobConfiguration jobConfiguration,
                                                                              Class<U> fgType)
                                                                       throws FeatureStoreException,
                                                                              IOException

Throws:

FeatureStoreException

IOException