Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/BlazingDB/blazingsql
/ functions
Functions
3,772 in github.com/BlazingDB/blazingsql
⨍
Functions
3,772
◇
Types & classes
519
↓ 1 callers
Function
executionTest
(queryType)
tests/BlazingSQLTest/EndToEndTests/oldScripts/fileSystemS3Test.py:16
↓ 1 callers
Function
executionTestAuto
(dask_client, spark, dir_data_file, bc, nRals)
tests/BlazingSQLTest/EndToEndTests/oldScripts/hiveFileTest.py:17
↓ 1 callers
Function
executionTestWithPartitions
(dask_client, spark, dir_data_file, bc, nRals)
tests/BlazingSQLTest/EndToEndTests/oldScripts/hiveFileTest.py:258
↓ 1 callers
Function
executionTestWithSomePartitions
(dask_client, spark, dir_data_file, bc, nRals)
tests/BlazingSQLTest/EndToEndTests/oldScripts/hiveFileTest.py:598
↓ 1 callers
Function
expectSync
( elem, type )
docs/_static/jquery-3.5.1.js:5111
↓ 1 callers
Function
extract_table_name
Input: [[hr, emps]] or [[emps]] Output: hr.emps or emps
engine/src/parser/expression_utils.cpp:991
↓ 1 callers
Method
fetch
(self, token)
pyblazing/pyblazing/apiv2/context.py:3066
↓ 1 callers
Function
filterHivePartitionsWithUserPartitions
(hive_partitions, user_partitions)
pyblazing/pyblazing/apiv2/hive.py:113
↓ 1 callers
Function
final_performance_delinquency
(gdf, joined_df, **kwargs)
tests/BlazingSQLTest/DemoTest/demoTest_wo_coalesce.py:596
↓ 1 callers
Function
final_performance_delinquency
(gdf, joined_df, **kwargs)
tests/BlazingSQLTest/DemoTest/demoTest.py:341
↓ 1 callers
Function
finalize
engine/src/cython/initialize.cpp:644
↓ 1 callers
Method
findExprInLists
Looks for a matching RexNode from among two lists of RexNodes and returns the offset into the list corresponding to the match, adjusted by an amount,
algebra/blazingdb-calcite-application/src/main/java/com/blazingdb/calcite/rules/PushProjector.java:847
↓ 1 callers
Method
findReducibleExps
Locates expressions that can be reduced to literals or converted to expressions with redundant casts removed. @param typeFactory Type factory @par
algebra/blazingdb-calcite-application/src/main/java/com/blazingdb/calcite/rules/ReduceExpressionsRule.java:710
↓ 1 callers
Function
find_closing_char
takes an expression and given a starting index pointing at either ( or [, it finds the corresponding closing char ) or ]
engine/src/parser/CalciteExpressionParsing.cpp:285
↓ 1 callers
Function
find_last_bracket_pos
Used by `nary_to_nestedbinary` to find the end pos for expression call
engine/src/parser/expression_utils.cpp:1521
↓ 1 callers
Method
finish
engine/src/cache_machine/CacheMachine.cpp:62
↓ 1 callers
Method
finish_execute
engine/src/execution_graph/graph.cpp:80
↓ 1 callers
Function
fixInput
( src, dest )
docs/_static/jquery-3.5.1.js:6034
↓ 1 callers
Function
fix_column_names_duplicated
engine/src/cython/engine.cpp:162
↓ 1 callers
Method
flush
io/src/FileSystem/private/S3OutputStream.cpp:155
↓ 1 callers
Method
flush
io/src/FileSystem/private/GoogleCloudStorageOutputStream.cpp:139
↓ 1 callers
Function
format_json_plan
(json_plan)
pyblazing/pyblazing/apiv2/algebra/json_plan.py:24
↓ 1 callers
Function
format_pdf
(pdf, worder, orderBy)
tests/BlazingSQLTest/Runner/runTest.py:1381
↓ 1 callers
Method
free_chunk
engine/src/bmr/BufferProvider.cpp:161
↓ 1 callers
Method
fromTypeId
(int type_id)
algebra/blazingdb-calcite-core/src/main/java/com/blazingdb/calcite/catalog/domain/CatalogColumnDataType.java:68
↓ 1 callers
Function
ft
(o,e,t)
docs/_static/jquery.js:2
↓ 1 callers
Function
fu
(n)
docsrc/source/_static/js/d3.v3.min.js:2
↓ 1 callers
Function
fu
(n)
docs/_static/js/d3.v3.min.js:2
↓ 1 callers
Method
functionThatCallsNoArgs
io/tests/ExceptionHandling/BlazingThreadTest.cpp:94
↓ 1 callers
Method
functionThatCallsWithArgs
io/tests/ExceptionHandling/BlazingThreadTest.cpp:98
↓ 1 callers
Method
functionThatCallsWithErrorWithArgs
io/tests/ExceptionHandling/BlazingThreadTest.cpp:81
↓ 1 callers
Method
functionThatRethrowsNoArgs
io/tests/ExceptionHandling/BlazingThreadTest.cpp:105
↓ 1 callers
Method
functionThatRethrowsWithArgs
io/tests/ExceptionHandling/BlazingThreadTest.cpp:113
↓ 1 callers
Function
g
()
docsrc/source/_static/js/d3.v3.min.js:1
↓ 1 callers
Function
generatePartitionPlans
engine/src/distribution_utils/primitives.cpp:34
↓ 1 callers
Function
generate_graph
engine/src/execution_graph/CalciteInterpreter.cpp:26
↓ 1 callers
Function
generate_predicate
engine/src/io/data_provider/sql/compatibility/SQLTranspiler.cpp:76
↓ 1 callers
Function
generate_test_string
engine/tests/communication/message_send_receive.cpp:523
↓ 1 callers
Method
getAlgebraGenerator
Synchronizes access to the relational algebra generator in case an update is occurring @return {@link #relationalAlgebraGenerator}
algebra/blazingdb-calcite-application/src/main/java/com/blazingdb/calcite/application/ApplicationContext.java:94
↓ 1 callers
Method
getBytesReceived
io/tests/Library/Logging/Performance/LibraryLoggingPerformanceTest.cpp:33
↓ 1 callers
Function
getChunks
(year, quarter)
tests/BlazingSQLTest/DemoTest/demoTest_wo_coalesce.py:731
↓ 1 callers
Function
getChunks
(year, quarter)
tests/BlazingSQLTest/DemoTest/demoTest.py:459
↓ 1 callers
Method
getColumnDataType
()
algebra/blazingdb-calcite-core/src/main/java/com/blazingdb/calcite/catalog/domain/CatalogColumn.java:7
↓ 1 callers
Method
getColumnName
()
algebra/blazingdb-calcite-application/src/main/java/com/blazingdb/calcite/catalog/domain/CatalogColumnImpl.java:85
↓ 1 callers
Method
getColumns
()
algebra/blazingdb-calcite-core/src/main/java/com/blazingdb/calcite/catalog/domain/CatalogTable.java:9
↓ 1 callers
Method
getConnectionProperties
io/src/FileSystem/FileSystemConnection.cpp:395
↓ 1 callers
Method
getCurrentTimestamp
engine/src/execution_graph/Context.cpp:77
↓ 1 callers
Method
getDaskDataFrameKeySlices
(self, nodes, client)
pyblazing/pyblazing/apiv2/context.py:1133
↓ 1 callers
Function
getData
( data )
docs/_static/jquery-3.5.1.js:4401
↓ 1 callers
Function
getDefaultDisplay
( elem )
docs/_static/jquery-3.5.1.js:4806
↓ 1 callers
Function
getDriverTypeEnvValue
io/tests/FileSystem/HadoopFileSystemTest/Common/SystemEnvironment.cpp:44
↓ 1 callers
Method
getEncryptedAuthority
io/src/FileSystem/FileSystemEntity.cpp:60
↓ 1 callers
Method
getEncryptedFileSystemConnection
io/src/FileSystem/FileSystemEntity.cpp:62
↓ 1 callers
Method
getEncryptedRoot
io/src/FileSystem/FileSystemEntity.cpp:66
↓ 1 callers
Function
getExecuteGraphResult
engine/src/cython/engine.cpp:234
↓ 1 callers
Function
getFileName
(dir_log)
tests/BlazingSQLTest/Runner/runTest.py:868
↓ 1 callers
Method
getId
()
algebra/blazingdb-calcite-application/src/main/java/com/blazingdb/calcite/catalog/domain/CatalogTableImpl.java:114
↓ 1 callers
Method
getMessages
io/tests/ExceptionHandling/BlazingThreadTest.cpp:46
↓ 1 callers
Function
getNodePartitionKeys
(df, client)
pyblazing/pyblazing/apiv2/context.py:269
↓ 1 callers
Method
getOrderValue
()
algebra/blazingdb-calcite-application/src/main/java/com/blazingdb/calcite/catalog/domain/CatalogColumnImpl.java:123
↓ 1 callers
Function
getPartitions
(tableName, schema, cursor)
pyblazing/pyblazing/apiv2/hive.py:96
↓ 1 callers
Function
getPartitionsFromUserPartitions
(user_partitions)
pyblazing/pyblazing/apiv2/hive.py:132
↓ 1 callers
Function
getPivotPointsTable
engine/src/distribution_utils/primitives.cpp:129
↓ 1 callers
Function
getProductDetails
engine/src/cython/static.cpp:8
↓ 1 callers
Function
getRegion
io/src/FileSystem/private/S3FileSystem_p.cpp:104
↓ 1 callers
Method
getRelationalAlgebraString
(String sql)
algebra/blazingdb-calcite-application/src/main/java/com/blazingdb/calcite/application/RelationalAlgebraGenerator.java:269
↓ 1 callers
Method
getSchema
(String schemaName)
algebra/blazingdb-calcite-core/src/main/java/com/blazingdb/calcite/catalog/connection/CatalogService.java:10
↓ 1 callers
Method
getService
Synchronizes access to the catalog service in case an update is occurring. @return {@link #catalogService}
algebra/blazingdb-calcite-application/src/main/java/com/blazingdb/calcite/application/ApplicationContext.java:86
↓ 1 callers
Method
getSessionFactory
Creates a SessionFactory @return A session factory capable of opening sessions
algebra/blazingdb-calcite-application/src/main/java/com/blazingdb/calcite/catalog/repository/DatabaseRepository.java:41
↓ 1 callers
Method
getStatistic
()
algebra/blazingdb-calcite-core/src/main/java/com/blazingdb/calcite/schema/BlazingTable.java:73
↓ 1 callers
Method
getTable
(String name)
algebra/blazingdb-calcite-core/src/main/java/com/blazingdb/calcite/schema/BlazingSchema.java:43
↓ 1 callers
Method
getTable
Gets a table by name @return the table that has this name
algebra/blazingdb-calcite-application/src/main/java/com/blazingdb/calcite/catalog/domain/CatalogDatabaseImpl.java:125
↓ 1 callers
Method
getTableNames
()
algebra/blazingdb-calcite-core/src/main/java/com/blazingdb/calcite/catalog/domain/CatalogDatabase.java:12
↓ 1 callers
Method
getTableNames
@return The names of all the tables in the database by getting them from the keySet() of {@link #databaseTables}
algebra/blazingdb-calcite-application/src/main/java/com/blazingdb/calcite/catalog/domain/CatalogDatabaseImpl.java:136
↓ 1 callers
Method
getTotalBytesSent
io/tests/Library/Logging/Performance/LibraryLoggingPerformanceTest.cpp:96
↓ 1 callers
Method
getTotalPacketsSent
io/tests/Library/Logging/Performance/LibraryLoggingPerformanceTest.cpp:98
↓ 1 callers
Method
getTypeId
()
algebra/blazingdb-calcite-core/src/main/java/com/blazingdb/calcite/catalog/domain/CatalogColumnDataType.java:60
↓ 1 callers
Function
getValidUris
io/tests/FileSystem/UriTest/UriTest.cpp:30
↓ 1 callers
Function
get_Branch
()
tests/BlazingSQLTest/Runner/runTest.py:248
↓ 1 callers
Function
get_CommitHash
()
tests/BlazingSQLTest/Runner/runTest.py:253
↓ 1 callers
Function
get_QueryId
(input_type, test_name, test_id)
tests/BlazingSQLTest/Runner/runTest.py:258
↓ 1 callers
Function
get_aggregation_operation_string
engine/src/parser/CalciteExpressionParsing.cpp:264
↓ 1 callers
Function
get_aggregation_output_type
TODO all these return types need to be revisited later. Right now we have issues with some aggregators that only support returning the same input type
engine/src/operators/GroupBy.cpp:30
↓ 1 callers
Method
get_all_or_wait
* Waits until all messages are ready then returns all of them. * You should never call this function more than once on a WaitingQueue else * race co
engine/src/cache_machine/WaitingQueue.h:440
↓ 1 callers
Function
get_all_str_values_in_the_same_col
engine/src/io/data_parser/metadata/orc_metadata.cpp:29
↓ 1 callers
Function
get_all_values_in_the_same_col
engine/src/io/data_parser/metadata/orc_metadata.cpp:18
↓ 1 callers
Method
get_calcite_to_file_indices
engine/src/io/Schema.h:52
↓ 1 callers
Function
get_config_option_from_env
(option_name: str, default_value)
pyblazing/pyblazing/apiv2/context.py:1232
↓ 1 callers
Method
get_count
engine/src/cython/initialize.cpp:78
↓ 1 callers
Function
get_current_date_or_timestamp
engine/src/parser/expression_utils.cpp:1494
↓ 1 callers
Function
get_drill_query
(query)
tests/BlazingSQLTest/Runner/runTest.py:943
↓ 1 callers
Function
get_dtypes_hive
(type)
tests/BlazingSQLTest/DataBase/createSchema.py:944
↓ 1 callers
Function
get_dtypes_spark
(type)
tests/BlazingSQLTest/DataBase/createSchema.py:928
↓ 1 callers
Function
get_execute_graph_results
engine/src/execution_graph/CalciteInterpreter.cpp:179
↓ 1 callers
Method
get_expr_output_type
engine/src/execution_kernels/LogicalProject.cpp:784
↓ 1 callers
Function
get_filenames_table
(table, dir_data_lc, n_files, ext='psv', **kwargs)
tests/BlazingSQLTest/DataBase/createSchema.py:1004
↓ 1 callers
Method
get_from_driver_used_memory
engine/src/bmr/BlazingMemoryResource.cpp:88
↓ 1 callers
Method
get_full_memory_summary
engine/src/bmr/BlazingMemoryResource.cpp:107
↓ 1 callers
Method
get_gpu_table
engine/src/blazing_table/BlazingHostTable.cpp:82
↓ 1 callers
Function
get_group_columns
engine/src/operators/GroupBy.cpp:124
← previous
next →
1,501–1,600 of 3,772, ranked by callers