Functions — github.com/csimplestring/delta-go

hub / github.com/csimplestring/delta-go / functions

Functions719 in github.com/csimplestring/delta-go

⨍ Functions 719◇ Types & classes 134

FunctionTestConvertToBlobURL

(t *testing.T)

internal/util/path/path_test.go:9

FunctionTestDataTypeSerde

(t *testing.T)

types/type_parser_test.go:39

FunctionTestDataTypeSerde_fieldMetadata

(t *testing.T)

types/type_parser_test.go:81

FunctionTestExplodeNestedFieldNames

(t *testing.T)

types/type_utils_test.go:147

FunctionTestFindLastCompleteCheckpoint

(t *testing.T)

checkpoint_test.go:17

FunctionTestFromReadCloser

(t *testing.T)

iter/line_reader_test.go:35

FunctionTestGCSBlobLogStore

(t *testing.T)

store/gcs_test.go:12

FunctionTestGCSLogStoreExample

(t *testing.T)

examples/gcs_example_test.go:11

FunctionTestHashStruct

types/type_utils_test.go:10

FunctionTestIsNotNull

(t *testing.T)

types/expr_unary_test.go:18

FunctionTestIsNull

(t *testing.T)

types/expr_unary_test.go:13

FunctionTestLiteral

(t *testing.T)

types/expr_literal_test.go:11

FunctionTestLocalExample

(t *testing.T)

examples/local_example_test.go:11

FunctionTestLocalParquetReadWrite

(t *testing.T)

parquet_test.go:16

FunctionTestLocalStore

(t *testing.T)

store/local_test.go:14

FunctionTestLog_checkpoint

(t *testing.T)

log_test.go:353

FunctionTestLog_delete_and_readd_the_same_file_in_different_transactions

(t *testing.T)

log_test.go:645

FunctionTestLog_do_not_relative_path_in_remove_files

(t *testing.T)

log_test.go:601

FunctionTestLog_getChanges_data_loss

(t *testing.T)

log_test.go:851

FunctionTestLog_getChanges_no_data_loss

(t *testing.T)

log_test.go:782

FunctionTestLog_getVersionBeforeOrAtTimestamp_and_getVersionAtOrAfterTimestamp_recoverability

func TestLog_getVersionBeforeOrAtTimestamp_and_getVersionAtOrAfterTimestamp(t *testing.T) { t.Parallel() for _, tt := range newTestLogCases("file",

log_test.go:1062

FunctionTestLog_get_commit_info

(t *testing.T)

log_test.go:735

FunctionTestLog_handle_corrupted_last_checkpoint_file

(t *testing.T)

log_test.go:506

FunctionTestLog_paths_should_be_canonicalized_normal_characters

(t *testing.T)

log_test.go:542

FunctionTestLog_paths_should_be_canonicalized_special_characters

(t *testing.T)

log_test.go:573

FunctionTestLog_schema_contains_no_data_columns_and_only_partition_columns

(t *testing.T)

log_test.go:955

FunctionTestLog_schema_must_contain_all_partition_columns

(t *testing.T)

log_test.go:908

FunctionTestLog_snapshot

(t *testing.T)

log_test.go:248

FunctionTestLog_state_reconstruction_from_checkpoint_with_missing_action_should_fail

(t *testing.T)

log_test.go:703

FunctionTestLog_state_reconstruction_without_action_should_fail

(t *testing.T)

log_test.go:687

FunctionTestLog_table_exists

(t *testing.T)

log_test.go:881

FunctionTestLog_table_protocol_version_greater_than_client_reader_protocol_version

(t *testing.T)

log_test.go:720

FunctionTestLog_time_travel_versionAsOf

(t *testing.T)

log_timetravel_test.go:67

FunctionTestLog_time_travel_with_partition_changes_should_instantiate_old_schema

(t *testing.T)

log_timetravel_test.go:217

FunctionTestLog_time_travel_with_schema_changes_should_instantiate_old_schema

(t *testing.T)

log_timetravel_test.go:195

FunctionTestLog_timestampAsOf_with_timestamp_after_last_commit_should_fail

(t *testing.T)

log_timetravel_test.go:136

FunctionTestLog_timestampAsOf_with_timestamp_in_between_commits_should_use_commit_before_timestamp

(t *testing.T)

log_timetravel_test.go:108

FunctionTestLog_timestampAsOf_with_timestamp_on_exact_commit_timestamp

(t *testing.T)

log_timetravel_test.go:163

FunctionTestLog_updateDeletedDir

(t *testing.T)

log_test.go:402

FunctionTestLog_update_should_not_pick_up_delta_files_earlier_than_checkpoint

(t *testing.T)

log_test.go:425

FunctionTestLog_version_not_continuous

(t *testing.T)

log_test.go:672

FunctionTestMetadata_Equal

(t *testing.T)

action/actions_test.go:9

FunctionTestNot

(t *testing.T)

types/expr_unary_test.go:7

FunctionTestOr

(t *testing.T)

types/expr_binary_test.go:17

FunctionTestQualified

(t *testing.T)

internal/util/path/resolver_test.go:7

FunctionTestRelative

(t *testing.T)

internal/util/path/resolver_test.go:45

FunctionTestS3LogStore

(t *testing.T)

store/s3_test.go:12

FunctionTestS3LogStoreExample

(t *testing.T)

examples/s3_example_test.go:11

FunctionTestScan_correct_reverse_replay

(t *testing.T)

scan_test.go:216

FunctionTestScan_filtered_scan_with_a_metadata_pushed_conjunct_should_return_matched_files

(t *testing.T)

scan_test.go:141

FunctionTestScan_filtered_scan_with_only_data_residual_predicate_should_return_all_files

(t *testing.T)

scan_test.go:183

FunctionTestScan_properly_splits_metadata_pushed_and_data_residual_predicates

(t *testing.T)

scan_test.go:110

FunctionTestSystemClock_WaitTill

(t *testing.T)

clock_test.go:10

FunctionTestTrx_add_rea_no_write

(t *testing.T)

trnx_test.go:272

FunctionTestTrx_add_read_write

(t *testing.T)

trnx_test.go:343

FunctionTestTrx_apend_apend

(t *testing.T)

trnx_test.go:124

FunctionTestTrx_can_change_schema_to_valid_schema

(t *testing.T)

trnx_test.go:629

FunctionTestTrx_conflicting_txns

(t *testing.T)

trnx_test.go:464

FunctionTestTrx_delete_delete

(t *testing.T)

trnx_test.go:309

FunctionTestTrx_delete_read

(t *testing.T)

trnx_test.go:381

FunctionTestTrx_disjoint_add_reads

(t *testing.T)

trnx_test.go:235

FunctionTestTrx_disjoint_delete_reads

(t *testing.T)

trnx_test.go:197

FunctionTestTrx_disjoint_txns

(t *testing.T)

trnx_test.go:159

FunctionTestTrx_relative_path_is_unchanged

TODO: regarding the absolute path and relative path, it depends on how the compute engine handles the conversion so i leave it as it is for now unless

trnx_test.go:666

FunctionTestTrx_schema_change

(t *testing.T)

trnx_test.go:419

FunctionTestTrx_taint_whole_table

(t *testing.T)

trnx_test.go:544

FunctionTestTrx_taint_whole_table_concurrent_remove

(t *testing.T)

trnx_test.go:588

FunctionTestTrx_upgrade_upgrade

(t *testing.T)

trnx_test.go:504

FunctionTest_LocalBlobDir

(t *testing.T)

internal/util/blob_test.go:13

FunctionTest_checkFieldNames

(t *testing.T)

types/type_utils_test.go:17

FunctionTest_isWriteCompatible

(t *testing.T)

types/type_utils_test.go:121

FunctionTest_nameToType

(t *testing.T)

types/type_parser_test.go:11

FunctionTest_parseDataType

(t *testing.T)

types/type_parser_test.go:31

FunctionTest_relativePath

(t *testing.T)

store/local_test.go:55

MethodTxnVersion

returns the latest version that has committed for the idempotent transaction with given id.

FunctionUtilFnCollect

(actions []Action)

action/utils.go:7

FunctionUtilFnCollectFirst

Version returns the versiion of this Snapshot

snapshot.go:132

MethodVersionAtOrAfterTimestamp

Returns the latest version that was committed at or after timestamp. If no version exists, returns -1. Specifically: if a commit version exactly match

log.go:257

MethodVersionBeforeOrAtTimestamp

Returns the latest version that was committed before or at timestamp. If no version exists, returns -1. Specifically: if a commit version exactly matc

history_manager.go:255

MethodWithTimestamp

(timestamp int64)

action/commit_info.go:9

MethodWithTimestamp

(timestamp int64)

action/commit_info.go:43

MethodWrap

()

action/commit_info.go:31

action/metadata.go:35

(a *action.SingleAction)

parquet_writer.go:23

MethodWrite

(a *action.SingleAction)

parquet_writer.go:81

MethodWrite

(path string, actions iter.Iter[string], overwrite bool)

checkpoint_test.go:124

MethodWrite

(path string, actions iter.Iter[string], overwrite bool)

store/base.go:27

← previous next →601–700 of 719, ranked by callers