OmniSciDB  8fa3bf436f
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Pages
test_fsi Namespace Reference

Variables

tuple d = dbe.PyDbEngine(enable_fsi=1, data='data', calcite_port=9091)
 
tuple root = os.path.dirname(os.path.dirname(os.path.dirname(os.path.abspath(__file__))))
 
string csv_file = root+"/Tests/Import/datafiles/trips_with_headers_top1000.csv"
 
tuple r = d.executeDDL("""CREATE TEMPORARY TABLE trips (trip_id BIGINT,vendor_id TEXT ENCODING NONE,pickup_datetime TIMESTAMP,dropoff_datetime TIMESTAMP,store_and_fwd_flag TEXT ENCODING DICT,rate_code_id BIGINT,pickup_longitude DOUBLE,pickup_latitude DOUBLE,dropoff_longitude DOUBLE,dropoff_latitude DOUBLE,passenger_count BIGINT,trip_distance DOUBLE,fare_amount DOUBLE,extra DOUBLE,mta_tax DOUBLE,tip_amount DOUBLE,tolls_amount DOUBLE,ehail_fee DOUBLE,improvement_surcharge DOUBLE,total_amount DOUBLE,payment_type TEXT ENCODING DICT,trip_type BIGINT,pickup TEXT ENCODING DICT,dropoff TEXT ENCODING NONE,cab_type TEXT ENCODING DICT,precipitation DOUBLE,snow_depth BIGINT,snowfall DOUBLE,max_temperature BIGINT,min_temperature BIGINT,average_wind_speed DOUBLE,pickup_nyct2010_gid BIGINT,pickup_ctlabel DOUBLE,pickup_borocode BIGINT,pickup_boroname TEXT ENCODING NONE,pickup_ct2010 BIGINT,pickup_boroct2010 BIGINT,pickup_cdeligibil TEXT ENCODING DICT,pickup_ntacode TEXT ENCODING DICT,pickup_ntaname TEXT ENCODING DICT,pickup_puma BIGINT,dropoff_nyct2010_gid BIGINT,dropoff_ctlabel DOUBLE,dropoff_borocode BIGINT,dropoff_boroname TEXT ENCODING NONE,dropoff_ct2010 BIGINT,dropoff_boroct2010 BIGINT,dropoff_cdeligibil TEXT ENCODING NONE,dropoff_ntacode TEXT ENCODING NONE,dropoff_ntaname TEXT ENCODING NONE,dropoff_puma BIGINT) WITH (storage_type='CSV:""" + csv_file + """', fragment_size=100);""")
 

Variable Documentation

string test_fsi.csv_file = root+"/Tests/Import/datafiles/trips_with_headers_top1000.csv"

Definition at line 13 of file test_fsi.py.

tuple test_fsi.d = dbe.PyDbEngine(enable_fsi=1, data='data', calcite_port=9091)

Definition at line 9 of file test_fsi.py.

Referenced by import_export::TypedImportBuffer.add_value(), Parser::FixedPtLiteral.analyze(), Parser::FloatLiteral.analyze(), Parser::DoubleLiteral.analyze(), Parser::UserLiteral.analyze(), Parser::InsertValuesStmt.analyze(), Parser::StringLiteral.analyzeValue(), Parser::IntLiteral.analyzeValue(), Parser::FixedPtLiteral.analyzeValue(), com.mapd.tests.DateTimeTest.Encoding.clear(), com.mapd.tests.DateTimeTest.Encoding.clearForDateAddResult(), CodeGenerator.codegenCmpDecimalConst(), CodeGenerator.codegenRowId(), RelAlgExecutor.createTableFunctionWorkUnit(), foreign_storage.datetime_to_string(), anonymous_namespace{RelAlgTranslator.cpp}.datum_from_scalar_tv(), Analyzer::Constant.deep_copy(), Catalog_Namespace::SysCatalog.deleteObjectDescriptorMap(), Parser::InsertValuesStmt.determineLeafIndex(), Catalog_Namespace::Catalog.dropTableFromJsonUnlocked(), shared.formatDate(), shared.formatDateTime(), ExtractExpr.generate(), DateTruncExpr.generate(), Parser::TimestampLiteral.get(), Parser::UserLiteral.get(), anonymous_namespace{RelAlgTranslator.cpp}.get_in_values_expr(), Catalog_Namespace::SysCatalog.getDatabaseListForUser(), com.omnisci.jdbc.OmniSciResultSet.getDate(), Catalog_Namespace::SysCatalog.getMetadataForObject(), DateTimeTranslator.getNumericConstant(), CgenState.getOrAddLiteral(), main(), anonymous_namespace{ResultSetIteration.cpp}.make_avg_target_value(), make_fp_constant(), Parser::CaseExpr.normalize(), import_export.NullArray(), import_export.NullArrayDatum(), import_export.NullDatum(), populate_TColumn(), foreign_storage::CsvDataWrapper.populateChunks(), foreign_storage::json_utils.read_from_file(), Catalog_Namespace::SysCatalog.renameObjectsInDescriptorMap(), foreign_storage::ParquetDataWrapper.restoreDataWrapperInternals(), foreign_storage::CsvDataWrapper.restoreDataWrapperInternals(), Catalog_Namespace::SysCatalog.revokeAllOnDatabase_unsafe(), foreign_storage::ParquetDataWrapper.serializeDataWrapperInternals(), foreign_storage::CsvDataWrapper.serializeDataWrapperInternals(), Catalog_Namespace::Catalog.serializeTableJsonUnlocked(), Analyzer::Constant.set_constval(), SQLTypeInfo.set_dimension(), SQLTypeInfo.set_input_srid(), Analyzer::Query.set_is_distinct(), SQLTypeInfo.set_precision(), com.mapd.utility.SQLImporter.setColValue(), import_export.StringToArray(), StringToDatum(), CudaMgr_Namespace::CudaMgr.synchronizeDevices(), import_export.TDatumToDatum(), com.mapd.tests.DateTimeTest.testAdd(), com.mapd.tests.DateTimeTest.testDateAdd(), com.mapd.tests.DateTimeTest.testDateAddTable(), com.mapd.tests.DateTimeTest.testDateExtract(), com.mapd.tests.DateTimeTest.testDateExtractTable(), com.mapd.tests.DateTimeTest.testDateTrunc(), com.mapd.tests.DateTimeTest.testDateTruncTable(), com.mapd.tests.DateTimeTest.testSub(), com.mapd.tests.DateTimeTest.Encoding.toSql(), RelAlgTranslator.translateBinaryGeoFunction(), RelAlgTranslator.translateFunction(), RelAlgTranslator.translateGeoLiteral(), RelAlgTranslator.translateInOper(), RelAlgTranslator.translateLiteral(), RelAlgTranslator.translateScalarSubquery(), Catalog_Namespace::SysCatalog.updateObjectDescriptorMap(), anonymous_namespace{ExpressionRewrite.cpp}::ConstantFoldingVisitor.visitBinOper(), and CudaMgr_Namespace::CudaMgr.~CudaMgr().

tuple test_fsi.r = d.executeDDL("""CREATE TEMPORARY TABLE trips (trip_id BIGINT,vendor_id TEXT ENCODING NONE,pickup_datetime TIMESTAMP,dropoff_datetime TIMESTAMP,store_and_fwd_flag TEXT ENCODING DICT,rate_code_id BIGINT,pickup_longitude DOUBLE,pickup_latitude DOUBLE,dropoff_longitude DOUBLE,dropoff_latitude DOUBLE,passenger_count BIGINT,trip_distance DOUBLE,fare_amount DOUBLE,extra DOUBLE,mta_tax DOUBLE,tip_amount DOUBLE,tolls_amount DOUBLE,ehail_fee DOUBLE,improvement_surcharge DOUBLE,total_amount DOUBLE,payment_type TEXT ENCODING DICT,trip_type BIGINT,pickup TEXT ENCODING DICT,dropoff TEXT ENCODING NONE,cab_type TEXT ENCODING DICT,precipitation DOUBLE,snow_depth BIGINT,snowfall DOUBLE,max_temperature BIGINT,min_temperature BIGINT,average_wind_speed DOUBLE,pickup_nyct2010_gid BIGINT,pickup_ctlabel DOUBLE,pickup_borocode BIGINT,pickup_boroname TEXT ENCODING NONE,pickup_ct2010 BIGINT,pickup_boroct2010 BIGINT,pickup_cdeligibil TEXT ENCODING DICT,pickup_ntacode TEXT ENCODING DICT,pickup_ntaname TEXT ENCODING DICT,pickup_puma BIGINT,dropoff_nyct2010_gid BIGINT,dropoff_ctlabel DOUBLE,dropoff_borocode BIGINT,dropoff_boroname TEXT ENCODING NONE,dropoff_ct2010 BIGINT,dropoff_boroct2010 BIGINT,dropoff_cdeligibil TEXT ENCODING NONE,dropoff_ntacode TEXT ENCODING NONE,dropoff_ntaname TEXT ENCODING NONE,dropoff_puma BIGINT) WITH (storage_type='CSV:""" + csv_file + """', fragment_size=100);""")

Definition at line 16 of file test_fsi.py.

Referenced by Catalog_Namespace::Catalog.addForeignTableDetails(), org.apache.calcite.rel.rules.OuterJoinOptViaNullRejectionRule.addNullRejectedJoinCols(), agg_max_double(), agg_max_float(), agg_min_double(), agg_min_float(), agg_sum_double(), agg_sum_float(), area_polygon(), Catalog_Namespace::Catalog.buildMaps(), Catalog_Namespace::SysCatalog.buildObjectDescriptorMap(), Catalog_Namespace::SysCatalog.buildRoleMap(), Catalog_Namespace::SysCatalog.buildUserRoleMap(), centroid_add_polygon(), Grantee.checkCycles(), Contains_Polygon_Point_Impl(), org.apache.calcite.sql2rel.SqlToRelConverter.convertWhere(), org.apache.calcite.sql2rel.SqlToRelConverter.createAggImpl(), ArrowForeignStorageBase.createDictionaryEncodedColumn(), org.apache.calcite.sql2rel.SqlToRelConverter.createJoin(), Catalog_Namespace::Catalog.executeDropTableSqliteQueries(), TableFunctionCompilationContext.generateEntryPoint(), Geospatial::GeoMultiPolygon.GeoMultiPolygon(), Geospatial::GeoPolygon.GeoPolygon(), Catalog_Namespace::anonymous_namespace{SysCatalog.cpp}.get_users(), Catalog_Namespace::SysCatalog.getAllDBMetadata(), Geospatial::GeoPolygon.getColumns(), Geospatial::GeoMultiPolygon.getColumns(), org.apache.calcite.sql2rel.SqlToRelConverter.getCorrelationUse(), com.mapd.tests.DateTimeTest.getDateTimeFromQuery(), com.mapd.tests.DateTimeTest.getLongFromQuery(), Catalog_Namespace::SysCatalog.getRoles(), Fragmenter_Namespace::InsertOrderFragmenter.getVacuumOffsets(), StringDictionary.hashStrings(), Grantee.hasRole(), hll_unify(), DBHandler.import_geo_table(), anonymous_namespace{TypedDataAccessors.h}.integer_setter(), com.mapd.tests.DateTimeTest.main(), anonymous_namespace{ResultSetIteration.cpp}.make_bin_search(), MurmurHash1Impl(), MurmurHash64AImpl(), org.apache.calcite.rel.rules.OuterJoinOptViaNullRejectionRule.onMatch(), com.mapd.parser.server.ExtensionFunctionSignatureParser.parseFromString(), com.mapd.parser.server.test.TestServer.randomCalciteCall(), com.mapd.parser.server.test.TestMapDServer.randomMapDCall(), Catalog_Namespace::Catalog.recordOwnershipOfObjectsInObjectPermissions(), Executor.reduceMultiDeviceResultSets(), Executor.reduceResults(), org.apache.calcite.sql2rel.SqlToRelConverter.rewriteAggregateWithGroupId(), Catalog_Namespace::SessionInfo.set_restriction(), Analyzer::Var.set_which_row(), ST_Distance_LineString_Polygon(), ST_Distance_Point_Polygon(), org.apache.calcite.sql2rel.SqlToRelConverter.substituteSubQuery(), com.mapd.tests.DateTimeTest.testAdd(), com.mapd.tests.DateTimeTest.testDateAdd(), com.mapd.tests.DateTimeTest.testDateAddTable(), com.mapd.tests.DateTimeTest.testDateExtract(), com.mapd.tests.DateTimeTest.testDateExtractTable(), com.mapd.tests.DateTimeTest.testDateTrunc(), com.mapd.tests.DateTimeTest.testDateTruncTable(), com.mapd.tests.DateTimeTest.testDiff(), com.mapd.tests.DateTimeTest.testDiffTable(), com.mapd.tests.DateTimeTest.testSub(), com.mapd.parser.server.test.TestMapDServer.testThreadedCall(), com.mapd.parser.server.test.TestServer.testThreadedCall(), ExtensionFunctionsWhitelist.toString(), ExtensionFunctionsWhitelist.toStringSQL(), Fragmenter_Namespace::InsertOrderFragmenter.updateColumn(), Catalog_Namespace::Catalog.updateDictionaryNames(), and foreign_storage::anonymous_namespace{LazyParquetChunkLoader.cpp}.validate_column_mapping_and_row_group_metadata().

tuple test_fsi.root = os.path.dirname(os.path.dirname(os.path.dirname(os.path.abspath(__file__))))

Definition at line 12 of file test_fsi.py.