veenaypatil commented on a change in pull request #3151:
URL: https://github.com/apache/hudi/pull/3151#discussion_r658612045
##########
File path:
hudi-flink/src/main/java/org/apache/hudi/streamer/FlinkStreamerConfig.java
##########
@@ -130,6 +131,162 @@
@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 = {"--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 = "";
+
+ @Parameter(names = {"--utc-timezone"}, description = "Use UTC timezone or
local timezone to the conversion between epoch"
+ + " time and LocalDateTime. Hive 0.x/1.x/2.x use local timezone. But
Hive 3.x"
+ + " use UTC timezone, by default true")
+ public Boolean utcTimezone = true;
+
Review comment:
done
--
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]
