有没有人是用scala写flink的？想问一下，怎么自定义hbase sink？

是的，很多人使用Scala来编写Flink应用。以下是在Flink中创建自定义HBase Sink的基本步骤：

1. 创建一个新的Scala对象以定义Sink的功能。这通常涉及到继承RichSinkFunction类，并重写其中的一些方法，如open，invoke等。

2. 在open方法中，你需要连接到HBase实例并获取表的句柄。

3. 在invoke方法中，你将接收到从上游算子传来的数据，并将它们写入到HBase表中。

以下是一个简单的示例：

class HBaseSink extends RichSinkFunction[YourType] {

    private var hbaseAdmin: Connection = _
    private var table: Table = _

    override def open(parameters: Configuration): Unit = {
        // 连接到HBase实例并获取表的句柄
    }

    override def invoke(value: YourType, context: SinkFunction.Context): Unit = {
        // 写入HBase表
    }
}

请注意，这只是一个基本示例，实际的情况可能更复杂。你可能需要处理错误，优化性能，等等。

在完成以上步骤后，你就可以在你的Flink程序中添加这个Sink了：

val stream: DataStream[YourType] = ...
stream.addSink(new HBaseSink())