MCPcopy Create free account

hub / github.com/BlazingDB/blazingsql / functions

Functions3,772 in github.com/BlazingDB/blazingsql

⨍ Functions 3,772◇ Types & classes 519
↓ 1 callersFunctionsample
engine/src/operators/OrderBy.cpp:275
↓ 1 callersFunctionsample_items
(bc, dask_client, nRals, **kwargs)
tests/BlazingSQLTest/EndToEndTests/oldScripts/tablesFromSQL.py:101
↓ 1 callersFunctionsaveLogInFile
(df)
tests/BlazingSQLTest/Runner/runTest.py:657
↓ 1 callersFunctionsave_results_parquet
(filename, pdf2)
tests/BlazingSQLTest/Runner/runTest.py:1024
↓ 1 callersFunctionschedule
()
docs/_static/jquery-3.5.1.js:7269
↓ 1 callersMethodsend_begin_transmission
engine/src/communication/CommunicationInterface/protocols.cpp:273
↓ 1 callersFunctionserialize_gpu_message_to_gpu_containers
engine/src/communication/messages/GPUComponentMessage.cpp:9
↓ 1 callersMethodsetColumnDataType
(CatalogColumnDataType dataType)
algebra/blazingdb-calcite-application/src/main/java/com/blazingdb/calcite/catalog/domain/CatalogColumnImpl.java:102
↓ 1 callersMethodsetColumnName
(String name)
algebra/blazingdb-calcite-application/src/main/java/com/blazingdb/calcite/catalog/domain/CatalogColumnImpl.java:91
↓ 1 callersMethodsetDetached
io/src/ExceptionHandling/BlazingExceptionHolder.cpp:12
↓ 1 callersFunctionsetMatcher
( preFilter, selector, matcher, postFilter, postFinder, postSelector )
docs/_static/jquery-3.5.1.js:2504
↓ 1 callersMethodsetOrderValue
(int orderValue)
algebra/blazingdb-calcite-application/src/main/java/com/blazingdb/calcite/catalog/domain/CatalogColumnImpl.java:128
↓ 1 callersFunctionsetPositiveNumber
( _elem, value, subtract )
docs/_static/jquery-3.5.1.js:6690
↓ 1 callersMethodsetRules
(List<RelOptRule> rules)
algebra/blazingdb-calcite-application/src/main/java/com/blazingdb/calcite/application/RelationalAlgebraGenerator.java:148
↓ 1 callersMethodsetTargetTest
(self, testList)
tests/BlazingSQLTest/Runner/testSuites.py:85
↓ 1 callersMethodsetTotalBytesMessage
io/tests/Library/Logging/Performance/LibraryLoggingPerformanceTest.cpp:94
↓ 1 callersMethodsetUcpContext
engine/src/bmr/BufferProvider.cpp:23
↓ 1 callersMethodset_has_header_csv
engine/src/io/Schema.cpp:79
↓ 1 callersMethodset_inputs
engine/src/execution_graph/executor.cpp:199
↓ 1 callersMethodset_kernels_order
engine/src/execution_graph/graph.cpp:339
↓ 1 callersMethodset_memory_monitor
engine/src/execution_graph/graph.cpp:30
↓ 1 callersFunctionset_min_max
engine/src/io/data_parser/metadata/parquet_metadata.cpp:13
↓ 1 callersFunctionset_min_max_string
engine/src/io/data_parser/metadata/orc_metadata.cpp:87
↓ 1 callersFunctionset_msg_data_len
engine/tests/communication/message_send_receive.cpp:519
↓ 1 callersMethodset_parent
* @brief Sets its parent kernel. * * @param id The identifier of its parent. */
engine/src/execution_kernels/kernel.h:52
↓ 1 callersMethodset_thread
engine/src/utilities/ctpl_stl.h:210
↓ 1 callersFunctionsetup_test
(data_type: DataType)
tests/BlazingSQLTest/EndToEndTests/oldScripts/tablesFromSQL.py:190
↓ 1 callersMethodsizeInBytes
engine/src/cache_machine/CacheDataLocalFile.cpp:75
↓ 1 callersFunctionsortedMerger
engine/src/distribution_utils/primitives.cpp:107
↓ 1 callersFunctionsplitQuery
(query)
docs/_static/searchtools.js:47
↓ 1 callersFunctionsqlite_is_cudf_string
engine/src/io/data_parser/sql/SQLiteParser.cpp:51
↓ 1 callersFunctionsqlite_is_string_col_type
TODO percy avoid code duplication
engine/src/io/data_provider/sql/SQLiteDataProvider.cpp:85
↓ 1 callersFunctionsqlite_load_data_in_file
(table: str, full_path_wildcard: str, cursor: sqlite
tests/BlazingSQLTest/DataBase/sqliteSchema.py:93
↓ 1 callersFunctionst
()
docs/_static/jquery.js:2
↓ 1 callersMethodstart
engine/src/utilities/CodeTimer.h:19
↓ 1 callersMethodstart
()
algebra/blazingdb-calcite-application/src/main/java/com/blazingdb/calcite/application/Chrono/Chronometer.java:32
↓ 1 callersMethodstart
(self)
tests/BlazingSQLTest/DemoTest/chronometer.py:33
↓ 1 callersMethodstart_execute
engine/src/execution_graph/graph.cpp:49
↓ 1 callersFunctionstart_execute_graph
engine/src/execution_graph/CalciteInterpreter.cpp:150
↓ 1 callersFunctionstatistic_to_dtype
engine/src/io/data_parser/metadata/orc_metadata.cpp:50
↓ 1 callersMethodstop
wait for all computing threads to finish and stop all threads may be called asynchronously to not pause the calling thread while waiting if isWait ==
engine/src/utilities/ctpl_stl.h:143
↓ 1 callersFunctionstr_to_timestamp_scalar_with_day_format
engine/src/parser/CalciteExpressionParsing.cpp:114
↓ 1 callersFunctionstr_to_timestamp_scalar_with_decimal_format
engine/src/parser/CalciteExpressionParsing.cpp:130
↓ 1 callersMethodsubstitute
Converts op(arg0, ..., argOrdinal, ..., argN) to op(arg0,..., node, ..., argN).
algebra/blazingdb-calcite-application/src/main/java/com/blazingdb/calcite/rules/ReduceExpressionsRule.java:795
↓ 1 callersMethodtask_memory_needed
engine/src/execution_graph/executor.cpp:61
↓ 1 callersMethodtell
io/src/FileSystem/private/S3OutputStream.cpp:189
↓ 1 callersMethodtell
io/src/FileSystem/private/GoogleCloudStorageOutputStream.cpp:174
↓ 1 callersFunctiontest_hive_partition_data
(input, file_format, table_name, partitions, partitions_schema, output, num_files=1)
tests/BlazingSQLTest/Utils/utilityHive.py:377
↓ 1 callersFunctiontesting_load_hive_table
(table_name, file_format, location, partitions, partitions_schema)
tests/BlazingSQLTest/Utils/utilityHive.py:360
↓ 1 callersFunctiontime_to_hms
engine/src/io/data_parser/sql/PostgreSQLParser.cpp:56
↓ 1 callersFunctiontimestamp_to_string
engine/src/io/data_parser/sql/PostgreSQLParser.cpp:107
↓ 1 callersFunctiontimestamp_to_tm
engine/src/io/data_parser/sql/PostgreSQLParser.cpp:74
↓ 1 callersMethodtoBlazingColumns
engine/src/execution_kernels/LogicPrimitives.cpp:120
↓ 1 callersFunctionto_dtype
This function is copied and adapted from cudf
engine/src/io/data_parser/metadata/parquet_metadata.cpp:129
↓ 1 callersFunctionto_pandas_f64_engine
(df, expected_types_list)
tests/BlazingSQLTest/Runner/runTest.py:76
↓ 1 callersFunctiontokenizer_helper
engine/src/parser/expression_tree.hpp:164
↓ 1 callersMethodtotal_bytes_added
engine/src/execution_graph/port.cpp:58
↓ 1 callersMethodtotal_input_rows_added
* @brief Returns sum of all the rows added to all caches of the input port. */
engine/src/execution_kernels/kernel.h:157
↓ 1 callersMethodtransform
engine/src/io/data_provider/sql/compatibility/SQLTranspiler.cpp:109
↓ 1 callersMethodtransform
engine/src/execution_kernels/LogicalProject.cpp:675
↓ 1 callersMethodtransform_physical_plan
engine/src/execution_graph/PhysicalPlanGenerator.h:429
↓ 1 callersFunctiontransform_predicate
engine/src/io/data_provider/sql/compatibility/SQLTranspiler.cpp:22
↓ 1 callersMethodtruncateFile
io/src/FileSystem/S3FileSystem.cpp:73
↓ 1 callersFunctiontry_to_get_dask_client
(n_workers, n_gpus, iface)
tests/BlazingSQLTest/Utils/__init__.py:103
↓ 1 callersFunctiontype_from_type_token
engine/src/parser/expression_tree.cpp:324
↓ 1 callersFunctiontype_statistic_valid
engine/src/io/data_parser/metadata/orc_metadata.cpp:40
↓ 1 callersFunctionu
()
docs/_static/js/index.d3f166471bb80abb5163.js:32
↓ 1 callersFunctionun
(n)
docsrc/source/_static/js/d3.v3.min.js:1
↓ 1 callersFunctionun
(n)
docs/_static/js/d3.v3.min.js:1
↓ 1 callersFunctionunzip
()
tests/BlazingSQLTest/manualTesting.py:37
↓ 1 callersFunctionupcast_to_float
(df)
tests/BlazingSQLTest/manualTesting.py:118
↓ 1 callersMethodupdateSchema
Refreshes the schema after ddl has occurred. The application context needs to reload every time we update the ddl right now. Synchronizes access to av
algebra/blazingdb-calcite-application/src/main/java/com/blazingdb/calcite/application/ApplicationContext.java:104
↓ 1 callersFunctionuse_gtest_lib
()
engine/setup.py:38
↓ 1 callersFunctionv
()
docsrc/source/_static/js/d3.v3.min.js:1
↓ 1 callersFunctionv
(t,e)
docs/_static/js/index.d3f166471bb80abb5163.js:26
↓ 1 callersFunctionv
()
docs/_static/js/d3.v3.min.js:1
↓ 1 callersMethodvalidateQuery
(String sql)
algebra/blazingdb-calcite-application/src/main/java/com/blazingdb/calcite/application/RelationalAlgebraGenerator.java:153
↓ 1 callersFunctionvalidate_messages
(error_message, message_validation)
tests/BlazingSQLTest/Runner/runTest.py:662
↓ 1 callersFunctionvendorPropName
( name )
docs/_static/jquery-3.5.1.js:6649
↓ 1 callersMethodvisit
engine/src/execution_kernels/LogicalProject.cpp:753
↓ 1 callersMethodvisitCall
(RexCall call)
algebra/blazingdb-calcite-application/src/main/java/com/blazingdb/calcite/rules/PushProjector.java:821
↓ 1 callersFunctionvisitJson
(data, result, level)
pyblazing/pyblazing/apiv2/algebra/json_plan.py:8
↓ 1 callersFunctionvisitPartitionFolder
engine/src/cython/io.cpp:302
↓ 1 callersFunctionw
(t,e)
docs/_static/js/index.d3f166471bb80abb5163.js:26
↓ 1 callersMethodwait_for_begin_transmission
engine/src/communication/CommunicationInterface/bufferTransport.cpp:192
↓ 1 callersMethodwait_for_next
* Wait for the next message to be ready. * @return Waits for the next CacheData to be available. Returns true when this * is the case. Returns false
engine/src/cache_machine/WaitingQueue.h:188
↓ 1 callersMethodwait_until_complete
engine/src/communication/CommunicationInterface/bufferTransport.cpp:211
↓ 1 callersFunctionwindow_expression_contains_bounds_by_range
engine/src/parser/expression_utils.cpp:639
↓ 1 callersFunctionwn
(n,t,e)
docsrc/source/_static/js/d3.v3.min.js:1
↓ 1 callersFunctionwn
(n,t,e)
docs/_static/js/d3.v3.min.js:1
↓ 1 callersFunctionwr
(n)
docsrc/source/_static/js/d3.v3.min.js:2
↓ 1 callersFunctionwr
(n)
docs/_static/js/d3.v3.min.js:2
↓ 1 callersMethodwrite
io/src/FileSystem/private/GoogleCloudStorageOutputStream.cpp:100
↓ 1 callersFunctionx
(t)
docs/_static/js/index.d3f166471bb80abb5163.js:26
↓ 1 callersFunctionzn
(n)
docsrc/source/_static/js/d3.v3.min.js:1
↓ 1 callersFunctionzn
(n)
docs/_static/js/d3.v3.min.js:1
↓ 1 callersFunctionzu
(n)
docsrc/source/_static/js/d3.v3.min.js:2
↓ 1 callersFunctionzu
(n)
docs/_static/js/d3.v3.min.js:2
Function$n
(n,t,e)
docsrc/source/_static/js/d3.v3.min.js:1
Function$n
(n,t,e)
docs/_static/js/d3.v3.min.js:1
← previousnext →1,901–2,000 of 3,772, ranked by callers