C E G K M O S
All Classes All Packages

C

COLUMN_KEY - Static variable in class org.apache.metamodel.kafka.KafkaDataContext

COLUMN_OFFSET - Static variable in class org.apache.metamodel.kafka.KafkaDataContext

COLUMN_PARTITION - Static variable in class org.apache.metamodel.kafka.KafkaDataContext

COLUMN_TIMESTAMP - Static variable in class org.apache.metamodel.kafka.KafkaDataContext

COLUMN_VALUE - Static variable in class org.apache.metamodel.kafka.KafkaDataContext

ConsumerAndProducerFactory - Interface in org.apache.metamodel.kafka

Factory interface for Kafka Consumer and Producer objects to be used by Apache MetaModel.

createConsumer(String, Class<K>, Class<V>) - Method in interface org.apache.metamodel.kafka.ConsumerAndProducerFactory

createConsumer(String, Class<K>, Class<V>) - Method in class org.apache.metamodel.kafka.KafkaConsumerAndProducerFactory

createProducer(Class<K>, Class<V>) - Method in interface org.apache.metamodel.kafka.ConsumerAndProducerFactory

createProducer(Class<K>, Class<V>) - Method in class org.apache.metamodel.kafka.KafkaConsumerAndProducerFactory

E

executeUpdate(UpdateScript) - Method in class org.apache.metamodel.kafka.KafkaDataContext

G

getMainSchema() - Method in class org.apache.metamodel.kafka.KafkaDataContext

getMainSchemaName() - Method in class org.apache.metamodel.kafka.KafkaDataContext

K

KafkaConsumerAndProducerFactory - Class in org.apache.metamodel.kafka

Default ConsumerAndProducerFactory implementation.

KafkaConsumerAndProducerFactory(String) - Constructor for class org.apache.metamodel.kafka.KafkaConsumerAndProducerFactory

KafkaConsumerAndProducerFactory(Properties) - Constructor for class org.apache.metamodel.kafka.KafkaConsumerAndProducerFactory

KafkaDataContext<K,V> - Class in org.apache.metamodel.kafka

KafkaDataContext(Class<K>, Class<V>, String, Collection<String>) - Constructor for class org.apache.metamodel.kafka.KafkaDataContext

KafkaDataContext(Class<K>, Class<V>, ConsumerAndProducerFactory, Supplier<Collection<String>>) - Constructor for class org.apache.metamodel.kafka.KafkaDataContext

M

materializeMainSchemaTable(Table, List<SelectItem>, List<FilterItem>, int, int) - Method in class org.apache.metamodel.kafka.KafkaDataContext

materializeMainSchemaTable(Table, List<Column>, int) - Method in class org.apache.metamodel.kafka.KafkaDataContext

materializeMainSchemaTableFromConsumer(Consumer<K, V>, List<SelectItem>, int, int) - Method in class org.apache.metamodel.kafka.KafkaDataContext

O

org.apache.metamodel.kafka - package org.apache.metamodel.kafka

S

SYSTEM_PROPERTY_CONSUMER_POLL_TIMEOUT - Static variable in class org.apache.metamodel.kafka.KafkaDataContext

C E G K M O S
All Classes All Packages