[jira] [Updated] (HUDI-981) Add async compact implemetation to hudi-flink-client

[wangxianghu (Jira)]

 [ 
https://issues.apache.org/jira/browse/HUDI-981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

wangxianghu updated HUDI-981:
-
Summary: Add async compact implemetation to hudi-flink-client  (was: 
Introduce AbstractHoodieIndex for hudi write client)

> Add async compact implemetation to hudi-flink-client
> 
>
> Key: HUDI-981
> URL: https://issues.apache.org/jira/browse/HUDI-981
> Project: Apache Hudi
>  Issue Type: Sub-task
>Reporter: wangxianghu
>Assignee: wangxianghu
>Priority: Major
>
> At a high level, HoodieIndex should be irrelevant to engines. So we should 
> abstract it.
> would be like this
> {code:java}
> public abstract class AbstractHoodieIndex, 
> I, K, O, P> implements Serializable {
>   protected final HoodieWriteConfig config;
>   protected AbstractHoodieIndex(HoodieWriteConfig config) {
> this.config = config;
>   }
>   public abstract P fetchRecordLocation(HoodieWriteInput inputs, final 
> HoodieEngineContext context, HoodieTable hoodieTable);
>   public abstract HoodieWriteInput tagLocation(HoodieWriteInput inputs, 
> HoodieEngineContext context, HoodieTable table);
>   public abstract HoodieWriteOutput updateLocation(HoodieWriteOutput 
> inputs, HoodieEngineContext context, HoodieTable table);
> ...
> }{code}
>  



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

[jira] [Updated] (HUDI-981) Add async compact implemetation to hudi-flink-client

[wangxianghu (Jira)]

 [ 
https://issues.apache.org/jira/browse/HUDI-981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

wangxianghu updated HUDI-981:
-
Description: Add async compact implemetation to hudi-flink-client

> Add async compact implemetation to hudi-flink-client
> 
>
> Key: HUDI-981
> URL: https://issues.apache.org/jira/browse/HUDI-981
> Project: Apache Hudi
>  Issue Type: Sub-task
>Reporter: wangxianghu
>Assignee: wangxianghu
>Priority: Major
>
> Add async compact implemetation to hudi-flink-client



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

[jira] [Updated] (HUDI-981) Add async compact implemetation to hudi-flink-client

[wangxianghu (Jira)]

 [ 
https://issues.apache.org/jira/browse/HUDI-981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

wangxianghu updated HUDI-981:
-
Description: (was: At a high level, HoodieIndex should be irrelevant to 
engines. So we should abstract it.

would be like this
{code:java}
public abstract class AbstractHoodieIndex, I, 
K, O, P> implements Serializable {

  protected final HoodieWriteConfig config;

  protected AbstractHoodieIndex(HoodieWriteConfig config) {
this.config = config;
  }

  public abstract P fetchRecordLocation(HoodieWriteInput inputs, final 
HoodieEngineContext context, HoodieTable hoodieTable);

  public abstract HoodieWriteInput tagLocation(HoodieWriteInput inputs, 
HoodieEngineContext context, HoodieTable table);

  public abstract HoodieWriteOutput updateLocation(HoodieWriteOutput 
inputs, HoodieEngineContext context, HoodieTable table);
...
}{code}
 )

> Add async compact implemetation to hudi-flink-client
> 
>
> Key: HUDI-981
> URL: https://issues.apache.org/jira/browse/HUDI-981
> Project: Apache Hudi
>  Issue Type: Sub-task
>Reporter: wangxianghu
>Assignee: wangxianghu
>Priority: Major
>




--
This message was sent by Atlassian Jira
(v8.3.4#803005)