MCPcopy Create free account

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

Functions719 in github.com/csimplestring/delta-go

⨍ Functions 719◇ Types & classes 134
↓ 4 callersFunctionLiteralShort
(n int8)
types/expr_literal.go:70
↓ 4 callersFunctionLiteralString
(s string)
types/expr_literal.go:74
↓ 4 callersFunctionLiteralTimestamp
(t time.Time)
types/expr_literal.go:78
↓ 4 callersMethodRemoveWithTimestamp
(ts *int64, dataChange *bool)
action/add.go:40
↓ 4 callersFunctionUnmarshalBool
(obj interfaces.UnmarshalObject, fieldName string, setter func(s bool))
internal/util/parquet/serde.go:38
↓ 4 callersMethodUnwrap
()
action/action.go:63
↓ 4 callersMethodcopyLog
(name string)
log_test.go:149
↓ 4 callersFunctiongetTestDirDataFile
(tablePath string)
log_timetravel_test.go:17
↓ 4 callersFunctiongetTestMetedata
()
log_test.go:102
↓ 4 callersFunctionmustNoError
(err error)
scan_test.go:30
↓ 4 callersFunctionnewScanTestFixtures
()
scan_test.go:49
↓ 4 callersFunctionnewTestLogCase
(name string, baseDir string, c Config)
log_test.go:193
↓ 4 callersFunctiontestDatatypeChange
(t *testing.T, scenario string, makeFn func(DataType) *StructType)
types/type_utils_test.go:37
↓ 4 callersMethodupdate
()
snapshot_reader.go:279
↓ 3 callersFunctionCheckpointVersion
(path string)
internal/util/filenames/filename.go:21
↓ 3 callersMethodCommitInfoAt
(version int64)
log.go:32
↓ 3 callersMethodCompare
(other CheckpointInstance)
checkpoint.go:35
↓ 3 callersMethodDeleteFile
(file string)
internal/util/blob.go:125
↓ 3 callersFunctionExplodeNestedFieldNames
(schema *StructType)
types/type_utils.go:275
↓ 3 callersFunctionFromJson
(s string)
action/action.go:26
↓ 3 callersFunctionIllegalStateError
(msg string)
errno/errors.go:54
↓ 3 callersFunctionInvalidProtocolVersionError
()
errno/errors.go:50
↓ 3 callersFunctionLastCheckpoint
(s store.Store)
checkpoint.go:91
↓ 3 callersFunctionMapOptional
(m mo.Option[S], mapper func(v S) D)
internal/util/optional.go:5
↓ 3 callersMethodMetadata
the metadata for this transaction. It refers to the metadata of the table's latest version as of this transaction's instantiation unless updated durin
trnx.go:58
↓ 3 callersFunctionNestedNotNullConstraintError
(parent string, nested string, nestType string)
errno/errors.go:108
↓ 3 callersFunctionNewNot
(e Expression)
types/expr_unary.go:68
↓ 3 callersMethodOpen
(path string, schema string)
parquet_writer.go:22
↓ 3 callersMethodResidualPredicate
ResidualPredicate Returns portion of the input predicate that may not be fully applied. Files returned by Files() are not guaranteed to satisfy the re
scan.go:39
↓ 3 callersMethodResolvePathOnPhysicalStore
Resolve the fully qualified path for the given `path`.
store/azure.go:107
↓ 3 callersMethodResolvePathOnPhysicalStore
Resolve the fully qualified path for the given `path`.
store/s3.go:110
↓ 3 callersMethodResolvePathOnPhysicalStore
(path string)
store/local.go:52
↓ 3 callersMethodResolvePathOnPhysicalStore
Resolve the fully qualified path for the given `path`.
store/gcs.go:104
↓ 3 callersMethodTimeModified
()
store/store.go:67
↓ 3 callersFunctionVersionNotExist
(userVersion int64, earliest int64, latest int64)
errno/errors.go:154
↓ 3 callersMethodcreateSnapshot
(segment *LogSegment, lastCommitTs int64)
snapshot_reader.go:270
↓ 3 callersMethodfromMetadata
(metadata *action.Metadata)
config.go:25
↓ 3 callersMethodgetActiveCommitAtTime
(sr *SnapshotReader, timestamp int64, canReturnLastCommit bool, mustBeRecreatable bool, canReturnEarliestComm
history_manager.go:68
↓ 3 callersMethodgetLogSegmentForVersion
(startCheckpoint mo.Option[int64], versionToLoad mo.Option[int64])
snapshot_reader.go:133
↓ 3 callersFunctiongetTestEngineInfo
()
log_test.go:94
↓ 3 callersFunctiongetTestFileConfig
()
log_test.go:50
↓ 3 callersFunctionmatchesNullableType
(x DataType)
types/type_utils.go:154
↓ 3 callersFunctionprettyFieldName
(columnPath []string)
types/type_utils.go:193
↓ 3 callersMethodsetUp
(log Log, actions []action.Action)
scan_test.go:36
↓ 3 callersMethodupdateInternal
updateInternal is not goroutine-safe, the caller should take care of locking.
snapshot_reader.go:287
↓ 2 callersMethodAdd3
(fieldName string, dt DataType, nullable bool)
types/type_struct.go:50
↓ 2 callersFunctionAsReadCloser
(itr Iter[string], appendNewline bool)
iter/line_reader.go:43
↓ 2 callersFunctionCheckColumnNameDuplication
(schema *StructType, colType string)
types/type_utils.go:290
↓ 2 callersFunctionCheckpointFileSingular
(dir string, version int64)
internal/util/filenames/filename.go:69
↓ 2 callersFunctionCheckpointPrefix
(path string, version int64)
internal/util/filenames/filename.go:65
↓ 2 callersMethodClose
()
parquet_writer.go:24
↓ 2 callersFunctionConcurrentDeleteRead
(file string)
errno/errors.go:181
↓ 2 callersMethodCopy
(version int64)
action/commit_info.go:55
↓ 2 callersMethodCreateTemp
()
internal/util/blob.go:129
↓ 2 callersFunctionDefaultProtocol
()
action/protocol.go:23
↓ 2 callersFunctionDeltaVersionNotContinuous
(versions []int64)
errno/errors.go:130
↓ 2 callersMethodEquals
(other *Protocol)
action/protocol.go:16
↓ 2 callersFunctionFindLastCompleteCheckpoint
(s store.Store, cv CheckpointInstance)
checkpoint.go:156
↓ 2 callersFunctionFromMetadata
(metadata CheckpointMetaDataJSON)
checkpoint.go:80
↓ 2 callersFunctionFromPath
(path string)
checkpoint.go:73
↓ 2 callersFunctionFromReadCloser
FromReadCloser returns an iterator producing lines from the given reader.
iter/line_reader.go:12
↓ 2 callersFunctionGetLatestCompleteCheckpointFromList
(instances []*CheckpointInstance, notLaterThan CheckpointInstance)
checkpoint.go:214
↓ 2 callersMethodGetReverseIterator
()
replay_file.go:77
↓ 2 callersFunctionJsonMarshalError
(err error)
errno/errors.go:38
↓ 2 callersMethodLength
()
types/interfaces.go:12
↓ 2 callersFunctionMaxInt64
(x int64, y int64)
internal/util/partition_utils.go:73
↓ 2 callersMethodMetadata
the metadata for this transaction. It refers to the metadata of the table's latest version as of this transaction's instantiation unless updated durin
trnx.go:311
↓ 2 callersFunctionNewAzureBlobLogStore
(logDir string)
store/azure.go:20
↓ 2 callersFunctionNewBlobDir
(urlstr string)
internal/util/blob.go:25
↓ 2 callersFunctionNewFileLogStore
(logDirUrl string)
store/local.go:17
↓ 2 callersFunctionNewGCSLogStore
(logDir string)
store/gcs.go:17
↓ 2 callersFunctionNewIsNotNull
(e Expression)
types/expr_unary.go:94
↓ 2 callersFunctionNewIsNull
(e Expression)
types/expr_unary.go:53
↓ 2 callersFunctionNewLessThan
(l Expression, r Expression)
types/expr_binary.go:237
↓ 2 callersFunctionNewS3LogStore
Note: currently s3 log store only supports single driver. TODO: support multi-drivers writes see https://delta.io/blog/2022-05-18-multi-cluster-writes
store/s3.go:20
↓ 2 callersFunctionNoHistoryFound
(path string)
errno/errors.go:150
↓ 2 callersFunctionNoReproducibleHistoryFound
(path string)
errno/errors.go:146
↓ 2 callersMethodNowInMillis
()
clock.go:6
↓ 2 callersFunctionNumCheckpointParts
(path string)
internal/util/filenames/filename.go:54
↓ 2 callersFunctionParseName
ParseName attempts to convert a string to a Name.
op/names.go:87
↓ 2 callersMethodPartitionSchema
()
action/metadata.go:55
↓ 2 callersMethodReadWholeTable
Mark the entire table as tainted (i.e. read) by this transaction.
trnx.go:61
↓ 2 callersMethodReferences
References returns the set of column names
types/interfaces.go:50
↓ 2 callersFunctionRelative
(base string, path string)
internal/util/path/resolver.go:25
↓ 2 callersMethodSchema
()
action/metadata.go:43
↓ 2 callersMethodTableExists
()
log.go:52
↓ 2 callersMethodTableExists
()
log.go:283
↓ 2 callersFunctionTimestampLaterThanTableLastCommit
(userTimestamp int64, commitTs int64)
errno/errors.go:163
↓ 2 callersMethodTxnVersion
returns the latest version that has committed for the idempotent transaction with given id.
trnx.go:64
↓ 2 callersFunctionUnmarshalInt32
(obj interfaces.UnmarshalObject, fieldName string, setter func(s int32))
internal/util/parquet/serde.go:27
↓ 2 callersFunctionUnsupportedFileSystem
(msg string)
errno/errors.go:30
↓ 2 callersFunctionassertProtocolRead
(protocol *action.Protocol)
conflict_checker.go:245
↓ 2 callersMethodcheckVersionExists
(versionToCkeck int64, sr *SnapshotReader)
history_manager.go:50
↓ 2 callersFunctioncompareTime
(t1 time.Time, t2 time.Time)
types/expr_binary.go:124
↓ 2 callersFunctiondataTypeToJSON
(d DataType)
types/type_parser.go:67
↓ 2 callersMethoddoCommit
(attemptVersion int64, actions []action.Action, isolationLevel isolation.Level)
trnx.go:578
↓ 2 callersFunctionexplode
(schema *StructType)
types/type_utils.go:236
↓ 2 callersMethodfiles
()
snapshot.go:170
↓ 2 callersMethodfindNextValid
()
scan.go:92
↓ 2 callersMethodgetEarliestReproducibleCommitVersion
()
history_manager.go:130
← previousnext →101–200 of 719, ranked by callers