| <!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd"> |
| <!-- NewPage --> |
| <html lang="en"> |
| <head> |
| <!-- Generated by javadoc (1.8.0_40) on Thu Jul 20 13:22:44 PDT 2017 --> |
| <title>Index (gobblin-kafka-09 0.11.0 API)</title> |
| <meta name="date" content="2017-07-20"> |
| <link rel="stylesheet" type="text/css" href="stylesheet.css" title="Style"> |
| <script type="text/javascript" src="script.js"></script> |
| </head> |
| <body> |
| <script type="text/javascript"><!-- |
| try { |
| if (location.href.indexOf('is-external=true') == -1) { |
| parent.document.title="Index (gobblin-kafka-09 0.11.0 API)"; |
| } |
| } |
| catch(err) { |
| } |
| //--> |
| </script> |
| <noscript> |
| <div>JavaScript is disabled on your browser.</div> |
| </noscript> |
| <!-- ========= START OF TOP NAVBAR ======= --> |
| <div class="topNav"><a name="navbar.top"> |
| <!-- --> |
| </a> |
| <div class="skipNav"><a href="#skip.navbar.top" title="Skip navigation links">Skip navigation links</a></div> |
| <a name="navbar.top.firstrow"> |
| <!-- --> |
| </a> |
| <ul class="navList" title="Navigation"> |
| <li><a href="overview-summary.html">Overview</a></li> |
| <li>Package</li> |
| <li>Class</li> |
| <li><a href="overview-tree.html">Tree</a></li> |
| <li><a href="deprecated-list.html">Deprecated</a></li> |
| <li class="navBarCell1Rev">Index</li> |
| <li><a href="help-doc.html">Help</a></li> |
| </ul> |
| </div> |
| <div class="subNav"> |
| <ul class="navList"> |
| <li>Prev</li> |
| <li>Next</li> |
| </ul> |
| <ul class="navList"> |
| <li><a href="index.html?index-all.html" target="_top">Frames</a></li> |
| <li><a href="index-all.html" target="_top">No Frames</a></li> |
| </ul> |
| <ul class="navList" id="allclasses_navbar_top"> |
| <li><a href="allclasses-noframe.html">All Classes</a></li> |
| </ul> |
| <div> |
| <script type="text/javascript"><!-- |
| allClassesLink = document.getElementById("allclasses_navbar_top"); |
| if(window==top) { |
| allClassesLink.style.display = "block"; |
| } |
| else { |
| allClassesLink.style.display = "none"; |
| } |
| //--> |
| </script> |
| </div> |
| <a name="skip.navbar.top"> |
| <!-- --> |
| </a></div> |
| <!-- ========= END OF TOP NAVBAR ========= --> |
| <div class="contentContainer"><a href="#I:C">C</a> <a href="#I:D">D</a> <a href="#I:E">E</a> <a href="#I:F">F</a> <a href="#I:G">G</a> <a href="#I:H">H</a> <a href="#I:K">K</a> <a href="#I:L">L</a> <a href="#I:R">R</a> <a href="#I:S">S</a> <a href="#I:T">T</a> <a href="#I:W">W</a> <a href="#I:Z:Z_">_</a> <a name="I:C"> |
| <!-- --> |
| </a> |
| <h2 class="title">C</h2> |
| <dl> |
| <dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaSimpleStreamingExtractor.KafkaWatermark.html#calculatePercentCompletion-gobblin.source.extractor.Watermark-gobblin.source.extractor.Watermark-">calculatePercentCompletion(Watermark, Watermark)</a></span> - Method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaSimpleStreamingExtractor.KafkaWatermark.html" title="class in gobblin.source.extractor.extract.kafka">KafkaSimpleStreamingExtractor.KafkaWatermark</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/kafka/client/Kafka09ConsumerClient.html#close--">close()</a></span> - Method in class gobblin.kafka.client.<a href="gobblin/kafka/client/Kafka09ConsumerClient.html" title="class in gobblin.kafka.client">Kafka09ConsumerClient</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/kafka/writer/Kafka09DataWriter.html#close--">close()</a></span> - Method in class gobblin.kafka.writer.<a href="gobblin/kafka/writer/Kafka09DataWriter.html" title="class in gobblin.kafka.writer">Kafka09DataWriter</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaSimpleStreamingExtractor.html#close--">close()</a></span> - Method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaSimpleStreamingExtractor.html" title="class in gobblin.source.extractor.extract.kafka">KafkaSimpleStreamingExtractor</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaSimpleStreamingExtractor.KafkaWatermark.html#compareTo-gobblin.source.extractor.CheckpointableWatermark-">compareTo(CheckpointableWatermark)</a></span> - Method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaSimpleStreamingExtractor.KafkaWatermark.html" title="class in gobblin.source.extractor.extract.kafka">KafkaSimpleStreamingExtractor.KafkaWatermark</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/kafka/client/Kafka09ConsumerClient.html#consume-gobblin.source.extractor.extract.kafka.KafkaPartition-long-long-">consume(KafkaPartition, long, long)</a></span> - Method in class gobblin.kafka.client.<a href="gobblin/kafka/client/Kafka09ConsumerClient.html" title="class in gobblin.kafka.client">Kafka09ConsumerClient</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/kafka/client/Kafka09ConsumerClient.Factory.html#create-com.typesafe.config.Config-">create(Config)</a></span> - Method in class gobblin.kafka.client.<a href="gobblin/kafka/client/Kafka09ConsumerClient.Factory.html" title="class in gobblin.kafka.client">Kafka09ConsumerClient.Factory</a></dt> |
| <dd> </dd> |
| </dl> |
| <a name="I:D"> |
| <!-- --> |
| </a> |
| <h2 class="title">D</h2> |
| <dl> |
| <dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaSimpleStreamingSource.html#DEFAULT_NAMESPACE_NAME">DEFAULT_NAMESPACE_NAME</a></span> - Static variable in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaSimpleStreamingSource.html" title="class in gobblin.source.extractor.extract.kafka">KafkaSimpleStreamingSource</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaSimpleStreamingSource.html#DEFAULT_TABLE_TYPE">DEFAULT_TABLE_TYPE</a></span> - Static variable in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaSimpleStreamingSource.html" title="class in gobblin.source.extractor.extract.kafka">KafkaSimpleStreamingSource</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/kafka/serialize/LiAvroDeserializer.html#deserialize-java.lang.String-byte:A-">deserialize(String, byte[])</a></span> - Method in class gobblin.kafka.serialize.<a href="gobblin/kafka/serialize/LiAvroDeserializer.html" title="class in gobblin.kafka.serialize">LiAvroDeserializer</a></dt> |
| <dd> </dd> |
| </dl> |
| <a name="I:E"> |
| <!-- --> |
| </a> |
| <h2 class="title">E</h2> |
| <dl> |
| <dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaSimpleStreamingExtractor.KafkaWatermark.html#equals-java.lang.Object-">equals(Object)</a></span> - Method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaSimpleStreamingExtractor.KafkaWatermark.html" title="class in gobblin.source.extractor.extract.kafka">KafkaSimpleStreamingExtractor.KafkaWatermark</a></dt> |
| <dd> </dd> |
| </dl> |
| <a name="I:F"> |
| <!-- --> |
| </a> |
| <h2 class="title">F</h2> |
| <dl> |
| <dt><span class="memberNameLink"><a href="gobblin/kafka/client/Kafka09ConsumerClient.Factory.html#Factory--">Factory()</a></span> - Constructor for class gobblin.kafka.client.<a href="gobblin/kafka/client/Kafka09ConsumerClient.Factory.html" title="class in gobblin.kafka.client">Kafka09ConsumerClient.Factory</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/kafka/writer/Kafka09DataWriter.html#flush--">flush()</a></span> - Method in class gobblin.kafka.writer.<a href="gobblin/kafka/writer/Kafka09DataWriter.html" title="class in gobblin.kafka.writer">Kafka09DataWriter</a></dt> |
| <dd> </dd> |
| </dl> |
| <a name="I:G"> |
| <!-- --> |
| </a> |
| <h2 class="title">G</h2> |
| <dl> |
| <dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaSimpleStreamingExtractor.html#generateTags-gobblin.configuration.State-">generateTags(State)</a></span> - Method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaSimpleStreamingExtractor.html" title="class in gobblin.source.extractor.extract.kafka">KafkaSimpleStreamingExtractor</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/kafka/writer/KafkaDataWriterBuilder.html#getAsyncDataWriter-java.util.Properties-">getAsyncDataWriter(Properties)</a></span> - Method in class gobblin.kafka.writer.<a href="gobblin/kafka/writer/KafkaDataWriterBuilder.html" title="class in gobblin.kafka.writer">KafkaDataWriterBuilder</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/kafka/client/Kafka09ConsumerClient.html#getEarliestOffset-gobblin.source.extractor.extract.kafka.KafkaPartition-">getEarliestOffset(KafkaPartition)</a></span> - Method in class gobblin.kafka.client.<a href="gobblin/kafka/client/Kafka09ConsumerClient.html" title="class in gobblin.kafka.client">Kafka09ConsumerClient</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaSimpleStreamingExtractor.html#getExpectedRecordCount--">getExpectedRecordCount()</a></span> - Method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaSimpleStreamingExtractor.html" title="class in gobblin.source.extractor.extract.kafka">KafkaSimpleStreamingExtractor</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaSimpleStreamingSource.html#getExtractor-gobblin.configuration.WorkUnitState-">getExtractor(WorkUnitState)</a></span> - Method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaSimpleStreamingSource.html" title="class in gobblin.source.extractor.extract.kafka">KafkaSimpleStreamingSource</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaSimpleStreamingExtractor.html#getHighWatermark--">getHighWatermark()</a></span> - Method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaSimpleStreamingExtractor.html" title="class in gobblin.source.extractor.extract.kafka">KafkaSimpleStreamingExtractor</a></dt> |
| <dd> |
| <div class="block"><span class="deprecatedLabel">Deprecated.</span></div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaSimpleStreamingSource.html#getKafkaConsumer-com.typesafe.config.Config-">getKafkaConsumer(Config)</a></span> - Static method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaSimpleStreamingSource.html" title="class in gobblin.source.extractor.extract.kafka">KafkaSimpleStreamingSource</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/kafka/writer/Kafka09DataWriter.html#getKafkaProducer-java.util.Properties-">getKafkaProducer(Properties)</a></span> - Static method in class gobblin.kafka.writer.<a href="gobblin/kafka/writer/Kafka09DataWriter.html" title="class in gobblin.kafka.writer">Kafka09DataWriter</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/kafka/client/Kafka09ConsumerClient.Kafka09ConsumerRecord.html#getKey--">getKey()</a></span> - Method in class gobblin.kafka.client.<a href="gobblin/kafka/client/Kafka09ConsumerClient.Kafka09ConsumerRecord.html" title="class in gobblin.kafka.client">Kafka09ConsumerClient.Kafka09ConsumerRecord</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/kafka/client/Kafka09ConsumerClient.html#getLatestOffset-gobblin.source.extractor.extract.kafka.KafkaPartition-">getLatestOffset(KafkaPartition)</a></span> - Method in class gobblin.kafka.client.<a href="gobblin/kafka/client/Kafka09ConsumerClient.html" title="class in gobblin.kafka.client">Kafka09ConsumerClient</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaSimpleStreamingExtractor.KafkaWatermark.html#getLwm--">getLwm()</a></span> - Method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaSimpleStreamingExtractor.KafkaWatermark.html" title="class in gobblin.source.extractor.extract.kafka">KafkaSimpleStreamingExtractor.KafkaWatermark</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaSimpleStreamingSource.html#getPartitionIdFromState-gobblin.configuration.State-">getPartitionIdFromState(State)</a></span> - Static method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaSimpleStreamingSource.html" title="class in gobblin.source.extractor.extract.kafka">KafkaSimpleStreamingSource</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaSimpleStreamingExtractor.html#getSchema--">getSchema()</a></span> - Method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaSimpleStreamingExtractor.html" title="class in gobblin.source.extractor.extract.kafka">KafkaSimpleStreamingExtractor</a></dt> |
| <dd> |
| <div class="block">Get the schema (metadata) of the extracted data records.</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaSimpleStreamingExtractor.KafkaWatermark.html#getSource--">getSource()</a></span> - Method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaSimpleStreamingExtractor.KafkaWatermark.html" title="class in gobblin.source.extractor.extract.kafka">KafkaSimpleStreamingExtractor.KafkaWatermark</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaSimpleStreamingSource.html#getTopicNameFromState-gobblin.configuration.State-">getTopicNameFromState(State)</a></span> - Static method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaSimpleStreamingSource.html" title="class in gobblin.source.extractor.extract.kafka">KafkaSimpleStreamingSource</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaSimpleStreamingExtractor.KafkaWatermark.html#getTopicPartition--">getTopicPartition()</a></span> - Method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaSimpleStreamingExtractor.KafkaWatermark.html" title="class in gobblin.source.extractor.extract.kafka">KafkaSimpleStreamingExtractor.KafkaWatermark</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/kafka/client/Kafka09ConsumerClient.html#getTopics--">getTopics()</a></span> - Method in class gobblin.kafka.client.<a href="gobblin/kafka/client/Kafka09ConsumerClient.html" title="class in gobblin.kafka.client">Kafka09ConsumerClient</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/kafka/client/Kafka09ConsumerClient.Kafka09ConsumerRecord.html#getValue--">getValue()</a></span> - Method in class gobblin.kafka.client.<a href="gobblin/kafka/client/Kafka09ConsumerClient.Kafka09ConsumerRecord.html" title="class in gobblin.kafka.client">Kafka09ConsumerClient.Kafka09ConsumerRecord</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaSimpleStreamingExtractor.KafkaWatermark.html#getWatermark--">getWatermark()</a></span> - Method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaSimpleStreamingExtractor.KafkaWatermark.html" title="class in gobblin.source.extractor.extract.kafka">KafkaSimpleStreamingExtractor.KafkaWatermark</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaSimpleStreamingSource.html#getWorkunits-gobblin.configuration.SourceState-">getWorkunits(SourceState)</a></span> - Method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaSimpleStreamingSource.html" title="class in gobblin.source.extractor.extract.kafka">KafkaSimpleStreamingSource</a></dt> |
| <dd> </dd> |
| <dt><a href="gobblin/kafka/client/package-summary.html">gobblin.kafka.client</a> - package gobblin.kafka.client</dt> |
| <dd> </dd> |
| <dt><a href="gobblin/kafka/serialize/package-summary.html">gobblin.kafka.serialize</a> - package gobblin.kafka.serialize</dt> |
| <dd> </dd> |
| <dt><a href="gobblin/kafka/writer/package-summary.html">gobblin.kafka.writer</a> - package gobblin.kafka.writer</dt> |
| <dd> </dd> |
| <dt><a href="gobblin/source/extractor/extract/kafka/package-summary.html">gobblin.source.extractor.extract.kafka</a> - package gobblin.source.extractor.extract.kafka</dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/kafka/client/Kafka09ConsumerClient.html#GOBBLIN_CONFIG_KEY_DESERIALIZER_CLASS_KEY">GOBBLIN_CONFIG_KEY_DESERIALIZER_CLASS_KEY</a></span> - Static variable in class gobblin.kafka.client.<a href="gobblin/kafka/client/Kafka09ConsumerClient.html" title="class in gobblin.kafka.client">Kafka09ConsumerClient</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/kafka/client/Kafka09ConsumerClient.html#GOBBLIN_CONFIG_VALUE_DESERIALIZER_CLASS_KEY">GOBBLIN_CONFIG_VALUE_DESERIALIZER_CLASS_KEY</a></span> - Static variable in class gobblin.kafka.client.<a href="gobblin/kafka/client/Kafka09ConsumerClient.html" title="class in gobblin.kafka.client">Kafka09ConsumerClient</a></dt> |
| <dd> </dd> |
| </dl> |
| <a name="I:H"> |
| <!-- --> |
| </a> |
| <h2 class="title">H</h2> |
| <dl> |
| <dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaSimpleStreamingExtractor.KafkaWatermark.html#hashCode--">hashCode()</a></span> - Method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaSimpleStreamingExtractor.KafkaWatermark.html" title="class in gobblin.source.extractor.extract.kafka">KafkaSimpleStreamingExtractor.KafkaWatermark</a></dt> |
| <dd> </dd> |
| </dl> |
| <a name="I:K"> |
| <!-- --> |
| </a> |
| <h2 class="title">K</h2> |
| <dl> |
| <dt><a href="gobblin/kafka/client/Kafka09ConsumerClient.html" title="class in gobblin.kafka.client"><span class="typeNameLink">Kafka09ConsumerClient</span></a><<a href="gobblin/kafka/client/Kafka09ConsumerClient.html" title="type parameter in Kafka09ConsumerClient">K</a>,<a href="gobblin/kafka/client/Kafka09ConsumerClient.html" title="type parameter in Kafka09ConsumerClient">V</a>> - Class in <a href="gobblin/kafka/client/package-summary.html">gobblin.kafka.client</a></dt> |
| <dd> |
| <div class="block">A <a href="http://linkedin.github.io/gobblin/javadoc/0.11.0/gobblin-kafka-common/gobblin/kafka/client/GobblinKafkaConsumerClient.html?is-external=true" title="class or interface in gobblin.kafka.client"><code>GobblinKafkaConsumerClient</code></a> that uses kafka 09 consumer client.</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/kafka/client/Kafka09ConsumerClient.html#Kafka09ConsumerClient-com.typesafe.config.Config-org.apache.kafka.clients.consumer.Consumer-">Kafka09ConsumerClient(Config, Consumer<K, V>)</a></span> - Constructor for class gobblin.kafka.client.<a href="gobblin/kafka/client/Kafka09ConsumerClient.html" title="class in gobblin.kafka.client">Kafka09ConsumerClient</a></dt> |
| <dd> </dd> |
| <dt><a href="gobblin/kafka/client/Kafka09ConsumerClient.Factory.html" title="class in gobblin.kafka.client"><span class="typeNameLink">Kafka09ConsumerClient.Factory</span></a> - Class in <a href="gobblin/kafka/client/package-summary.html">gobblin.kafka.client</a></dt> |
| <dd> |
| <div class="block">A factory class to instantiate <a href="gobblin/kafka/client/Kafka09ConsumerClient.html" title="class in gobblin.kafka.client"><code>Kafka09ConsumerClient</code></a></div> |
| </dd> |
| <dt><a href="gobblin/kafka/client/Kafka09ConsumerClient.Kafka09ConsumerRecord.html" title="class in gobblin.kafka.client"><span class="typeNameLink">Kafka09ConsumerClient.Kafka09ConsumerRecord</span></a><<a href="gobblin/kafka/client/Kafka09ConsumerClient.Kafka09ConsumerRecord.html" title="type parameter in Kafka09ConsumerClient.Kafka09ConsumerRecord">K</a>,<a href="gobblin/kafka/client/Kafka09ConsumerClient.Kafka09ConsumerRecord.html" title="type parameter in Kafka09ConsumerClient.Kafka09ConsumerRecord">V</a>> - Class in <a href="gobblin/kafka/client/package-summary.html">gobblin.kafka.client</a></dt> |
| <dd> |
| <div class="block">A record returned by <a href="gobblin/kafka/client/Kafka09ConsumerClient.html" title="class in gobblin.kafka.client"><code>Kafka09ConsumerClient</code></a></div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/kafka/client/Kafka09ConsumerClient.Kafka09ConsumerRecord.html#Kafka09ConsumerRecord-org.apache.kafka.clients.consumer.ConsumerRecord-">Kafka09ConsumerRecord(ConsumerRecord<K, V>)</a></span> - Constructor for class gobblin.kafka.client.<a href="gobblin/kafka/client/Kafka09ConsumerClient.Kafka09ConsumerRecord.html" title="class in gobblin.kafka.client">Kafka09ConsumerClient.Kafka09ConsumerRecord</a></dt> |
| <dd> </dd> |
| <dt><a href="gobblin/kafka/writer/Kafka09DataWriter.html" title="class in gobblin.kafka.writer"><span class="typeNameLink">Kafka09DataWriter</span></a><<a href="gobblin/kafka/writer/Kafka09DataWriter.html" title="type parameter in Kafka09DataWriter">D</a>> - Class in <a href="gobblin/kafka/writer/package-summary.html">gobblin.kafka.writer</a></dt> |
| <dd> |
| <div class="block">Implementation of KafkaWriter that wraps a <code>KafkaProducer</code>.</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/kafka/writer/Kafka09DataWriter.html#Kafka09DataWriter-java.util.Properties-">Kafka09DataWriter(Properties)</a></span> - Constructor for class gobblin.kafka.writer.<a href="gobblin/kafka/writer/Kafka09DataWriter.html" title="class in gobblin.kafka.writer">Kafka09DataWriter</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/kafka/writer/Kafka09DataWriter.html#Kafka09DataWriter-org.apache.kafka.clients.producer.Producer-com.typesafe.config.Config-">Kafka09DataWriter(Producer, Config)</a></span> - Constructor for class gobblin.kafka.writer.<a href="gobblin/kafka/writer/Kafka09DataWriter.html" title="class in gobblin.kafka.writer">Kafka09DataWriter</a></dt> |
| <dd> </dd> |
| <dt><a href="gobblin/kafka/writer/KafkaDataWriterBuilder.html" title="class in gobblin.kafka.writer"><span class="typeNameLink">KafkaDataWriterBuilder</span></a> - Class in <a href="gobblin/kafka/writer/package-summary.html">gobblin.kafka.writer</a></dt> |
| <dd> |
| <div class="block">Builder that hands back a <a href="gobblin/kafka/writer/Kafka09DataWriter.html" title="class in gobblin.kafka.writer"><code>Kafka09DataWriter</code></a></div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/kafka/writer/KafkaDataWriterBuilder.html#KafkaDataWriterBuilder--">KafkaDataWriterBuilder()</a></span> - Constructor for class gobblin.kafka.writer.<a href="gobblin/kafka/writer/KafkaDataWriterBuilder.html" title="class in gobblin.kafka.writer">KafkaDataWriterBuilder</a></dt> |
| <dd> </dd> |
| <dt><a href="gobblin/source/extractor/extract/kafka/KafkaSimpleStreamingExtractor.html" title="class in gobblin.source.extractor.extract.kafka"><span class="typeNameLink">KafkaSimpleStreamingExtractor</span></a><<a href="gobblin/source/extractor/extract/kafka/KafkaSimpleStreamingExtractor.html" title="type parameter in KafkaSimpleStreamingExtractor">S</a>,<a href="gobblin/source/extractor/extract/kafka/KafkaSimpleStreamingExtractor.html" title="type parameter in KafkaSimpleStreamingExtractor">D</a>> - Class in <a href="gobblin/source/extractor/extract/kafka/package-summary.html">gobblin.source.extractor.extract.kafka</a></dt> |
| <dd> |
| <div class="block">An implementation of <a href="http://linkedin.github.io/gobblin/javadoc/0.11.0/gobblin-core-base/gobblin/source/extractor/StreamingExtractor.html?is-external=true" title="class or interface in gobblin.source.extractor"><code>StreamingExtractor</code></a> which reads from Kafka and returns records .</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaSimpleStreamingExtractor.html#KafkaSimpleStreamingExtractor-gobblin.configuration.WorkUnitState-">KafkaSimpleStreamingExtractor(WorkUnitState)</a></span> - Constructor for class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaSimpleStreamingExtractor.html" title="class in gobblin.source.extractor.extract.kafka">KafkaSimpleStreamingExtractor</a></dt> |
| <dd> </dd> |
| <dt><a href="gobblin/source/extractor/extract/kafka/KafkaSimpleStreamingExtractor.KafkaWatermark.html" title="class in gobblin.source.extractor.extract.kafka"><span class="typeNameLink">KafkaSimpleStreamingExtractor.KafkaWatermark</span></a> - Class in <a href="gobblin/source/extractor/extract/kafka/package-summary.html">gobblin.source.extractor.extract.kafka</a></dt> |
| <dd> </dd> |
| <dt><a href="gobblin/source/extractor/extract/kafka/KafkaSimpleStreamingSource.html" title="class in gobblin.source.extractor.extract.kafka"><span class="typeNameLink">KafkaSimpleStreamingSource</span></a><<a href="gobblin/source/extractor/extract/kafka/KafkaSimpleStreamingSource.html" title="type parameter in KafkaSimpleStreamingSource">S</a>,<a href="gobblin/source/extractor/extract/kafka/KafkaSimpleStreamingSource.html" title="type parameter in KafkaSimpleStreamingSource">D</a>> - Class in <a href="gobblin/source/extractor/extract/kafka/package-summary.html">gobblin.source.extractor.extract.kafka</a></dt> |
| <dd> |
| <div class="block">A <a href="http://linkedin.github.io/gobblin/javadoc/0.11.0/gobblin-core-base/gobblin/source/extractor/extract/EventBasedSource.html?is-external=true" title="class or interface in gobblin.source.extractor.extract"><code>EventBasedSource</code></a> implementation for a simple streaming kafka extractor.</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaSimpleStreamingSource.html#KafkaSimpleStreamingSource--">KafkaSimpleStreamingSource()</a></span> - Constructor for class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaSimpleStreamingSource.html" title="class in gobblin.source.extractor.extract.kafka">KafkaSimpleStreamingSource</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaSimpleStreamingExtractor.KafkaWatermark.html#KafkaWatermark-org.apache.kafka.common.TopicPartition-gobblin.source.extractor.extract.LongWatermark-">KafkaWatermark(TopicPartition, LongWatermark)</a></span> - Constructor for class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaSimpleStreamingExtractor.KafkaWatermark.html" title="class in gobblin.source.extractor.extract.kafka">KafkaSimpleStreamingExtractor.KafkaWatermark</a></dt> |
| <dd> </dd> |
| </dl> |
| <a name="I:L"> |
| <!-- --> |
| </a> |
| <h2 class="title">L</h2> |
| <dl> |
| <dt><a href="gobblin/kafka/serialize/LiAvroDeserializer.html" title="class in gobblin.kafka.serialize"><span class="typeNameLink">LiAvroDeserializer</span></a> - Class in <a href="gobblin/kafka/serialize/package-summary.html">gobblin.kafka.serialize</a></dt> |
| <dd> |
| <div class="block">The LinkedIn Avro Deserializer (works with records serialized by the <a href="gobblin/kafka/serialize/LiAvroSerializer.html" title="class in gobblin.kafka.serialize"><code>LiAvroSerializer</code></a>)</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/kafka/serialize/LiAvroDeserializer.html#LiAvroDeserializer-gobblin.kafka.schemareg.KafkaSchemaRegistry-">LiAvroDeserializer(KafkaSchemaRegistry<MD5Digest, Schema>)</a></span> - Constructor for class gobblin.kafka.serialize.<a href="gobblin/kafka/serialize/LiAvroDeserializer.html" title="class in gobblin.kafka.serialize">LiAvroDeserializer</a></dt> |
| <dd> </dd> |
| <dt><a href="gobblin/kafka/serialize/LiAvroSerializer.html" title="class in gobblin.kafka.serialize"><span class="typeNameLink">LiAvroSerializer</span></a> - Class in <a href="gobblin/kafka/serialize/package-summary.html">gobblin.kafka.serialize</a></dt> |
| <dd> |
| <div class="block">LinkedIn's implementation of Avro-schema based serialization for Kafka |
| TODO: Implement this for IndexedRecord not just GenericRecord</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/kafka/serialize/LiAvroSerializer.html#LiAvroSerializer--">LiAvroSerializer()</a></span> - Constructor for class gobblin.kafka.serialize.<a href="gobblin/kafka/serialize/LiAvroSerializer.html" title="class in gobblin.kafka.serialize">LiAvroSerializer</a></dt> |
| <dd> </dd> |
| </dl> |
| <a name="I:R"> |
| <!-- --> |
| </a> |
| <h2 class="title">R</h2> |
| <dl> |
| <dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaSimpleStreamingExtractor.html#readRecordEnvelopeImpl--">readRecordEnvelopeImpl()</a></span> - Method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaSimpleStreamingExtractor.html" title="class in gobblin.source.extractor.extract.kafka">KafkaSimpleStreamingExtractor</a></dt> |
| <dd> |
| <div class="block">Return the next record when available.</div> |
| </dd> |
| </dl> |
| <a name="I:S"> |
| <!-- --> |
| </a> |
| <h2 class="title">S</h2> |
| <dl> |
| <dt><span class="memberNameLink"><a href="gobblin/kafka/serialize/LiAvroSerializer.html#serialize-java.lang.String-org.apache.avro.generic.GenericRecord-">serialize(String, GenericRecord)</a></span> - Method in class gobblin.kafka.serialize.<a href="gobblin/kafka/serialize/LiAvroSerializer.html" title="class in gobblin.kafka.serialize">LiAvroSerializer</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaSimpleStreamingSource.html#setPartitionId-gobblin.configuration.State-int-">setPartitionId(State, int)</a></span> - Static method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaSimpleStreamingSource.html" title="class in gobblin.source.extractor.extract.kafka">KafkaSimpleStreamingSource</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaSimpleStreamingSource.html#setTopicNameInState-gobblin.configuration.State-java.lang.String-">setTopicNameInState(State, String)</a></span> - Static method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaSimpleStreamingSource.html" title="class in gobblin.source.extractor.extract.kafka">KafkaSimpleStreamingSource</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaSimpleStreamingExtractor.html#start-gobblin.writer.WatermarkStorage-">start(WatermarkStorage)</a></span> - Method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaSimpleStreamingExtractor.html" title="class in gobblin.source.extractor.extract.kafka">KafkaSimpleStreamingExtractor</a></dt> |
| <dd> </dd> |
| </dl> |
| <a name="I:T"> |
| <!-- --> |
| </a> |
| <h2 class="title">T</h2> |
| <dl> |
| <dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaSimpleStreamingExtractor.KafkaWatermark.html#toJson--">toJson()</a></span> - Method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaSimpleStreamingExtractor.KafkaWatermark.html" title="class in gobblin.source.extractor.extract.kafka">KafkaSimpleStreamingExtractor.KafkaWatermark</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaSimpleStreamingSource.html#TOPIC_KEY_DESERIALIZER">TOPIC_KEY_DESERIALIZER</a></span> - Static variable in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaSimpleStreamingSource.html" title="class in gobblin.source.extractor.extract.kafka">KafkaSimpleStreamingSource</a></dt> |
| <dd> |
| <div class="block">Deserializer to be used by this source.</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaSimpleStreamingSource.html#TOPIC_VALUE_DESERIALIZER">TOPIC_VALUE_DESERIALIZER</a></span> - Static variable in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaSimpleStreamingSource.html" title="class in gobblin.source.extractor.extract.kafka">KafkaSimpleStreamingSource</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaSimpleStreamingSource.html#TOPIC_WHITELIST">TOPIC_WHITELIST</a></span> - Static variable in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaSimpleStreamingSource.html" title="class in gobblin.source.extractor.extract.kafka">KafkaSimpleStreamingSource</a></dt> |
| <dd> |
| <div class="block">This is the topic name used by this source .</div> |
| </dd> |
| </dl> |
| <a name="I:W"> |
| <!-- --> |
| </a> |
| <h2 class="title">W</h2> |
| <dl> |
| <dt><span class="memberNameLink"><a href="gobblin/kafka/writer/Kafka09DataWriter.html#write-D-gobblin.writer.WriteCallback-">write(D, WriteCallback)</a></span> - Method in class gobblin.kafka.writer.<a href="gobblin/kafka/writer/Kafka09DataWriter.html" title="class in gobblin.kafka.writer">Kafka09DataWriter</a></dt> |
| <dd> </dd> |
| </dl> |
| <a name="I:Z:Z_"> |
| <!-- --> |
| </a> |
| <h2 class="title">_</h2> |
| <dl> |
| <dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaSimpleStreamingExtractor.html#Z:Z_close">_close</a></span> - Variable in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaSimpleStreamingExtractor.html" title="class in gobblin.source.extractor.extract.kafka">KafkaSimpleStreamingExtractor</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaSimpleStreamingExtractor.html#Z:Z_schemaRegistry">_schemaRegistry</a></span> - Variable in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaSimpleStreamingExtractor.html" title="class in gobblin.source.extractor.extract.kafka">KafkaSimpleStreamingExtractor</a></dt> |
| <dd> </dd> |
| </dl> |
| <a href="#I:C">C</a> <a href="#I:D">D</a> <a href="#I:E">E</a> <a href="#I:F">F</a> <a href="#I:G">G</a> <a href="#I:H">H</a> <a href="#I:K">K</a> <a href="#I:L">L</a> <a href="#I:R">R</a> <a href="#I:S">S</a> <a href="#I:T">T</a> <a href="#I:W">W</a> <a href="#I:Z:Z_">_</a> </div> |
| <!-- ======= START OF BOTTOM NAVBAR ====== --> |
| <div class="bottomNav"><a name="navbar.bottom"> |
| <!-- --> |
| </a> |
| <div class="skipNav"><a href="#skip.navbar.bottom" title="Skip navigation links">Skip navigation links</a></div> |
| <a name="navbar.bottom.firstrow"> |
| <!-- --> |
| </a> |
| <ul class="navList" title="Navigation"> |
| <li><a href="overview-summary.html">Overview</a></li> |
| <li>Package</li> |
| <li>Class</li> |
| <li><a href="overview-tree.html">Tree</a></li> |
| <li><a href="deprecated-list.html">Deprecated</a></li> |
| <li class="navBarCell1Rev">Index</li> |
| <li><a href="help-doc.html">Help</a></li> |
| </ul> |
| </div> |
| <div class="subNav"> |
| <ul class="navList"> |
| <li>Prev</li> |
| <li>Next</li> |
| </ul> |
| <ul class="navList"> |
| <li><a href="index.html?index-all.html" target="_top">Frames</a></li> |
| <li><a href="index-all.html" target="_top">No Frames</a></li> |
| </ul> |
| <ul class="navList" id="allclasses_navbar_bottom"> |
| <li><a href="allclasses-noframe.html">All Classes</a></li> |
| </ul> |
| <div> |
| <script type="text/javascript"><!-- |
| allClassesLink = document.getElementById("allclasses_navbar_bottom"); |
| if(window==top) { |
| allClassesLink.style.display = "block"; |
| } |
| else { |
| allClassesLink.style.display = "none"; |
| } |
| //--> |
| </script> |
| </div> |
| <a name="skip.navbar.bottom"> |
| <!-- --> |
| </a></div> |
| <!-- ======== END OF BOTTOM NAVBAR ======= --> |
| </body> |
| </html> |
