[ 
https://issues.apache.org/jira/browse/GEARPUMP-204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15512285#comment-15512285
 ] 

ASF GitHub Bot commented on GEARPUMP-204:
-----------------------------------------

Github user manuzhang commented on a diff in the pull request:

    https://github.com/apache/incubator-gearpump/pull/86#discussion_r79979330
  
    --- Diff: 
external/hbase/src/main/scala/org/apache/gearpump/external/hbase/HBaseSink.scala
 ---
    @@ -19,39 +19,47 @@ package org.apache.gearpump.external.hbase
     
     import java.io.{File, ObjectInputStream, ObjectOutputStream}
     
    +import org.apache.gearpump.Message
    +import org.apache.gearpump.cluster.UserConfig
    +import org.apache.gearpump.streaming.sink.DataSink
    +import org.apache.gearpump.streaming.task.TaskContext
    +import org.apache.gearpump.util.{Constants, FileUtils}
     import org.apache.hadoop.conf.Configuration
     import org.apache.hadoop.hbase.client.{Connection, ConnectionFactory, Put}
    +import org.apache.hadoop.hbase.security.UserProvider
     import org.apache.hadoop.hbase.util.Bytes
     import org.apache.hadoop.hbase.{HBaseConfiguration, TableName}
    -import org.apache.hadoop.hbase.security.{User, UserProvider}
     import org.apache.hadoop.security.UserGroupInformation
     
    -import org.apache.gearpump.Message
    -import org.apache.gearpump.cluster.UserConfig
    -import org.apache.gearpump.streaming.sink.DataSink
    -import org.apache.gearpump.streaming.task.TaskContext
    -import org.apache.gearpump.util.{Constants, FileUtils}
    +class HBaseSink(userconfig: UserConfig, tableName: String, @transient var 
connection: Connection,
    +    @transient var configuration: Configuration)
    +  extends DataSink {
     
    -class HBaseSink(
    -    userconfig: UserConfig, tableName: String, @transient var 
configuration: Configuration)
    -  extends DataSink{
    -  lazy val connection = HBaseSink.getConnection(userconfig, configuration)
    +
    +  // var connection = HBaseSink.getConnection(userconfig, configuration)
    --- End diff --
    
    to allow it be mocked in test


> Add unit test for external_hbase module
> ---------------------------------------
>
>                 Key: GEARPUMP-204
>                 URL: https://issues.apache.org/jira/browse/GEARPUMP-204
>             Project: Apache Gearpump
>          Issue Type: Improvement
>            Reporter: Manu Zhang
>            Assignee: Kaifang Bao
>




--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Reply via email to