org.apache.kylin.metrics.lib.impl.kafka

Class KafkaSink

java.lang.Object

org.apache.kylin.metrics.lib.impl.kafka.KafkaSink

All Implemented Interfaces:

Sink

public class KafkaSink
extends Object
implements Sink

Constructor Summary

Constructors

Constructor and Description
KafkaSink()

Method Summary

Methods

Modifier and Type	Method and Description
String	getTableFromSubject(String subject)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

KafkaSink

public KafkaSink()

Method Detail

getTableFromSubject

public String getTableFromSubject(String subject)

Specified by:

getTableFromSubject in interface Sink