Analyzer | |
Analyzer.cpp | Analyzer functions |
Analyzer.h | Defines data structures for the semantic analysis phase of query processing |
RangeTableEntry.cpp | |
RangeTableEntry.h | |
Archive | |
Archive.h | |
PosixFileArchive.h | |
S3Archive.cpp | |
S3Archive.h | |
Benchmarks | |
conbench | |
benchmarks.py | |
report.py | |
scripts | |
bench_batch_streaming_ingest.py | |
bench_system_tables.py | |
bench_update.py | |
synthetic_benchmark | |
create_table.py | |
analyze_benchmark.py | |
run_benchmark.py | |
run_benchmark_arrow.py | |
run_benchmark_import.py | |
run_synthetic_benchmark.py | |
Calcite | |
Calcite.cpp | |
Calcite.h | |
Catalog | |
os | |
LdapServer.h | |
PkiServer.h | |
SamlServer.h | |
UserMapping.h | |
AlterColumnRecovery.cpp | |
AlterColumnRecovery.h | |
AlterColumnShared.h | |
AuthMetadata.h | |
Catalog.cpp | Functions for database metadata access |
Catalog.h | This file contains the class specification and related data structures for Catalog |
CatalogFwd.h | |
ColumnDescriptor.h | |
CustomExpression.h | |
DashboardDescriptor.h | |
DataframeTableDescriptor.h | |
DBObject.cpp | |
DBObject.h | Class specification and related data structures for DBObject class |
DdlCommandExecutor.cpp | |
DdlCommandExecutor.h | |
DictDescriptor.h | |
ForeignServer.h | |
ForeignTable.cpp | |
ForeignTable.h | |
Grantee.cpp | |
Grantee.h | |
LinkDescriptor.h | |
ObjectRoleDescriptor.h | |
OptionsContainer.h | |
RefreshTimeCalculator.cpp | |
RefreshTimeCalculator.h | |
RWLocks.h | |
SessionInfo.cpp | |
SessionInfo.h | |
SessionsStore.cpp | |
SessionsStore.h | |
SharedDictionaryValidator.cpp | |
SharedDictionaryValidator.h | |
SysCatalog.cpp | Functions for System Catalog |
SysCatalog.h | This file contains the class specification and related data structures for SysCatalog |
TableDescriptor.h | |
TableMetadata.h | |
Types.h | |
cmake | |
Modules | |
arrow_4_io_context.cpp | |
CudaMgr | |
CudaMgr.cpp | |
CudaMgr.h | |
CudaMgrNoCuda.cpp | |
DeviceMemoryAllocationMap.cpp | |
DeviceMemoryAllocationMap.h | |
DataMgr | |
Allocators | |
thrust | |
DataMgrAllocationPolicy.h | |
TypedThrustAllocator.h | |
ArenaAllocator.h | |
CpuMgrArenaAllocator.cpp | |
CpuMgrArenaAllocator.h | Allocate CPU memory using CpuBuffers via DataMgr |
CudaAllocator.cpp | |
CudaAllocator.h | Allocate GPU memory using GpuBuffers via DataMgr |
DeviceAllocator.h | Abstract class for managing device memory allocations |
FastAllocator.h | Quickly allocate many memory pieces by reserving them ahead of time. Calls to allocate() are thread-safe |
PMemAllocator.cpp | |
PMemAllocator.h | |
ThrustAllocator.cpp | |
ThrustAllocator.h | |
BufferMgr | |
CpuBufferMgr | |
CpuBuffer.cpp | |
CpuBuffer.h | |
CpuBufferMgr.cpp | |
CpuBufferMgr.h | |
TieredCpuBufferMgr.cpp | |
TieredCpuBufferMgr.h | |
GpuCudaBufferMgr | |
GpuCudaBuffer.cpp | |
GpuCudaBuffer.h | |
GpuCudaBufferMgr.cpp | |
GpuCudaBufferMgr.h | |
Buffer.cpp | |
Buffer.h | |
BufferMgr.cpp | |
BufferMgr.h | This file includes the class specification for the buffer manager (BufferMgr), and related data structures and types |
BufferSeg.h | |
Chunk | |
Chunk.cpp | |
Chunk.h | |
DataConversion | |
BaseConvertEncoder.h | |
ConversionFactory.h | |
StringViewSource.h | |
StringViewToArrayEncoder.h | |
StringViewToGeoEncoder.h | |
StringViewToScalarEncoder.h | |
StringViewToStringDictEncoder.h | |
StringViewToStringNoneEncoder.h | |
FileMgr | |
CachingFileMgr.cpp | |
CachingFileMgr.h | This file details an extension of the FileMgr that can contain pages from multiple tables (CachingFileMgr). The main differences between a CFM and an FM: |
CachingGlobalFileMgr.cpp | |
CachingGlobalFileMgr.h | |
Epoch.h | This file includes the class specification for the FILE manager (FileMgr), and related data structures and types |
FileBuffer.cpp | |
FileBuffer.h | |
FileInfo.cpp | |
FileInfo.h | |
FileMgr.cpp | |
FileMgr.h | This file includes the class specification for the FILE manager (FileMgr), and related data structures and types |
GlobalFileMgr.cpp | |
GlobalFileMgr.h | This file includes the class specification for the FILE manager (FileMgr), and related data structures and types |
Page.h | This file contains the declaration and definition of a Page type and a MultiPage type |
ForeignStorage | |
CacheEvictionAlgorithms | |
CacheEvictionAlgorithm.h | This file includes the class specification for the cache eviction algorithm interface used by the Foreign Storage Interface (FSI). This interface can be implemented to quickly slot out different caching algorithms for the FSI cache. A caching algorithm can be queried to determine which chunks should be evicted in what order and needs to be updated with cache usage data |
LRUEvictionAlgorithm.cpp | |
LRUEvictionAlgorithm.h | This file includes the class specification for the Least Recently Used cache eviction algorithm used by the Foreign Storage Interface (FSI) |
AbstractFileStorageDataWrapper.cpp | |
AbstractFileStorageDataWrapper.h | |
AbstractTextFileDataWrapper.cpp | |
AbstractTextFileDataWrapper.h | |
ArrowForeignStorage.cpp | |
ArrowForeignStorage.h | |
CachingForeignStorageMgr.cpp | |
CachingForeignStorageMgr.h | |
CsvDataWrapper.cpp | |
CsvDataWrapper.h | |
CsvFileBufferParser.cpp | |
CsvFileBufferParser.h | |
CsvShared.cpp | |
DataPreview.cpp | |
DataPreview.h | |
DummyForeignStorage.cpp | |
DummyForeignStorage.h | |
FileReader.cpp | |
FileReader.h | |
FileRegions.cpp | |
FileRegions.h | |
ForeignDataWrapper.h | |
ForeignDataWrapperFactory.cpp | |
ForeignDataWrapperFactory.h | |
ForeignStorageBuffer.cpp | |
ForeignStorageBuffer.h | |
ForeignStorageCache.cpp | |
ForeignStorageCache.h | This file includes the class specification for the cache used by the Foreign Storage Interface (FSI). This cache is used by FSI to cache data and metadata locally on disc to avoid repeated loads from foreign storage |
ForeignStorageException.h | |
ForeignStorageInterface.cpp | |
ForeignStorageInterface.h | |
ForeignStorageMgr.cpp | |
ForeignStorageMgr.h | |
ForeignTableRefresh.cpp | |
ForeignTableRefresh.h | |
ForeignTableSchema.cpp | |
ForeignTableSchema.h | |
FsiChunkUtils.cpp | |
FsiChunkUtils.h | |
GeospatialEncoder.h | |
InternalCatalogDataWrapper.cpp | |
InternalCatalogDataWrapper.h | |
InternalExecutorStatsDataWrapper.cpp | |
InternalExecutorStatsDataWrapper.h | |
InternalLogsDataWrapper.cpp | |
InternalLogsDataWrapper.h | |
InternalMemoryStatsDataWrapper.cpp | |
InternalMemoryStatsDataWrapper.h | |
InternalMLModelMetadataDataWrapper.cpp | |
InternalMLModelMetadataDataWrapper.h | |
InternalStorageStatsDataWrapper.cpp | |
InternalStorageStatsDataWrapper.h | |
InternalSystemDataWrapper.cpp | |
InternalSystemDataWrapper.h | |
Interval.h | |
LazyParquetChunkLoader.cpp | |
LazyParquetChunkLoader.h | |
LogFileBufferParser.cpp | |
LogFileBufferParser.h | |
OdbcGeospatialEncoder.h | |
ParquetArrayDetectEncoder.h | |
ParquetArrayEncoder.h | |
ParquetArrayImportEncoder.h | |
ParquetDataWrapper.cpp | |
ParquetDataWrapper.h | |
ParquetDateInDaysFromTimestampEncoder.h | |
ParquetDateInSecondsEncoder.h | |
ParquetDecimalEncoder.h | |
ParquetDetectStringEncoder.h | |
ParquetEncoder.h | |
ParquetFixedLengthArrayEncoder.h | |
ParquetFixedLengthEncoder.h | |
ParquetGeospatialEncoder.h | |
ParquetGeospatialImportEncoder.h | |
ParquetImporter.cpp | |
ParquetImporter.h | |
ParquetInPlaceEncoder.h | |
ParquetMetadataValidator.h | |
ParquetS3DetectFileSystem.h | |
ParquetShared.cpp | |
ParquetShared.h | |
ParquetStringEncoder.h | |
ParquetStringImportEncoder.h | |
ParquetStringNoneEncoder.h | |
ParquetTimeEncoder.h | |
ParquetTimestampEncoder.h | |
ParquetVariableLengthArrayEncoder.h | |
PassThroughBuffer.cpp | |
PassThroughBuffer.h | |
RegexFileBufferParser.cpp | |
RegexFileBufferParser.h | |
RegexParserDataWrapper.cpp | |
RegexParserDataWrapper.h | |
S3FilePathUtil.cpp | |
S3FilePathUtil.h | |
SharedMetadataValidator.h | |
TextFileBufferParser.cpp | |
TextFileBufferParser.h | |
TypedParquetDetectBuffer.cpp | |
TypedParquetDetectBuffer.h | |
TypedParquetStorageBuffer.cpp | |
TypedParquetStorageBuffer.h | |
PersistentStorageMgr | |
PersistentStorageMgr.cpp | |
PersistentStorageMgr.h | |
AbstractBuffer.cpp | |
AbstractBuffer.h | |
AbstractBufferMgr.h | |
ArrayNoneEncoder.h | Unencoded array encoder |
ChunkMetadata.h | |
DataMgr.cpp | |
DataMgr.h | |
DateDaysEncoder.h | |
Encoder.cpp | |
Encoder.h | |
FixedLengthArrayNoneEncoder.h | Unencoded fixed length array encoder |
FixedLengthEncoder.h | |
HeavyDbAwsSdk.cpp | |
HeavyDbAwsSdk.h | |
MemoryLevel.h | |
NoneEncoder.h | |
StringNoneEncoder.cpp | For unencoded strings |
StringNoneEncoder.h | For unencoded strings |
Distributed | |
os | |
DistributedLoader.h | |
LeafAggregator.h | |
LeafHostInfo.h | |
AggregatedResult.h | |
Embedded | |
test | |
test_exceptions.py | |
test_fsi.py | |
test_ra.py | |
test_readcsv.py | |
DBEngine.cpp | |
DBEngine.h | |
DBETypes.cpp | |
DBETypes.h | |
EmbeddedDbFSITest.cpp | |
EmbeddedDbTest.cpp | |
setup.in.py | |
Fragmenter | |
AbstractFragmenter.h | |
FragmentDefaultValues.h | |
Fragmenter.h | |
InsertDataLoader.cpp | |
InsertDataLoader.h | |
InsertOrderFragmenter.cpp | |
InsertOrderFragmenter.h | |
SortedOrderFragmenter.cpp | |
SortedOrderFragmenter.h | |
TargetValueConverters.h | |
TargetValueConvertersFactories.cpp | |
TargetValueConvertersFactories.h | |
TargetValueConvertersImpl.h | |
UpdelStorage.cpp | |
Geospatial | |
ColumnNames.h | |
Compression.cpp | |
Compression.h | |
CompressionRuntime.h | |
Conversion.h | |
GDAL.cpp | |
GDAL.h | |
GeosValidation.cpp | |
GeosValidation.h | |
Transforms.h | |
Types.cpp | |
Types.h | |
Utm.h | Convert to/from WGS84 (long,lat) and UTM (x,y) given utm zone srid |
ImportExport | |
AbstractImporter.h | |
ArrowImporter.h | |
CopyParams.h | |
DelimitedParserUtils.cpp | |
DelimitedParserUtils.h | |
ExpressionParser.cpp | |
ExpressionParser.h | |
ForeignDataImporter.cpp | |
ForeignDataImporter.h | |
ImportBatchResult.h | |
Importer.cpp | |
Importer.h | |
KafkaImporter.cpp | Based on StreamInsert code but using binary columnar format for inserting a stream of rows with optional transformations from stdin to a DB table |
MetadataColumn.cpp | |
MetadataColumn.h | |
QueryExporter.cpp | |
QueryExporter.h | |
QueryExporterCSV.cpp | |
QueryExporterCSV.h | |
QueryExporterGDAL.cpp | |
QueryExporterGDAL.h | |
RasterImporter.cpp | |
RasterImporter.h | |
RowToColumnLoader.cpp | Based on StreamInsert code but using binary columnar format for inserting a stream of rows with optional transformations from stdin to a MapD table |
RowToColumnLoader.h | Utility Function to convert rows to input columns for loading via load_table_binary_columnar |
SourceType.h | Shared Enum |
StreamImporter.cpp | Based on StreamInsert code but using binary columnar format for inserting a stream of rows with optional transformations from stdin to a DB table |
java | |
calcite | |
src | |
main | |
java | |
com | |
mapd | |
calcite | |
parser | |
ExtTableFunctionTypeChecker.java | |
HeavyDBParser.java | |
HeavyDBParserOptions.java | |
HeavyDBSchema.java | |
HeavyDBSerializer.java | |
HeavyDBSqlOperatorTable.java | |
HeavyDBTable.java | |
HeavyDBTypeCoercion.java | |
HeavyDBTypeSystem.java | |
HeavyDBUser.java | |
HeavyDBView.java | |
ProjectProjectRemoveRule.java | |
planner | |
tester.java | |
rel | |
rules | |
FilterTableFunctionMultiInputTransposeRule.java | |
metadata | |
GeoRelDataType.java | |
LinestringSqlType.java | |
MetaConnect.java | |
PointSqlType.java | |
PolygonSqlType.java | |
parser | |
extension | |
ddl | |
heavydb | |
HeavyDBEncoding.java | |
HeavyDBGeo.java | |
HeavyDBGeoTypeNameSpec.java | |
HeavyDBOptionsMap.java | |
HeavyDBSqlDataTypeSpec.java | |
HeavyDBTypeNameSpec.java | |
heavysql | |
HeavySqlArray.java | |
HeavySqlColumn.java | |
HeavySqlDataType.java | |
HeavySqlEncoding.java | |
HeavySqlJson.java | |
HeavySqlOptionPair.java | |
HeavySqlOptionsMap.java | |
HeavySqlSanitizedString.java | |
HeavySqlTypeNameSpec.java | |
DdlResponse.java | |
JsonSerializableDdl.java | |
SqlAlterDatabase.java | |
SqlAlterForeignTable.java | |
SqlAlterServer.java | |
SqlAlterSessionSet.java | |
SqlAlterSystemClear.java | |
SqlAlterSystemControlExecutorQueue.java | |
SqlAlterTable.java | |
SqlAlterUser.java | |
SqlAttributeDefinition.java | |
SqlCheckConstraint.java | |
SqlColumnDeclaration.java | |
SqlCopyTable.java | |
SqlCreateDataframe.java | |
SqlCreateDB.java | |
SqlCreateForeignTable.java | |
SqlCreateModel.java | |
SqlCreatePolicy.java | |
SqlCreateRole.java | |
SqlCreateServer.java | |
SqlCreateTable.java | |
SqlCreateUser.java | |
SqlCreateUserMapping.java | |
SqlCreateView.java | |
SqlCustomDdl.java | |
SqlDdlNodes.java | |
SqlDropDB.java | |
SqlDropForeignTable.java | |
SqlDropModel.java | |
SqlDropPolicy.java | |
SqlDropRole.java | |
SqlDropServer.java | |
SqlDropTable.java | |
SqlDropUser.java | |
SqlDropUserMapping.java | |
SqlDropView.java | |
SqlDumpTable.java | |
SqlEvaluateModel.java | |
SqlExportQuery.java | |
SqlFilter.java | |
SqlFirstLastValueInFrame.java | |
SqlGrantPrivilege.java | |
SqlGrantRole.java | |
SqlInsertIntoTable.java | |
SqlInsertValues.java | |
SqlKeyConstraint.java | |
SqlKillQuery.java | |
SqlLeadLag.java | |
SqlNthValueInFrame.java | |
SqlOptimizeTable.java | |
SqlOptionsBuilder.java | |
SqlReassignOwned.java | |
SqlRefreshForeignTables.java | |
SqlRenameTable.java | |
SqlRenameUser.java | |
SqlRestoreTable.java | |
SqlRevokePrivilege.java | |
SqlRevokeRole.java | |
SqlShowCreateServer.java | |
SqlShowCreateTable.java | |
SqlShowDatabases.java | |
SqlShowDataSources.java | |
SqlShowDiskCacheUsage.java | |
SqlShowForeignServers.java | |
SqlShowFunctions.java | |
SqlShowModelDetails.java | |
SqlShowModelFeatureDetails.java | |
SqlShowModels.java | |
SqlShowPolicies.java | |
SqlShowQueries.java | |
SqlShowRoles.java | |
SqlShowRuntimeFunctions.java | |
SqlShowRuntimeTableFunctions.java | |
SqlShowTableDetails.java | |
SqlShowTableFunctions.java | |
SqlShowTables.java | |
SqlShowUserDetails.java | |
SqlShowUserSessions.java | |
SqlTruncateTable.java | |
SqlValidateSystem.java | |
hint | |
HeavyDBHintStrategyTable.java | |
server | |
CalciteParserFactory.java | |
CalciteServerCaller.java | |
CalciteServerHandler.java | |
CalciteServerWrapper.java | |
ExtensionFunction.java | |
ExtensionFunctionSignatureParser.java | |
org | |
apache | |
calcite | |
prepare | |
CalciteSqlValidator.java | |
HeavyDBPlanner.java | |
HeavyDBSqlAdvisor.java | |
HeavyDBSqlAdvisorValidator.java | |
SqlIdentifierCapturer.java | |
rel | |
externalize | |
HeavyDBRelJson.java | |
HeavyDBRelJsonReader.java | |
HeavyDBRelJsonWriter.java | |
HeavyDBRelWriterImpl.java | |
rules | |
DynamicFilterJoinRule.java | |
InjectFilterRule.java | |
OuterJoinOptViaNullRejectionRule.java | |
QueryOptimizationRules.java | |
Restriction.java | |
sql | |
validate | |
implicit | |
TypeCoercions.java | |
SqlValidatorImpl.java | |
SqlOperator.java | |
sql2rel | |
SqlToRelConverter.java | |
StandardConvertletTable.java | |
util | |
EscapedStringJsonBuilder.java | |
test | |
java | |
com | |
heavydb | |
parser | |
extension | |
ddl | |
AlterDatabaseTest.java | |
AlterTableTest.java | |
DDLTest.java | |
ForeignServerTest.java | |
ForeignTableTest.java | |
InsertValuesTest.java | |
InterruptCommandTest.java | |
ReassignOwnedTest.java | |
ShowCommandTest.java | |
UserMappingTest.java | |
server | |
test | |
SqlIdentifierCapturerTest.java | |
TestDBServer.java | |
TestServer.java | |
heavyaijdbc | |
src | |
main | |
java | |
ai | |
heavy | |
jdbc | |
HeavyAIArray.java | |
HeavyAIConnection.java | |
HeavyAIData.java | |
HeavyAIDatabaseMetaData.java | |
HeavyAIDriver.java | |
HeavyAIEscapeFunctions.java | |
HeavyAIEscapeParser.java | |
HeavyAIExceptionText.java | |
HeavyAIPreparedStatement.java | |
HeavyAIResultSet.java | |
HeavyAIResultSetMetaData.java | |
HeavyAIStatement.java | |
HeavyAIType.java | |
test | |
java | |
ai | |
heavy | |
jdbc | |
HeavyAIArrayTest.java | |
HeavyAIColumnTypeTest.java | |
HeavyAIConnectionTest.java | |
HeavyAIDatabaseMetaDataTest.java | |
HeavyAIGeomTest.java | |
HeavyAIPrepareTest.java | |
HeavyAIStatementTest.java | |
Property_loader.java | |
heavydbcommon | |
src | |
main | |
java | |
com | |
mapd | |
common | |
SockTransportProperties.java | |
utility | |
src | |
main | |
java | |
com | |
mapd | |
bench | |
Benchmark.java | |
BenchmarkCloud.java | |
dashboard | |
DashboardTest.java | |
logrunner | |
LogRunner.java | |
tests | |
AlterDropTruncateValidateConcurrencyTest.java | |
CalciteViewsConcurrencyTest.java | |
CatalogConcurrencyTest.java | |
ConcurrencyTest.java | |
CtasItasSelectUpdelConcurrencyTest.java | |
DateTimeTest.java | |
DdlConcurrencyTest.java | |
DistributedConcurrencyTest.java | |
DumpRestoreConcurrencyTest.java | |
EagainConcurrencyTest.java | |
ForeignStorageConcurrencyTest.java | |
ForeignTableRefreshConcurrencyTest.java | |
HeavyDBAsserts.java | |
HeavyDBTestClient.java | |
ImportAlterValidateSelectConcurrencyTest.java | |
ReductionConcurrencyTest.java | |
RuntimeInterruptConcurrencyTest.java | |
SelectCopyFromDeleteConcurrencyTest.java | |
SelectUpdateDeleteDifferentTables.java | |
SystemTableConcurrencyTest.java | |
TablePermissionsTest.java | |
UpdateDeleteInsertConcurrencyTest.java | |
ViewPermissionsTest.java | |
testthrift | |
ThriftTester.java | |
utility | |
db_vendors | |
Db_vendor_types.java | |
SQLImporter.java | |
L0Mgr | |
L0Exception.cpp | |
L0Exception.h | |
L0ExceptionNoL0.cpp | |
L0Mgr.cpp | |
L0Mgr.h | |
L0MgrNoL0.cpp | |
Utils.h | |
LockMgr | |
LegacyLockMgr.h | |
LockMgr.cpp | |
LockMgr.h | |
LockMgrImpl.h | |
Logger | |
Logger.cpp | |
Logger.h | |
MigrationMgr | |
MigrationMgr.cpp | |
MigrationMgr.h | |
NvidiaComputeCapability | |
get_nvidia_compute_capability.cpp | |
OSDependent | |
os | |
heavyai_locks.h | |
Unix | |
heavyai_fs.cpp | |
heavyai_glob.cpp | |
heavyai_hostname.cpp | |
heavyai_path.cpp | |
Windows | |
heavyai_fs.cpp | |
heavyai_glob.cpp | |
heavyai_hostname.cpp | |
heavyai_path.cpp | |
heavyai_fs.h | |
heavyai_glob.h | |
heavyai_hostname.h | |
heavyai_locks.h | |
heavyai_path.h | |
Parser | |
ParserNode.cpp | Functions for ParserNode classes |
ParserNode.h | Classes representing a parse tree |
ParserWrapper.cpp | |
ParserWrapper.h | Classes used to wrap parser calls for calcite redirection |
ReservedKeywords.h | |
python | |
heavydb | |
common | |
__init__.py | |
constants.py | |
ttypes.py | |
completion_hints | |
__init__.py | |
constants.py | |
ttypes.py | |
extension_functions | |
__init__.py | |
constants.py | |
ttypes.py | |
serialized_result_set | |
__init__.py | |
constants.py | |
ttypes.py | |
thrift | |
__init__.py | |
constants.py | |
Heavy.py | |
ttypes.py | |
__init__.py | |
_parsers.py | |
_samlutils.py | |
_utils.py | |
connection.py | |
cursor.py | |
dtypes.py | |
exceptions.py | |
version.py | |
tests | |
test_data | |
dashboard_metadata.py | |
__init__.py | |
conftest.py | |
test_connection.py | |
test_cursor.py | |
test_integration.py | |
test_results_set.py | |
test_runtime_udf.py | |
QueryEngine | |
DataRecycler | |
BoundingBoxIntersectTuningParamRecycler.cpp | |
BoundingBoxIntersectTuningParamRecycler.h | |
ChunkMetadataRecycler.cpp | |
ChunkMetadataRecycler.h | |
DataRecycler.h | |
HashingSchemeRecycler.cpp | |
HashingSchemeRecycler.h | |
HashtableRecycler.cpp | |
HashtableRecycler.h | |
ResultSetRecycler.cpp | |
ResultSetRecycler.h | |
Descriptors | |
ApproxQuantileDescriptor.h | |
ColSlotContext.cpp | Provides column and slot info for the output buffer and some metadata helpers |
ColSlotContext.h | Provides column info and slot info for the output buffer and some metadata helpers |
CountDistinctDescriptor.h | Descriptor for the storage layout use for (approximate) count distinct operations |
InputDescriptors.cpp | |
InputDescriptors.h | |
QueryCompilationDescriptor.cpp | |
QueryCompilationDescriptor.h | Container for compilation results and assorted options for a single execution unit |
QueryFragmentDescriptor.cpp | |
QueryFragmentDescriptor.h | Descriptor for the fragments required for an execution kernel |
QueryMemoryDescriptor.cpp | |
QueryMemoryDescriptor.h | Descriptor for the result set buffer layout |
RelAlgExecutionDescriptor.cpp | |
RelAlgExecutionDescriptor.h | |
RowSetMemoryOwner.h | |
ExecutorResourceMgr | |
ExecutorResourceMgr.cpp | |
ExecutorResourceMgr.h | |
ExecutorResourceMgrCommon.h | |
ExecutorResourcePool.cpp | |
ExecutorResourcePool.h | |
OutstandingQueueRequests.h | |
ResourceGrantPolicy.cpp | |
ResourceGrantPolicy.h | |
ResourceRequest.h | |
ExtensionFunctions | |
h3lib | |
include | |
baseCells.h | Base cell related lookup tables and access functions |
constants.h | Constants used by more than one source code file |
coordijk.h | Header file for CoordIJK functions including conversion from lat/lon |
faceijk.h | FaceIJK functions including conversion to/from lat/lon |
geoCoord.h | Geodetic (lat/lon) functions |
h3api.h | Primary H3 core library entry points |
h3Index.h | H3Index functions |
vec2d.h | 2D floating point vector functions |
vec3d.h | 3D floating point vector functions |
lib | |
baseCells.hpp | |
coordijk.hpp | |
faceijk.hpp | |
geoCoord.hpp | |
h3Index.hpp | |
vec2d.hpp | |
vec3d.hpp | |
GeoOperators | |
API.h | |
AreaPerimeter.h | |
Centroid.h | |
Codegen.cpp | |
Codegen.h | |
Distance.h | |
NPoints.h | |
NRings.h | |
NumGeometries.h | |
PointAccessors.h | |
PointConstructor.h | |
PointN.h | |
StartEndPoint.h | |
Transform.h | |
invoke_example | |
sample.cpp | |
JoinHashTable | |
Builders | |
BaselineHashTableBuilder.h | |
PerfectHashTableBuilder.h | |
Runtime | |
HashJoinKeyHandlers.h | |
HashJoinRuntime.cpp | |
HashJoinRuntime.h | |
HashJoinRuntimeGpu.cu | |
JoinColumnIterator.h | |
JoinHashImpl.h | |
JoinHashTableGpuUtils.h | |
JoinHashTableQueryRuntime.cpp | |
BaselineHashTable.h | |
BaselineJoinHashTable.cpp | |
BaselineJoinHashTable.h | |
BoundingBoxIntersectJoinHashTable.cpp | |
BoundingBoxIntersectJoinHashTable.h | |
HashJoin.cpp | |
HashJoin.h | |
HashTable.cpp | |
HashTable.h | |
PerfectHashTable.h | |
PerfectJoinHashTable.cpp | |
PerfectJoinHashTable.h | |
RangeJoinHashTable.cpp | |
RangeJoinHashTable.h | |
LoopControlFlow | |
generate_loop_ref.py | |
JoinLoop.cpp | |
JoinLoop.h | |
JoinLoopTest.cpp | |
Optimization | |
AnnotateInternalFunctionsPass.h | |
RelAlgDagSerializer | |
serialization | |
ExecutionResultSerializer.h | |
QueryHintSerializer.h | |
RelAlgDagSerializer.h | |
RexWindowBoundSerializer.h | |
SortFieldSerializer.h | |
SQLTypeInfoSerializer.h | |
StdOptionalSerializer.h | |
TargetMetaInfoSerializer.h | |
Serializer.cpp | |
Serializer.h | |
Rendering | |
os | |
RenderAllocator.cpp | |
RenderInfo.cpp | |
RenderAllocator.h | |
RenderInfo.h | |
scripts | |
generate_TableFunctionsFactory_init.py | |
parse_ast.py | |
TableFunctionsFactory_declbracket.py | |
TableFunctionsFactory_linker.py | |
TableFunctionsFactory_node.py | |
TableFunctionsFactory_parser.py | |
TableFunctionsFactory_transformers.py | |
TableFunctionsFactory_util.py | |
test_udtf_signatures.hpp | |
TableFunctions | |
RuntimeLibTestFunctions | |
RuntimeLibTestTableFunctions.hpp | |
TestRuntimeLib.cpp | |
TestRuntimeLib.h | |
SystemFunctions | |
os | |
Graph | |
GraphTableFunctions.hpp | |
ML | |
AbstractMLModel.h | |
MLModel.h | |
MLModelMetadata.cpp | |
MLModelMetadata.h | |
MLModelType.h | |
MLPackFunctions.hpp | |
MLTableFunctionsCommon.h | |
OneAPIFunctions.hpp | |
OneDalFunctions.hpp | |
OneHotEncoder.cpp | |
OneHotEncoder.h | |
Shared | |
Loaders | |
PdalLoader.cpp | |
PdalLoader.h | |
CpuTimer.hpp | |
NullRowsRemoval.cpp | |
NullRowsRemoval.h | |
RasterFormat.hpp | |
RasterInfo.h | |
TableFunctionsCommon.cpp | |
TableFunctionsCommon.hpp | |
TableFunctionsDataCache.h | |
TableFunctionsMatrix.hpp | |
TableFunctionsStats.cpp | |
TableFunctionsStats.hpp | |
Torch | |
TestTorchTableFunctions.cpp | |
TestTorchTableFunctions.h | |
TorchOps.hpp | |
TorchTableFunctions.cpp | |
TorchTableFunctions.h | |
TorchWrapper.cpp | |
TorchWrapper.h | |
CrossSectionTableFunctions.hpp | |
ExampleTableFunctions.cpp | |
ExampleTableFunctions.h | |
GDALTableFunctions.hpp | |
GeoRasterTableFunctions.cpp | |
GeoRasterTableFunctions.hpp | |
MLTableFunctions.cpp | |
MLTableFunctions.hpp | |
PointCloudTableFunctions.cpp | |
PointCloudTableFunctions.h | |
SessionizeTableFunctions.hpp | |
SimilarityTableFunctions.hpp | |
UtilityTableFunctions.cpp | |
UtilityTableFunctions.h | |
TestFunctions | |
ArrayTestTableFunctions.cpp | |
FilterPushdownTestTableFunctions.cpp | |
FlatBufferTableFunctions.cpp | |
GeoTestTableFunctions.cpp | |
OtherTestTableFunctions.cpp | |
RbcTestTableFunctions.cpp | |
SignatureTestTableFunctions.cpp | |
StringTestTableFunctions.cpp | |
TableFunctionsTesting.h | |
TableFunctionCompilationContext.cpp | |
TableFunctionCompilationContext.h | |
TableFunctionExecutionContext.cpp | |
TableFunctionExecutionContext.h | |
TableFunctionManager.h | |
TableFunctionOps.cpp | |
TableFunctionOutputBufferSizeType.h | |
TableFunctionsFactory.cpp | |
TableFunctionsFactory.h | |
Utils | |
DiamondCodegen.cpp | |
DiamondCodegen.h | |
FlatBuffer.h | |
SegmentTree.h | |
SegmentTreeUtils.h | |
Visitors | |
GeospatialFunctionFinder.cpp | |
GeospatialFunctionFinder.h | |
QueryPlanDagChecker.cpp | |
QueryPlanDagChecker.h | |
RelAlgDagViewer.h | |
RelRexDagVisitor.cpp | |
RelRexDagVisitor.h | |
RexSubQueryIdCollector.cpp | |
RexSubQueryIdCollector.h | RexSubQueryIdCollector is a visitor class that collects all RexSubQuery::getId() values for all RexSubQuery nodes. This uses sorted arrays of (hash_code, handler) pairs for tree navigation |
SQLOperatorDetector.cpp | |
SQLOperatorDetector.h | |
TransientStringLiteralsVisitor.h | |
TypeHandler.h | Sortable utility struct for visitor patterns |
AggMode.h | Calculate statistical mode as an aggregate function |
AggregatedColRange.cpp | |
AggregatedColRange.h | Cache for physical column ranges. Set by the aggregator on the leaves |
AggregateUtils.h | |
ArithmeticIR.cpp | |
ArrayIR.cpp | |
ArrayOps.cpp | Functions to support array operations used by the executor |
ArrowResultSet.cpp | |
ArrowResultSet.h | |
ArrowResultSetConverter.cpp | |
AutomaticIRMetadataGuard.h | |
BufferCompaction.h | Macros and functions for groupby buffer compaction |
BufferEntryUtils.h | Utility functions for group by buffer entries |
CacheInvalidator.h | |
CalciteAdapter.cpp | |
CalciteAdapter.h | |
CalciteDeserializerUtils.cpp | |
CalciteDeserializerUtils.h | |
CardinalityEstimator.cpp | |
CardinalityEstimator.h | Estimators to be used when precise cardinality isn't useful |
CartesianProduct.h | |
CaseIR.cpp | |
CastIR.cpp | |
CgenState.cpp | |
CgenState.h | |
Codec.cpp | |
Codec.h | |
CodeCache.h | |
CodeCacheAccessor.cpp | |
CodeCacheAccessor.h | |
CodeGenerator.h | |
CodegenHelper.cpp | |
CodegenHelper.h | |
ColumnarResults.cpp | |
ColumnarResults.h | |
ColumnFetcher.cpp | |
ColumnFetcher.h | |
ColumnIR.cpp | |
CompareIR.cpp | |
CompareKeysInl.h | |
CompilationContext.h | |
CompilationOptions.h | |
ConstantIR.cpp | |
CountDistinct.h | Functions used to work with (approximate) count distinct sets |
cuda_mapd_rt.cu | |
DateAdd.cpp | |
DateAdd.h | |
DateTimeIR.cpp | |
DateTimePlusRewrite.cpp | |
DateTimePlusRewrite.h | |
DateTimeTranslator.cpp | |
DateTimeTranslator.h | |
DateTimeUtils.h | |
DateTruncate.cpp | |
DateTruncate.h | |
DecisionTreeEntry.h | |
DecodersImpl.h | |
DeepCopyVisitor.h | |
DeviceKernel.cpp | |
DeviceKernel.h | |
DynamicWatchdog.cpp | |
DynamicWatchdog.h | |
enums.h | QueryEngine enum classes with minimal #include files |
EquiJoinCondition.cpp | |
EquiJoinCondition.h | |
ErrorHandling.h | |
Execute.cpp | |
Execute.h | |
ExecuteUpdate.cpp | |
ExecutionKernel.cpp | |
ExecutionKernel.h | |
ExecutorDeviceType.cpp | |
ExecutorDeviceType.h | |
ExpressionRange.cpp | |
ExpressionRange.h | |
ExpressionRewrite.cpp | |
ExpressionRewrite.h | |
ExtensionFunctions.hpp | |
ExtensionFunctionsArray.hpp | |
ExtensionFunctionsArrayTesting.hpp | |
ExtensionFunctionsBinding.cpp | |
ExtensionFunctionsBinding.h | Argument type based extension function binding |
ExtensionFunctionsGeo.hpp | |
ExtensionFunctionsTesting.hpp | |
ExtensionFunctionsText.hpp | |
ExtensionFunctionsTextTesting.hpp | |
ExtensionFunctionsWhitelist.cpp | |
ExtensionFunctionsWhitelist.h | Supported runtime functions management and retrieval |
ExtensionsIR.cpp | |
ExternalCacheInvalidators.h | |
ExternalExecutor.cpp | |
ExternalExecutor.h | |
ExtractFromTime.cpp | |
ExtractFromTime.h | |
FromTableReordering.cpp | |
FromTableReordering.h | |
GeoIR.cpp | |
GeoOps.cpp | Functions to support geospatial operations used by the executor |
GeoOpsRuntime.cpp | |
GeosRuntime.cpp | |
GeosRuntime.h | |
GpuInitGroups.cu | |
GpuInitGroups.h | |
GpuInterrupt.cpp | |
GpuMemUtils.cpp | |
GpuMemUtils.h | |
GpuRtConstants.h | |
GpuSharedMemoryContext.h | |
GpuSharedMemoryUtils.cpp | |
GpuSharedMemoryUtils.h | |
GroupByAndAggregate.cpp | |
GroupByAndAggregate.h | |
GroupByRuntime.cpp | |
heavydbColumnOps.cpp | |
heavydbTypes.h | |
HyperLogLog.h | Functions used to work with HyperLogLog records |
HyperLogLogRank.h | |
InPlaceSort.cpp | |
InPlaceSort.h | |
InPlaceSortImpl.cu | |
InPlaceSortImpl.h | |
InputMetadata.cpp | |
InputMetadata.h | |
InValuesBitmap.cpp | |
InValuesBitmap.h | |
InValuesIR.cpp | |
IRCodegen.cpp | |
IRCodegenUtils.h | |
JoinFilterPushDown.cpp | |
JoinFilterPushDown.h | |
JsonAccessors.h | Checked json field retrieval |
LLVMFunctionAttributesUtil.cpp | |
LLVMFunctionAttributesUtil.h | |
LLVMGlobalContext.cpp | |
LLVMGlobalContext.h | |
LogicalIR.cpp | |
MaxwellCodegenPatch.cpp | |
MaxwellCodegenPatch.h | |
MLPredictCodegen.cpp | |
MurmurHash.cpp | |
MurmurHash.h | |
MurmurHash1Inl.h | |
MurmurHash3Inl.h | |
NativeCodegen.cpp | |
NullableValue.h | |
NvidiaKernel.cpp | |
NvidiaKernel.h | |
OutputBufferInitialization.cpp | |
OutputBufferInitialization.h | |
PlanState.cpp | |
PlanState.h | |
QueryDispatchQueue.h | |
QueryEngine.cpp | |
QueryEngine.h | |
QueryExecutionContext.cpp | |
QueryExecutionContext.h | |
QueryHint.h | |
QueryMemoryInitializer.cpp | |
QueryMemoryInitializer.h | |
QueryPhysicalInputsCollector.cpp | |
QueryPhysicalInputsCollector.h | Find out all the physical inputs (columns) a query is using |
QueryPlanDagCache.cpp | |
QueryPlanDagCache.h | |
QueryPlanDagExtractor.cpp | |
QueryPlanDagExtractor.h | |
QueryRewrite.cpp | |
QueryRewrite.h | |
QueryTemplateGenerator.cpp | |
QueryTemplateGenerator.h | |
RangeTableIndexVisitor.h | |
RegexpFunctions.cpp | |
RelAlgDag.cpp | |
RelAlgDag.h | |
RelAlgExecutionUnit.h | Execution unit for relational algebra. It's a low-level description of any relational algebra operation in a format understood by our VM |
RelAlgExecutor.cpp | |
RelAlgExecutor.h | |
RelAlgOptimizer.cpp | |
RelAlgOptimizer.h | |
RelAlgTranslator.cpp | |
RelAlgTranslator.h | |
RelAlgTranslatorGeo.cpp | |
RelAlgVisitor.h | |
RelLeftDeepInnerJoin.cpp | |
RelLeftDeepInnerJoin.h | |
ResultSet.cpp | Basic constructors and methods of the row set interface |
ResultSet.h | Basic constructors and methods of the row set interface |
ResultSetBufferAccessors.h | Utility functions for easy access to the result set buffers |
ResultSetBuilder.cpp | Basic constructors and methods of the row set interface |
ResultSetBuilder.h | Basic constructors and methods of the row set interface |
ResultSetGeoSerialization.h | Serialization routines for geospatial types |
ResultSetIteration.cpp | Iteration part of the row set interface |
ResultSetRecyclerHolder.cpp | |
ResultSetRecyclerHolder.h | |
ResultSetReduction.cpp | Reduction part of the row set interface |
ResultSetReductionCodegen.cpp | |
ResultSetReductionCodegen.h | |
ResultSetReductionInterpreter.cpp | |
ResultSetReductionInterpreter.h | |
ResultSetReductionInterpreterStubs.cpp | |
ResultSetReductionInterpreterStubs.h | |
ResultSetReductionJIT.cpp | |
ResultSetReductionJIT.h | |
ResultSetReductionOps.h | |
ResultSetSort.cpp | Efficient baseline sort implementation |
ResultSetSortImpl.cu | |
ResultSetSortImpl.h | |
ResultSetStorage.cpp | Basic constructors and methods of the row set interface |
ResultSetStorage.h | Basic constructors and methods of the row set interface |
RexVisitor.h | |
RowFunctionManager.h | |
RowFunctionOps.cpp | |
RuntimeFunctions.cpp | |
RuntimeFunctions.h | |
ScalarCodeGenerator.cpp | |
ScalarExprVisitor.h | |
SerializeToSql.cpp | |
SerializeToSql.h | |
SpeculativeTopN.cpp | |
SpeculativeTopN.h | Speculative top N algorithm |
StorageIOFacility.h | |
StreamingTopN.cpp | |
StreamingTopN.h | Streaming Top N algorithm |
StringDictionaryGenerations.cpp | |
StringDictionaryGenerations.h | |
StringDictionaryTranslationMgr.cpp | |
StringDictionaryTranslationMgr.h | |
StringFunctions.cpp | |
StringOpsIR.cpp | |
TableFunctionHelper.h | |
TableFunctionMetadataType.h | |
TableGenerations.cpp | |
TableGenerations.h | |
TableOptimizer.cpp | |
TableOptimizer.h | |
TargetExprBuilder.cpp | Helpers for codegen of target expressions |
TargetExprBuilder.h | Helpers for codegen of target expressions |
TargetMetaInfo.h | |
TargetValue.h | High-level representation of SQL values |
ThriftSerializers.h | Serializers for query engine types to/from thrift |
TopKRuntime.cpp | Structures and runtime functions of streaming top-k heap |
TopKSort.cu | |
TopKSort.h | |
TreeModelPredictionMgr.cpp | |
TreeModelPredictionMgr.h | |
TypePunning.h | |
UsedColumnsVisitor.h | |
WindowContext.cpp | |
WindowContext.h | |
WindowExpressionRewrite.cpp | |
WindowExpressionRewrite.h | |
WindowFunctionIR.cpp | |
QueryRunner | |
os | |
DistributedQueryRunner.h | |
QueryRunner.cpp | |
QueryRunner.h | |
TestProcessSignalHandler.cpp | |
TestProcessSignalHandler.h | |
RuntimeLibManager | |
RuntimeLibManager.cpp | |
RuntimeLibManager.h | |
scripts | |
conda | |
make-m2-proxy.py | |
Shared | |
Rendering | |
HitTestTypes.h | |
InSituFlags.h | |
RenderQueryOptions.h | |
ArrowUtil.h | |
base64.cpp | |
base64.h | |
BinarySemaphore.h | |
boost_stacktrace.hpp | |
CallbackManager.h | |
checked_alloc.h | |
clean_boost_regex.hpp | |
clean_windows.h | |
cleanup_global_namespace.h | |
Compressor.cpp | Singleton class to handle concurrancy and state for blosc library. A C++ wrapper over a pure C library |
Compressor.h | Singleton class to handle concurrancy and state for blosc library. A C++ wrapper over a pure C library |
DateConverters.h | |
DateTimeParser.cpp | |
DateTimeParser.h | |
Datum.cpp | |
Datum.h | Definitions for core Datum union type |
DatumFetchers.h | |
DbObjectKeys.cpp | |
DbObjectKeys.h | |
DebugOutputStream.h | |
define_enum_class.h | Macros/templates for defining enum classes and related utilities. Place macro calls in the heavyai namespace so that functions like to_string() can be found by the compiler via ADL |
DeviceGroup.h | |
distributed.cpp | |
distributed.h | |
DoubleSort.h | |
EnumBitmaskOps.h | |
File.cpp | Implementation of helper methods for File I/O |
File.h | A selection of helper methods for File I/O |
file_delete.h | Shared utility for the db server and string dictionary server to remove old files |
file_path_util.cpp | Shared utility for globbing files, paths can be specified as either a single file, directory or wildcards |
file_path_util.h | Shared utility for globbing files, paths can be specified as either a single file, directory or wildcards |
file_type.cpp | Shared utility for mime-types |
file_type.h | Shared utility for mime-types |
fixautotools.h | |
FullyQualifiedTableName.cpp | |
FullyQualifiedTableName.h | |
funcannotations.h | |
get_nvidia_compute_capability.h | |
gpu_enabled.h | |
heavyai_shared_mutex.h | |
import_helpers.h | |
InlineNullValues.h | |
InsertionOrderedMap.h | |
Intervals.h | Divide up indexes (A, A+1, A+2, ..., B-2, B-1) among N workers as evenly as possible in a range-based for loop: for (auto const& interval : makeIntervals(A, B, N)) {} where interval is a 2-member struct of (begin,end) values. This just does the arithmetic to divide up work into chunks; asynchronous thread management is done separately |
Iteration.h | |
json.h | |
JsonUtils.cpp | |
JsonUtils.h | |
likely.h | |
LruCache.h | |
macros.h | |
MapDProgramOptions.h | |
math_consts.h | |
MathUtils.cpp | |
MathUtils.h | |
measure.h | |
misc.cpp | |
misc.h | |
nocuda.h | |
nvtx_helpers.cpp | |
nvtx_helpers.h | |
quantile.h | Calculate approximate median and general quantiles, based on "Computing Extremely Accurate Quantiles Using t-Digests" by T. Dunning et al. https://arxiv.org/abs/1902.04023 |
release.h | Defines the release number string |
scope.h | |
shard_key.h | |
SimpleAllocator.h | |
sqldefs.h | Common Enum definitions for SQL processing |
sqltypes.h | Constants for Builtin SQL Types supported by HEAVY.AI |
sqltypes_lite.h | |
SqlTypesLayout.h | |
StackTrace.cpp | |
StackTrace.h | |
string_view_unordered_map.h | |
StringTransform.cpp | |
StringTransform.h | |
SysDefinitions.h | |
SystemParameters.h | |
TargetInfo.cpp | |
TargetInfo.h | |
thread_count.cpp | |
thread_count.h | |
ThreadController.h | |
ThreadInfo.h | |
threading.cpp | |
threading.h | |
threading_serial.h | |
threading_std.h | |
threading_tbb.h | |
ThriftClient.cpp | |
ThriftClient.h | |
ThriftConfig.h | |
ThriftJSONProtocolInclude.h | |
ThriftTypesConvert.h | |
toString.h | |
type_name_to_string.h | |
TypedDataAccessors.h | |
types.h | |
UpdelRoll.h | |
uuid.h | No-frills UUID type class to allow easy containerization and comparison of device UUIDs from different APIs |
VectorView.h | |
SqliteConnector | |
SqliteConnector.cpp | |
SqliteConnector.h | |
StringDictionary | |
DictionaryCache.hpp | |
DictRef.h | |
StringDictionary.cpp | |
StringDictionary.h | |
StringDictionaryClient.h | |
StringDictionaryProxy.cpp | |
StringDictionaryProxy.h | |
StringOps | |
StringOpInfo.cpp | |
StringOpInfo.h | |
StringOps.cpp | |
StringOps.h | |
TableArchiver | |
TableArchiver.cpp | |
TableArchiver.h | |
TableArchiverWindows.cpp | |
ThriftHandler | |
os | |
DistributedHandler.h | |
RenderHandler.cpp | |
CommandLineOptions.cpp | |
CommandLineOptions.h | |
ConnectionInfo.h | |
DBHandler.cpp | |
DBHandler.h | |
ForeignTableRefreshScheduler.cpp | |
ForeignTableRefreshScheduler.h | |
QueryState.cpp | |
QueryState.h | |
RenderHandler.h | |
RequestInfo.cpp | |
RequestInfo.h | |
SystemValidator.cpp | |
SystemValidator.h | |
TokenCompletionHints.cpp | |
TokenCompletionHints.h | |
UdfCompiler | |
UdfCompiler.cpp | |
UdfCompiler.h | |
Utils | |
ChunkAccessorTable.cpp | |
ChunkAccessorTable.h | |
ChunkIter.cpp | |
ChunkIter.h | |
DdlUtils.cpp | |
DdlUtils.h | |
FsiUtils.h | |
Regexp.cpp | |
Regexp.h | |
StringLike.cpp | Functions to support the LIKE and ILIKE operator in SQL. Only single-byte character set is supported for now |
StringLike.h | Functions to support the LIKE and ILIKE operator in SQL. Only single-byte character set is supported for now |
HeavyDB.cpp | |
initdb.cpp | |