blob: 313a3bb81725075390739f86601103f0e89fbb88 [file] [log] [blame]
<!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&nbsp;Frames</a></li>
</ul>
<ul class="navList" id="allclasses_navbar_top">
<li><a href="allclasses-noframe.html">All&nbsp;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>&nbsp;<a href="#I:D">D</a>&nbsp;<a href="#I:E">E</a>&nbsp;<a href="#I:F">F</a>&nbsp;<a href="#I:G">G</a>&nbsp;<a href="#I:H">H</a>&nbsp;<a href="#I:K">K</a>&nbsp;<a href="#I:L">L</a>&nbsp;<a href="#I:R">R</a>&nbsp;<a href="#I:S">S</a>&nbsp;<a href="#I:T">T</a>&nbsp;<a href="#I:W">W</a>&nbsp;<a href="#I:Z:Z_">_</a>&nbsp;<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>&nbsp;</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>&nbsp;</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>&nbsp;</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>&nbsp;</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>&nbsp;</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>&nbsp;</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>&nbsp;</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>&nbsp;</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>&nbsp;</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>&nbsp;</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>&nbsp;</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>&nbsp;</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>&nbsp;</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>&nbsp;</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>&nbsp;</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>&nbsp;</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>&nbsp;</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>&nbsp;</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>&nbsp;</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>&nbsp;</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>&nbsp;</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>&nbsp;</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>&nbsp;</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>&nbsp;</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>&nbsp;</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>&nbsp;</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>&nbsp;</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>&nbsp;</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>&nbsp;</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>&nbsp;</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>&nbsp;</dd>
<dt><a href="gobblin/kafka/client/package-summary.html">gobblin.kafka.client</a> - package gobblin.kafka.client</dt>
<dd>&nbsp;</dd>
<dt><a href="gobblin/kafka/serialize/package-summary.html">gobblin.kafka.serialize</a> - package gobblin.kafka.serialize</dt>
<dd>&nbsp;</dd>
<dt><a href="gobblin/kafka/writer/package-summary.html">gobblin.kafka.writer</a> - package gobblin.kafka.writer</dt>
<dd>&nbsp;</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>&nbsp;</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>&nbsp;</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>&nbsp;</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>&nbsp;</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>&lt;<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>&gt; - 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&lt;K, V&gt;)</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>&nbsp;</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>&lt;<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>&gt; - 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&lt;K, V&gt;)</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>&nbsp;</dd>
<dt><a href="gobblin/kafka/writer/Kafka09DataWriter.html" title="class in gobblin.kafka.writer"><span class="typeNameLink">Kafka09DataWriter</span></a>&lt;<a href="gobblin/kafka/writer/Kafka09DataWriter.html" title="type parameter in Kafka09DataWriter">D</a>&gt; - 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>&nbsp;</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>&nbsp;</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>&nbsp;</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>&lt;<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>&gt; - 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>&nbsp;</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>&nbsp;</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>&lt;<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>&gt; - 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>&nbsp;</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>&nbsp;</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&lt;MD5Digest, Schema&gt;)</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>&nbsp;</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>&nbsp;</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>&nbsp;</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>&nbsp;</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>&nbsp;</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>&nbsp;</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>&nbsp;</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>&nbsp;</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>&nbsp;</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>&nbsp;</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>&nbsp;</dd>
</dl>
<a href="#I:C">C</a>&nbsp;<a href="#I:D">D</a>&nbsp;<a href="#I:E">E</a>&nbsp;<a href="#I:F">F</a>&nbsp;<a href="#I:G">G</a>&nbsp;<a href="#I:H">H</a>&nbsp;<a href="#I:K">K</a>&nbsp;<a href="#I:L">L</a>&nbsp;<a href="#I:R">R</a>&nbsp;<a href="#I:S">S</a>&nbsp;<a href="#I:T">T</a>&nbsp;<a href="#I:W">W</a>&nbsp;<a href="#I:Z:Z_">_</a>&nbsp;</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&nbsp;Frames</a></li>
</ul>
<ul class="navList" id="allclasses_navbar_bottom">
<li><a href="allclasses-noframe.html">All&nbsp;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>