akonopko

package com.memsql.spark.connector.dataframe

import org.apache.spark.sql.types._
import org.apache.spark.unsafe.types.UTF8String


@SQLUserDefinedType(udt = classOf[UTF8JsonType])
class UTF8JsonValue(val value: String) extends Serializable with MemSQLCustomType {
  override def toString: String = value
}

akonopko

import com.memsql.spark.connector.MemSQLContext
import com.memsql.spark.connector.dataframe.JsonValue
import org.apache.log4j.{Level, Logger}
import org.apache.spark.sql.Row
import org.apache.spark.sql.types._
import org.apache.spark.{SparkConf, SparkContext}

object TestError {

  def main(args: Array[String]) {

akonopko

 [x] Getting releases download page   --2014-01-15 09:41:11--  http://www.oracle.com/technetwork/java/javase/downloads/jdk7-downloads-1880260.html
Resolving www.oracle.com (www.oracle.com)... 23.37.22.140
Connecting to www.oracle.com (www.oracle.com)|23.37.22.140|:80... connected.
HTTP request sent, awaiting response... 200 OK
Length: unspecified [text/html]
Saving to: `/tmp/oab-download.html'

     0K .......... .......... .......... .......... .......... 8.75M
    50K .......... ........                                    8.85M=0.008s