Google Git Google Git
Sign in
apache/paimon/refs/heads/master/./paimon-python/pypaimon/tests
tree: 2d94b8db7f611be99a96e6023dc0a5c3fcf21522 [search]
  1. api/
  2. branch/
  3. daft/
  4. e2e/
  5. manifest/
  6. py36/
  7. resources/
  8. rest/
  9. scanner/
  10. system/
  11. table/
  12. write/
  13. __init__.py
  14. arrow_schema_test.py
  15. arrow_write_nullability_test.py
  16. auth_masking_reader_test.py
  17. batch_scan_level_filter_test.py
  18. batch_vector_lookup_test.py
  19. batch_vector_raw_scan_test.py
  20. batch_vector_streaming_refine_test.py
  21. binary_row_test.py
  22. blob_index_cache_test.py
  23. blob_table_test.py
  24. blob_test.py
  25. branch_manager_test.py
  26. btree_bloom_filter_test.py
  27. btree_index_reader_test.py
  28. btree_posting_list_test.py
  29. btree_thread_safety_test.py
  30. build_info_test.py
  31. caching_file_io_test.py
  32. catalog_environment_test.py
  33. changelog_follow_up_scanner_test.py
  34. changelog_manager_test.py
  35. cli_branch_test.py
  36. cli_db_test.py
  37. cli_table_test.py
  38. cli_tag_test.py
  39. column_directive_utils_test.py
  40. commit_message_serializer_test.py
  41. commit_update_schema_identity_test.py
  42. composite_btree_fallback_test.py
  43. concat_batch_reader_test.py
  44. concurrent_import_test.py
  45. consumer_manager_test.py
  46. consumer_test.py
  47. contiguous_window_dataset_test.py
  48. contiguous_window_plan_test.py
  49. contiguous_window_resume_test.py
  50. data_evolution_deletion_vector_test.py
  51. data_evolution_formats_test.py
  52. data_evolution_group_stats_test.py
  53. data_evolution_row_rolling_test.py
  54. data_evolution_split_generator_test.py
  55. data_evolution_test.py
  56. data_evolution_test_helpers.py
  57. data_file_creation_time_test.py
  58. data_file_path_directory_test.py
  59. data_types_test.py
  60. datasource_ray_adapter_test.py
  61. datasource_torch_adapter_test.py
  62. decimal_key_serializer_test.py
  63. decimal_predicate_test.py
  64. decimal_test.py
  65. deferred_blob_resolve_test.py
  66. deletion_vector_path_test.py
  67. delta_varint_compressor_test.py
  68. dynamic_bucket_execution_boundary_test.py
  69. execution_backend_isolation_test.py
  70. execution_dispatch_test.py
  71. execution_layout_test.py
  72. execution_table_read_boundary_test.py
  73. external_paths_test.py
  74. field_bunch_test.py
  75. file_io_test.py
  76. file_store_commit_test.py
  77. file_type_test.py
  78. filesystem_catalog_branch_test.py
  79. filesystem_catalog_tag_test.py
  80. filesystem_catalog_test.py
  81. follow_up_scanner_test.py
  82. format_mosaic_reader_test.py
  83. format_pyarrow_shared_shredding_map_test.py
  84. format_pyarrow_variant_row_group_test.py
  85. format_write_execution_test.py
  86. full_text_reader_cleanup_test.py
  87. full_text_scalar_filter_test.py
  88. full_text_top_k_test.py
  89. gcs_file_io_test.py
  90. global_index_build_test.py
  91. global_index_drop_predicate_test.py
  92. global_index_evaluator_test.py
  93. global_index_execution_boundary_test.py
  94. global_index_family_parity_test.py
  95. global_index_live_row_filter_test.py
  96. global_index_scalar_search_mode_test.py
  97. global_index_test.py
  98. global_index_update_action_test.py
  99. hdfs_native_test.py
  100. hdfs_native_write_row_test.py
  101. hybrid_search_execution_test.py
  102. hybrid_search_ranker_test.py
  103. identifier_test.py
  104. index_execution_boundary_test.py
  105. index_file_handler_test.py
  106. index_manifest_definition_test.py
  107. index_manifest_write_test.py
  108. interval_partition_test.py
  109. jdbc_catalog_test.py
  110. jindo_file_system_test.py
  111. kerberos_test.py
  112. lance_utils_test.py
  113. lazy_read_execution_test.py
  114. lazy_search_execution_test.py
  115. lerobot_native_reader_test.py
  116. lumina_vector_index_test.py
  117. map_selected_key_projection_test.py
  118. map_shared_shredding_write_test.py
  119. merge_execution_boundary_test.py
  120. mosaic_writer_options_test.py
  121. multimodal_hdf5_test.py
  122. multimodal_lerobot_ray_test.py
  123. multimodal_lerobot_test.py
  124. multimodal_lerobot_writer_test.py
  125. multimodal_rosbag_test.py
  126. multimodal_table_test.py
  127. multimodal_temporal_test.py
  128. multimodal_video_test.py
  129. native_append_index_search_test.py
  130. native_authorized_update_test.py
  131. native_blob_collection_write_test.py
  132. native_blob_consumer_test.py
  133. native_blob_row_write_test.py
  134. native_blob_update_test.py
  135. native_blob_uri_reader_test.py
  136. native_blob_write_test.py
  137. native_branch_write_test.py
  138. native_bucket_selector_test.py
  139. native_calendar_mask_test.py
  140. native_cast_completion_test.py
  141. native_changelog_batch_test.py
  142. native_commit_partition_spec_test.py
  143. native_commit_semantics_test.py
  144. native_commit_test.py
  145. native_constructed_evolution_test.py
  146. native_cross_partition_write_test.py
  147. native_data_directory_test.py
  148. native_data_evolution_commit_test.py
  149. native_decimal_cast_test.py
  150. native_decimal_integer_input_test.py
  151. native_decimal_predicate_test.py
  152. native_dv_merge_engine_write_test.py
  153. native_dynamic_write_test.py
  154. native_external_write_test.py
  155. native_file_scan_test.py
  156. native_filtered_write_validation_test.py
  157. native_filtered_writer_configuration_test.py
  158. native_full_startup_test.py
  159. native_full_text_search_test.py
  160. native_generic_index_build_test.py
  161. native_global_index_drop_test.py
  162. native_historical_update_test.py
  163. native_historical_write_commit_test.py
  164. native_hybrid_search_test.py
  165. native_index_result_scan_test.py
  166. native_iterator_test.py
  167. native_loaded_schema_io_test.py
  168. native_managed_blob_write_test.py
  169. native_manifest_compression_test.py
  170. native_map_shredding_write_test.py
  171. native_merge_dictionary_keys_test.py
  172. native_merge_incremental_test.py
  173. native_merge_into_test.py
  174. native_merge_read_test.py
  175. native_merge_source_metadata_test.py
  176. native_mod_bucket_write_test.py
  177. native_nested_predicate_test.py
  178. native_nested_update_test.py
  179. native_nullable_primary_key_test.py
  180. native_overwrite_indexes_test.py
  181. native_overwrite_restore_test.py
  182. native_parallel_index_build_test.py
  183. native_parquet_vector_update_test.py
  184. native_partition_blob_read_test.py
  185. native_partition_delete_changelog_test.py
  186. native_partition_filter_test.py
  187. native_partition_metadata_test.py
  188. native_partition_types_test.py
  189. native_pk_blob_limit_test.py
  190. native_pk_full_text_search_test.py
  191. native_pk_sorted_index_test.py
  192. native_plan_capabilities_test.py
  193. native_plan_chunk_shuffle_test.py
  194. native_plan_distribution_test.py
  195. native_plan_dynamic_bucket_test.py
  196. native_plan_expanded_test.py
  197. native_plan_incremental_test.py
  198. native_plan_integration_test.py
  199. native_plan_materialized_pk_test.py
  200. native_plan_resolved_schema_test.py
  201. native_plan_rest_test.py
  202. native_plan_test.py
  203. native_postpone_fixed_write_test.py
  204. native_postpone_write_test.py
  205. native_precomputed_bucket_test.py
  206. native_predicate_delete_test.py
  207. native_preplanned_row_id_read_test.py
  208. native_query_auth_test.py
  209. native_read_path_completion_test.py
  210. native_read_snapshot_test.py
  211. native_read_test.py
  212. native_read_type_test.py
  213. native_row_sidecar_test.py
  214. native_scan_stats_test.py
  215. native_schema_cast_test.py
  216. native_schema_evolution_cast_test.py
  217. native_search_plan_test.py
  218. native_sequence_test.py
  219. native_shard_partition_carrier_test.py
  220. native_shard_update_test.py
  221. native_sliced_split_read_test.py
  222. native_snapshot_properties_test.py
  223. native_sorted_index_build_test.py
  224. native_stream_consumer_branch_test.py
  225. native_stream_query_auth_test.py
  226. native_stream_table_scan_test.py
  227. native_system_columns_test.py
  228. native_system_table_test.py
  229. native_temporal_zone_cast_test.py
  230. native_test_instrumentation_test.py
  231. native_timestamp_bucket_write_test.py
  232. native_transform_filter_test.py
  233. native_update_binary_text_test.py
  234. native_update_container_casts_test.py
  235. native_update_encoded_inputs_test.py
  236. native_update_inactive_vector_option_test.py
  237. native_update_map_pairs_test.py
  238. native_update_source_nullability_test.py
  239. native_update_test.py
  240. native_upsert_capabilities_test.py
  241. native_upsert_encoded_keys_test.py
  242. native_upsert_key_normalization_test.py
  243. native_upsert_layout_test.py
  244. native_upsert_row_key_identity_test.py
  245. native_upsert_row_shapes_test.py
  246. native_upsert_selected_values_test.py
  247. native_upsert_temporal_row_keys_test.py
  248. native_variant_update_test.py
  249. native_vector_context_test.py
  250. native_vector_index_build_test.py
  251. native_vector_search_test.py
  252. native_video_read_test.py
  253. native_vindex_reader_test.py
  254. native_write_capabilities_test.py
  255. native_write_fork_safety_test.py
  256. native_write_inactive_options_test.py
  257. native_write_path_completion_test.py
  258. native_write_routing_test.py
  259. native_write_test.py
  260. native_write_type_test.py
  261. nested_type_read_write_test.py
  262. normal_map_selected_keys_test.py
  263. numeric_utils_test.py
  264. oss_atomic_write_test.py
  265. oss_blob_presigner_test.py
  266. oss_file_io_test.py
  267. oss_legacy_mode_test.py
  268. oss_user_agent_test.py
  269. overwrite_changes_cache_test.py
  270. overwrite_commit_conflict_test.py
  271. parquet_metadata_cache_test.py
  272. parquet_page_index_test.py
  273. parquet_row_range_test.py
  274. parquet_write_page_index_test.py
  275. partition_predicate_test.py
  276. permission_management_json_test.py
  277. polars_map_null_test.py
  278. policy_management_json_test.py
  279. predicate_json_parser_test.py
  280. predicates_test.py
  281. primary_key_global_index_golden_test.py
  282. primary_key_index_definitions_test.py
  283. primary_key_sorted_index_result_test.py
  284. primary_key_sorted_index_scan_test.py
  285. projection_predicate_index_test.py
  286. public_streaming_table_scan_test.py
  287. pure_writer_creation_time_test.py
  288. pushdown_bucket_test.py
  289. pushdown_correctness_test.py
  290. pvfs_oss_filesystem_test.py
  291. pvfs_test.py
  292. python_shard_update_alignment_test.py
  293. query_auth_execution_boundary_test.py
  294. query_auth_filter_test.py
  295. query_auth_validation_test.py
  296. query_auth_widening_test.py
  297. range_test.py
  298. raw_file_scan_auth_scope_test.py
  299. ray_batch_vector_refinement_test.py
  300. ray_batch_vector_search_test.py
  301. ray_blob_affinity_test.py
  302. ray_bucket_join_test.py
  303. ray_data_evolution_merge_into_test.py
  304. ray_data_test.py
  305. ray_full_text_search_test.py
  306. ray_hdf5_test.py
  307. ray_hybrid_parallel_test.py
  308. ray_integration_test.py
  309. ray_partitioning_test.py
  310. ray_process_row_id_ranges_test.py
  311. ray_range_join_test.py
  312. ray_read_by_row_id_test.py
  313. ray_repartition_test.py
  314. ray_rosbag_test.py
  315. ray_row_id_conflict_rewriter_test.py
  316. ray_search_execution_test.py
  317. ray_search_order_test.py
  318. ray_search_result_metadata_test.py
  319. ray_search_result_test.py
  320. ray_sink_test.py
  321. ray_update_by_row_id_test.py
  322. ray_vector_filter_exactness_test.py
  323. ray_vector_index_build_test.py
  324. ray_vector_refinement_test.py
  325. ray_vector_result_conversion_test.py
  326. ray_vector_search_test.py
  327. read_builder_explain_test.py
  328. read_execution_boundary_test.py
  329. read_execution_protocol_test.py
  330. reader_append_only_test.py
  331. reader_base_test.py
  332. reader_parallel_test.py
  333. reader_predicate_test.py
  334. reader_primary_key_test.py
  335. reader_split_generator_test.py
  336. resolving_file_io_test.py
  337. rest_user_agent_test.py
  338. roaring_bitmap_test.py
  339. row_to_string_test.py
  340. s3_client_compatibility_test.py
  341. s3_delete_compatibility_test.py
  342. scan_file_shard_test.py
  343. scan_request_test.py
  344. schema_evolution_cast_test.py
  345. schema_evolution_nested_read_test.py
  346. schema_evolution_pk_read_test.py
  347. schema_evolution_read_test.py
  348. schema_manager_test.py
  349. search_execution_test_helpers.py
  350. search_query_auth_reject_test.py
  351. search_result_metadata_test.py
  352. search_snapshot_test.py
  353. search_task_execution_test.py
  354. serializable_test.py
  355. shard_batch_reader_test.py
  356. shard_table_updator_test.py
  357. shared_execution_import_test.py
  358. shared_shredding_full_restore_test.py
  359. snapshot_manager_test.py
  360. sorted_index_file_meta_test.py
  361. sorted_index_options_test.py
  362. split_provider_test.py
  363. split_serializer_test.py
  364. sql_context_test.py
  365. sql_permission_test.py
  366. sql_system_table_test.py
  367. sst_file_iterator_test.py
  368. stream_execution_protocol_test.py
  369. stream_initial_level_filter_test.py
  370. stream_read_builder_test.py
  371. streaming_scan_import_boundary_test.py
  372. streaming_table_scan_test.py
  373. table_commit_test.py
  374. table_merge_into_test.py
  375. table_query_auth_test.py
  376. table_read_chunked_overflow_test.py
  377. table_scan_mode_test.py
  378. table_schema_test.py
  379. table_update_arrow_compatibility_test.py
  380. table_update_by_row_id_chunked_test.py
  381. table_update_test.py
  382. table_upsert_by_key_test.py
  383. tag_ttl_serde_test.py
  384. test_aggregation_e2e.py
  385. test_aggregation_merge_function.py
  386. test_decimal.py
  387. test_early_row_range_filter.py
  388. test_field_aggregator_registry.py
  389. test_field_aggregators.py
  390. test_first_row_e2e.py
  391. test_first_row_merge_function.py
  392. test_format_mosaic_reader_writer.py
  393. test_format_mosaic_table.py
  394. test_format_row_reader_writer.py
  395. test_format_row_table.py
  396. test_limit_pushdown.py
  397. test_limited_record_reader.py
  398. test_merge_engine_dispatch.py
  399. test_nested_projection_e2e.py
  400. test_optional_datasketches_dependency.py
  401. test_outer_projection_record_reader.py
  402. test_partial_update_e2e.py
  403. test_partial_update_merge_function.py
  404. test_projection_utility.py
  405. test_ray_shuffle_helper.py
  406. test_read_builder_nested_projection.py
  407. test_sequence_field_read.py
  408. test_sequence_field_write.py
  409. test_sort_merge_reader.py
  410. test_write_merge_buffer.py
  411. time_travel_util_test.py
  412. timestamp_key_serializer_test.py
  413. timestamp_test.py
  414. torch_distributed_sharding_worker.py
  415. torch_read_test.py
  416. union_global_index_reader_test.py
  417. update_commit_identifier_test.py
  418. upsert_btree_lookup_test.py
  419. uri_reader_factory_test.py
  420. variant_path_test.py
  421. variant_row_sidecar_index_test.py
  422. variant_set_test.py
  423. variant_test.py
  424. vector_filter_exactness_test.py
  425. vector_index_dv_build_test.py
  426. vector_index_parallel_search_test.py
  427. vector_metric_consistency_test.py
  428. vector_scoring_test.py
  429. vector_search_filter_test.py
  430. vector_table_test.py
  431. video_column_reassign_test.py
  432. video_decode_parallelism_test.py
  433. video_format_test.py
  434. video_keyframe_index_test.py
  435. vindex_batch_write_test.py
  436. vindex_execution_boundary_test.py
  437. vindex_input_test.py
  438. vindex_training_test.py
  439. vindex_vector_index_test.py
  440. where_parser_test.py
  441. window_transforms_test.py