MCPcopy Create free account

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

Functions719 in github.com/csimplestring/delta-go

⨍ Functions 719◇ Types & classes 134
↓ 86 callersMethodWrap
()
action/action.go:16
↓ 60 callersFunctionNewStructField
(name string, t DataType, nullable bool)
types/type_struct.go:87
↓ 48 callersMethodNext
()
iter/iterator.go:13
↓ 44 callersMethodclean
()
log_test.go:176
↓ 44 callersFunctionnewTestLogCases
(names ...string)
log_test.go:214
↓ 37 callersMethodClose
()
iter/iterator.go:14
↓ 35 callersFunctionFromSlice
(s []T)
iter/slice.go:30
↓ 31 callersFunctionNewStructType
(fields []*StructField)
types/type_struct.go:65
↓ 28 callersFunctiontestPredicate
(t *testing.T, p Expression, expected any, record RowRecord)
types/expr_binary_test.go:11
↓ 27 callersMethodVersion
Version returns the versiion of this Snapshot
snapshot.go:33
↓ 26 callersFunctionLiteralNull
(dt DataType)
types/expr_literal.go:86
↓ 26 callersMethodPath
()
log.go:34
↓ 25 callersMethodCommit
Commit Modifies the state of the log by adding a new commit that is based on a read at the table's latest version as of this transaction's instantiati
trnx.go:39
↓ 25 callersMethodgetLog
(name string)
log_test.go:126
↓ 24 callersMethodAdd
(field *StructField)
types/type_struct.go:39
↓ 24 callersMethodgetTempLog
()
log_test.go:132
↓ 23 callersFunctionUnmarshalString
(obj interfaces.UnmarshalObject, fieldName string, setter func(s string))
internal/util/parquet/serde.go:5
↓ 20 callersMethodAdd2
(fieldName string, dt DataType)
types/type_struct.go:46
↓ 20 callersMethodRoot
()
store/store.go:29
↓ 19 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/store.go:34
↓ 18 callersMethodString
String returns the String representation of this expression.
types/interfaces.go:44
↓ 17 callersMethodAllFiles
AllFiles returns all of the files present in this snapshot
snapshot.go:27
↓ 15 callersMethodError
()
errno/errors.go:231
↓ 15 callersMethodGet
Get runs the specified function only once, but all callers gets the same result from that single execution.
internal/util/lazy.go:25
↓ 15 callersFunctionNewAnd
(l Expression, r Expression)
types/expr_binary.go:139
↓ 15 callersMethodSnapshot
Snapshot the current Snapshot of the Delta table. You may need to call update() to access the latest snapshot if the current snapshot is stale.
log.go:22
↓ 15 callersFunctiontestLiteral
(l *Literal, expected any, t *testing.T)
types/expr_literal_test.go:34
↓ 14 callersMethodStartTransaction
()
log.go:30
↓ 14 callersFunctiongetTestFileDir
File log store tests
log_test.go:33
↓ 14 callersFunctionnewTrxTestFixture
()
trnx_test.go:33
↓ 13 callersMethodCopy
(dataChange bool, path string)
action/add.go:55
↓ 13 callersMethodName
()
types/interfaces.go:33
↓ 13 callersFunctioncheckTrx
( conflict bool, log Log, reads []func(OptimisticTransaction), concurrentWrites []func(OptimisticTransacti
trnx_test.go:91
↓ 13 callersFunctionsetUpTestTrxLog
(setup []action.Action, log Log, f *trxTestFixture, t *testing.T)
trnx_test.go:80
↓ 12 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/store.go:37
↓ 12 callersMethodUpdate
()
log.go:24
↓ 12 callersFunctioncheckPrimitiveField
(p *PartitionRowRecord, fieldName string, expectedType string)
record.go:161
↓ 11 callersFunctionToSlice
(iter Iter[T])
iter/slice.go:37
↓ 11 callersFunctionUnmarshalInt64
(obj interfaces.UnmarshalObject, fieldName string, setter func(s int64))
internal/util/parquet/serde.go:16
↓ 10 callersFunctionDeltaFile
(path string, version int64)
internal/util/filenames/filename.go:17
↓ 10 callersFunctionDeltaVersion
(path string)
internal/util/filenames/filename.go:32
↓ 10 callersFunctionMarshalMap
(obj interfaces.MarshalObject, fieldName string, m map[string]string)
internal/util/parquet/serde.go:122
↓ 10 callersFunctionToJSON
(d DataType)
types/type_parser.go:38
↓ 10 callersFunctionUnmarshalMap
(obj interfaces.UnmarshalObject, fieldName string, setter func(map[string]string))
internal/util/parquet/serde.go:82
↓ 10 callersMethodWrite
Write the given `actions` to the given `path` with or without overwrite as indicated. Implementation must throw FileAlreadyExistsException exception i
store/store.go:44
↓ 9 callersMethodEval
Eval returns the result of evaluating this expression on the given input RowRecord.
types/interfaces.go:38
↓ 9 callersMethodExists
(path string)
store/store.go:52
↓ 9 callersFunctionIsWriteCompatible
As the Delta table updates, the schema may change as well. This method defines whether a new schema can replace a pre-existing schema of a Delta table
types/type_utils.go:131
↓ 9 callersFunctionLiteralInt
(n int)
types/expr_literal.go:42
↓ 9 callersMethodverifyTimeTravelSnapshot
(t *testing.T, s Snapshot, expectedFiles []string, expectedVersion int64)
log_timetravel_test.go:53
↓ 8 callersFunctionConvertToBlobURL
From constructs azblob://my-bucket/path/to/log/ file:///path/to/ gs://my-bucket/path/to/
internal/util/path/path.go:15
↓ 8 callersMethodDelete
(dir string, files []string, hardDelete bool)
internal/util/blob.go:98
↓ 8 callersFunctionNewOr
(l Expression, r Expression)
types/expr_binary.go:158
↓ 8 callersMethodSnapshotForVersionAsOf
(version int64)
log.go:26
↓ 8 callersFunctionrelativePath
(scheme string, basePath string, path string)
store/store.go:94
↓ 7 callersMethodColumn
(fieldName string)
types/type_struct.go:60
↓ 7 callersFunctionIsCheckpointFile
(path string)
internal/util/filenames/filename.go:27
↓ 7 callersFunctionIsDeltaFile
(path string)
internal/util/filenames/filename.go:38
↓ 7 callersFunctionPtrOf
(t T)
internal/util/ptr.go:3
↓ 7 callersMethodScan
Scan scan of the files in this snapshot matching the pushed portion of predicate
snapshot.go:24
↓ 7 callersFunctionjsonString
(a Action)
action/action.go:35
↓ 6 callersFunctionActionNotFound
(action string, version int64)
errno/errors.go:24
↓ 6 callersMethodCreate
(path string)
store/store.go:54
↓ 6 callersMethodFiles
Creates a CloseableIterator over files belonging to this snapshot. There is no iteration ordering guarantee among files. Files returned are guaranteed
scan.go:27
↓ 6 callersFunctionForceToJSON
(d DataType)
types/type_parser.go:43
↓ 6 callersFunctionLazyValue
(f func() (T, error))
internal/util/lazy.go:18
↓ 6 callersFunctionMap
(iter Iter[T], mapper func(t T) (R, error))
iter/iterator.go:17
↓ 6 callersMethodMarkFilesAsRead
Mark files matched by the readPredicate as read by this transaction. Please note filtering is only supported on partition columns, thus the files matc
trnx.go:50
↓ 6 callersFunctionMustHash
(v interface{})
internal/util/hash.go:9
↓ 6 callersFunctionNewEqualTo
(l Expression, r Expression)
types/expr_binary.go:177
↓ 6 callersMethodSnapshotForTimestampAsOf
(timestamp int64)
log.go:28
↓ 6 callersMethodsnapshot
()
snapshot_reader.go:73
↓ 5 callersFunctionAssertionError
(msg string)
errno/errors.go:96
↓ 5 callersFunctionCanonicalize
(path string, schema string)
internal/util/path/resolver.go:87
↓ 5 callersMethodChanges
Get all actions starting from startVersion (inclusive) in increasing order of committed version. If startVersion doesn't exist, return an empty Iterat
log.go:38
↓ 5 callersMethodDataType
DataType returns the DataType of the result of evaluating this expression.
types/interfaces.go:41
↓ 5 callersFunctionExists
(elements []T, predicate func(e T) bool)
internal/util/slice.go:5
↓ 5 callersFunctionFileAlreadyExists
(file string)
errno/errors.go:235
↓ 5 callersFunctionForTable
ForTable Create a DeltaLog instance representing the table located at the provided path.
log.go:61
↓ 5 callersMethodGetFields
()
types/type_struct.go:54
↓ 5 callersMethodMetadata
Metadata returns the table metadata for this snapshot
snapshot.go:30
↓ 5 callersFunctionOptionalToPtr
(o mo.Option[V])
internal/util/optional.go:27
↓ 5 callersMethodPushedPredicate
PushedPredicate Returns portion of the input predicate that can be evaluated by Delta Standalone using only metadata (filters on partition columns). F
scan.go:35
↓ 5 callersMethodSchema
()
types/interfaces.go:11
↓ 5 callersMethodString
()
isolation/delta_isolationlevel.go:4
↓ 5 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:54
↓ 5 callersFunctioncompareWithType
(dataType DataType, l any, r any)
types/expr_binary.go:70
↓ 5 callersFunctionnameToType
(s string)
types/type_parser.go:51
↓ 5 callersFunctionnewTimeTravelFixture
()
log_timetravel_test.go:39
↓ 5 callersFunctiontestColumnVariantions
(t *testing.T, scenario string, makeFn func(fn func(*StructType) *StructType) *StructType)
types/type_utils_test.go:63
↓ 5 callersFunctiontestNullability
(t *testing.T, scenario string, makeFn func(bool) *StructType)
types/type_utils_test.go:55
↓ 4 callersFunctionCheckFieldNames
(names []string)
types/type_utils.go:19
↓ 4 callersMethodFieldNames
()
types/type_struct.go:19
↓ 4 callersFunctionFromJSON
(s string)
types/type_parser.go:30
↓ 4 callersFunctionLiteralBigDecimal
(d decimal.Decimal)
types/expr_literal.go:54
↓ 4 callersFunctionLiteralBinary
(b []byte)
types/expr_literal.go:46
↓ 4 callersFunctionLiteralByte
(b byte)
types/expr_literal.go:82
↓ 4 callersFunctionLiteralDouble
(d float64)
types/expr_literal.go:58
↓ 4 callersFunctionLiteralFloat
(f float32)
types/expr_literal.go:62
↓ 4 callersFunctionLiteralLong
(n int64)
types/expr_literal.go:66
next →1–100 of 719, ranked by callers