lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

[MINOR] optimize in constructor of inputbatch class (#4040)

Browse Source 
Co-authored-by: 闫杜峰 <yandufeng@sinochem.com>
This commit is contained in:
dufeng1010
2021-11-21 10:11:01 +08:00
committed by GitHub
parent 1a5484d2db
commit 305d160081
1 changed files with 1 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/InputBatch.java
View File

@@ -39,9 +39,7 @@ public class InputBatch<T> {
} }
public InputBatch(Option<T> batch, String checkpointForNextBatch) { public InputBatch(Option<T> batch, String checkpointForNextBatch) {
this.batch = batch; this(batch, checkpointForNextBatch, null);
this.checkpointForNextBatch = checkpointForNextBatch;
this.schemaProvider = null;
} }
public Option<T> getBatch() { public Option<T> getBatch() {