MCPcopy Create free account

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

Functions719 in github.com/csimplestring/delta-go

⨍ Functions 719◇ Types & classes 134
↓ 2 callersMethodgetSnapshotAt
(version int64)
snapshot_reader.go:97
↓ 2 callersMethodgetSnapshotForVersionAsOf
(version int64)
snapshot_reader.go:116
↓ 2 callersFunctiongetTestManualUpdate
()
log_test.go:98
↓ 2 callersFunctionnewCheckpointReader
(urlstr string)
checkpoint_reader.go:22
↓ 2 callersFunctionnewInitialSnapshotImp
(config Config, path string, store store.Store, cpReader checkpointReader)
snapshot.go:307
↓ 2 callersFunctionnewParquetActionWriter
(urlstr string)
parquet_writer.go:27
↓ 2 callersMethodnumOfFiles
()
snapshot.go:162
↓ 2 callersFunctionparseDataType
(s interface{})
types/type_parser.go:113
↓ 2 callersMethodreadVersion
()
trnx.go:136
↓ 2 callersFunctionrecurseIntoComplexTypes
(complexType DataType)
types/type_utils.go:257
↓ 2 callersMethodsetTransactions
()
snapshot.go:144
↓ 2 callersMethodtombstones
()
snapshot.go:136
↓ 2 callersFunctionupload_file
Upload a single file to a path inside the container.
init_azurite.py:9
↓ 1 callersMethodActions
()
version_log.go:11
↓ 1 callersFunctionAddFilePartitioningMismatchError
()
errno/errors.go:66
↓ 1 callersMethodAppend
(version int64, iter iter.Iter[action.Action])
replay_action.go:63
↓ 1 callersFunctionCheckField
(path []string, f *StructField)
types/type_utils.go:27
↓ 1 callersFunctionCheckMetadataProtocolProperties
(metadata *Metadata, protocol *Protocol)
action/action.go:43
↓ 1 callersFunctionCheckUnenforceableNotNullConstraints
(schema *StructType)
types/type_utils.go:23
↓ 1 callersFunctionCheckpointFileWithParts
(dir string, version int64, numParts int)
internal/util/filenames/filename.go:73
↓ 1 callersMethodChildren
()
types/expr_binary.go:34
↓ 1 callersMethodChildren
Children returns List of the immediate children of this node
types/interfaces.go:47
↓ 1 callersFunctionConcurrentAppend
(partition string)
errno/errors.go:187
↓ 1 callersFunctionConcurrentDeleteDelete
(file string)
errno/errors.go:175
↓ 1 callersMethodCopy
(srcPrefix string)
internal/util/blob.go:71
↓ 1 callersMethodDataSchema
()
action/metadata.go:72
↓ 1 callersFunctionDefaultMetadata
()
action/metadata.go:24
↓ 1 callersMethodDelTimestamp
()
action/remove.go:35
↓ 1 callersFunctionEmptyDirectoryError
(path string)
errno/errors.go:122
↓ 1 callersMethodEquals
(other *Metadata)
action/metadata.go:86
↓ 1 callersFunctionFieldTypeMismatch
(fieldName string, actualType string, desiredType string)
errno/errors.go:118
↓ 1 callersMethodGetActiveFiles
()
replay_action.go:45
↓ 1 callersMethodGetBigDecimal
(fieldName string)
types/interfaces.go:24
↓ 1 callersMethodGetBinary
(fieldName string)
types/interfaces.go:23
↓ 1 callersMethodGetBoolean
(fieldName string)
types/interfaces.go:19
↓ 1 callersMethodGetByte
(fieldName string)
types/interfaces.go:17
↓ 1 callersMethodGetCorrespondingFiles
(dir string)
checkpoint.go:65
↓ 1 callersMethodGetDate
(fieldName string)
types/interfaces.go:26
↓ 1 callersMethodGetDouble
(fieldName string)
types/interfaces.go:21
↓ 1 callersFunctionGetFileVersion
(path string)
internal/util/filenames/filename.go:44
↓ 1 callersMethodGetFloat
(fieldName string)
types/interfaces.go:20
↓ 1 callersMethodGetInt
(fieldName string)
types/interfaces.go:15
↓ 1 callersMethodGetInt64
(fieldName string)
types/interfaces.go:16
↓ 1 callersFunctionGetMapValue
(m map[K]V, key K, defaultVal V)
internal/util/optional.go:13
↓ 1 callersFunctionGetMapValueOptional
(m map[K]V, key K)
internal/util/optional.go:20
↓ 1 callersMethodGetSetTransactions
()
replay_action.go:37
↓ 1 callersMethodGetShort
(fieldName string)
types/interfaces.go:18
↓ 1 callersMethodGetString
(fieldName string)
types/interfaces.go:22
↓ 1 callersMethodGetTimestamp
(fieldName string)
types/interfaces.go:25
↓ 1 callersMethodGetTombstones
()
replay_action.go:53
↓ 1 callersFunctionInvalidPartitionColumn
(err error)
errno/errors.go:100
↓ 1 callersMethodIsDataChanged
()
action/action.go:23
↓ 1 callersMethodIsEarlierThan
(other CheckpointInstance)
checkpoint.go:46
↓ 1 callersMethodIsNotLaterThan
(other CheckpointInstance)
checkpoint.go:58
↓ 1 callersMethodIsNullAt
(fieldName string)
types/interfaces.go:13
↓ 1 callersFunctionIsPredicateMetadataOnly
(condition types.Expression, partitionColumns []string)
internal/util/partition_utils.go:65
↓ 1 callersMethodJSON
()
types/type_primitives.go:42
↓ 1 callersFunctionJobInfoFromContext
(context map[string]string)
action/job_info.go:11
↓ 1 callersMethodJson
()
action/action.go:17
↓ 1 callersFunctionJsonUnmarshalError
(err error)
errno/errors.go:34
↓ 1 callersFunctionKeySet
(m map[K]V)
internal/util/slice.go:22
↓ 1 callersFunctionKeys
(m map[K]V)
internal/util/slice.go:14
↓ 1 callersMethodListFrom
List the paths in the same directory that are lexicographically greater or equal to (UTF-8 sorting) the given `path`. The result should also be sorted
store/azure.go:82
↓ 1 callersMethodListFrom
List the paths in the same directory that are lexicographically greater or equal to (UTF-8 sorting) the given `path`. The result should also be sorted
store/gcs.go:79
↓ 1 callersFunctionLiteralDate
(d time.Time)
types/expr_literal.go:50
↓ 1 callersFunctionLoadMetadataFromFile
(s store.Store)
checkpoint.go:95
↓ 1 callersFunctionMarshalList
(obj interfaces.MarshalObject, fieldName string, arr []string)
internal/util/parquet/serde.go:135
↓ 1 callersMethodMarshalParquet
(obj interfaces.MarshalObject)
parquet_marshaller.go:13
↓ 1 callersFunctionMaxCommitRetriesExceededError
(msg string)
errno/errors.go:58
↓ 1 callersMethodMetadata
Metadata returns the table metadata for this snapshot
snapshot.go:126
↓ 1 callersFunctionMetadataAbsentError
()
errno/errors.go:62
↓ 1 callersFunctionMetadataChangedError
()
errno/errors.go:42
↓ 1 callersFunctionMinInt64
(x int64, y int64)
internal/util/partition_utils.go:80
↓ 1 callersFunctionMissingPartFile
(version int64)
errno/errors.go:142
↓ 1 callersFunctionModifyAppendOnlyTableError
()
errno/errors.go:70
↓ 1 callersFunctionNew
(path string)
store/store.go:75
↓ 1 callersFunctionNewColumn
(name string, t DataType)
types/expr_column.go:13
↓ 1 callersFunctionNewGreaterThan
(l Expression, r Expression)
types/expr_binary.go:197
↓ 1 callersFunctionNewGreaterThanOrEq
(l Expression, r Expression)
types/expr_binary.go:217
↓ 1 callersFunctionNewInMemoryLogReplayer
(minFileRetentionTimestamp int64, storageType string)
replay_action.go:27
↓ 1 callersFunctionNewLessThanOrEq
(l Expression, r Expression)
types/expr_binary.go:257
↓ 1 callersFunctionNoFirstDeltaFile
()
errno/errors.go:134
↓ 1 callersFunctionNoLastDeltaFile
()
errno/errors.go:138
↓ 1 callersFunctionNonPartitionColumnAbsentError
()
errno/errors.go:86
↓ 1 callersFunctionNotebookInfoFromContext
(context map[string]string)
action/notebook_info.go:7
↓ 1 callersFunctionNullValueFoundForPrimitiveTypes
(name string)
errno/errors.go:239
↓ 1 callersFunctionOptionalFilterToPtr
(m mo.Option[V], filter func(V) bool)
internal/util/optional.go:46
↓ 1 callersFunctionPartitionColumnsNotFoundError
(partCols []string, schema string)
errno/errors.go:91
↓ 1 callersMethodPath
()
store/store.go:63
↓ 1 callersFunctionProtocolChangedException
(msg string)
errno/errors.go:46
↓ 1 callersFunctionQualified
(base string, path string)
internal/util/path/resolver.go:13
↓ 1 callersMethodRead
Read the given file and return an `Iterator` of lines, with line breaks removed from each line. Callers of this function are responsible to close the
store/azure.go:72
↓ 1 callersMethodRead
Read the given file and return an `Iterator` of lines, with line breaks removed from each line. Callers of this function are responsible to close the
store/gcs.go:69
↓ 1 callersMethodRemove
()
action/add.go:36
↓ 1 callersFunctionSchemaChangeError
(oldSchema string, newSchema string)
errno/errors.go:77
↓ 1 callersMethodSize
()
store/store.go:71
↓ 1 callersFunctionSplitConjunctivePredicates
(condition types.Expression)
internal/util/partition_utils.go:56
↓ 1 callersFunctionSplitMetadataAndDataPredicates
(condition types.Expression, partitionColumns []string)
internal/util/partition_utils.go:12
↓ 1 callersFunctionTimestampEarlierThanTableFirstCommit
(userTimestamp int64, commitTs int64)
errno/errors.go:159
↓ 1 callersFunctionUnexpectedFileType
(path string)
errno/errors.go:126
← previousnext →201–300 of 719, ranked by callers