Remove null values
Project: http://git-wip-us.apache.org/repos/asf/incubator-gearpump/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-gearpump/commit/e3797899 Tree: http://git-wip-us.apache.org/repos/asf/incubator-gearpump/tree/e3797899 Diff: http://git-wip-us.apache.org/repos/asf/incubator-gearpump/diff/e3797899 Branch: refs/heads/sql Commit: e37978998ebb2095b47f8644bfec943b2575ee96 Parents: 30a9ac5 Author: Buddhi Ayesha <[email protected]> Authored: Thu Jun 8 19:39:21 2017 +0530 Committer: manuzhang <[email protected]> Committed: Sun Jul 9 07:52:48 2017 +0800 ---------------------------------------------------------------------- .../gearpump/experiments/sql/Connection.scala | 113 +++++++++---------- 1 file changed, 56 insertions(+), 57 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-gearpump/blob/e3797899/experiments/sql/src/main/scala/org/apache/gearpump/experiments/sql/Connection.scala ---------------------------------------------------------------------- diff --git a/experiments/sql/src/main/scala/org/apache/gearpump/experiments/sql/Connection.scala b/experiments/sql/src/main/scala/org/apache/gearpump/experiments/sql/Connection.scala index 0c4658c..8fae091 100644 --- a/experiments/sql/src/main/scala/org/apache/gearpump/experiments/sql/Connection.scala +++ b/experiments/sql/src/main/scala/org/apache/gearpump/experiments/sql/Connection.scala @@ -3,15 +3,14 @@ package org.apache.gearpump.experiments.sql import java.lang.reflect.Type import java.sql.{Blob, CallableStatement, Clob, DatabaseMetaData, NClob, PreparedStatement, SQLException, SQLWarning, SQLXML, Savepoint, Statement, Struct} import java.util.Properties -import java.{sql, util} import java.util.concurrent.Executor +import java.{sql, util} import org.apache.calcite.adapter.java.JavaTypeFactory import org.apache.calcite.config.CalciteConnectionConfig import org.apache.calcite.jdbc.CalciteConnection -import org.apache.calcite.linq4j.{Enumerator, Queryable} import org.apache.calcite.linq4j.tree.Expression -import org.apache.calcite.schema.SchemaPlus +import org.apache.calcite.linq4j.{Enumerator, Queryable} import org.apache.log4j.Logger /** @@ -33,125 +32,125 @@ class Connection extends CalciteConnection { override def getSchema: String = schema - override def getTypeFactory: JavaTypeFactory = null + override def getTypeFactory: JavaTypeFactory = ??? - override def getProperties: Properties = null + override def getProperties: Properties = ??? override def getRootSchema: SchemaPlus = rootSchema - override def config(): CalciteConnectionConfig = null + override def config(): CalciteConnectionConfig = ??? - override def commit(): Unit = null + override def commit(): Unit = ??? override def getHoldability: Int = 0 - override def setCatalog(catalog: String): Unit = null + override def setCatalog(catalog: String): Unit = ??? - override def setHoldability(holdability: Int): Unit = null + override def setHoldability(holdability: Int): Unit = ??? - override def prepareStatement(sql: String): PreparedStatement = null + override def prepareStatement(sql: String): PreparedStatement = ??? - override def prepareStatement(sql: String, resultSetType: Int, resultSetConcurrency: Int): PreparedStatement = null + override def prepareStatement(sql: String, resultSetType: Int, resultSetConcurrency: Int): PreparedStatement = ??? - override def prepareStatement(sql: String, resultSetType: Int, resultSetConcurrency: Int, resultSetHoldability: Int): PreparedStatement = null + override def prepareStatement(sql: String, resultSetType: Int, resultSetConcurrency: Int, resultSetHoldability: Int): PreparedStatement = ??? - override def prepareStatement(sql: String, autoGeneratedKeys: Int): PreparedStatement = null + override def prepareStatement(sql: String, autoGeneratedKeys: Int): PreparedStatement = ??? - override def prepareStatement(sql: String, columnIndexes: Array[Int]): PreparedStatement = null + override def prepareStatement(sql: String, columnIndexes: Array[Int]): PreparedStatement = ??? - override def prepareStatement(sql: String, columnNames: Array[String]): PreparedStatement = null + override def prepareStatement(sql: String, columnNames: Array[String]): PreparedStatement = ??? - override def createClob(): Clob = null + override def createClob(): Clob = ??? - override def setClientInfo(name: String, value: String): Unit = null + override def setClientInfo(name: String, value: String): Unit = ??? - override def setClientInfo(properties: Properties): Unit = null + override def setClientInfo(properties: Properties): Unit = ??? - override def createSQLXML(): SQLXML = null + override def createSQLXML(): SQLXML = ??? - override def getCatalog: String = null + override def getCatalog: String = ??? - override def createBlob(): Blob = null + override def createBlob(): Blob = ??? - override def createStatement(): Statement = null + override def createStatement(): Statement = ??? - override def createStatement(resultSetType: Int, resultSetConcurrency: Int): Statement = null + override def createStatement(resultSetType: Int, resultSetConcurrency: Int): Statement = ??? - override def createStatement(resultSetType: Int, resultSetConcurrency: Int, resultSetHoldability: Int): Statement = null + override def createStatement(resultSetType: Int, resultSetConcurrency: Int, resultSetHoldability: Int): Statement = ??? - override def abort(executor: Executor): Unit = null + override def abort(executor: Executor): Unit = ??? - override def setAutoCommit(autoCommit: Boolean): Unit = null + override def setAutoCommit(autoCommit: Boolean): Unit = ??? - override def getMetaData: DatabaseMetaData = null + override def getMetaData: DatabaseMetaData = ??? - override def setReadOnly(readOnly: Boolean): Unit = null + override def setReadOnly(readOnly: Boolean): Unit = ??? - override def prepareCall(sql: String): CallableStatement = null + override def prepareCall(sql: String): CallableStatement = ??? - override def prepareCall(sql: String, resultSetType: Int, resultSetConcurrency: Int): CallableStatement = null + override def prepareCall(sql: String, resultSetType: Int, resultSetConcurrency: Int): CallableStatement = ??? - override def prepareCall(sql: String, resultSetType: Int, resultSetConcurrency: Int, resultSetHoldability: Int): CallableStatement = null + override def prepareCall(sql: String, resultSetType: Int, resultSetConcurrency: Int, resultSetHoldability: Int): CallableStatement = ??? - override def setTransactionIsolation(level: Int): Unit = null + override def setTransactionIsolation(level: Int): Unit = ??? - override def getWarnings: SQLWarning = null + override def getWarnings: SQLWarning = ??? - override def releaseSavepoint(savepoint: Savepoint): Unit = null + override def releaseSavepoint(savepoint: Savepoint): Unit = ??? - override def nativeSQL(sql: String): String = null + override def nativeSQL(sql: String): String = ??? - override def isReadOnly: Boolean = null + override def isReadOnly: Boolean = ??? - override def createArrayOf(typeName: String, elements: Array[AnyRef]): sql.Array = null + override def createArrayOf(typeName: String, elements: Array[AnyRef]): sql.Array = ??? - override def setSavepoint(): Savepoint = null + override def setSavepoint(): Savepoint = ??? - override def setSavepoint(name: String): Savepoint = null + override def setSavepoint(name: String): Savepoint = ??? - override def close(): Unit = null + override def close(): Unit = ??? - override def createNClob(): NClob = null + override def createNClob(): NClob = ??? - override def rollback(): Unit = null + override def rollback(): Unit = ??? - override def rollback(savepoint: Savepoint): Unit = null + override def rollback(savepoint: Savepoint): Unit = ??? - override def setNetworkTimeout(executor: Executor, milliseconds: Int): Unit = null + override def setNetworkTimeout(executor: Executor, milliseconds: Int): Unit = ??? - override def setTypeMap(map: util.Map[String, Class[_]]): Unit = null + override def setTypeMap(map: util.Map[String, Class[_]]): Unit = ??? - override def isValid(timeout: Int): Boolean = null + override def isValid(timeout: Int): Boolean = ??? - override def getAutoCommit: Boolean = null + override def getAutoCommit: Boolean = ??? - override def clearWarnings(): Unit = null + override def clearWarnings(): Unit = ??? override def getNetworkTimeout: Int = 0 - override def isClosed: Boolean = null + override def isClosed: Boolean = ??? override def getTransactionIsolation: Int = 0 - override def createStruct(typeName: String, attributes: Array[AnyRef]): Struct = null + override def createStruct(typeName: String, attributes: Array[AnyRef]): Struct = ??? - override def getClientInfo(name: String): String = null + override def getClientInfo(name: String): String = ??? - override def getClientInfo: Properties = null + override def getClientInfo: Properties = ??? - override def getTypeMap: util.Map[String, Class[_]] = null + override def getTypeMap: util.Map[String, Class[_]] = ??? override def unwrap[T](iface: Class[T]): T = ??? - override def isWrapperFor(iface: Class[_]): Boolean = null + override def isWrapperFor(iface: Class[_]): Boolean = ??? override def execute[T](expression: Expression, aClass: Class[T]): T = ??? override def execute[T](expression: Expression, `type`: Type): T = ??? - override def executeQuery[T](queryable: Queryable[T]): Enumerator[T] = null + override def executeQuery[T](queryable: Queryable[T]): Enumerator[T] = ??? - override def createQuery[T](expression: Expression, aClass: Class[T]): Queryable[T] = null + override def createQuery[T](expression: Expression, aClass: Class[T]): Queryable[T] = ??? - override def createQuery[T](expression: Expression, `type`: Type): Queryable[T] = null + override def createQuery[T](expression: Expression, `type`: Type): Queryable[T] = ??? }
