| A | D | E | F | G | H | I | J | K | L | M | N | O | P | Q | R | S | T | U | V | W | X | Y | Z | |
|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|
1 | Order | Module | Class | Java/ Scala | Key | Default value | Advanced | Deprecated | Public/ private | Type | Constant | Duplicates | Comments | |||||||||||
2 | 1 | hudi-flink-datasource | CatalogOptions | java | catalog.path | 0 | 0 | public | String | CATALOG_PATH | ||||||||||||||
3 | 2 | hudi-flink-datasource | CatalogOptions | java | default-database | default | 0 | 0 | public | String | DEFAULT_DATABASE | |||||||||||||
4 | 3 | hudi-flink-datasource | CatalogOptions | java | hive.conf.dir | 0 | 0 | public | String | HIVE_CONF_DIR | ||||||||||||||
5 | 4 | hudi-flink-datasource | CatalogOptions | java | mode | dfs | 0 | 0 | public | String | MODE | |||||||||||||
6 | 5 | hudi-flink-datasource | CatalogOptions | java | table.external | FALSE | 0 | 0 | public | Boolean | TABLE_EXTERNAL | |||||||||||||
7 | 6 | hudi-flink-datasource | SchemaRegistryProvider | java | hoodie.streamer.schemaprovider.registry.url | 0 | 0 | private | String | SRC_SCHEMA_REGISTRY_URL | ||||||||||||||
8 | 7 | hudi-flink-datasource | SchemaRegistryProvider | java | hoodie.streamer.schemaprovider.registry.targetUrl | 0 | 0 | private | String | TARGET_SCHEMA_REGISTRY_URL | ||||||||||||||
9 | 8 | hudi-flink-datasource | FilebasedSchemaProvider | java | hoodie.streamer.schemaprovider.source.schema.file | 0 | 0 | private | String | SOURCE_SCHEMA_FILE | ||||||||||||||
10 | 9 | hudi-flink-datasource | FilebasedSchemaProvider | java | hoodie.streamer.schemaprovider.target.schema.file | 0 | 0 | private | String | TARGET_SCHEMA_FILE | ||||||||||||||
11 | 10 | hudi-flink-datasource | FlinkOptions | java | path | 0 | 0 | public | String | PATH | ||||||||||||||
12 | 11 | hudi-flink-datasource | FlinkOptions | java | hoodie.database.name | 0 | 0 | public | String | DATABASE_NAME | ||||||||||||||
13 | 12 | hudi-flink-datasource | FlinkOptions | java | hoodie.table.name | 0 | 0 | public | String | TABLE_NAME | ||||||||||||||
14 | 13 | hudi-flink-datasource | FlinkOptions | java | table.type | TABLE_TYPE_COPY_ON_WRITE | 0 | 0 | public | String | TABLE_TYPE | |||||||||||||
15 | 14 | hudi-flink-datasource | FlinkOptions | java | precombine.field | ts | 0 | 0 | public | String | PRECOMBINE_FIELD | |||||||||||||
16 | 15 | hudi-flink-datasource | FlinkOptions | java | payload.class | EventTimeAvroPayload.class.getName() | 1 | 0 | public | String | PAYLOAD_CLASS_NAME | |||||||||||||
17 | 16 | hudi-flink-datasource | FlinkOptions | java | write.insert.partitioner.class.name | 0 | 0 | public | String | INSERT_PARTITIONER_CLASS_NAME | ||||||||||||||
18 | 17 | hudi-flink-datasource | FlinkOptions | java | write.insert.partitioner.default_parallelism_per_partition | 30 | 0 | 0 | public | Integer | DEFAULT_PARALLELISM_PER_PARTITION | |||||||||||||
19 | 18 | hudi-flink-datasource | FlinkOptions | java | record.merger.impls | EventTimeFlinkRecordMerger.class.getName() | 1 | 0 | public | String | RECORD_MERGER_IMPLS | |||||||||||||
20 | 19 | hudi-flink-datasource | FlinkOptions | java | hoodie.write.record.merge.mode | 1 | 0 | public | String | RECORD_MERGE_MODE | ||||||||||||||
21 | 20 | hudi-flink-datasource | FlinkOptions | java | record.merger.strategy | HoodieRecordMerger.EVENT_TIME_BASED_MERGE_STRATEGY_UUID | 1 | 0 | public | String | RECORD_MERGER_STRATEGY_ID | |||||||||||||
22 | 21 | hudi-flink-datasource | FlinkOptions | java | partition.default_name | DEFAULT_PARTITION_PATH | 1 | 0 | public | String | PARTITION_DEFAULT_NAME | |||||||||||||
23 | 22 | hudi-flink-datasource | FlinkOptions | java | write.extra.metadata.enabled | FALSE | 1 | 0 | public | Boolean | WRITE_EXTRA_METADATA_ENABLED | |||||||||||||
24 | 23 | hudi-flink-datasource | FlinkOptions | java | changelog.enabled | FALSE | 0 | 0 | public | Boolean | CHANGELOG_ENABLED | |||||||||||||
25 | 24 | hudi-flink-datasource | FlinkOptions | java | cdc.enabled | FALSE | 0 | 0 | public | Boolean | CDC_ENABLED | |||||||||||||
26 | 25 | hudi-flink-datasource | FlinkOptions | java | cdc.supplemental.logging.mode | DATA_BEFORE_AFTER.name() | 0 | 0 | public | String | SUPPLEMENTAL_LOGGING_MODE | |||||||||||||
27 | 26 | hudi-flink-datasource | FlinkOptions | java | metadata.enabled | TRUE | 0 | 0 | public | Boolean | METADATA_ENABLED | |||||||||||||
28 | 27 | hudi-flink-datasource | FlinkOptions | java | metadata.compaction.delta_commits | 10 | 0 | 0 | public | Integer | METADATA_COMPACTION_DELTA_COMMITS | |||||||||||||
29 | 28 | hudi-flink-datasource | FlinkOptions | java | index.type | HoodieIndex.IndexType.FLINK_STATE.name() | 0 | 0 | public | String | INDEX_TYPE | |||||||||||||
30 | 29 | hudi-flink-datasource | FlinkOptions | java | index.bootstrap.enabled | FALSE | 1 | 0 | public | Boolean | INDEX_BOOTSTRAP_ENABLED | |||||||||||||
31 | 30 | hudi-flink-datasource | FlinkOptions | java | index.state.ttl | 0D | 1 | 0 | public | Double | INDEX_STATE_TTL | |||||||||||||
32 | 31 | hudi-flink-datasource | FlinkOptions | java | index.global.enabled | TRUE | 1 | 0 | public | Boolean | INDEX_GLOBAL_ENABLED | |||||||||||||
33 | 32 | hudi-flink-datasource | FlinkOptions | java | index.partition.regex | .* | 1 | 0 | public | String | INDEX_PARTITION_REGEX | |||||||||||||
34 | 33 | hudi-flink-datasource | FlinkOptions | java | read.tasks | 1 | 0 | public | Integer | READ_TASKS | ||||||||||||||
35 | 34 | hudi-flink-datasource | FlinkOptions | java | source.avro-schema.path | 1 | 0 | public | String | SOURCE_AVRO_SCHEMA_PATH | ||||||||||||||
36 | 35 | hudi-flink-datasource | FlinkOptions | java | source.avro-schema | 1 | 0 | public | String | SOURCE_AVRO_SCHEMA | ||||||||||||||
37 | 36 | hudi-flink-datasource | FlinkOptions | java | hoodie.datasource.query.type | QUERY_TYPE_SNAPSHOT | 0 | 0 | public | String | QUERY_TYPE | |||||||||||||
38 | 37 | hudi-flink-datasource | FlinkOptions | java | hoodie.datasource.merge.type | HoodieReaderConfig.MERGE_TYPE) | 1 | 0 | public | String | MERGE_TYPE | |||||||||||||
39 | 38 | hudi-flink-datasource | FlinkOptions | java | read.utc-timezone | TRUE | 1 | 0 | public | Boolean | READ_UTC_TIMEZONE | |||||||||||||
40 | 39 | hudi-flink-datasource | FlinkOptions | java | read.streaming.enabled | FALSE | 0 | 0 | public | Boolean | READ_AS_STREAMING | |||||||||||||
41 | 40 | hudi-flink-datasource | FlinkOptions | java | read.streaming.check-interval | 60 | 1 | 0 | public | Integer | READ_STREAMING_CHECK_INTERVAL | |||||||||||||
42 | 41 | hudi-flink-datasource | FlinkOptions | java | read.streaming.skip_compaction | TRUE | 0 | 0 | public | Boolean | READ_STREAMING_SKIP_COMPACT | |||||||||||||
43 | 42 | hudi-flink-datasource | FlinkOptions | java | read.streaming.skip_clustering | TRUE | 0 | 0 | public | Boolean | READ_STREAMING_SKIP_CLUSTERING | |||||||||||||
44 | 43 | hudi-flink-datasource | FlinkOptions | java | read.streaming.skip_insertoverwrite | FALSE | 0 | 0 | public | Boolean | READ_STREAMING_SKIP_INSERT_OVERWRITE | |||||||||||||
45 | 44 | hudi-flink-datasource | FlinkOptions | java | read.start-commit | 0 | 0 | public | String | READ_START_COMMIT | ||||||||||||||
46 | 45 | hudi-flink-datasource | FlinkOptions | java | read.end-commit | 0 | 0 | public | String | READ_END_COMMIT | ||||||||||||||
47 | 46 | hudi-flink-datasource | FlinkOptions | java | read.commits.limit | 0 | 0 | public | Integer | READ_COMMITS_LIMIT | ||||||||||||||
48 | 47 | hudi-flink-datasource | FlinkOptions | java | read.cdc.from.changelog | TRUE | 1 | 0 | public | Boolean | READ_CDC_FROM_CHANGELOG | |||||||||||||
49 | 48 | hudi-flink-datasource | FlinkOptions | java | read.data.skipping.enabled | FALSE | 1 | 0 | public | Boolean | READ_DATA_SKIPPING_ENABLED | |||||||||||||
50 | 49 | hudi-flink-datasource | FlinkOptions | java | write.insert.cluster | FALSE | 1 | 0 | public | Boolean | INSERT_CLUSTER | |||||||||||||
51 | 50 | hudi-flink-datasource | FlinkOptions | java | write.operation | WriteOperationType.UPSERT.value() | 0 | 0 | public | String | OPERATION | |||||||||||||
52 | 51 | hudi-flink-datasource | FlinkOptions | java | hoodie.write.table.version | HoodieWriteConfig.WRITE_TABLE_VERSION) | 1 | 0 | public | Integer | WRITE_TABLE_VERSION | |||||||||||||
53 | 52 | hudi-flink-datasource | FlinkOptions | java | hoodie.table.format | HoodieTableConfig.TABLE_FORMAT) | 1 | 0 | public | String | WRITE_TABLE_FORMAT | |||||||||||||
54 | 53 | hudi-flink-datasource | FlinkOptions | java | write.precombine | FALSE | 1 | 0 | public | Boolean | PRE_COMBINE | |||||||||||||
55 | 54 | hudi-flink-datasource | FlinkOptions | java | write.retry.times | 3 | 1 | 0 | public | Integer | RETRY_TIMES | |||||||||||||
56 | 55 | hudi-flink-datasource | FlinkOptions | java | write.retry.interval.ms | 2000L | 1 | 0 | public | Long | RETRY_INTERVAL_MS | |||||||||||||
57 | 56 | hudi-flink-datasource | FlinkOptions | java | write.ignore.failed | FALSE | 1 | 0 | public | Boolean | IGNORE_FAILED | |||||||||||||
58 | 57 | hudi-flink-datasource | FlinkOptions | java | write.fail.fast | FALSE | 1 | 0 | public | Boolean | WRITE_FAIL_FAST | |||||||||||||
59 | 58 | hudi-flink-datasource | FlinkOptions | java | hoodie.datasource.write.recordkey.field | uuid | 0 | 0 | public | String | RECORD_KEY_FIELD | |||||||||||||
60 | 59 | hudi-flink-datasource | FlinkOptions | java | hoodie.bucket.index.hash.field | 1 | 0 | public | String | INDEX_KEY_FIELD | ||||||||||||||
61 | 60 | hudi-flink-datasource | FlinkOptions | java | hoodie.index.bucket.engine | SIMPLE | 1 | 0 | public | String | BUCKET_INDEX_ENGINE_TYPE | |||||||||||||
62 | 61 | hudi-flink-datasource | FlinkOptions | java | hoodie.bucket.index.num.buckets | 4 | 1 | 0 | public | Integer | BUCKET_INDEX_NUM_BUCKETS | |||||||||||||
63 | 62 | hudi-flink-datasource | FlinkOptions | java | hoodie.bucket.index.partition.rule.type | HoodieIndexConfig.BUCKET_INDEX_PARTITION_RULE_TYPE) | 1 | 0 | public | String | BUCKET_INDEX_PARTITION_RULE | |||||||||||||
64 | 63 | hudi-flink-datasource | FlinkOptions | java | hoodie.bucket.index.partition.expressions | 1 | 0 | public | String | BUCKET_INDEX_PARTITION_EXPRESSIONS | ||||||||||||||
65 | 64 | hudi-flink-datasource | FlinkOptions | java | hoodie.datasource.write.partitionpath.field | 0 | 0 | public | String | PARTITION_PATH_FIELD | ||||||||||||||
66 | 65 | hudi-flink-datasource | FlinkOptions | java | hoodie.datasource.write.partitionpath.urlencode | FALSE | 1 | 0 | public | Boolean | URL_ENCODE_PARTITIONING | |||||||||||||
67 | 66 | hudi-flink-datasource | FlinkOptions | java | hoodie.datasource.write.hive_style_partitioning | FALSE | 0 | 0 | public | Boolean | HIVE_STYLE_PARTITIONING | |||||||||||||
68 | 67 | hudi-flink-datasource | FlinkOptions | java | hoodie.datasource.write.keygenerator.class | 1 | 0 | public | String | KEYGEN_CLASS_NAME | ||||||||||||||
69 | 68 | hudi-flink-datasource | FlinkOptions | java | hoodie.datasource.write.keygenerator.type | KeyGeneratorType.SIMPLE.name() | 1 | 0 | public | String | KEYGEN_TYPE | |||||||||||||
70 | 69 | hudi-flink-datasource | FlinkOptions | java | write.utc-timezone | TRUE | 1 | 0 | public | Boolean | WRITE_UTC_TIMEZONE | |||||||||||||
71 | 70 | hudi-flink-datasource | FlinkOptions | java | write.partition.format | 1 | 0 | public | String | PARTITION_FORMAT | ||||||||||||||
72 | 71 | hudi-flink-datasource | FlinkOptions | java | write.index_bootstrap.tasks | 1 | 0 | public | Integer | INDEX_BOOTSTRAP_TASKS | ||||||||||||||
73 | 72 | hudi-flink-datasource | FlinkOptions | java | write.bucket_assign.tasks | 1 | 0 | public | Integer | BUCKET_ASSIGN_TASKS | ||||||||||||||
74 | 73 | hudi-flink-datasource | FlinkOptions | java | write.tasks | 1 | 0 | public | Integer | WRITE_TASKS | ||||||||||||||
75 | 74 | hudi-flink-datasource | FlinkOptions | java | write.task.max.size | 1024D | 1 | 0 | public | Double | WRITE_TASK_MAX_SIZE | |||||||||||||
76 | 75 | hudi-flink-datasource | FlinkOptions | java | write.rate.limit | 0L | 1 | 0 | public | Long | WRITE_RATE_LIMIT | |||||||||||||
77 | 76 | hudi-flink-datasource | FlinkOptions | java | write.batch.size | 256D | 1 | 0 | public | Double | WRITE_BATCH_SIZE | |||||||||||||
78 | 77 | hudi-flink-datasource | FlinkOptions | java | write.log_block.size | 128 | 1 | 0 | public | Integer | WRITE_LOG_BLOCK_SIZE | |||||||||||||
79 | 78 | hudi-flink-datasource | FlinkOptions | java | write.log.max.size | 1024L | 1 | 0 | public | Long | WRITE_LOG_MAX_SIZE | |||||||||||||
80 | 79 | hudi-flink-datasource | FlinkOptions | java | write.parquet.block.size | 120 | 1 | 0 | public | Integer | WRITE_PARQUET_BLOCK_SIZE | |||||||||||||
81 | 80 | hudi-flink-datasource | FlinkOptions | java | write.parquet.max.file.size | 120 | 0 | 0 | public | Integer | WRITE_PARQUET_MAX_FILE_SIZE | |||||||||||||
82 | 81 | hudi-flink-datasource | FlinkOptions | java | write.parquet.page.size | 1 | 1 | 0 | public | Integer | WRITE_PARQUET_PAGE_SIZE | |||||||||||||
83 | 82 | hudi-flink-datasource | FlinkOptions | java | write.merge.max_memory | 100 | 1 | 0 | public | Integer | WRITE_MERGE_MAX_MEMORY | |||||||||||||
84 | 83 | hudi-flink-datasource | FlinkOptions | java | write.memory.segment.page.size | 32 * 1024 | 1 | 0 | public | Integer | WRITE_MEMORY_SEGMENT_PAGE_SIZE | |||||||||||||
85 | 84 | hudi-flink-datasource | FlinkOptions | java | write.commit.ack.timeout | 300_000L | 1 | 0 | public | Long | WRITE_COMMIT_ACK_TIMEOUT | |||||||||||||
86 | 85 | hudi-flink-datasource | FlinkOptions | java | write.incremental.job.graph.generation | FALSE | 1 | 0 | public | Boolean | WRITE_INCREMENTAL_JOB_GRAPH_GENERATION | |||||||||||||
87 | 86 | hudi-flink-datasource | FlinkOptions | java | write.bulk_insert.shuffle_input | TRUE | 1 | 0 | public | Boolean | WRITE_BULK_INSERT_SHUFFLE_INPUT | |||||||||||||
88 | 87 | hudi-flink-datasource | FlinkOptions | java | write.bulk_insert.sort_input | TRUE | 1 | 0 | public | Boolean | WRITE_BULK_INSERT_SORT_INPUT | |||||||||||||
89 | 88 | hudi-flink-datasource | FlinkOptions | java | write.bulk_insert.sort_input.by_record_key | FALSE | 1 | 0 | public | Boolean | WRITE_BULK_INSERT_SORT_INPUT_BY_RECORD_KEY | |||||||||||||
90 | 89 | hudi-flink-datasource | FlinkOptions | java | write.sort.memory | 128 | 1 | 0 | public | Integer | WRITE_SORT_MEMORY | |||||||||||||
91 | 90 | hudi-flink-datasource | FlinkOptions | java | write.partition.overwrite.mode | PartitionOverwriteMode.STATIC.name() | 1 | 0 | public | String | WRITE_PARTITION_OVERWRITE_MODE | |||||||||||||
92 | 91 | hudi-flink-datasource | FlinkOptions | java | write.client.id | ClientIds.INIT_CLIENT_ID | 1 | 0 | public | String | WRITE_CLIENT_ID | |||||||||||||
93 | 92 | hudi-flink-datasource | FlinkOptions | java | compaction.schedule.enabled | TRUE | 1 | 0 | public | Boolean | COMPACTION_SCHEDULE_ENABLED | |||||||||||||
94 | 93 | hudi-flink-datasource | FlinkOptions | java | compaction.async.enabled | TRUE | 0 | 0 | public | Boolean | COMPACTION_ASYNC_ENABLED | |||||||||||||
95 | 94 | hudi-flink-datasource | FlinkOptions | java | compaction.tasks | 1 | 0 | public | Integer | COMPACTION_TASKS | ||||||||||||||
96 | 95 | hudi-flink-datasource | FlinkOptions | java | compaction.trigger.strategy | NUM_COMMITS | 1 | 0 | public | String | COMPACTION_TRIGGER_STRATEGY | |||||||||||||
97 | 96 | hudi-flink-datasource | FlinkOptions | java | compaction.delta_commits | 5 | 0 | 0 | public | Integer | COMPACTION_DELTA_COMMITS | |||||||||||||
98 | 97 | hudi-flink-datasource | FlinkOptions | java | compaction.delta_seconds | 3600 | 1 | 0 | public | Integer | COMPACTION_DELTA_SECONDS | |||||||||||||
99 | 98 | hudi-flink-datasource | FlinkOptions | java | compaction.timeout.seconds | 1200 | 1 | 0 | public | Integer | COMPACTION_TIMEOUT_SECONDS | |||||||||||||
100 | 99 | hudi-flink-datasource | FlinkOptions | java | compaction.max_memory | 100 | 1 | 0 | public | Integer | COMPACTION_MAX_MEMORY |