Function GetTestingHiveURL

go/database/testing.go:99–109

GetTestingHiveURL reutrns Hive connection URL

()

// GetTestingHiveURL reutrns Hive connection URL
func GetTestingHiveURL() string {
	// NOTE: sample dataset is written in
	// https://github.com/sql-machine-learning/gohive/blob/develop/docker/entrypoint.sh#L123
	namenodeAddr := os.Getenv("SQLFLOW_TEST_HDFS_NAMENODE_ADDR")
	hiveLocation := os.Getenv("SQLFLOW_HIVE_LOCATION")
	if hiveLocation == "" {
		hiveLocation = "/sqlflow"
	}
	return fmt.Sprintf("hive://root:root@localhost:10000/iris?"+
		"hdfs_namenode_addr=%s&hive_location=%s", namenodeAddr, hiveLocation)
}

func createTestingHiveDB() *DB {
	db, e := OpenAndConnectDB(GetTestingHiveURL())