[MINOR] typo fix (#1142)
This commit is contained in:
committed by
vinoth chandar
parent
842eabb27f
commit
f20a130e3a
@@ -74,7 +74,7 @@ import java.util.stream.IntStream;
|
|||||||
*
|
*
|
||||||
* In continuous mode, DeltaStreamer runs in loop-mode going through the below operations (a) pull-from-source (b)
|
* In continuous mode, DeltaStreamer runs in loop-mode going through the below operations (a) pull-from-source (b)
|
||||||
* write-to-sink (c) Schedule Compactions if needed (d) Conditionally Sync to Hive each cycle. For MOR table with
|
* write-to-sink (c) Schedule Compactions if needed (d) Conditionally Sync to Hive each cycle. For MOR table with
|
||||||
* continuous mode enabled, a seperate compactor thread is allocated to execute compactions
|
* continuous mode enabled, a separate compactor thread is allocated to execute compactions
|
||||||
*/
|
*/
|
||||||
public class HoodieDeltaStreamer implements Serializable {
|
public class HoodieDeltaStreamer implements Serializable {
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user