Fix the problem that DFTextFileLoadDataFrameSample fail randomly

This commit is contained in:
tqin 2015-12-07 19:03:33 -08:00
Родитель 96fdeb2776
Коммит d214f949d6
1 изменённых файлов: 1 добавлений и 1 удалений

Просмотреть файл

@ -163,7 +163,7 @@ object SQLUtils {
sqlContext.read.format(source).schema(schema).load()
}
def loadTextFile(sqlContext: SQLContext, path: String, hasHeader: Boolean, inferSchema: Boolean) : DataFrame = {
def loadTextFile(sqlContext: SQLContext, path: String, hasHeader: java.lang.Boolean, inferSchema: java.lang.Boolean) : DataFrame = {
var dfReader = sqlContext.read.format("com.databricks.spark.csv")
if (hasHeader)
{