Skip to content

Commit

Permalink
simplify StarRocksTRowSetGenerator
Browse files Browse the repository at this point in the history
  • Loading branch information
bowenliang123 committed Dec 21, 2023
1 parent c857224 commit 4bf55bb
Showing 1 changed file with 2 additions and 16 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -16,20 +16,6 @@
*/
package org.apache.kyuubi.engine.jdbc.starrocks

import org.apache.kyuubi.engine.jdbc.schema.DefaultJdbcTRowSetGenerator
import org.apache.kyuubi.shaded.hive.service.rpc.thrift.{TColumn, TColumnValue}
import org.apache.kyuubi.engine.jdbc.mysql.MySQLTRowSetGenerator

class StarRocksTRowSetGenerator extends DefaultJdbcTRowSetGenerator {

override def toTinyIntTColumn(rows: Seq[Seq[_]], ordinal: Int): TColumn =
toIntegerTColumn(rows, ordinal)

override def toSmallIntTColumn(rows: Seq[Seq[_]], ordinal: Int): TColumn =
toIntegerTColumn(rows, ordinal)

override def toTinyIntTColumnValue(row: Seq[_], ordinal: Int): TColumnValue =
toIntegerTColumnValue(row, ordinal)

override def toSmallIntTColumnValue(row: Seq[_], ordinal: Int): TColumnValue =
toIntegerTColumnValue(row, ordinal)
}
class StarRocksTRowSetGenerator extends MySQLTRowSetGenerator {}

0 comments on commit 4bf55bb

Please sign in to comment.