yanghua commented on a change in pull request #3151:
URL: https://github.com/apache/hudi/pull/3151#discussion_r658572030
##########
File path:
hudi-flink/src/main/java/org/apache/hudi/streamer/FlinkStreamerConfig.java
##########
@@ -130,6 +131,183 @@
@Parameter(names = {"--write-task-num"}, description = "Parallelism of tasks
that do actual write, default is 4.")
public Integer writeTaskNum = 4;
+ @Parameter(names = {"--partition-default-name"},
+ description = "The default partition name in case the dynamic
partition column value is null/empty string")
+ public String partitionDefaultName = "__DEFAULT_PARTITION__";
+
+ @Parameter(names = {"--index-bootstrap-enabled"},
+ description = "Whether to bootstrap the index state from existing
hoodie table, default false")
+ public Boolean indexBootstrapEnabled = false;
+
+ @Parameter(names = {"--index-state-ttl"}, description = "Index state ttl in
days, default 1.5 day")
+ public Double indexStateTtl = 1.5D;
+
+ @Parameter(names = {"--index-global-enabled"}, description = "Whether to
update index for the old partition path " +
+ "if same key record with different partition path came in, default
false")
+ public Boolean indexGlobalEnabled = false;
+
+ @Parameter(names = {"--index-partition-regex"},
+ description = "Whether to load partitions in state if partition path
matching， default *")
+ public String indexPartitionRegex = ".*";
+
+ @Parameter(names = {"--read-tasks-parallelism"}, description = "Parallelism
of tasks that do actual read, default is 4")
+ public Integer readTasksParallelism = 4;
+
+ @Parameter(names = {"--avro-schema-path"}, description = "Avro schema file
path, the parsed schema is used for deserialization")
+ public String avroSchemaPath;
+
+ @Parameter(names = {"--avro-schema"}, description = "Avro schema string, the
parsed schema is used for deserialization")
+ public String avroSchema;
Review comment:
It has no default value, and is not required. It would cause exception
when copying if we do not verify before setting.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
