MCPcopy Create free account

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

Functions719 in github.com/csimplestring/delta-go

MethodJson
()
action/commit_info.go:35
MethodJson
()
action/protocol.go:12
MethodJson
()
action/remove.go:31
MethodJson
()
action/metadata.go:39
MethodJson
()
action/cdc.go:27
MethodJson
()
action/add.go:32
MethodJson
()
action/trx.go:13
MethodLength
()
record.go:30
MethodLength
()
types/type_struct.go:27
MethodListFrom
(path string)
checkpoint_test.go:102
MethodListFrom
(path string)
store/base.go:53
MethodListFrom
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/s3.go:73
MethodListFrom
(path string)
store/local.go:65
MethodMarkFilesAsRead
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:235
FunctionMustParseName
MustParseName converts a string to a Name, and panics if is not valid.
op/names.go:95
MethodName
()
types/type_array.go:8
MethodName
()
types/type_primitives.go:8
MethodName
()
types/type_primitives.go:15
MethodName
()
types/type_primitives.go:22
MethodName
()
types/type_primitives.go:29
MethodName
()
types/type_primitives.go:38
MethodName
()
types/type_primitives.go:49
MethodName
()
types/type_primitives.go:56
MethodName
()
types/type_primitives.go:63
MethodName
()
types/type_primitives.go:70
MethodName
()
types/type_primitives.go:77
MethodName
()
types/type_primitives.go:84
MethodName
()
types/type_primitives.go:91
MethodName
()
types/type_primitives.go:98
MethodName
()
types/type_map.go:9
MethodName
()
types/type_struct.go:15
MethodNext
()
scan.go:164
MethodNext
()
checkpoint_reader.go:66
MethodNext
()
checkpoint_test.go:112
MethodNext
()
replay_file.go:28
MethodNext
()
replay_file.go:54
MethodNext
()
replay_file.go:98
MethodNext
()
store/base.go:78
MethodNext
()
iter/map_iter.go:8
MethodNext
Value implements Iterator[T].Value by returning the next line from the reader.
iter/line_reader.go:28
MethodNext
()
iter/slice.go:16
MethodNowInMillis
()
clock.go:13
MethodNowInNano
()
clock.go:7
MethodNowInNano
()
clock.go:17
FunctionNullValueFoundForNonNullSchemaField
(name string, schema string)
errno/errors.go:243
MethodOpen
(path string, schemaString string)
parquet_writer.go:50
FunctionOptionalFilter
(m mo.Option[V], filter func(V) bool)
internal/util/optional.go:36
MethodPath
()
log.go:182
MethodPathAsUri
()
action/remove.go:23
MethodPathAsUri
()
action/cdc.go:19
MethodPathAsUri
()
action/add.go:24
MethodPathAsUri
()
action/action.go:22
MethodPushedPredicate
()
scan.go:75
MethodPushedPredicate
()
scan.go:241
MethodRead
(path string)
checkpoint_reader.go:19
MethodRead
(path string)
checkpoint_reader.go:43
MethodRead
(path string)
checkpoint_test.go:96
MethodRead
(path string)
store/base.go:17
MethodRead
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/s3.go:63
MethodRead
(path string)
store/local.go:56
MethodRead
(p []byte)
iter/line_reader.go:57
MethodReadWholeTable
Mark the entire table as tainted (i.e. read) by this transaction.
trnx.go:323
FunctionReferences
References returns the names of columns referenced by this expression.
types/interfaces.go:54
MethodReferences
()
types/expr_binary.go:46
MethodReferences
()
types/expr_unary.go:31
MethodReferences
()
types/expr_column.go:79
MethodReferences
()
types/expr_literal.go:35
MethodResidualPredicate
()
scan.go:79
MethodResidualPredicate
()
scan.go:245
MethodResolvePathOnPhysicalStore
(path string)
checkpoint_test.go:128
MethodResolvePathOnPhysicalStore
Resolve the fully qualified path for the given `path`.
store/store.go:47
MethodRoot
()
checkpoint_test.go:92
MethodRoot
()
store/azure.go:65
MethodRoot
()
store/s3.go:56
MethodRoot
()
store/local.go:47
MethodRoot
()
store/gcs.go:62
MethodScan
Scan scan of the files in this snapshot matching the pushed portion of predicate
snapshot.go:98
MethodSchema
()
record.go:26
MethodSnapshot
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:148
MethodSnapshotForTimestampAsOf
(timestamp int64)
log.go:160
MethodSnapshotForVersionAsOf
(version int64)
log.go:156
MethodStartTransaction
()
log.go:164
MethodString
()
isolation/delta_isolationlevel.go:9
MethodString
()
isolation/delta_isolationlevel.go:13
MethodString
()
types/expr_binary.go:42
MethodString
String returns the String representation of this expression.
types/expr_unary.go:27
MethodString
()
types/expr_unary.go:44
MethodString
()
types/expr_unary.go:64
MethodString
()
types/expr_unary.go:82
MethodString
String returns the String representation of this expression.
types/expr_column.go:70
MethodString
String returns the String representation of this expression.
types/expr_literal.go:26
MethodString
String implements the Stringer interface.
op/names.go:56
FunctionTestAnd
(t *testing.T)
types/expr_binary_test.go:30
FunctionTestAsReader
(t *testing.T)
iter/line_reader_test.go:13
FunctionTestAzureBlobExample
(t *testing.T)
examples/azblob_example_test.go:11
FunctionTestAzureBlobLogStore
(t *testing.T)
store/azure_test.go:12
FunctionTestCanonicalize
(t *testing.T)
internal/util/path/resolver_test.go:89
FunctionTestCheckColumnNameDuplication
(t *testing.T)
types/type_utils_test.go:163
FunctionTestColumnVariantions
(t *testing.T)
types/type_utils_test.go:95
FunctionTestComparison
(t *testing.T)
types/expr_binary_test.go:43
← previousnext →501–600 of 719, ranked by callers