satishkotha commented on a change in pull request #2263:
URL: https://github.com/apache/hudi/pull/2263#discussion_r532813395
##########
File path:
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/HoodieTable.java
##########
@@ -326,6 +327,28 @@ public HoodieActiveTimeline getActiveTimeline() {
public abstract HoodieWriteMetadata<O> compact(HoodieEngineContext context,
String compactionInstantTime);
+
+ /**
+ * Schedule clustering for the instant time.
+ *
+ * @param context HoodieEngineContext
+ * @param instantTime Instant Time for scheduling clustering
+ * @param extraMetadata additional metadata to write into plan
+ * @return HoodieClusteringPlan, if there is enough data for clustering.
+ */
+ public abstract Option<HoodieClusteringPlan>
scheduleClustering(HoodieEngineContext context,
+ String
instantTime,
+
Option<Map<String, String>> extraMetadata);
+
+ /**
+ * Run Clustering on the table. Clustering re-arranges the data so that it
is optimized for data access.
+ *
+ * @param context HoodieEngineContext
+ * @param clusteringInstantTime Instant Time
+ */
+ public abstract HoodieWriteMetadata<O> clustering(HoodieEngineContext
context,
Review comment:
Fixed
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
