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

Class KafkaReservoirReporter

java.lang.Object

org.apache.kylin.metrics.lib.ActiveReservoirReporter

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

All Implemented Interfaces:

Closeable, AutoCloseable

public class KafkaReservoirReporter
extends ActiveReservoirReporter

A reporter which listens for new records and publishes them to Kafka.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	KafkaReservoirReporter.Builder A builder for KafkaReservoirReporter instances.

Field Summary

Fields

Modifier and Type	Field and Description
static String	KAFKA_REPORTER_SUFFIX
protected static org.slf4j.Logger	logger
static KafkaSink	sink

Fields inherited from class org.apache.kylin.metrics.lib.ActiveReservoirReporter

KYLIN_PREFIX

Method Summary

Methods

Modifier and Type	Method and Description
void	close() Stops the reporter.
static KafkaReservoirReporter.Builder	forRegistry(ActiveReservoir activeReservoir) Returns a new KafkaReservoirReporter.Builder for KafkaReservoirReporter.
static String	getTableFromSubject(String subject)
void	start() Starts the reporter.
void	stop() Stops the reporter.

Methods inherited from class org.apache.kylin.metrics.lib.ActiveReservoirReporter

getTableName, getTableNameSplits

Methods inherited from class java.lang.Object

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

Field Detail

KAFKA_REPORTER_SUFFIX

public static final String KAFKA_REPORTER_SUFFIX

See Also:

Constant Field Values

sink

public static final KafkaSink sink

logger

protected static final org.slf4j.Logger logger

Method Detail

forRegistry

public static KafkaReservoirReporter.Builder forRegistry(ActiveReservoir activeReservoir)

Returns a new KafkaReservoirReporter.Builder for KafkaReservoirReporter.

Parameters:

activeReservoir - the registry to report

Returns:

a KafkaReservoirReporter.Builder instance for a KafkaReservoirReporter

getTableFromSubject

public static String getTableFromSubject(String subject)

start

public void start()

Starts the reporter.

Specified by:

start in class ActiveReservoirReporter

stop

public void stop()

Stops the reporter.

Specified by:

stop in class ActiveReservoirReporter

close

public void close()

Stops the reporter.