Package 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	Description
static final String	FEATURE_GROUP_CLEAR_PATH
static final String	FEATURE_GROUP_COMMIT_PATH
static final String	FEATURE_GROUP_ID_PATH
static final String	FEATURE_GROUP_PATH
static final String	FEATURE_GROUP_ROOT_PATH

Constructor Summary

Constructors

Constructor	Description
FeatureGroupApi()

Method Summary

Modifier and Type	Method	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 extends FeatureGroupBase> 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 Details

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 Details

FeatureGroupApi

public FeatureGroupApi()

Method Details

getInternal

public <T extends FeatureGroupBase> 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