MCPcopy Create free account

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

Functions719 in github.com/csimplestring/delta-go

⨍ Functions 719◇ Types & classes 134
↓ 1 callersFunctionUnmarshalList
(obj interfaces.UnmarshalObject, fieldName string, setter func([]string))
internal/util/parquet/serde.go:49
↓ 1 callersMethodUnmarshalParquet
(obj interfaces.UnmarshalObject)
parquet_marshaller.go:40
↓ 1 callersMethodUpdateMetadata
Records an update to the metadata that should be committed with this transaction. IMPORTANT: It is the responsibility of the caller to ensure that fil
trnx.go:264
↓ 1 callersFunctionUtilFnMapToString
(actions []Action)
action/utils.go:28
↓ 1 callersMethodVersionAtOrAfterTimestamp
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:50
↓ 1 callersMethodVersionBeforeOrAtTimestamp
Returns the latest version that was committed before or at timestamp. If no version exists, returns -1. Specifically: if a commit version exactly matc
log.go:44
↓ 1 callersMethodWaitTill
(target int64)
clock.go:21
↓ 1 callersMethodaccept
(addFile *action.AddFile)
scan.go:43
↓ 1 callersFunctionasSliceOf
(s []interface{}, mapper func(i interface{}) (T, error))
types/type_parser.go:219
↓ 1 callersFunctionassertProtocolWrite
(protocol *action.Protocol)
conflict_checker.go:252
↓ 1 callersFunctionazblobCanonicalize
(p string)
internal/util/path/resolver.go:116
↓ 1 callersFunctionazureBlobRelative
for azblob file, return as it is. Since we do not support reading/writing data file, we leave this to the caller of this lib to decide how to handle t
internal/util/path/resolver.go:75
↓ 1 callersMethodcheckConflicts
()
conflict_checker.go:108
↓ 1 callersMethodcheckFieldName
(name string)
types/type_utils.go:209
↓ 1 callersMethodcheckFieldNames
(names []string)
types/type_utils.go:219
↓ 1 callersMethodcheckForConflicts
(checkVersion int64, actions []action.Action, attemptNumber int, commitIsolationLevel isolation.Level)
trnx.go:603
↓ 1 callersMethodcheckPartitionColumns
(partitionCols []string, schema *types.StructType)
trnx.go:376
↓ 1 callersFunctioncheckpoint
(logPath string, store store.Store, snapshotToCheckpoint *snapshotImp)
checkpoint.go:247
↓ 1 callersMethodcleanTempDir
()
log_test.go:163
↓ 1 callersFunctioncompareBinary
(b1 []byte, b2 []byte)
types/expr_binary.go:102
↓ 1 callersFunctioncompareBool
(b1 bool, b2 bool)
types/expr_binary.go:113
↓ 1 callersMethodcreateWinningCommitSummary
must call it when crreating conflictChecker
conflict_checker.go:92
↓ 1 callersMethoddoCommitRetryIteratively
(attemptVersion int64, actions []action.Action, isolationLevel isolation.Level)
trnx.go:541
↓ 1 callersFunctionemptyLogSegment
(logPath string)
log_segment.go:41
↓ 1 callersMethodequal
(other *LogSegment)
log_segment.go:20
↓ 1 callersMethodextractActions
(snapshot *snapshotImp)
checkpoint_writer.go:60
↓ 1 callersFunctionfilterFileList
(paritionSchema *types.StructType, files []*action.AddFile, filter types.Expression)
conflict_checker.go:153
↓ 1 callersFunctiongcsCanonicalize
(p string)
internal/util/path/resolver.go:120
↓ 1 callersFunctiongcsRelative
(base string, path string)
internal/util/path/resolver.go:79
↓ 1 callersMethodget
(key string)
types/type_utils.go:148
↓ 1 callersMethodgetCommitInfo
(version int64)
history_manager.go:20
↓ 1 callersMethodgetCommits
(logStore store.Store, logPath string, start int64, end int64)
history_manager.go:205
↓ 1 callersMethodgetEarliestDeltaFile
()
history_manager.go:106
↓ 1 callersMethodgetLastCommitBeforeTimestamp
(commits []*commit, timeInMill int64)
history_manager.go:191
↓ 1 callersFunctiongetLogPath
(dataPath string)
log.go:55
↓ 1 callersMethodgetMinFileRetentionTimestamp
()
snapshot_reader.go:55
↓ 1 callersMethodgetNextAttemptVersion
()
trnx.go:638
↓ 1 callersMethodgetNextIter
()
replay_file.go:124
↓ 1 callersMethodgetPrimitive
(field *types.StructField)
record.go:18
↓ 1 callersMethodgetSnapshotAtInit
()
snapshot_reader.go:77
↓ 1 callersMethodgetSnapshotForTimestampAsOf
(timestamp int64)
snapshot_reader.go:124
↓ 1 callersFunctiongetTestAzBlobBaseDir
Azure Blob log store tests
log_test.go:58
↓ 1 callersFunctiongetTestAzBlobConfig
()
log_test.go:65
↓ 1 callersFunctiongetTestFileBaseDir
()
log_test.go:42
↓ 1 callersFunctiongetTestGoogleStorageBaseDir
Google Cloud Storage log store tests
log_test.go:73
↓ 1 callersFunctiongetTestGoogleStorageConfig
()
log_test.go:77
↓ 1 callersFunctiongetTestS3BaseDir
s3 log store tests
log_test.go:84
↓ 1 callersFunctiongetTestS3Config
()
log_test.go:88
↓ 1 callersMethodhasNext
()
scan.go:157
↓ 1 callersFunctioninit_containers
Iterate on the containers directory and do the following: 1- create the container. 2- upload all folders and files to the container.
init_azurite.py:35
↓ 1 callersFunctionisDatatypeWriteCompatible
(_existingType DataType, _newType DataType)
types/type_utils.go:77
↓ 1 callersFunctionisStructWriteCompatible
(_existingSchema *StructType, _newSchema *StructType)
types/type_utils.go:97
↓ 1 callersMethodlistingBlob
(ctx context.Context, prefix string)
internal/util/blob.go:37
↓ 1 callersMethodloadInMemory
(files []string)
snapshot.go:224
↓ 1 callersFunctionmanuallyLoadCheckpoint
(t mo.Option[*CheckpointInstance])
checkpoint.go:143
↓ 1 callersFunctionmergeGlobalTableConfigurations
(confs tableConfigurations, tableConf map[string]string)
config.go:102
↓ 1 callersFunctionnewConflictChecker
(currentTransactionInfo *currentTransactionInfo, winningCommitVersion int64, isolationLevel isolation.Level)
conflict_checker.go:77
↓ 1 callersFunctionnewFilteredScan
(replay *MemoryOptimizedLogReplay, config Config, exp expr.Expression, partitionSchema *expr.StructType)
scan.go:209
↓ 1 callersFunctionnewListingIter
(logDir string, startPath string, bucket *blob.Bucket)
store/base.go:66
↓ 1 callersFunctionnewMemLogStore
()
checkpoint_test.go:80
↓ 1 callersFunctionnewOptimisticTransaction
(snapshot *snapshotImp, snapshotManager *SnapshotReader, clock Clock, configuration tableConfigurations, l
trnx.go:95
↓ 1 callersFunctionnewSnapshotImp
(config Config, path string, version int64, logsegment *LogSegment, minFileRetentionTimestamp int64, timestam
snapshot.go:66
↓ 1 callersFunctionnewSnapshotReader
(config Config, cpReader checkpointReader, logStore store.Store, clock Clock, history *historyManager, mu *syn
snapshot_reader.go:34
↓ 1 callersFunctionnewWinningCommitSummary
(actions []action.Action, commitVersion int64)
conflict_checker.go:41
↓ 1 callersFunctionparquetMarshaProtocol
(p *action.Protocol, obj interfaces.MarshalObject)
parquet_marshaller.go:260
↓ 1 callersFunctionparquetMarshalAdd
(add *action.AddFile, obj interfaces.MarshalObject)
parquet_marshaller.go:105
↓ 1 callersFunctionparquetMarshalCDC
(add *action.AddCDCFile, obj interfaces.MarshalObject)
parquet_marshaller.go:280
↓ 1 callersFunctionparquetMarshalCommitInfo
(add *action.CommitInfo, obj interfaces.MarshalObject)
parquet_marshaller.go:313
↓ 1 callersFunctionparquetMarshalMetadata
(meta *action.Metadata, obj interfaces.MarshalObject)
parquet_marshaller.go:199
↓ 1 callersFunctionparquetMarshalRemove
(rm *action.RemoveFile, obj interfaces.MarshalObject)
parquet_marshaller.go:154
↓ 1 callersFunctionparquetMarshalTxn
(txn *action.SetTransaction, obj interfaces.MarshalObject)
parquet_marshaller.go:73
↓ 1 callersFunctionparquetUnmarshaProtocol
(p *action.Protocol, obj interfaces.UnmarshalObject)
parquet_marshaller.go:266
↓ 1 callersFunctionparquetUnmarshalAdd
(add *action.AddFile, obj interfaces.UnmarshalObject)
parquet_marshaller.go:123
↓ 1 callersFunctionparquetUnmarshalCDC
(add *action.AddCDCFile, obj interfaces.UnmarshalObject)
parquet_marshaller.go:291
↓ 1 callersFunctionparquetUnmarshalCommitInfo
(add *action.CommitInfo, obj interfaces.UnmarshalObject)
parquet_marshaller.go:362
↓ 1 callersFunctionparquetUnmarshalMetadata
(meta *action.Metadata, obj interfaces.UnmarshalObject)
parquet_marshaller.go:217
↓ 1 callersFunctionparquetUnmarshalRemove
(rm *action.RemoveFile, obj interfaces.UnmarshalObject)
parquet_marshaller.go:169
↓ 1 callersFunctionparquetUnmarshalTxn
(txn *action.SetTransaction, obj interfaces.UnmarshalObject)
parquet_marshaller.go:86
↓ 1 callersFunctionparseStructField
(v map[string]interface{})
types/type_parser.go:158
↓ 1 callersFunctionparseStructFieldMetadata
(m map[string]interface{})
types/type_parser.go:181
↓ 1 callersMethodpostCommit
(commitVersion int64)
trnx.go:647
↓ 1 callersMethodprepareCommit
(actions []action.Action)
trnx.go:428
↓ 1 callersMethodprotocol
()
trnx.go:125
↓ 1 callersFunctions3Canonicalize
(p string)
internal/util/path/resolver.go:124
↓ 1 callersFunctions3Relative
(base string, path string)
internal/util/path/resolver.go:83
↓ 1 callersMethodsetNextMatching
()
scan.go:135
↓ 1 callersMethodshouldCheckpoint
(committedVersion int64, checkpointInterval int)
trnx.go:673
↓ 1 callersFunctionsplitDeltaAndCheckpoint
(a []*store.FileMeta)
snapshot_reader.go:331
↓ 1 callersFunctionstructFieldToJSON
(f *StructField)
types/type_parser.go:104
↓ 1 callersFunctiontoFieldMap
(fields []*StructField)
types/type_utils.go:135
↓ 1 callersMethodtoInstance
()
checkpoint.go:207
↓ 1 callersMethodtransactions
()
snapshot.go:152
↓ 1 callersFunctiontraverseColumns
(path []string, dt DataType)
types/type_utils.go:50
↓ 1 callersFunctionunixCanonicalize
(p string)
internal/util/path/resolver.go:102
↓ 1 callersFunctionunixQualified
(base string, path string)
internal/util/path/resolver.go:43
↓ 1 callersFunctionunixRelative
(base string, path string)
internal/util/path/resolver.go:51
↓ 1 callersFunctionupload_contents
Upload recursively contents of specified directory. Args: client (google.cloud.storage.Client): Google Storage Client. directory
init_gcs.py:15
↓ 1 callersFunctionupload_dir
Upload a directory to a path inside the container.
init_azurite.py:21
↓ 1 callersFunctionverifyDeltaVersions
(deltaVersions []int64)
snapshot_reader.go:319
↓ 1 callersMethodverifyNewMetadata
(metadata *action.Metadata)
trnx.go:347
← previousnext →301–400 of 719, ranked by callers