here is source code aboout exception 
==============================================================================
/**
  * Construct fields with the TSFile data type converted to the SparkSQL data 
type.
  *
  * @param tsfileSchema tsfileSchema
  * @param addTimeField true to add a time field; false to not
  * @return the converted list of fields
  */
def toSqlField(tsfileSchema: util.ArrayList[Series], addTimeField: Boolean):
ListBuffer[StructField] = {
val fields = new ListBuffer[StructField]()

if (addTimeField) {
fields += StructField(QueryConstant.RESERVED_TIME, LongType, nullable = false)
  }

tsfileSchema.foreach((series: Series) => {
fields += StructField(series.getName, series.getType match {
case TSDataType.BOOLEAN => BooleanType
case TSDataType.INT32 => IntegerType
case TSDataType.INT64 => LongType
case TSDataType.FLOAT => FloatType
case TSDataType.DOUBLE => DoubleType
case TSDataType.TEXT => StringType
case other => throw new UnsupportedOperationException(s"Unsupported type 
$other")
    }, nullable = true)
  })

fields
}

Reply via email to