B C D F G K L M O S T

B

build() - Method in class org.apache.kylin.metrics.lib.impl.kafka.KafkaReservoirReporter.Builder

Builds a KafkaReservoirReporter with the given properties.

C

checkAvailable(String) - Method in class org.apache.kylin.metrics.lib.impl.kafka.KafkaActiveReserviorListener

close() - Method in class org.apache.kylin.metrics.lib.impl.kafka.KafkaReservoirReporter

Stops the reporter.

D

decorateTopic(String) - Method in class org.apache.kylin.metrics.lib.impl.kafka.KafkaActiveReserviorListener

F

forRegistry(ActiveReservoir) - Static method in class org.apache.kylin.metrics.lib.impl.kafka.KafkaReservoirReporter

Returns a new KafkaReservoirReporter.Builder for KafkaReservoirReporter.

G

getTableFromSubject(String) - Static method in class org.apache.kylin.metrics.lib.impl.kafka.KafkaReservoirReporter

getTableFromSubject(String) - Method in class org.apache.kylin.metrics.lib.impl.kafka.KafkaSink

K

KAFKA_REPORTER_SUFFIX - Static variable in class org.apache.kylin.metrics.lib.impl.kafka.KafkaReservoirReporter

KafkaActiveReserviorListener - Class in org.apache.kylin.metrics.lib.impl.kafka

KafkaActiveReserviorListener() - Constructor for class org.apache.kylin.metrics.lib.impl.kafka.KafkaActiveReserviorListener

KafkaReservoirReporter - Class in org.apache.kylin.metrics.lib.impl.kafka

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

KafkaReservoirReporter.Builder - Class in org.apache.kylin.metrics.lib.impl.kafka

A builder for KafkaReservoirReporter instances.

KafkaSink - Class in org.apache.kylin.metrics.lib.impl.kafka

KafkaSink() - Constructor for class org.apache.kylin.metrics.lib.impl.kafka.KafkaSink

L

logger - Static variable in class org.apache.kylin.metrics.lib.impl.kafka.KafkaActiveReserviorListener

logger - Static variable in class org.apache.kylin.metrics.lib.impl.kafka.KafkaReservoirReporter

M

maxBlockMs - Variable in class org.apache.kylin.metrics.lib.impl.kafka.KafkaActiveReserviorListener

maxRecordForLogNum - Variable in class org.apache.kylin.metrics.lib.impl.kafka.KafkaActiveReserviorListener

maxRecordSkipForLogNum - Variable in class org.apache.kylin.metrics.lib.impl.kafka.KafkaActiveReserviorListener

O

onRecordUpdate(List<Record>) - Method in class org.apache.kylin.metrics.lib.impl.kafka.KafkaActiveReserviorListener

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

S

send(String, Record, Callback) - Method in class org.apache.kylin.metrics.lib.impl.kafka.KafkaActiveReserviorListener

sendWrapper(String, Record, Callback) - Method in class org.apache.kylin.metrics.lib.impl.kafka.KafkaActiveReserviorListener

setUnAvailable(String) - Method in class org.apache.kylin.metrics.lib.impl.kafka.KafkaActiveReserviorListener

sink - Static variable in class org.apache.kylin.metrics.lib.impl.kafka.KafkaReservoirReporter

start() - Method in class org.apache.kylin.metrics.lib.impl.kafka.KafkaReservoirReporter

Starts the reporter.

stop() - Method in class org.apache.kylin.metrics.lib.impl.kafka.KafkaReservoirReporter

Stops the reporter.

T

TOPIC_AVAILABLE_TAG - Static variable in class org.apache.kylin.metrics.lib.impl.kafka.KafkaActiveReserviorListener

topicsIfAvailable - Variable in class org.apache.kylin.metrics.lib.impl.kafka.KafkaActiveReserviorListener

tryFetchMetadataFor(String) - Method in class org.apache.kylin.metrics.lib.impl.kafka.KafkaActiveReserviorListener

B C D F G K L M O S T