void |
FeatureGroupBaseForApi.commitDeleteRecord(FeatureGroupBaseForApi featureData) |
void |
FeatureGroupBaseForApi.commitDeleteRecord(FeatureGroupBaseForApi featureData,
Map<String,String> writeOptions) |
void |
FeatureGroupBaseForApi.insert(FeatureGroupBaseForApi featureData) |
void |
FeatureGroupBaseForApi.insert(FeatureGroupBaseForApi featureData,
boolean overwrite) |
void |
FeatureGroupBaseForApi.insert(FeatureGroupBaseForApi featureData,
boolean overwrite,
Map<String,String> writeOptions) |
void |
FeatureGroupBaseForApi.insert(FeatureGroupBaseForApi featureData,
boolean overwrite,
Map<String,String> writeOptions,
JobConfiguration jobConfiguration) |
void |
FeatureGroupBaseForApi.insert(FeatureGroupBaseForApi featureData,
HudiOperationType operation) |
void |
FeatureGroupBaseForApi.insert(FeatureGroupBaseForApi featureData,
JobConfiguration jobConfiguration) |
void |
FeatureGroupBaseForApi.insert(FeatureGroupBaseForApi featureData,
Map<String,String> writeOptions) |
void |
FeatureGroupBaseForApi.insert(FeatureGroupBaseForApi featureData,
Storage storage) |
void |
FeatureGroupBaseForApi.insert(FeatureGroupBaseForApi featureData,
Storage storage,
boolean overwrite) |
void |
FeatureGroupBaseForApi.insert(FeatureGroupBaseForApi featureData,
Storage storage,
boolean overwrite,
HudiOperationType operation,
Map<String,String> writeOptions) |
Object |
FeatureGroupBaseForApi.insertStream(FeatureGroupBaseForApi featureData) |
Object |
FeatureGroupBaseForApi.insertStream(FeatureGroupBaseForApi featureData,
Map<String,String> writeOptions) |
Object |
FeatureGroupBaseForApi.insertStream(FeatureGroupBaseForApi featureData,
String queryName) |
Object |
FeatureGroupBaseForApi.insertStream(FeatureGroupBaseForApi featureData,
String queryName,
Map<String,String> writeOptions) |
Object |
FeatureGroupBaseForApi.insertStream(FeatureGroupBaseForApi featureData,
String queryName,
String outputMode) |
Object |
FeatureGroupBaseForApi.insertStream(FeatureGroupBaseForApi featureData,
String queryName,
String outputMode,
boolean awaitTermination,
Long timeout) |
Object |
FeatureGroupBaseForApi.insertStream(FeatureGroupBaseForApi featureData,
String queryName,
String outputMode,
boolean awaitTermination,
Long timeout,
String checkpointLocation) |
Object |
FeatureGroupBaseForApi.insertStream(FeatureGroupBaseForApi featureData,
String queryName,
String outputMode,
boolean awaitTermination,
Long timeout,
String checkpointLocation,
Map<String,String> writeOptions) |
Object |
FeatureGroupBaseForApi.insertStream(FeatureGroupBaseForApi featureData,
String queryName,
String outputMode,
boolean awaitTermination,
Long timeout,
String checkpointLocation,
Map<String,String> writeOptions,
JobConfiguration jobConfiguration) |
Object |
FeatureGroupBaseForApi.insertStream(FeatureGroupBaseForApi featureData,
String queryName,
String outputMode,
boolean awaitTermination,
String checkpointLocation) |
Object |
FeatureGroupBaseForApi.insertStream(FeatureGroupBaseForApi featureData,
String queryName,
String outputMode,
String checkpointLocation) |