lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

Fix formatting in HoodieWriteClient

Browse Source
This commit is contained in:
Vinoth Chandar
2018-02-13 17:40:09 -08:00
committed by vinoth chandar
parent 3bdd750982
commit eb3d0c470f
1 changed files with 784 additions and 792 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
hoodie-client/src/main/java/com/uber/hoodie/HoodieWriteClient.java
View File

@@ -57,7 +57,6 @@ import java.io.IOException;
import java.io.Serializable; import java.io.Serializable;
import java.nio.charset.StandardCharsets; import java.nio.charset.StandardCharsets;
import java.text.ParseException; import java.text.ParseException;
import java.util.Arrays;
import java.util.Collections; import java.util.Collections;
import java.util.Date; import java.util.Date;
import java.util.HashMap; import java.util.HashMap;
@@ -65,9 +64,7 @@ import java.util.List;
import java.util.Map; import java.util.Map;
import java.util.Optional; import java.util.Optional;
import java.util.stream.Collectors; import java.util.stream.Collectors;
import org.apache.hadoop.fs.FileStatus;
import org.apache.hadoop.fs.FileSystem; import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path;
import org.apache.log4j.LogManager; import org.apache.log4j.LogManager;
import org.apache.log4j.Logger; import org.apache.log4j.Logger;
import org.apache.spark.Partitioner; import org.apache.spark.Partitioner;
@@ -846,11 +843,8 @@ public class HoodieWriteClient<T extends HoodieRecordPayload> implements Seriali
} }
/** /**
* Performs a compaction operation on a dataset. * Performs a compaction operation on a dataset. WARNING: Compaction operation cannot be executed
* WARNING: Compaction operation cannot be executed asynchronously. Please always use this serially * asynchronously. Please always use this serially before or after an insert/upsert action.
* before or after an insert/upsert action.
* @param compactionCommitTime
* @throws IOException
*/ */
private void compact(String compactionCommitTime) throws IOException { private void compact(String compactionCommitTime) throws IOException {
// Create a Hoodie table which encapsulated the commits and files visible // Create a Hoodie table which encapsulated the commits and files visible
@@ -866,10 +860,8 @@ public class HoodieWriteClient<T extends HoodieRecordPayload> implements Seriali
} }
/** /**
* Performs a compaction operation on a dataset. * Performs a compaction operation on a dataset. WARNING: Compaction operation cannot be executed
* WARNING: Compaction operation cannot be executed asynchronously. Please always use this serially * asynchronously. Please always use this serially before or after an insert/upsert action.
* before or after an insert/upsert action.
* @throws IOException
*/ */
public String forceCompact() throws IOException { public String forceCompact() throws IOException {
String compactionCommitTime = HoodieActiveTimeline.createNewCommitTime(); String compactionCommitTime = HoodieActiveTimeline.createNewCommitTime();