risingwave_connector/sink/iceberg/
engine_options.rs1pub const ICEBERG_ENGINE_OPTION_KEYS: &[&str] = &[
19 "partition_by",
20 "order_key",
21 "commit_checkpoint_interval",
22 "enable_compaction",
23 "compaction_interval_sec",
24 "enable_snapshot_expiration",
25 "write_mode",
26 "format_version",
27 "snapshot_expiration_max_age_millis",
28 "snapshot_expiration_retain_last",
29 "snapshot_expiration_clear_expired_files",
30 "snapshot_expiration_clear_expired_meta_data",
31 "enable_manifest_rewrite",
32 "manifest_rewrite_target_size_bytes",
33 "manifest_rewrite_min_count_to_merge",
34 "compaction.max_snapshots_num",
35 "compaction.small_files_threshold_mb",
36 "compaction.delete_files_count_threshold",
37 "compaction.trigger_snapshot_count",
38 "compaction.target_file_size_mb",
39 "compaction.type",
40 "compaction.write_parquet_compression",
41 "compaction.write_parquet_max_row_group_rows",
42 "compaction.write_parquet_max_row_group_bytes",
43 "enable_pk_index",
44];
45
46pub fn is_iceberg_engine_option(key: &str) -> bool {
47 ICEBERG_ENGINE_OPTION_KEYS.contains(&key)
48}