lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

[MINOR] Add omissive param desc on method doc and cleanup redundant code (#1437)

Browse Source
This commit is contained in:
Zhiyuan Zhao
2020-03-22 21:39:33 +08:00
committed by GitHub
parent 8b00791ef4
commit 06652aa935
2 changed files with 4 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
hudi-client/src/main/java/org/apache/hudi/client/AbstractHoodieWriteClient.java
View File

@@ -417,17 +417,4 @@ public abstract class AbstractHoodieWriteClient<T extends HoodieRecordPayload> e
} }
} }
/**
* Refers to different operation types.
*/
enum OperationType {
INSERT,
INSERT_PREPPED,
UPSERT,
UPSERT_PREPPED,
DELETE,
BULK_INSERT,
BULK_INSERT_PREPPED,
BOOTSTRAP
}
} }

7
hudi-utilities/src/main/java/org/apache/hudi/utilities/deltastreamer/DeltaSync.java
View File

@@ -342,9 +342,10 @@ public class DeltaSync implements Serializable {
/** /**
* Perform Hoodie Write. Run Cleaner, schedule compaction and syncs to hive if needed. * Perform Hoodie Write. Run Cleaner, schedule compaction and syncs to hive if needed.
* *
* @param records Input Records * @param records Input Records
* @param checkpointStr Checkpoint String * @param checkpointStr Checkpoint String
* @param metrics Metrics * @param metrics Metrics
* @param overallTimerContext Timer Context
* @return Option Compaction instant if one is scheduled * @return Option Compaction instant if one is scheduled
*/ */
private Option<String> writeToSink(JavaRDD<HoodieRecord> records, String checkpointStr, private Option<String> writeToSink(JavaRDD<HoodieRecord> records, String checkpointStr,