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