File tree Expand file tree Collapse file tree 1 file changed +2
-5
lines changed
src/main/scala/com/intenthq/action_processor/integrationsV2 Expand file tree Collapse file tree 1 file changed +2
-5
lines changed Original file line number Diff line number Diff line change 1
1
package com .intenthq .hybrid .integrationsV2
2
2
3
- import java .nio .charset .StandardCharsets
4
-
5
3
import cats .effect ._
6
4
import com .intenthq .hybrid .integrations .{JavaLegacyTimeMeta , TimeMeta }
7
5
import doobie .util .transactor .{Strategy , Transactor }
8
6
9
7
import scala .util .Properties
10
8
11
- abstract class HiveSource [O ] extends Processor with SQLSource [O ] with Aggregations [O ] with TimeMeta with JavaLegacyTimeMeta {
9
+ abstract class HiveSource [O ] extends SQLSource [O ] with Aggregations [O ] with TimeMeta with JavaLegacyTimeMeta {
12
10
13
11
override protected val driver : String = " org.apache.hive.jdbc.HiveDriver"
14
12
15
13
override val jdbcUrl : String = Properties .envOrElse(" HIVE_JDBC_URL" , " jdbc:hive2://localhost:10000" )
16
14
17
15
override protected lazy val transactor : Transactor [IO ] = Transactor .strategy.set(createTransactor, Strategy .void)
18
16
19
- override def serialize (o2 : (String , Long )): Array [Byte ] = s " ${o2._1}, ${o2._2}\n " .getBytes(StandardCharsets .UTF_8 )
20
-
17
+ override def serialize (o2 : (String , Long )): Array [Byte ]
21
18
}
You can’t perform that action at this time.
0 commit comments