yuchuanchen commented on code in PR #21563:
URL: https://github.com/apache/flink/pull/21563#discussion_r1066533653
##########
flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/table/FileSystemConnectorOptions.java:
##########
@@ -68,6 +70,22 @@ public class FileSystemConnectorOptions {
+ "The statistics reporting is a heavy
operation in some cases,"
+ "this config allows users to choose the
statistics type according to different situations.");
+ public static final ConfigOption<List<String>>
+ SOURCE_NESTED_PROJECTION_PUSHDOWN_SUPPORTED_FORMATS =
+
ConfigOptions.key("source.nested.projection.pushdown.supported.formats")
+ .stringType()
+ .asList()
+ .defaultValues("parquet")
+ .withDescription("supported formats for nested
projection pushdown");
+
+ public static final ConfigOption<Boolean>
SOURCE_NESTED_PROJECTION_PUSHDOWN_ENABLED =
+ key("source.nested.projection.pushdown.enabled")
+ .booleanType()
+ .defaultValue(true)
+ .withDescription(
+ "Whether to push down nested projections, should
be configured in flink-conf.yaml")
+ .withDeprecatedKeys("nested.projection.pushdown");
Review Comment:
deprecated in our interval flink version. I will remove it.
--
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.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
