blob: 8ab975c895ef7da0a0b40a3f9ae50f2c95c47d86 [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:16:32 PDT 2017 -->
<title>Index (gobblin-kafka-common 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-common 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:A">A</a>&nbsp;<a href="#I:B">B</a>&nbsp;<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:I">I</a>&nbsp;<a href="#I:K">K</a>&nbsp;<a href="#I:L">L</a>&nbsp;<a href="#I:M">M</a>&nbsp;<a href="#I:N">N</a>&nbsp;<a href="#I:O">O</a>&nbsp;<a href="#I:P">P</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:U">U</a>&nbsp;<a href="#I:V">V</a>&nbsp;<a href="#I:W">W</a>&nbsp;<a name="I:A">
<!-- -->
</a>
<h2 class="title">A</h2>
<dl>
<dt><a href="gobblin/kafka/client/AbstractBaseKafkaConsumerClient.html" title="class in gobblin.kafka.client"><span class="typeNameLink">AbstractBaseKafkaConsumerClient</span></a> - Class in <a href="gobblin/kafka/client/package-summary.html">gobblin.kafka.client</a></dt>
<dd>
<div class="block">A base <a href="gobblin/kafka/client/GobblinKafkaConsumerClient.html" title="interface in gobblin.kafka.client"><code>GobblinKafkaConsumerClient</code></a> that sets configurations shared by all <a href="gobblin/kafka/client/GobblinKafkaConsumerClient.html" title="interface in gobblin.kafka.client"><code>GobblinKafkaConsumerClient</code></a>s</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/client/AbstractBaseKafkaConsumerClient.html#AbstractBaseKafkaConsumerClient-com.typesafe.config.Config-">AbstractBaseKafkaConsumerClient(Config)</a></span> - Constructor for class gobblin.kafka.client.<a href="gobblin/kafka/client/AbstractBaseKafkaConsumerClient.html" title="class in gobblin.kafka.client">AbstractBaseKafkaConsumerClient</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaExtractor.html#ACTUAL_HIGH_WATERMARK">ACTUAL_HIGH_WATERMARK</a></span> - Static variable in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaExtractor.html" title="class in gobblin.source.extractor.extract.kafka">KafkaExtractor</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/workunit/packer/KafkaWorkUnitPacker.html#addWorkUnitsToMultiWorkUnit-java.util.List-gobblin.source.workunit.MultiWorkUnit-">addWorkUnitsToMultiWorkUnit(List&lt;WorkUnit&gt;, MultiWorkUnit)</a></span> - Static method in class gobblin.source.extractor.extract.kafka.workunit.packer.<a href="gobblin/source/extractor/extract/kafka/workunit/packer/KafkaWorkUnitPacker.html" title="class in gobblin.source.extractor.extract.kafka.workunit.packer">KafkaWorkUnitPacker</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/workunit/packer/KafkaWorkUnitPacker.html#addWorkUnitToMultiWorkUnit-gobblin.source.workunit.WorkUnit-gobblin.source.workunit.MultiWorkUnit-">addWorkUnitToMultiWorkUnit(WorkUnit, MultiWorkUnit)</a></span> - Static method in class gobblin.source.extractor.extract.kafka.workunit.packer.<a href="gobblin/source/extractor/extract/kafka/workunit/packer/KafkaWorkUnitPacker.html" title="class in gobblin.source.extractor.extract.kafka.workunit.packer">KafkaWorkUnitPacker</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaSource.html#ALL_TOPICS">ALL_TOPICS</a></span> - Static variable in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaSource.html" title="class in gobblin.source.extractor.extract.kafka">KafkaSource</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/serialize/MD5Digest.html#asBytes--">asBytes()</a></span> - Method in class gobblin.kafka.serialize.<a href="gobblin/kafka/serialize/MD5Digest.html" title="class in gobblin.kafka.serialize">MD5Digest</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/serialize/MD5Digest.html#asString--">asString()</a></span> - Method in class gobblin.kafka.serialize.<a href="gobblin/kafka/serialize/MD5Digest.html" title="class in gobblin.kafka.serialize">MD5Digest</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaSource.html#AVG_RECORD_MILLIS">AVG_RECORD_MILLIS</a></span> - Static variable in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaSource.html" title="class in gobblin.source.extractor.extract.kafka">KafkaSource</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaExtractor.html#AVG_RECORD_PULL_TIME">AVG_RECORD_PULL_TIME</a></span> - Static variable in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaExtractor.html" title="class in gobblin.source.extractor.extract.kafka">KafkaExtractor</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaSource.html#AVG_RECORD_SIZE">AVG_RECORD_SIZE</a></span> - Static variable in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaSource.html" title="class in gobblin.source.extractor.extract.kafka">KafkaSource</a></dt>
<dd>&nbsp;</dd>
</dl>
<a name="I:B">
<!-- -->
</a>
<h2 class="title">B</h2>
<dl>
<dt><a href="gobblin/kafka/client/BaseKafkaConsumerRecord.html" title="class in gobblin.kafka.client"><span class="typeNameLink">BaseKafkaConsumerRecord</span></a> - Class in <a href="gobblin/kafka/client/package-summary.html">gobblin.kafka.client</a></dt>
<dd>
<div class="block">A base <a href="gobblin/kafka/client/KafkaConsumerRecord.html" title="interface in gobblin.kafka.client"><code>KafkaConsumerRecord</code></a> that with offset and valueSizeInBytes</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/client/BaseKafkaConsumerRecord.html#BaseKafkaConsumerRecord--">BaseKafkaConsumerRecord()</a></span> - Constructor for class gobblin.kafka.client.<a href="gobblin/kafka/client/BaseKafkaConsumerRecord.html" title="class in gobblin.kafka.client">BaseKafkaConsumerRecord</a></dt>
<dd>&nbsp;</dd>
<dt><a href="gobblin/kafka/writer/BaseKafkaDataWriterBuilder.html" title="class in gobblin.kafka.writer"><span class="typeNameLink">BaseKafkaDataWriterBuilder</span></a> - Class in <a href="gobblin/kafka/writer/package-summary.html">gobblin.kafka.writer</a></dt>
<dd>
<div class="block">Base class for creating KafkaDataWriter builders.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/writer/BaseKafkaDataWriterBuilder.html#BaseKafkaDataWriterBuilder--">BaseKafkaDataWriterBuilder()</a></span> - Constructor for class gobblin.kafka.writer.<a href="gobblin/kafka/writer/BaseKafkaDataWriterBuilder.html" title="class in gobblin.kafka.writer">BaseKafkaDataWriterBuilder</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaSource.html#BOOTSTRAP_WITH_OFFSET">BOOTSTRAP_WITH_OFFSET</a></span> - Static variable in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaSource.html" title="class in gobblin.source.extractor.extract.kafka">KafkaSource</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/client/AbstractBaseKafkaConsumerClient.html#brokers">brokers</a></span> - Variable in class gobblin.kafka.client.<a href="gobblin/kafka/client/AbstractBaseKafkaConsumerClient.html" title="class in gobblin.kafka.client">AbstractBaseKafkaConsumerClient</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/writer/BaseKafkaDataWriterBuilder.html#build--">build()</a></span> - Method in class gobblin.kafka.writer.<a href="gobblin/kafka/writer/BaseKafkaDataWriterBuilder.html" title="class in gobblin.kafka.writer">BaseKafkaDataWriterBuilder</a></dt>
<dd>
<div class="block">Build a <a href="http://linkedin.github.io/gobblin/javadoc/0.11.0/gobblin-api/gobblin/writer/DataWriter.html?is-external=true" title="class or interface in gobblin.writer"><code>DataWriter</code></a>.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaPartition.Builder.html#build--">build()</a></span> - Method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaPartition.Builder.html" title="class in gobblin.source.extractor.extract.kafka">KafkaPartition.Builder</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaPartition.Builder.html#Builder--">Builder()</a></span> - Constructor for class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaPartition.Builder.html" title="class in gobblin.source.extractor.extract.kafka">KafkaPartition.Builder</a></dt>
<dd>&nbsp;</dd>
<dt><a href="gobblin/kafka/client/ByteArrayBasedKafkaRecord.html" title="interface in gobblin.kafka.client"><span class="typeNameLink">ByteArrayBasedKafkaRecord</span></a> - Interface in <a href="gobblin/kafka/client/package-summary.html">gobblin.kafka.client</a></dt>
<dd>
<div class="block">A kafka record that provides getters for raw bytes of key and value .</div>
</dd>
</dl>
<a name="I:C">
<!-- -->
</a>
<h2 class="title">C</h2>
<dl>
<dt><span class="memberNameLink"><a href="gobblin/metrics/kafka/KafkaSchemaRegistry.html#cachedSchemasByKeys">cachedSchemasByKeys</a></span> - Variable in class gobblin.metrics.kafka.<a href="gobblin/metrics/kafka/KafkaSchemaRegistry.html" title="class in gobblin.metrics.kafka">KafkaSchemaRegistry</a></dt>
<dd>&nbsp;</dd>
<dt><a href="gobblin/kafka/schemareg/CachingKafkaSchemaRegistry.html" title="class in gobblin.kafka.schemareg"><span class="typeNameLink">CachingKafkaSchemaRegistry</span></a>&lt;<a href="gobblin/kafka/schemareg/CachingKafkaSchemaRegistry.html" title="type parameter in CachingKafkaSchemaRegistry">K</a>,<a href="gobblin/kafka/schemareg/CachingKafkaSchemaRegistry.html" title="type parameter in CachingKafkaSchemaRegistry">S</a>&gt; - Class in <a href="gobblin/kafka/schemareg/package-summary.html">gobblin.kafka.schemareg</a></dt>
<dd>
<div class="block">An implementation that wraps a passed in schema registry and caches interactions with it
</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/schemareg/CachingKafkaSchemaRegistry.html#CachingKafkaSchemaRegistry-gobblin.kafka.schemareg.KafkaSchemaRegistry-">CachingKafkaSchemaRegistry(KafkaSchemaRegistry)</a></span> - Constructor for class gobblin.kafka.schemareg.<a href="gobblin/kafka/schemareg/CachingKafkaSchemaRegistry.html" title="class in gobblin.kafka.schemareg">CachingKafkaSchemaRegistry</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/schemareg/CachingKafkaSchemaRegistry.html#CachingKafkaSchemaRegistry-gobblin.kafka.schemareg.KafkaSchemaRegistry-int-">CachingKafkaSchemaRegistry(KafkaSchemaRegistry, int)</a></span> - Constructor for class gobblin.kafka.schemareg.<a href="gobblin/kafka/schemareg/CachingKafkaSchemaRegistry.html" title="class in gobblin.kafka.schemareg">CachingKafkaSchemaRegistry</a></dt>
<dd>
<div class="block">Create a caching schema registry.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/workunit/packer/KafkaAvgRecordSizeBasedWorkUnitSizeEstimator.html#calcEstimatedSize-gobblin.source.workunit.WorkUnit-">calcEstimatedSize(WorkUnit)</a></span> - Method in class gobblin.source.extractor.extract.kafka.workunit.packer.<a href="gobblin/source/extractor/extract/kafka/workunit/packer/KafkaAvgRecordSizeBasedWorkUnitSizeEstimator.html" title="class in gobblin.source.extractor.extract.kafka.workunit.packer">KafkaAvgRecordSizeBasedWorkUnitSizeEstimator</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/workunit/packer/KafkaAvgRecordTimeBasedWorkUnitSizeEstimator.html#calcEstimatedSize-gobblin.source.workunit.WorkUnit-">calcEstimatedSize(WorkUnit)</a></span> - Method in class gobblin.source.extractor.extract.kafka.workunit.packer.<a href="gobblin/source/extractor/extract/kafka/workunit/packer/KafkaAvgRecordTimeBasedWorkUnitSizeEstimator.html" title="class in gobblin.source.extractor.extract.kafka.workunit.packer">KafkaAvgRecordTimeBasedWorkUnitSizeEstimator</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/workunit/packer/KafkaWorkUnitSizeEstimator.html#calcEstimatedSize-gobblin.source.workunit.WorkUnit-">calcEstimatedSize(WorkUnit)</a></span> - Method in interface gobblin.source.extractor.extract.kafka.workunit.packer.<a href="gobblin/source/extractor/extract/kafka/workunit/packer/KafkaWorkUnitSizeEstimator.html" title="interface in gobblin.source.extractor.extract.kafka.workunit.packer">KafkaWorkUnitSizeEstimator</a></dt>
<dd>
<div class="block">Estimates the size of a Kafka <a href="http://linkedin.github.io/gobblin/javadoc/0.11.0/gobblin-api/gobblin/source/workunit/WorkUnit.html?is-external=true" title="class or interface in gobblin.source.workunit"><code>WorkUnit</code></a>.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/MultiLongWatermark.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/MultiLongWatermark.html" title="class in gobblin.source.extractor.extract.kafka">MultiLongWatermark</a></dt>
<dd>
<div class="block">Given a low watermark (starting point) and a high watermark (target), returns the percentage
of events pulled.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/serialize/LiAvroDeserializerBase.html#close--">close()</a></span> - Method in class gobblin.kafka.serialize.<a href="gobblin/kafka/serialize/LiAvroDeserializerBase.html" title="class in gobblin.kafka.serialize">LiAvroDeserializerBase</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/serialize/LiAvroSerializerBase.html#close--">close()</a></span> - Method in class gobblin.kafka.serialize.<a href="gobblin/kafka/serialize/LiAvroSerializerBase.html" title="class in gobblin.kafka.serialize">LiAvroSerializerBase</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaExtractor.html#close--">close()</a></span> - Method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaExtractor.html" title="class in gobblin.source.extractor.extract.kafka">KafkaExtractor</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaRecord.html#compareTo-gobblin.source.extractor.extract.kafka.KafkaRecord-">compareTo(KafkaRecord)</a></span> - Method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaRecord.html" title="class in gobblin.source.extractor.extract.kafka">KafkaRecord</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/client/AbstractBaseKafkaConsumerClient.html#CONFIG_KAFKA_FETCH_REQUEST_MIN_BYTES">CONFIG_KAFKA_FETCH_REQUEST_MIN_BYTES</a></span> - Static variable in class gobblin.kafka.client.<a href="gobblin/kafka/client/AbstractBaseKafkaConsumerClient.html" title="class in gobblin.kafka.client">AbstractBaseKafkaConsumerClient</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/client/AbstractBaseKafkaConsumerClient.html#CONFIG_KAFKA_FETCH_TIMEOUT_VALUE">CONFIG_KAFKA_FETCH_TIMEOUT_VALUE</a></span> - Static variable in class gobblin.kafka.client.<a href="gobblin/kafka/client/AbstractBaseKafkaConsumerClient.html" title="class in gobblin.kafka.client">AbstractBaseKafkaConsumerClient</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/client/AbstractBaseKafkaConsumerClient.html#CONFIG_KAFKA_FETCH_TIMEOUT_VALUE_DEFAULT">CONFIG_KAFKA_FETCH_TIMEOUT_VALUE_DEFAULT</a></span> - Static variable in class gobblin.kafka.client.<a href="gobblin/kafka/client/AbstractBaseKafkaConsumerClient.html" title="class in gobblin.kafka.client">AbstractBaseKafkaConsumerClient</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/client/AbstractBaseKafkaConsumerClient.html#CONFIG_KAFKA_SOCKET_TIMEOUT_VALUE">CONFIG_KAFKA_SOCKET_TIMEOUT_VALUE</a></span> - Static variable in class gobblin.kafka.client.<a href="gobblin/kafka/client/AbstractBaseKafkaConsumerClient.html" title="class in gobblin.kafka.client">AbstractBaseKafkaConsumerClient</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/client/AbstractBaseKafkaConsumerClient.html#CONFIG_KAFKA_SOCKET_TIMEOUT_VALUE_DEFAULT">CONFIG_KAFKA_SOCKET_TIMEOUT_VALUE_DEFAULT</a></span> - Static variable in class gobblin.kafka.client.<a href="gobblin/kafka/client/AbstractBaseKafkaConsumerClient.html" title="class in gobblin.kafka.client">AbstractBaseKafkaConsumerClient</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/client/AbstractBaseKafkaConsumerClient.html#CONFIG_PREFIX">CONFIG_PREFIX</a></span> - Static variable in class gobblin.kafka.client.<a href="gobblin/kafka/client/AbstractBaseKafkaConsumerClient.html" title="class in gobblin.kafka.client">AbstractBaseKafkaConsumerClient</a></dt>
<dd>&nbsp;</dd>
<dt><a href="gobblin/kafka/schemareg/ConfigDrivenMd5SchemaRegistry.html" title="class in gobblin.kafka.schemareg"><span class="typeNameLink">ConfigDrivenMd5SchemaRegistry</span></a> - Class in <a href="gobblin/kafka/schemareg/package-summary.html">gobblin.kafka.schemareg</a></dt>
<dd>
<div class="block">A SchemaRegistry that hands out MD5 based ids based on configuration
Can be configured to be initialized with a single schema name, value pair.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/schemareg/ConfigDrivenMd5SchemaRegistry.html#ConfigDrivenMd5SchemaRegistry-java.lang.String-org.apache.avro.Schema-">ConfigDrivenMd5SchemaRegistry(String, Schema)</a></span> - Constructor for class gobblin.kafka.schemareg.<a href="gobblin/kafka/schemareg/ConfigDrivenMd5SchemaRegistry.html" title="class in gobblin.kafka.schemareg">ConfigDrivenMd5SchemaRegistry</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/schemareg/ConfigDrivenMd5SchemaRegistry.html#ConfigDrivenMd5SchemaRegistry-java.util.Properties-">ConfigDrivenMd5SchemaRegistry(Properties)</a></span> - Constructor for class gobblin.kafka.schemareg.<a href="gobblin/kafka/schemareg/ConfigDrivenMd5SchemaRegistry.html" title="class in gobblin.kafka.schemareg">ConfigDrivenMd5SchemaRegistry</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/schemareg/ConfigDrivenMd5SchemaRegistry.html#ConfigDrivenMd5SchemaRegistry-com.typesafe.config.Config-">ConfigDrivenMd5SchemaRegistry(Config)</a></span> - Constructor for class gobblin.kafka.schemareg.<a href="gobblin/kafka/schemareg/ConfigDrivenMd5SchemaRegistry.html" title="class in gobblin.kafka.schemareg">ConfigDrivenMd5SchemaRegistry</a></dt>
<dd>&nbsp;</dd>
<dt><a href="gobblin/source/extractor/extract/kafka/ConfigStoreUtils.html" title="class in gobblin.source.extractor.extract.kafka"><span class="typeNameLink">ConfigStoreUtils</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><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/ConfigStoreUtils.html#ConfigStoreUtils--">ConfigStoreUtils()</a></span> - Constructor for class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/ConfigStoreUtils.html" title="class in gobblin.source.extractor.extract.kafka">ConfigStoreUtils</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/serialize/LiAvroDeserializerBase.html#configure-java.util.Map-boolean-">configure(Map&lt;String, ?&gt;, boolean)</a></span> - Method in class gobblin.kafka.serialize.<a href="gobblin/kafka/serialize/LiAvroDeserializerBase.html" title="class in gobblin.kafka.serialize">LiAvroDeserializerBase</a></dt>
<dd>
<div class="block">Configure this class.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/serialize/LiAvroSerializerBase.html#configure-java.util.Map-boolean-">configure(Map&lt;String, ?&gt;, boolean)</a></span> - Method in class gobblin.kafka.serialize.<a href="gobblin/kafka/serialize/LiAvroSerializerBase.html" title="class in gobblin.kafka.serialize">LiAvroSerializerBase</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/ConfluentKafkaSchemaRegistry.html#CONFLUENT_MAX_SCHEMAS_PER_SUBJECT">CONFLUENT_MAX_SCHEMAS_PER_SUBJECT</a></span> - Static variable in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/ConfluentKafkaSchemaRegistry.html" title="class in gobblin.source.extractor.extract.kafka">ConfluentKafkaSchemaRegistry</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/ConfluentKafkaSchemaRegistry.html#CONFLUENT_SCHEMA_NAME_SUFFIX">CONFLUENT_SCHEMA_NAME_SUFFIX</a></span> - Static variable in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/ConfluentKafkaSchemaRegistry.html" title="class in gobblin.source.extractor.extract.kafka">ConfluentKafkaSchemaRegistry</a></dt>
<dd>&nbsp;</dd>
<dt><a href="gobblin/source/extractor/extract/kafka/ConfluentKafkaSchemaRegistry.html" title="class in gobblin.source.extractor.extract.kafka"><span class="typeNameLink">ConfluentKafkaSchemaRegistry</span></a> - Class in <a href="gobblin/source/extractor/extract/kafka/package-summary.html">gobblin.source.extractor.extract.kafka</a></dt>
<dd>
<div class="block">Extension of <a href="gobblin/metrics/kafka/KafkaSchemaRegistry.html" title="class in gobblin.metrics.kafka"><code>KafkaSchemaRegistry</code></a> that wraps Confluent's <code>SchemaRegistryClient</code>.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/ConfluentKafkaSchemaRegistry.html#ConfluentKafkaSchemaRegistry-java.util.Properties-">ConfluentKafkaSchemaRegistry(Properties)</a></span> - Constructor for class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/ConfluentKafkaSchemaRegistry.html" title="class in gobblin.source.extractor.extract.kafka">ConfluentKafkaSchemaRegistry</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/client/GobblinKafkaConsumerClient.html#consume-gobblin.source.extractor.extract.kafka.KafkaPartition-long-long-">consume(KafkaPartition, long, long)</a></span> - Method in interface gobblin.kafka.client.<a href="gobblin/kafka/client/GobblinKafkaConsumerClient.html" title="interface in gobblin.kafka.client">GobblinKafkaConsumerClient</a></dt>
<dd>
<div class="block">API to consume records from kakfa starting from <code>nextOffset</code> till <code>maxOffset</code>.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaUtils.html#containsPartitionAvgRecordMillis-gobblin.configuration.State-gobblin.source.extractor.extract.kafka.KafkaPartition-">containsPartitionAvgRecordMillis(State, KafkaPartition)</a></span> - Static method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaUtils.html" title="class in gobblin.source.extractor.extract.kafka">KafkaUtils</a></dt>
<dd>
<div class="block">Determines whether the given <a href="http://linkedin.github.io/gobblin/javadoc/0.11.0/gobblin-api/gobblin/configuration/State.html?is-external=true" title="class or interface in gobblin.configuration"><code>State</code></a> contains "[topicname].[partitionid].avg.record.millis".</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaUtils.html#containsPartitionAvgRecordSize-gobblin.configuration.State-gobblin.source.extractor.extract.kafka.KafkaPartition-">containsPartitionAvgRecordSize(State, KafkaPartition)</a></span> - Static method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaUtils.html" title="class in gobblin.source.extractor.extract.kafka">KafkaUtils</a></dt>
<dd>
<div class="block">Determines whether the given <a href="http://linkedin.github.io/gobblin/javadoc/0.11.0/gobblin-api/gobblin/configuration/State.html?is-external=true" title="class or interface in gobblin.configuration"><code>State</code></a> contains "[topicname].[partitionid].avg.record.size".</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/converter/EnvelopeSchemaConverter.html#convertRecord-java.lang.String-org.apache.avro.generic.GenericRecord-gobblin.configuration.WorkUnitState-">convertRecord(String, GenericRecord, WorkUnitState)</a></span> - Method in class gobblin.converter.<a href="gobblin/converter/EnvelopeSchemaConverter.html" title="class in gobblin.converter">EnvelopeSchemaConverter</a></dt>
<dd>
<div class="block">Get actual schema from registry and deserialize payload using it.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/converter/LiKafkaByteArrayMsgToAvroConverter.html#convertRecord-org.apache.avro.Schema-byte:A-gobblin.configuration.WorkUnitState-">convertRecord(Schema, byte[], WorkUnitState)</a></span> - Method in class gobblin.converter.<a href="gobblin/converter/LiKafkaByteArrayMsgToAvroConverter.html" title="class in gobblin.converter">LiKafkaByteArrayMsgToAvroConverter</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaAvroExtractor.html#convertRecord-org.apache.avro.generic.GenericRecord-">convertRecord(GenericRecord)</a></span> - Method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaAvroExtractor.html" title="class in gobblin.source.extractor.extract.kafka">KafkaAvroExtractor</a></dt>
<dd>
<div class="block">Convert the record to the output schema of this extractor</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaExtractor.html#convertRecord-D-">convertRecord(D)</a></span> - Method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaExtractor.html" title="class in gobblin.source.extractor.extract.kafka">KafkaExtractor</a></dt>
<dd>
<div class="block">Convert a record to the output format</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/converter/EnvelopeSchemaConverter.html#convertSchema-org.apache.avro.Schema-gobblin.configuration.WorkUnitState-">convertSchema(Schema, WorkUnitState)</a></span> - Method in class gobblin.converter.<a href="gobblin/converter/EnvelopeSchemaConverter.html" title="class in gobblin.converter">EnvelopeSchemaConverter</a></dt>
<dd>
<div class="block">Do nothing, actual schema must be obtained from records.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/converter/LiKafkaByteArrayMsgToAvroConverter.html#convertSchema-S-gobblin.configuration.WorkUnitState-">convertSchema(S, WorkUnitState)</a></span> - Method in class gobblin.converter.<a href="gobblin/converter/LiKafkaByteArrayMsgToAvroConverter.html" title="class in gobblin.converter">LiKafkaByteArrayMsgToAvroConverter</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/client/GobblinKafkaConsumerClient.GobblinKafkaConsumerClientFactory.html#create-com.typesafe.config.Config-">create(Config)</a></span> - Method in interface gobblin.kafka.client.<a href="gobblin/kafka/client/GobblinKafkaConsumerClient.GobblinKafkaConsumerClientFactory.html" title="interface in gobblin.kafka.client">GobblinKafkaConsumerClient.GobblinKafkaConsumerClientFactory</a></dt>
<dd>
<div class="block">Creates a new <a href="gobblin/kafka/client/GobblinKafkaConsumerClient.html" title="interface in gobblin.kafka.client"><code>GobblinKafkaConsumerClient</code></a> for <code>config</code></div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/schemareg/HttpClientFactory.html#create--">create()</a></span> - Method in class gobblin.kafka.schemareg.<a href="gobblin/kafka/schemareg/HttpClientFactory.html" title="class in gobblin.kafka.schemareg">HttpClientFactory</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/metrics/kafka/KafkaAvroSchemaRegistryFactory.html#create-java.util.Properties-">create(Properties)</a></span> - Method in class gobblin.metrics.kafka.<a href="gobblin/metrics/kafka/KafkaAvroSchemaRegistryFactory.html" title="class in gobblin.metrics.kafka">KafkaAvroSchemaRegistryFactory</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/metrics/kafka/KafkaSchemaRegistryFactory.html#create-java.util.Properties-">create(Properties)</a></span> - Method in interface gobblin.metrics.kafka.<a href="gobblin/metrics/kafka/KafkaSchemaRegistryFactory.html" title="interface in gobblin.metrics.kafka">KafkaSchemaRegistryFactory</a></dt>
<dd>
<div class="block">Create a new KafkaSchemaRegistry</div>
</dd>
</dl>
<a name="I:D">
<!-- -->
</a>
<h2 class="title">D</h2>
<dl>
<dt><a href="gobblin/kafka/client/DecodeableKafkaRecord.html" title="interface in gobblin.kafka.client"><span class="typeNameLink">DecodeableKafkaRecord</span></a>&lt;<a href="gobblin/kafka/client/DecodeableKafkaRecord.html" title="type parameter in DecodeableKafkaRecord">K</a>,<a href="gobblin/kafka/client/DecodeableKafkaRecord.html" title="type parameter in DecodeableKafkaRecord">V</a>&gt; - Interface in <a href="gobblin/kafka/client/package-summary.html">gobblin.kafka.client</a></dt>
<dd>
<div class="block">A kafka record that provides getters for deserialized key and value.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaAvroExtractor.html#decodeRecord-gobblin.kafka.client.ByteArrayBasedKafkaRecord-">decodeRecord(ByteArrayBasedKafkaRecord)</a></span> - Method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaAvroExtractor.html" title="class in gobblin.source.extractor.extract.kafka">KafkaAvroExtractor</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaExtractor.html#decodeRecord-gobblin.kafka.client.ByteArrayBasedKafkaRecord-">decodeRecord(ByteArrayBasedKafkaRecord)</a></span> - Method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaExtractor.html" title="class in gobblin.source.extractor.extract.kafka">KafkaExtractor</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaSimpleExtractor.html#decodeRecord-gobblin.kafka.client.ByteArrayBasedKafkaRecord-">decodeRecord(ByteArrayBasedKafkaRecord)</a></span> - Method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaSimpleExtractor.html" title="class in gobblin.source.extractor.extract.kafka">KafkaSimpleExtractor</a></dt>
<dd>
<div class="block"><span class="deprecatedLabel">Deprecated.</span></div>
&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaSimpleJsonExtractor.html#decodeRecord-gobblin.kafka.client.ByteArrayBasedKafkaRecord-">decodeRecord(ByteArrayBasedKafkaRecord)</a></span> - Method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaSimpleJsonExtractor.html" title="class in gobblin.source.extractor.extract.kafka">KafkaSimpleJsonExtractor</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaExtractor.html#decodingErrorCount">decodingErrorCount</a></span> - Variable in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaExtractor.html" title="class in gobblin.source.extractor.extract.kafka">KafkaExtractor</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaSource.html#DEFAULT_BOOTSTRAP_WITH_OFFSET">DEFAULT_BOOTSTRAP_WITH_OFFSET</a></span> - Static variable in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaSource.html" title="class in gobblin.source.extractor.extract.kafka">KafkaSource</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaSource.html#DEFAULT_GOBBLIN_KAFKA_CONSUMER_CLIENT_FACTORY_CLASS">DEFAULT_GOBBLIN_KAFKA_CONSUMER_CLIENT_FACTORY_CLASS</a></span> - Static variable in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaSource.html" title="class in gobblin.source.extractor.extract.kafka">KafkaSource</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaSource.html#DEFAULT_GOBBLIN_KAFKA_SHOULD_ENABLE_DATASET_STATESTORE">DEFAULT_GOBBLIN_KAFKA_SHOULD_ENABLE_DATASET_STATESTORE</a></span> - Static variable in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaSource.html" title="class in gobblin.source.extractor.extract.kafka">KafkaSource</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/metrics/kafka/KafkaSchemaRegistry.html#DEFAULT_KAFKA_SCHEMA_REGISTRY_CACHE_EXPIRE_AFTER_WRITE_MIN">DEFAULT_KAFKA_SCHEMA_REGISTRY_CACHE_EXPIRE_AFTER_WRITE_MIN</a></span> - Static variable in class gobblin.metrics.kafka.<a href="gobblin/metrics/kafka/KafkaSchemaRegistry.html" title="class in gobblin.metrics.kafka">KafkaSchemaRegistry</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/converter/EnvelopeSchemaConverter.html#DEFAULT_KAFKA_SCHEMA_REGISTRY_FACTORY_CLASS">DEFAULT_KAFKA_SCHEMA_REGISTRY_FACTORY_CLASS</a></span> - Static variable in class gobblin.converter.<a href="gobblin/converter/EnvelopeSchemaConverter.html" title="class in gobblin.converter">EnvelopeSchemaConverter</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/metrics/kafka/KafkaSchemaRegistry.html#DEFAULT_KAFKA_SCHEMA_REGISTRY_MAX_CACHE_SIZE">DEFAULT_KAFKA_SCHEMA_REGISTRY_MAX_CACHE_SIZE</a></span> - Static variable in class gobblin.metrics.kafka.<a href="gobblin/metrics/kafka/KafkaSchemaRegistry.html" title="class in gobblin.metrics.kafka">KafkaSchemaRegistry</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaSource.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/KafkaSource.html" title="class in gobblin.source.extractor.extract.kafka">KafkaSource</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/converter/EnvelopeSchemaConverter.html#DEFAULT_PAYLOAD_FIELD">DEFAULT_PAYLOAD_FIELD</a></span> - Static variable in class gobblin.converter.<a href="gobblin/converter/EnvelopeSchemaConverter.html" title="class in gobblin.converter">EnvelopeSchemaConverter</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/converter/EnvelopeSchemaConverter.html#DEFAULT_PAYLOAD_SCHEMA_ID_FIELD">DEFAULT_PAYLOAD_SCHEMA_ID_FIELD</a></span> - Static variable in class gobblin.converter.<a href="gobblin/converter/EnvelopeSchemaConverter.html" title="class in gobblin.converter">EnvelopeSchemaConverter</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaSource.html#DEFAULT_RESET_ON_OFFSET_OUT_OF_RANGE">DEFAULT_RESET_ON_OFFSET_OUT_OF_RANGE</a></span> - Static variable in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaSource.html" title="class in gobblin.source.extractor.extract.kafka">KafkaSource</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaAvroExtractor.html#DEFAULT_SCHEMA">DEFAULT_SCHEMA</a></span> - Static variable in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaAvroExtractor.html" title="class in gobblin.source.extractor.extract.kafka">KafkaAvroExtractor</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaSource.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/KafkaSource.html" title="class in gobblin.source.extractor.extract.kafka">KafkaSource</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/schemareg/KafkaSchemaRegistryFactory.html#DEFAULT_TRY_CACHING">DEFAULT_TRY_CACHING</a></span> - Static variable in class gobblin.kafka.schemareg.<a href="gobblin/kafka/schemareg/KafkaSchemaRegistryFactory.html" title="class in gobblin.kafka.schemareg">KafkaSchemaRegistryFactory</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/workunit/packer/KafkaBiLevelWorkUnitPacker.html#DEFAULT_WORKUNIT_PRE_GROUPING_SIZE_FACTOR">DEFAULT_WORKUNIT_PRE_GROUPING_SIZE_FACTOR</a></span> - Static variable in class gobblin.source.extractor.extract.kafka.workunit.packer.<a href="gobblin/source/extractor/extract/kafka/workunit/packer/KafkaBiLevelWorkUnitPacker.html" title="class in gobblin.source.extractor.extract.kafka.workunit.packer">KafkaBiLevelWorkUnitPacker</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/serialize/LiAvroDeserializerBase.html#deserialize-java.lang.String-byte:A-org.apache.avro.Schema-">deserialize(String, byte[], Schema)</a></span> - Method in class gobblin.kafka.serialize.<a href="gobblin/kafka/serialize/LiAvroDeserializerBase.html" title="class in gobblin.kafka.serialize">LiAvroDeserializerBase</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/serialize/LiAvroDeserializerBase.html#deserialize-java.lang.String-byte:A-">deserialize(String, byte[])</a></span> - Method in class gobblin.kafka.serialize.<a href="gobblin/kafka/serialize/LiAvroDeserializerBase.html" title="class in gobblin.kafka.serialize">LiAvroDeserializerBase</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/converter/EnvelopeSchemaConverter.html#deserializePayload-byte:A-org.apache.avro.Schema-">deserializePayload(byte[], Schema)</a></span> - Method in class gobblin.converter.<a href="gobblin/converter/EnvelopeSchemaConverter.html" title="class in gobblin.converter">EnvelopeSchemaConverter</a></dt>
<dd>
<div class="block">Deserialize payload using payload schema</div>
</dd>
</dl>
<a name="I:E">
<!-- -->
</a>
<h2 class="title">E</h2>
<dl>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaSource.html#EARLIEST_OFFSET">EARLIEST_OFFSET</a></span> - Static variable in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaSource.html" title="class in gobblin.source.extractor.extract.kafka">KafkaSource</a></dt>
<dd>&nbsp;</dd>
<dt><a href="gobblin/converter/EnvelopeSchemaConverter.html" title="class in gobblin.converter"><span class="typeNameLink">EnvelopeSchemaConverter</span></a> - Class in <a href="gobblin/converter/package-summary.html">gobblin.converter</a></dt>
<dd>
<div class="block">A converter for extracting schema/records from an envelope schema.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/converter/EnvelopeSchemaConverter.html#EnvelopeSchemaConverter--">EnvelopeSchemaConverter()</a></span> - Constructor for class gobblin.converter.<a href="gobblin/converter/EnvelopeSchemaConverter.html" title="class in gobblin.converter">EnvelopeSchemaConverter</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/workunit/packer/KafkaWorkUnitPacker.html#EPS">EPS</a></span> - Static variable in class gobblin.source.extractor.extract.kafka.workunit.packer.<a href="gobblin/source/extractor/extract/kafka/workunit/packer/KafkaWorkUnitPacker.html" title="class in gobblin.source.extractor.extract.kafka.workunit.packer">KafkaWorkUnitPacker</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/serialize/MD5Digest.html#equals-java.lang.Object-">equals(Object)</a></span> - Method in class gobblin.kafka.serialize.<a href="gobblin/kafka/serialize/MD5Digest.html" title="class in gobblin.kafka.serialize">MD5Digest</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaPartition.html#equals-java.lang.Object-">equals(Object)</a></span> - Method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaPartition.html" title="class in gobblin.source.extractor.extract.kafka">KafkaPartition</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaRecord.html#equals-java.lang.Object-">equals(Object)</a></span> - Method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaRecord.html" title="class in gobblin.source.extractor.extract.kafka">KafkaRecord</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaExtractor.html#EXPECTED_HIGH_WATERMARK">EXPECTED_HIGH_WATERMARK</a></span> - Static variable in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaExtractor.html" title="class in gobblin.source.extractor.extract.kafka">KafkaExtractor</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/workunit/packer/KafkaWorkUnitPacker.html#extractNameSpace">extractNameSpace</a></span> - Variable in class gobblin.source.extractor.extract.kafka.workunit.packer.<a href="gobblin/source/extractor/extract/kafka/workunit/packer/KafkaWorkUnitPacker.html" title="class in gobblin.source.extractor.extract.kafka.workunit.packer">KafkaWorkUnitPacker</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/UniversalKafkaSource.html#EXTRACTOR_TYPE">EXTRACTOR_TYPE</a></span> - Static variable in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/UniversalKafkaSource.html" title="class in gobblin.source.extractor.extract.kafka">UniversalKafkaSource</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/AbstractBaseKafkaConsumerClient.html#fetchMinBytes">fetchMinBytes</a></span> - Variable in class gobblin.kafka.client.<a href="gobblin/kafka/client/AbstractBaseKafkaConsumerClient.html" title="class in gobblin.kafka.client">AbstractBaseKafkaConsumerClient</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/schemareg/LiKafkaSchemaRegistry.html#fetchSchemaByKey-gobblin.kafka.serialize.MD5Digest-">fetchSchemaByKey(MD5Digest)</a></span> - Method in class gobblin.kafka.schemareg.<a href="gobblin/kafka/schemareg/LiKafkaSchemaRegistry.html" title="class in gobblin.kafka.schemareg">LiKafkaSchemaRegistry</a></dt>
<dd>
<div class="block">Fetch schema by key.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/metrics/kafka/KafkaAvroSchemaRegistry.html#fetchSchemaByKey-java.lang.String-">fetchSchemaByKey(String)</a></span> - Method in class gobblin.metrics.kafka.<a href="gobblin/metrics/kafka/KafkaAvroSchemaRegistry.html" title="class in gobblin.metrics.kafka">KafkaAvroSchemaRegistry</a></dt>
<dd>
<div class="block">Fetch schema by key.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/metrics/kafka/KafkaSchemaRegistry.html#fetchSchemaByKey-K-">fetchSchemaByKey(K)</a></span> - Method in class gobblin.metrics.kafka.<a href="gobblin/metrics/kafka/KafkaSchemaRegistry.html" title="class in gobblin.metrics.kafka">KafkaSchemaRegistry</a></dt>
<dd>
<div class="block">Fetch schema by key.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/ConfluentKafkaSchemaRegistry.html#fetchSchemaByKey-java.lang.Integer-">fetchSchemaByKey(Integer)</a></span> - Method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/ConfluentKafkaSchemaRegistry.html" title="class in gobblin.source.extractor.extract.kafka">ConfluentKafkaSchemaRegistry</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/SimpleKafkaSchemaRegistry.html#fetchSchemaByKey-java.lang.String-">fetchSchemaByKey(String)</a></span> - Method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/SimpleKafkaSchemaRegistry.html" title="class in gobblin.source.extractor.extract.kafka">SimpleKafkaSchemaRegistry</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/client/AbstractBaseKafkaConsumerClient.html#fetchTimeoutMillis">fetchTimeoutMillis</a></span> - Variable in class gobblin.kafka.client.<a href="gobblin/kafka/client/AbstractBaseKafkaConsumerClient.html" title="class in gobblin.kafka.client">AbstractBaseKafkaConsumerClient</a></dt>
<dd>&nbsp;</dd>
<dt><a href="gobblin/source/extractor/extract/kafka/FixedSchemaKafkaAvroExtractor.html" title="class in gobblin.source.extractor.extract.kafka"><span class="typeNameLink">FixedSchemaKafkaAvroExtractor</span></a> - Class in <a href="gobblin/source/extractor/extract/kafka/package-summary.html">gobblin.source.extractor.extract.kafka</a></dt>
<dd>
<div class="block">Extract avro records from a Kafka topic using a fixed schema provided by <a href="gobblin/source/extractor/extract/kafka/FixedSchemaKafkaAvroExtractor.html#STATIC_SCHEMA_ROOT_KEY"><code>FixedSchemaKafkaAvroExtractor.STATIC_SCHEMA_ROOT_KEY</code></a>.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/FixedSchemaKafkaAvroExtractor.html#FixedSchemaKafkaAvroExtractor-gobblin.configuration.WorkUnitState-">FixedSchemaKafkaAvroExtractor(WorkUnitState)</a></span> - Constructor for class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/FixedSchemaKafkaAvroExtractor.html" title="class in gobblin.source.extractor.extract.kafka">FixedSchemaKafkaAvroExtractor</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/serialize/MD5Digest.html#fromBytes-byte:A-">fromBytes(byte[])</a></span> - Static method in class gobblin.kafka.serialize.<a href="gobblin/kafka/serialize/MD5Digest.html" title="class in gobblin.kafka.serialize">MD5Digest</a></dt>
<dd>
<div class="block">Static method to get an MD5Digest from a binary byte representation</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/serialize/MD5Digest.html#fromBytes-byte:A-int-">fromBytes(byte[], int)</a></span> - Static method in class gobblin.kafka.serialize.<a href="gobblin/kafka/serialize/MD5Digest.html" title="class in gobblin.kafka.serialize">MD5Digest</a></dt>
<dd>
<div class="block">Static method to get an MD5Digest from a binary byte representation.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/serialize/MD5Digest.html#fromString-java.lang.String-">fromString(String)</a></span> - Static method in class gobblin.kafka.serialize.<a href="gobblin/kafka/serialize/MD5Digest.html" title="class in gobblin.kafka.serialize">MD5Digest</a></dt>
<dd>
<div class="block">Static method to get an MD5Digest from a human-readable string representation</div>
</dd>
</dl>
<a name="I:G">
<!-- -->
</a>
<h2 class="title">G</h2>
<dl>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaExtractor.html#generateTags-gobblin.configuration.State-">generateTags(State)</a></span> - Method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaExtractor.html" title="class in gobblin.source.extractor.extract.kafka">KafkaExtractor</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/metrics/kafka/KafkaSchemaRegistry.html#get-java.util.Properties-">get(Properties)</a></span> - Static method in class gobblin.metrics.kafka.<a href="gobblin/metrics/kafka/KafkaSchemaRegistry.html" title="class in gobblin.metrics.kafka">KafkaSchemaRegistry</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/MultiLongWatermark.html#get-int-">get(int)</a></span> - Method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/MultiLongWatermark.html" title="class in gobblin.source.extractor.extract.kafka">MultiLongWatermark</a></dt>
<dd>
<div class="block">The idx'th value of this watermark.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/metrics/kafka/KafkaSchemaRegistry.html#GET_SCHEMA_BY_ID_MAX_TIRES">GET_SCHEMA_BY_ID_MAX_TIRES</a></span> - Static variable in class gobblin.metrics.kafka.<a href="gobblin/metrics/kafka/KafkaSchemaRegistry.html" title="class in gobblin.metrics.kafka">KafkaSchemaRegistry</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/metrics/kafka/KafkaSchemaRegistry.html#GET_SCHEMA_BY_ID_MIN_INTERVAL_SECONDS">GET_SCHEMA_BY_ID_MIN_INTERVAL_SECONDS</a></span> - Static variable in class gobblin.metrics.kafka.<a href="gobblin/metrics/kafka/KafkaSchemaRegistry.html" title="class in gobblin.metrics.kafka">KafkaSchemaRegistry</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/writer/BaseKafkaDataWriterBuilder.html#getAsyncDataWriter-java.util.Properties-">getAsyncDataWriter(Properties)</a></span> - Method in class gobblin.kafka.writer.<a href="gobblin/kafka/writer/BaseKafkaDataWriterBuilder.html" title="class in gobblin.kafka.writer">BaseKafkaDataWriterBuilder</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/schemareg/CachingKafkaSchemaRegistry.html#getById-K-">getById(K)</a></span> - Method in class gobblin.kafka.schemareg.<a href="gobblin/kafka/schemareg/CachingKafkaSchemaRegistry.html" title="class in gobblin.kafka.schemareg">CachingKafkaSchemaRegistry</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/schemareg/ConfigDrivenMd5SchemaRegistry.html#getById-gobblin.kafka.serialize.MD5Digest-">getById(MD5Digest)</a></span> - Method in class gobblin.kafka.schemareg.<a href="gobblin/kafka/schemareg/ConfigDrivenMd5SchemaRegistry.html" title="class in gobblin.kafka.schemareg">ConfigDrivenMd5SchemaRegistry</a></dt>
<dd>
<div class="block">Get a schema given an id</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/schemareg/KafkaSchemaRegistry.html#getById-K-">getById(K)</a></span> - Method in interface gobblin.kafka.schemareg.<a href="gobblin/kafka/schemareg/KafkaSchemaRegistry.html" title="interface in gobblin.kafka.schemareg">KafkaSchemaRegistry</a></dt>
<dd>
<div class="block">Get a schema given an id</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/schemareg/LiKafkaSchemaRegistry.html#getById-gobblin.kafka.serialize.MD5Digest-">getById(MD5Digest)</a></span> - Method in class gobblin.kafka.schemareg.<a href="gobblin/kafka/schemareg/LiKafkaSchemaRegistry.html" title="class in gobblin.kafka.schemareg">LiKafkaSchemaRegistry</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/ConfigStoreUtils.html#getConfig-gobblin.config.client.ConfigClient-java.net.URI-com.google.common.base.Optional-">getConfig(ConfigClient, URI, Optional&lt;Config&gt;)</a></span> - Static method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/ConfigStoreUtils.html" title="class in gobblin.source.extractor.extract.kafka">ConfigStoreUtils</a></dt>
<dd>
<div class="block">Wrapper to convert Checked Exception to Unchecked Exception
Easy to use in lambda expressions</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/ConfigStoreUtils.html#getConfigForTopic-java.util.Properties-java.lang.String-gobblin.config.client.ConfigClient-">getConfigForTopic(Properties, String, ConfigClient)</a></span> - Static method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/ConfigStoreUtils.html" title="class in gobblin.source.extractor.extract.kafka">ConfigStoreUtils</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/ConfigStoreUtils.html#getConfigStoreUri-java.util.Properties-">getConfigStoreUri(Properties)</a></span> - Static method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/ConfigStoreUtils.html" title="class in gobblin.source.extractor.extract.kafka">ConfigStoreUtils</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaExtractor.html#getCurrentPartition--">getCurrentPartition()</a></span> - Method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaExtractor.html" title="class in gobblin.source.extractor.extract.kafka">KafkaExtractor</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/FixedSchemaKafkaAvroExtractor.html#getDecoder-byte:A-">getDecoder(byte[])</a></span> - Method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/FixedSchemaKafkaAvroExtractor.html" title="class in gobblin.source.extractor.extract.kafka">FixedSchemaKafkaAvroExtractor</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaAvroExtractor.html#getDecoder-byte:A-">getDecoder(byte[])</a></span> - Method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaAvroExtractor.html" title="class in gobblin.source.extractor.extract.kafka">KafkaAvroExtractor</a></dt>
<dd>
<div class="block">Obtain the Avro <a href="http://avro.apache.org/docs/1.8.1/api/java/org/apache/avro/io/Decoder.html?is-external=true" title="class or interface in org.apache.avro.io"><code>Decoder</code></a> for a Kafka record given the payload of the record.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/client/GobblinKafkaConsumerClient.html#getEarliestOffset-gobblin.source.extractor.extract.kafka.KafkaPartition-">getEarliestOffset(KafkaPartition)</a></span> - Method in interface gobblin.kafka.client.<a href="gobblin/kafka/client/GobblinKafkaConsumerClient.html" title="interface in gobblin.kafka.client">GobblinKafkaConsumerClient</a></dt>
<dd>
<div class="block">Get the earliest available offset for a <code>partition</code></div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaExtractor.html#getExpectedRecordCount--">getExpectedRecordCount()</a></span> - Method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaExtractor.html" title="class in gobblin.source.extractor.extract.kafka">KafkaExtractor</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaSimpleSource.html#getExtractor-gobblin.configuration.WorkUnitState-">getExtractor(WorkUnitState)</a></span> - Method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaSimpleSource.html" title="class in gobblin.source.extractor.extract.kafka">KafkaSimpleSource</a></dt>
<dd>
<div class="block"><span class="deprecatedLabel">Deprecated.</span></div>
<div class="block">Get an <a href="http://linkedin.github.io/gobblin/javadoc/0.11.0/gobblin-api/gobblin/source/extractor/Extractor.html?is-external=true" title="class or interface in gobblin.source.extractor"><code>Extractor</code></a> based on a given <a href="http://linkedin.github.io/gobblin/javadoc/0.11.0/gobblin-api/gobblin/configuration/WorkUnitState.html?is-external=true" title="class or interface in gobblin.configuration"><code>WorkUnitState</code></a>.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/UniversalKafkaSource.html#getExtractor-gobblin.configuration.WorkUnitState-">getExtractor(WorkUnitState)</a></span> - Method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/UniversalKafkaSource.html" title="class in gobblin.source.extractor.extract.kafka">UniversalKafkaSource</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaAvroExtractor.html#getExtractorSchema--">getExtractorSchema()</a></span> - Method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaAvroExtractor.html" title="class in gobblin.source.extractor.extract.kafka">KafkaAvroExtractor</a></dt>
<dd>
<div class="block">Get the schema to be used by this extractor.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/client/AbstractBaseKafkaConsumerClient.html#getFilteredTopics-java.util.List-java.util.List-">getFilteredTopics(List&lt;Pattern&gt;, List&lt;Pattern&gt;)</a></span> - Method in class gobblin.kafka.client.<a href="gobblin/kafka/client/AbstractBaseKafkaConsumerClient.html" title="class in gobblin.kafka.client">AbstractBaseKafkaConsumerClient</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/client/GobblinKafkaConsumerClient.html#getFilteredTopics-java.util.List-java.util.List-">getFilteredTopics(List&lt;Pattern&gt;, List&lt;Pattern&gt;)</a></span> - Method in interface gobblin.kafka.client.<a href="gobblin/kafka/client/GobblinKafkaConsumerClient.html" title="interface in gobblin.kafka.client">GobblinKafkaConsumerClient</a></dt>
<dd>
<div class="block">Get a list of <a href="gobblin/source/extractor/extract/kafka/KafkaTopic.html" title="class in gobblin.source.extractor.extract.kafka"><code>KafkaTopic</code></a>s satisfy <code>blacklist</code> and <code>whitelist</code> patterns</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/MultiLongWatermark.html#getGap-gobblin.source.extractor.extract.kafka.MultiLongWatermark-">getGap(MultiLongWatermark)</a></span> - Method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/MultiLongWatermark.html" title="class in gobblin.source.extractor.extract.kafka">MultiLongWatermark</a></dt>
<dd>
<div class="block">Get the number of records that need to be pulled given the high watermark.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaExtractor.html#getHighWatermark--">getHighWatermark()</a></span> - Method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaExtractor.html" title="class in gobblin.source.extractor.extract.kafka">KafkaExtractor</a></dt>
<dd>
<div class="block"><span class="deprecatedLabel">Deprecated.</span></div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaPartition.KafkaLeader.html#getHostAndPort--">getHostAndPort()</a></span> - Method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaPartition.KafkaLeader.html" title="class in gobblin.source.extractor.extract.kafka">KafkaPartition.KafkaLeader</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaPartition.html#getId--">getId()</a></span> - Method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaPartition.html" title="class in gobblin.source.extractor.extract.kafka">KafkaPartition</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaPartition.KafkaLeader.html#getId--">getId()</a></span> - Method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaPartition.KafkaLeader.html" title="class in gobblin.source.extractor.extract.kafka">KafkaPartition.KafkaLeader</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/workunit/packer/KafkaWorkUnitPacker.html#getInstance-gobblin.source.extractor.extract.AbstractSource-gobblin.configuration.SourceState-">getInstance(AbstractSource&lt;?, ?&gt;, SourceState)</a></span> - Static method in class gobblin.source.extractor.extract.kafka.workunit.packer.<a href="gobblin/source/extractor/extract/kafka/workunit/packer/KafkaWorkUnitPacker.html" title="class in gobblin.source.extractor.extract.kafka.workunit.packer">KafkaWorkUnitPacker</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/workunit/packer/KafkaWorkUnitPacker.html#getInstance-gobblin.source.extractor.extract.kafka.workunit.packer.KafkaWorkUnitPacker.PackerType-gobblin.source.extractor.extract.AbstractSource-gobblin.configuration.SourceState-">getInstance(KafkaWorkUnitPacker.PackerType, AbstractSource&lt;?, ?&gt;, SourceState)</a></span> - Static method in class gobblin.source.extractor.extract.kafka.workunit.packer.<a href="gobblin/source/extractor/extract/kafka/workunit/packer/KafkaWorkUnitPacker.html" title="class in gobblin.source.extractor.extract.kafka.workunit.packer">KafkaWorkUnitPacker</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/writer/KafkaWriterHelper.html#getKafkaProducer-java.util.Properties-">getKafkaProducer(Properties)</a></span> - Static method in class gobblin.kafka.writer.<a href="gobblin/kafka/writer/KafkaWriterHelper.html" title="class in gobblin.kafka.writer">KafkaWriterHelper</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/client/DecodeableKafkaRecord.html#getKey--">getKey()</a></span> - Method in interface gobblin.kafka.client.<a href="gobblin/kafka/client/DecodeableKafkaRecord.html" title="interface in gobblin.kafka.client">DecodeableKafkaRecord</a></dt>
<dd>
<div class="block">The key of this record.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/client/ByteArrayBasedKafkaRecord.html#getKeyBytes--">getKeyBytes()</a></span> - Method in interface gobblin.kafka.client.<a href="gobblin/kafka/client/ByteArrayBasedKafkaRecord.html" title="interface in gobblin.kafka.client">ByteArrayBasedKafkaRecord</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/client/GobblinKafkaConsumerClient.html#getLatestOffset-gobblin.source.extractor.extract.kafka.KafkaPartition-">getLatestOffset(KafkaPartition)</a></span> - Method in interface gobblin.kafka.client.<a href="gobblin/kafka/client/GobblinKafkaConsumerClient.html" title="interface in gobblin.kafka.client">GobblinKafkaConsumerClient</a></dt>
<dd>
<div class="block">Get the latest available offset for a <code>partition</code></div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/schemareg/CachingKafkaSchemaRegistry.html#getLatestSchema-java.lang.String-">getLatestSchema(String)</a></span> - Method in class gobblin.kafka.schemareg.<a href="gobblin/kafka/schemareg/CachingKafkaSchemaRegistry.html" title="class in gobblin.kafka.schemareg">CachingKafkaSchemaRegistry</a></dt>
<dd>
<div class="block">This call is not cached because we never want to miss out on the latest schema.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/schemareg/ConfigDrivenMd5SchemaRegistry.html#getLatestSchema-java.lang.String-">getLatestSchema(String)</a></span> - Method in class gobblin.kafka.schemareg.<a href="gobblin/kafka/schemareg/ConfigDrivenMd5SchemaRegistry.html" title="class in gobblin.kafka.schemareg">ConfigDrivenMd5SchemaRegistry</a></dt>
<dd>
<div class="block">Will throw a SchemaRegistryException if it cannot find any schema for the provided name.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/schemareg/KafkaSchemaRegistry.html#getLatestSchema-java.lang.String-">getLatestSchema(String)</a></span> - Method in interface gobblin.kafka.schemareg.<a href="gobblin/kafka/schemareg/KafkaSchemaRegistry.html" title="interface in gobblin.kafka.schemareg">KafkaSchemaRegistry</a></dt>
<dd>
<div class="block">Get the latest schema that was registered under this name</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/schemareg/LiKafkaSchemaRegistry.html#getLatestSchema-java.lang.String-">getLatestSchema(String)</a></span> - Method in class gobblin.kafka.schemareg.<a href="gobblin/kafka/schemareg/LiKafkaSchemaRegistry.html" title="class in gobblin.kafka.schemareg">LiKafkaSchemaRegistry</a></dt>
<dd>
<div class="block">Get the latest schema of a topic.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/metrics/kafka/KafkaAvroSchemaRegistry.html#getLatestSchemaByTopic-java.lang.String-">getLatestSchemaByTopic(String)</a></span> - Method in class gobblin.metrics.kafka.<a href="gobblin/metrics/kafka/KafkaAvroSchemaRegistry.html" title="class in gobblin.metrics.kafka">KafkaAvroSchemaRegistry</a></dt>
<dd>
<div class="block">Get the latest schema of a topic.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/metrics/kafka/KafkaSchemaRegistry.html#getLatestSchemaByTopic-java.lang.String-">getLatestSchemaByTopic(String)</a></span> - Method in class gobblin.metrics.kafka.<a href="gobblin/metrics/kafka/KafkaSchemaRegistry.html" title="class in gobblin.metrics.kafka">KafkaSchemaRegistry</a></dt>
<dd>
<div class="block">Get the latest schema of a topic.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/ConfluentKafkaSchemaRegistry.html#getLatestSchemaByTopic-java.lang.String-">getLatestSchemaByTopic(String)</a></span> - Method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/ConfluentKafkaSchemaRegistry.html" title="class in gobblin.source.extractor.extract.kafka">ConfluentKafkaSchemaRegistry</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/FixedSchemaKafkaAvroExtractor.html#getLatestSchemaByTopic-java.lang.String-">getLatestSchemaByTopic(String)</a></span> - Method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/FixedSchemaKafkaAvroExtractor.html" title="class in gobblin.source.extractor.extract.kafka">FixedSchemaKafkaAvroExtractor</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaAvroExtractor.html#getLatestSchemaByTopic-java.lang.String-">getLatestSchemaByTopic(String)</a></span> - Method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaAvroExtractor.html" title="class in gobblin.source.extractor.extract.kafka">KafkaAvroExtractor</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/SimpleKafkaSchemaRegistry.html#getLatestSchemaByTopic-java.lang.String-">getLatestSchemaByTopic(String)</a></span> - Method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/SimpleKafkaSchemaRegistry.html" title="class in gobblin.source.extractor.extract.kafka">SimpleKafkaSchemaRegistry</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaPartition.html#getLeader--">getLeader()</a></span> - Method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaPartition.html" title="class in gobblin.source.extractor.extract.kafka">KafkaPartition</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/client/ByteArrayBasedKafkaRecord.html#getMessageBytes--">getMessageBytes()</a></span> - Method in interface gobblin.kafka.client.<a href="gobblin/kafka/client/ByteArrayBasedKafkaRecord.html" title="interface in gobblin.kafka.client">ByteArrayBasedKafkaRecord</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/workunit/packer/KafkaWorkUnitPacker.html#getMultiWorkUnitPartitions-gobblin.source.workunit.MultiWorkUnit-">getMultiWorkUnitPartitions(MultiWorkUnit)</a></span> - Static method in class gobblin.source.extractor.extract.kafka.workunit.packer.<a href="gobblin/source/extractor/extract/kafka/workunit/packer/KafkaWorkUnitPacker.html" title="class in gobblin.source.extractor.extract.kafka.workunit.packer">KafkaWorkUnitPacker</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaTopic.html#getName--">getName()</a></span> - Method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaTopic.html" title="class in gobblin.source.extractor.extract.kafka">KafkaTopic</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/client/BaseKafkaConsumerRecord.html#getNextOffset--">getNextOffset()</a></span> - Method in class gobblin.kafka.client.<a href="gobblin/kafka/client/BaseKafkaConsumerRecord.html" title="class in gobblin.kafka.client">BaseKafkaConsumerRecord</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/client/KafkaConsumerRecord.html#getNextOffset--">getNextOffset()</a></span> - Method in interface gobblin.kafka.client.<a href="gobblin/kafka/client/KafkaConsumerRecord.html" title="interface in gobblin.kafka.client">KafkaConsumerRecord</a></dt>
<dd>
<div class="block">Next offset after this record</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/client/BaseKafkaConsumerRecord.html#getOffset--">getOffset()</a></span> - Method in class gobblin.kafka.client.<a href="gobblin/kafka/client/BaseKafkaConsumerRecord.html" title="class in gobblin.kafka.client">BaseKafkaConsumerRecord</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/client/KafkaConsumerRecord.html#getOffset--">getOffset()</a></span> - Method in interface gobblin.kafka.client.<a href="gobblin/kafka/client/KafkaConsumerRecord.html" title="interface in gobblin.kafka.client">KafkaConsumerRecord</a></dt>
<dd>
<div class="block">Offset of this record</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaUtils.html#getPartition-gobblin.configuration.State-">getPartition(State)</a></span> - Static method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaUtils.html" title="class in gobblin.source.extractor.extract.kafka">KafkaUtils</a></dt>
<dd>
<div class="block">Get <a href="gobblin/source/extractor/extract/kafka/KafkaPartition.html" title="class in gobblin.source.extractor.extract.kafka"><code>KafkaPartition</code></a> from a <a href="http://linkedin.github.io/gobblin/javadoc/0.11.0/gobblin-api/gobblin/configuration/State.html?is-external=true" title="class or interface in gobblin.configuration"><code>State</code></a> object.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaUtils.html#getPartitionAvgRecordMillis-gobblin.configuration.State-gobblin.source.extractor.extract.kafka.KafkaPartition-">getPartitionAvgRecordMillis(State, KafkaPartition)</a></span> - Static method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaUtils.html" title="class in gobblin.source.extractor.extract.kafka">KafkaUtils</a></dt>
<dd>
<div class="block">Get the average time to pull a record of a partition, which is stored in property
"[topicname].[partitionid].avg.record.millis".</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaUtils.html#getPartitionAvgRecordSize-gobblin.configuration.State-gobblin.source.extractor.extract.kafka.KafkaPartition-">getPartitionAvgRecordSize(State, KafkaPartition)</a></span> - Static method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaUtils.html" title="class in gobblin.source.extractor.extract.kafka">KafkaUtils</a></dt>
<dd>
<div class="block">Get the average record size of a partition, which is stored in property "[topicname].[partitionid].avg.record.size".</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaUtils.html#getPartitionPropName-java.lang.String-int-">getPartitionPropName(String, int)</a></span> - Static method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaUtils.html" title="class in gobblin.source.extractor.extract.kafka">KafkaUtils</a></dt>
<dd>
<div class="block">This method returns topicName + '.' + partitionId.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaTopic.html#getPartitions--">getPartitions()</a></span> - Method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaTopic.html" title="class in gobblin.source.extractor.extract.kafka">KafkaTopic</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaUtils.html#getPartitions-gobblin.configuration.State-">getPartitions(State)</a></span> - Static method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaUtils.html" title="class in gobblin.source.extractor.extract.kafka">KafkaUtils</a></dt>
<dd>
<div class="block">Get a list of <a href="gobblin/source/extractor/extract/kafka/KafkaPartition.html" title="class in gobblin.source.extractor.extract.kafka"><code>KafkaPartition</code></a>s from a <a href="http://linkedin.github.io/gobblin/javadoc/0.11.0/gobblin-api/gobblin/configuration/State.html?is-external=true" title="class or interface in gobblin.configuration"><code>State</code></a> object.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/converter/EnvelopeSchemaConverter.html#getPayload-org.apache.avro.generic.GenericRecord-java.lang.String-">getPayload(GenericRecord, String)</a></span> - Method in class gobblin.converter.<a href="gobblin/converter/EnvelopeSchemaConverter.html" title="class in gobblin.converter">EnvelopeSchemaConverter</a></dt>
<dd>
<div class="block">Get payload field from GenericRecord and convert to byte array</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/FixedSchemaKafkaAvroExtractor.html#getRecordSchema-byte:A-">getRecordSchema(byte[])</a></span> - Method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/FixedSchemaKafkaAvroExtractor.html" title="class in gobblin.source.extractor.extract.kafka">FixedSchemaKafkaAvroExtractor</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaAvroExtractor.html#getRecordSchema-byte:A-">getRecordSchema(byte[])</a></span> - Method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaAvroExtractor.html" title="class in gobblin.source.extractor.extract.kafka">KafkaAvroExtractor</a></dt>
<dd>
<div class="block">Obtain the Avro <a href="http://avro.apache.org/docs/1.8.1/api/java/org/apache/avro/Schema.html?is-external=true" title="class or interface in org.apache.avro"><code>Schema</code></a> of a Kafka record given the payload of the record.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaAvroExtractor.html#getSchema--">getSchema()</a></span> - Method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaAvroExtractor.html" title="class in gobblin.source.extractor.extract.kafka">KafkaAvroExtractor</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaSimpleExtractor.html#getSchema--">getSchema()</a></span> - Method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaSimpleExtractor.html" title="class in gobblin.source.extractor.extract.kafka">KafkaSimpleExtractor</a></dt>
<dd>
<div class="block"><span class="deprecatedLabel">Deprecated.</span></div>
<div class="block">Get the schema (metadata) of the extracted data records.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/metrics/kafka/KafkaAvroSchemaRegistry.html#getSchemaByKey-java.lang.String-">getSchemaByKey(String)</a></span> - Method in class gobblin.metrics.kafka.<a href="gobblin/metrics/kafka/KafkaAvroSchemaRegistry.html" title="class in gobblin.metrics.kafka">KafkaAvroSchemaRegistry</a></dt>
<dd>
<div class="block">Get schema from schema registry by key</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/metrics/kafka/KafkaSchemaRegistry.html#getSchemaByKey-K-">getSchemaByKey(K)</a></span> - Method in class gobblin.metrics.kafka.<a href="gobblin/metrics/kafka/KafkaSchemaRegistry.html" title="class in gobblin.metrics.kafka">KafkaSchemaRegistry</a></dt>
<dd>
<div class="block">Get schema from schema registry by key.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/metrics/kafka/KafkaAvroSchemaRegistry.html#getSchemaIdLengthByte--">getSchemaIdLengthByte()</a></span> - Method in class gobblin.metrics.kafka.<a href="gobblin/metrics/kafka/KafkaAvroSchemaRegistry.html" title="class in gobblin.metrics.kafka">KafkaAvroSchemaRegistry</a></dt>
<dd>
<div class="block">Returns the length of schema ids in this schema registry in bytes.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/schemareg/KafkaSchemaRegistryFactory.html#getSchemaRegistry-java.util.Properties-">getSchemaRegistry(Properties)</a></span> - Static method in class gobblin.kafka.schemareg.<a href="gobblin/kafka/schemareg/KafkaSchemaRegistryFactory.html" title="class in gobblin.kafka.schemareg">KafkaSchemaRegistryFactory</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/serialize/LiAvroSerDeHelper.html#getSchemaRegistry-java.util.Map-">getSchemaRegistry(Map&lt;String, ?&gt;)</a></span> - Static method in class gobblin.kafka.serialize.<a href="gobblin/kafka/serialize/LiAvroSerDeHelper.html" title="class in gobblin.kafka.serialize">LiAvroSerDeHelper</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaPartition.html#getTopicName--">getTopicName()</a></span> - Method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaPartition.html" title="class in gobblin.source.extractor.extract.kafka">KafkaPartition</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaUtils.html#getTopicName-gobblin.configuration.State-">getTopicName(State)</a></span> - Static method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaUtils.html" title="class in gobblin.source.extractor.extract.kafka">KafkaUtils</a></dt>
<dd>
<div class="block">Get topic name from a <a href="http://linkedin.github.io/gobblin/javadoc/0.11.0/gobblin-api/gobblin/configuration/State.html?is-external=true" title="class or interface in gobblin.configuration"><code>State</code></a> object.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/ConfigStoreUtils.html#getTopicNameFromURI-java.net.URI-">getTopicNameFromURI(URI)</a></span> - Static method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/ConfigStoreUtils.html" title="class in gobblin.source.extractor.extract.kafka">ConfigStoreUtils</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/client/AbstractBaseKafkaConsumerClient.html#getTopics--">getTopics()</a></span> - Method in class gobblin.kafka.client.<a href="gobblin/kafka/client/AbstractBaseKafkaConsumerClient.html" title="class in gobblin.kafka.client">AbstractBaseKafkaConsumerClient</a></dt>
<dd>
<div class="block">Get a list of all kafka topics</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/ConfigStoreUtils.html#getTopicsFromConfigStore-java.util.Properties-java.lang.String-gobblin.kafka.client.GobblinKafkaConsumerClient-">getTopicsFromConfigStore(Properties, String, GobblinKafkaConsumerClient)</a></span> - Static method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/ConfigStoreUtils.html" title="class in gobblin.source.extractor.extract.kafka">ConfigStoreUtils</a></dt>
<dd>
<div class="block">Get topics from config store.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/ConfigStoreUtils.html#getTopicsURIFromConfigStore-gobblin.config.client.ConfigClient-org.apache.hadoop.fs.Path-java.lang.String-com.google.common.base.Optional-">getTopicsURIFromConfigStore(ConfigClient, Path, String, Optional&lt;Config&gt;)</a></span> - Static method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/ConfigStoreUtils.html" title="class in gobblin.source.extractor.extract.kafka">ConfigStoreUtils</a></dt>
<dd>
<div class="block">Will return the list of URIs given which are importing tag </div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/ConfigStoreUtils.html#getUriStringForTopic-java.lang.String-java.lang.String-java.lang.String-">getUriStringForTopic(String, String, String)</a></span> - Static method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/ConfigStoreUtils.html" title="class in gobblin.source.extractor.extract.kafka">ConfigStoreUtils</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/client/DecodeableKafkaRecord.html#getValue--">getValue()</a></span> - Method in interface gobblin.kafka.client.<a href="gobblin/kafka/client/DecodeableKafkaRecord.html" title="interface in gobblin.kafka.client">DecodeableKafkaRecord</a></dt>
<dd>
<div class="block">The value of this record.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/client/BaseKafkaConsumerRecord.html#getValueSizeInBytes--">getValueSizeInBytes()</a></span> - Method in class gobblin.kafka.client.<a href="gobblin/kafka/client/BaseKafkaConsumerRecord.html" title="class in gobblin.kafka.client">BaseKafkaConsumerRecord</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/client/KafkaConsumerRecord.html#getValueSizeInBytes--">getValueSizeInBytes()</a></span> - Method in interface gobblin.kafka.client.<a href="gobblin/kafka/client/KafkaConsumerRecord.html" title="interface in gobblin.kafka.client">KafkaConsumerRecord</a></dt>
<dd>
<div class="block">Size of the message in bytes.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/workunit/packer/KafkaWorkUnitPacker.html#getWatermarkIntervalFromMultiWorkUnit-gobblin.source.workunit.MultiWorkUnit-">getWatermarkIntervalFromMultiWorkUnit(MultiWorkUnit)</a></span> - Static method in class gobblin.source.extractor.extract.kafka.workunit.packer.<a href="gobblin/source/extractor/extract/kafka/workunit/packer/KafkaWorkUnitPacker.html" title="class in gobblin.source.extractor.extract.kafka.workunit.packer">KafkaWorkUnitPacker</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/workunit/packer/KafkaWorkUnitPacker.html#getWatermarkIntervalFromWorkUnit-gobblin.source.workunit.WorkUnit-">getWatermarkIntervalFromWorkUnit(WorkUnit)</a></span> - Static method in class gobblin.source.extractor.extract.kafka.workunit.packer.<a href="gobblin/source/extractor/extract/kafka/workunit/packer/KafkaWorkUnitPacker.html" title="class in gobblin.source.extractor.extract.kafka.workunit.packer">KafkaWorkUnitPacker</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/workunit/packer/KafkaWorkUnitPacker.html#getWorkUnitEstLoad-gobblin.source.workunit.WorkUnit-">getWorkUnitEstLoad(WorkUnit)</a></span> - Static method in class gobblin.source.extractor.extract.kafka.workunit.packer.<a href="gobblin/source/extractor/extract/kafka/workunit/packer/KafkaWorkUnitPacker.html" title="class in gobblin.source.extractor.extract.kafka.workunit.packer">KafkaWorkUnitPacker</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/workunit/packer/KafkaWorkUnitPacker.html#getWorkUnitEstSize-gobblin.source.workunit.WorkUnit-">getWorkUnitEstSize(WorkUnit)</a></span> - Static method in class gobblin.source.extractor.extract.kafka.workunit.packer.<a href="gobblin/source/extractor/extract/kafka/workunit/packer/KafkaWorkUnitPacker.html" title="class in gobblin.source.extractor.extract.kafka.workunit.packer">KafkaWorkUnitPacker</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaSource.html#getWorkunits-gobblin.configuration.SourceState-">getWorkunits(SourceState)</a></span> - Method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaSource.html" title="class in gobblin.source.extractor.extract.kafka">KafkaSource</a></dt>
<dd>&nbsp;</dd>
<dt><a href="gobblin/converter/package-summary.html">gobblin.converter</a> - package gobblin.converter</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/schemareg/package-summary.html">gobblin.kafka.schemareg</a> - package gobblin.kafka.schemareg</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/metrics/kafka/package-summary.html">gobblin.metrics.kafka</a> - package gobblin.metrics.kafka</dt>
<dd>&nbsp;</dd>
<dt><a href="gobblin/metrics/reporter/util/package-summary.html">gobblin.metrics.reporter.util</a> - package gobblin.metrics.reporter.util</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><a href="gobblin/source/extractor/extract/kafka/workunit/packer/package-summary.html">gobblin.source.extractor.extract.kafka.workunit.packer</a> - package gobblin.source.extractor.extract.kafka.workunit.packer</dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/ConfigStoreUtils.html#GOBBLIN_CONFIG_COMMONPATH">GOBBLIN_CONFIG_COMMONPATH</a></span> - Static variable in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/ConfigStoreUtils.html" title="class in gobblin.source.extractor.extract.kafka">ConfigStoreUtils</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/ConfigStoreUtils.html#GOBBLIN_CONFIG_FILTER">GOBBLIN_CONFIG_FILTER</a></span> - Static variable in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/ConfigStoreUtils.html" title="class in gobblin.source.extractor.extract.kafka">ConfigStoreUtils</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/ConfigStoreUtils.html#GOBBLIN_CONFIG_TAGS_BLACKLIST">GOBBLIN_CONFIG_TAGS_BLACKLIST</a></span> - Static variable in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/ConfigStoreUtils.html" title="class in gobblin.source.extractor.extract.kafka">ConfigStoreUtils</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/ConfigStoreUtils.html#GOBBLIN_CONFIG_TAGS_WHITELIST">GOBBLIN_CONFIG_TAGS_WHITELIST</a></span> - Static variable in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/ConfigStoreUtils.html" title="class in gobblin.source.extractor.extract.kafka">ConfigStoreUtils</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaSource.html#GOBBLIN_KAFKA_CONSUMER_CLIENT_FACTORY_CLASS">GOBBLIN_KAFKA_CONSUMER_CLIENT_FACTORY_CLASS</a></span> - Static variable in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaSource.html" title="class in gobblin.source.extractor.extract.kafka">KafkaSource</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaSource.html#GOBBLIN_KAFKA_EXTRACT_ALLOW_TABLE_TYPE_NAMESPACE_CUSTOMIZATION">GOBBLIN_KAFKA_EXTRACT_ALLOW_TABLE_TYPE_NAMESPACE_CUSTOMIZATION</a></span> - Static variable in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaSource.html" title="class in gobblin.source.extractor.extract.kafka">KafkaSource</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaExtractor.html#GOBBLIN_KAFKA_NAMESPACE">GOBBLIN_KAFKA_NAMESPACE</a></span> - Static variable in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaExtractor.html" title="class in gobblin.source.extractor.extract.kafka">KafkaExtractor</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaSource.html#GOBBLIN_KAFKA_SHOULD_ENABLE_DATASET_STATESTORE">GOBBLIN_KAFKA_SHOULD_ENABLE_DATASET_STATESTORE</a></span> - Static variable in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaSource.html" title="class in gobblin.source.extractor.extract.kafka">KafkaSource</a></dt>
<dd>&nbsp;</dd>
<dt><a href="gobblin/kafka/client/GobblinKafkaConsumerClient.html" title="interface in gobblin.kafka.client"><span class="typeNameLink">GobblinKafkaConsumerClient</span></a> - Interface in <a href="gobblin/kafka/client/package-summary.html">gobblin.kafka.client</a></dt>
<dd>
<div class="block">A simplified, generic wrapper client to communicate with Kafka.</div>
</dd>
<dt><a href="gobblin/kafka/client/GobblinKafkaConsumerClient.GobblinKafkaConsumerClientFactory.html" title="interface in gobblin.kafka.client"><span class="typeNameLink">GobblinKafkaConsumerClient.GobblinKafkaConsumerClientFactory</span></a> - Interface in <a href="gobblin/kafka/client/package-summary.html">gobblin.kafka.client</a></dt>
<dd>
<div class="block">A factory to create <a href="gobblin/kafka/client/GobblinKafkaConsumerClient.html" title="interface in gobblin.kafka.client"><code>GobblinKafkaConsumerClient</code></a>s</div>
</dd>
</dl>
<a name="I:H">
<!-- -->
</a>
<h2 class="title">H</h2>
<dl>
<dt><span class="memberNameLink"><a href="gobblin/kafka/serialize/MD5Digest.html#hashCode--">hashCode()</a></span> - Method in class gobblin.kafka.serialize.<a href="gobblin/kafka/serialize/MD5Digest.html" title="class in gobblin.kafka.serialize">MD5Digest</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaPartition.html#hashCode--">hashCode()</a></span> - Method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaPartition.html" title="class in gobblin.source.extractor.extract.kafka">KafkaPartition</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaRecord.html#hashCode--">hashCode()</a></span> - Method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaRecord.html" title="class in gobblin.source.extractor.extract.kafka">KafkaRecord</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/schemareg/CachingKafkaSchemaRegistry.html#hasInternalCache--">hasInternalCache()</a></span> - Method in class gobblin.kafka.schemareg.<a href="gobblin/kafka/schemareg/CachingKafkaSchemaRegistry.html" title="class in gobblin.kafka.schemareg">CachingKafkaSchemaRegistry</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/schemareg/ConfigDrivenMd5SchemaRegistry.html#hasInternalCache--">hasInternalCache()</a></span> - Method in class gobblin.kafka.schemareg.<a href="gobblin/kafka/schemareg/ConfigDrivenMd5SchemaRegistry.html" title="class in gobblin.kafka.schemareg">ConfigDrivenMd5SchemaRegistry</a></dt>
<dd>
<div class="block">SchemaRegistry implementations that do not have an internal cache can set this to false
and Gobblin will supplement such registries with a cache on top (if enabled).</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/schemareg/KafkaSchemaRegistry.html#hasInternalCache--">hasInternalCache()</a></span> - Method in interface gobblin.kafka.schemareg.<a href="gobblin/kafka/schemareg/KafkaSchemaRegistry.html" title="interface in gobblin.kafka.schemareg">KafkaSchemaRegistry</a></dt>
<dd>
<div class="block">SchemaRegistry implementations that do not have an internal cache can set this to false
and Gobblin will supplement such registries with a cache on top (if enabled).</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/schemareg/LiKafkaSchemaRegistry.html#hasInternalCache--">hasInternalCache()</a></span> - Method in class gobblin.kafka.schemareg.<a href="gobblin/kafka/schemareg/LiKafkaSchemaRegistry.html" title="class in gobblin.kafka.schemareg">LiKafkaSchemaRegistry</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaExtractor.html#highWatermark">highWatermark</a></span> - Variable in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaExtractor.html" title="class in gobblin.source.extractor.extract.kafka">KafkaExtractor</a></dt>
<dd>&nbsp;</dd>
<dt><a href="gobblin/kafka/schemareg/HttpClientFactory.html" title="class in gobblin.kafka.schemareg"><span class="typeNameLink">HttpClientFactory</span></a> - Class in <a href="gobblin/kafka/schemareg/package-summary.html">gobblin.kafka.schemareg</a></dt>
<dd>
<div class="block">An implementation of <code>BasePooledObjectFactory</code> for <code>HttpClient</code>.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/schemareg/HttpClientFactory.html#HttpClientFactory--">HttpClientFactory()</a></span> - Constructor for class gobblin.kafka.schemareg.<a href="gobblin/kafka/schemareg/HttpClientFactory.html" title="class in gobblin.kafka.schemareg">HttpClientFactory</a></dt>
<dd>&nbsp;</dd>
</dl>
<a name="I:I">
<!-- -->
</a>
<h2 class="title">I</h2>
<dl>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/MultiLongWatermark.html#increment-int-">increment(int)</a></span> - Method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/MultiLongWatermark.html" title="class in gobblin.source.extractor.extract.kafka">MultiLongWatermark</a></dt>
<dd>
<div class="block">Increment the idx'th value.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/converter/EnvelopeSchemaConverter.html#init-gobblin.configuration.WorkUnitState-">init(WorkUnitState)</a></span> - Method in class gobblin.converter.<a href="gobblin/converter/EnvelopeSchemaConverter.html" title="class in gobblin.converter">EnvelopeSchemaConverter</a></dt>
<dd>
<div class="block">To remove certain fields from the Avro schema or records of a topic/table, set property
{topic/table name}.remove.fields={comma-separated, fully qualified field names} in workUnit.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/converter/LiKafkaByteArrayMsgToAvroConverter.html#init-gobblin.configuration.WorkUnitState-">init(WorkUnitState)</a></span> - Method in class gobblin.converter.<a href="gobblin/converter/LiKafkaByteArrayMsgToAvroConverter.html" title="class in gobblin.converter">LiKafkaByteArrayMsgToAvroConverter</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaExtractor.html#INITIAL_PARTITION_IDX">INITIAL_PARTITION_IDX</a></span> - Static variable in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaExtractor.html" title="class in gobblin.source.extractor.extract.kafka">KafkaExtractor</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/workunit/packer/KafkaWorkUnitPacker.html#isFullExtract">isFullExtract</a></span> - Variable in class gobblin.source.extractor.extract.kafka.workunit.packer.<a href="gobblin/source/extractor/extract/kafka/workunit/packer/KafkaWorkUnitPacker.html" title="class in gobblin.source.extractor.extract.kafka.workunit.packer">KafkaWorkUnitPacker</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaSource.html#isTopicQualified-gobblin.source.extractor.extract.kafka.KafkaTopic-">isTopicQualified(KafkaTopic)</a></span> - Method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaSource.html" title="class in gobblin.source.extractor.extract.kafka">KafkaSource</a></dt>
<dd>
<div class="block">Whether a <a href="gobblin/source/extractor/extract/kafka/KafkaTopic.html" title="class in gobblin.source.extractor.extract.kafka"><code>KafkaTopic</code></a> is qualified to be pulled.</div>
</dd>
</dl>
<a name="I:K">
<!-- -->
</a>
<h2 class="title">K</h2>
<dl>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaExtractor.html#KAFKA_EXTRACTOR_TOPIC_METADATA_EVENT_NAME">KAFKA_EXTRACTOR_TOPIC_METADATA_EVENT_NAME</a></span> - Static variable in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaExtractor.html" title="class in gobblin.source.extractor.extract.kafka">KafkaExtractor</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/writer/KafkaWriterConfigurationKeys.html#KAFKA_PRODUCER_CONFIG_PREFIX">KAFKA_PRODUCER_CONFIG_PREFIX</a></span> - Static variable in class gobblin.kafka.writer.<a href="gobblin/kafka/writer/KafkaWriterConfigurationKeys.html" title="class in gobblin.kafka.writer">KafkaWriterConfigurationKeys</a></dt>
<dd>
<div class="block">Kafka producer configurations will be passed through as is as long as they are prefixed
by the PREFIX specified below.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/schemareg/KafkaSchemaRegistryConfigurationKeys.html#KAFKA_SCHEMA_REGISTRY_CACHE">KAFKA_SCHEMA_REGISTRY_CACHE</a></span> - Static variable in class gobblin.kafka.schemareg.<a href="gobblin/kafka/schemareg/KafkaSchemaRegistryConfigurationKeys.html" title="class in gobblin.kafka.schemareg">KafkaSchemaRegistryConfigurationKeys</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/metrics/kafka/KafkaSchemaRegistry.html#KAFKA_SCHEMA_REGISTRY_CACHE_EXPIRE_AFTER_WRITE_MIN">KAFKA_SCHEMA_REGISTRY_CACHE_EXPIRE_AFTER_WRITE_MIN</a></span> - Static variable in class gobblin.metrics.kafka.<a href="gobblin/metrics/kafka/KafkaSchemaRegistry.html" title="class in gobblin.metrics.kafka">KafkaSchemaRegistry</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/schemareg/KafkaSchemaRegistryConfigurationKeys.html#KAFKA_SCHEMA_REGISTRY_CLASS">KAFKA_SCHEMA_REGISTRY_CLASS</a></span> - Static variable in class gobblin.kafka.schemareg.<a href="gobblin/kafka/schemareg/KafkaSchemaRegistryConfigurationKeys.html" title="class in gobblin.kafka.schemareg">KafkaSchemaRegistryConfigurationKeys</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/metrics/kafka/KafkaSchemaRegistry.html#KAFKA_SCHEMA_REGISTRY_CLASS">KAFKA_SCHEMA_REGISTRY_CLASS</a></span> - Static variable in class gobblin.metrics.kafka.<a href="gobblin/metrics/kafka/KafkaSchemaRegistry.html" title="class in gobblin.metrics.kafka">KafkaSchemaRegistry</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/metrics/kafka/KafkaSchemaRegistryFactory.html#KAFKA_SCHEMA_REGISTRY_FACTORY_CLASS">KAFKA_SCHEMA_REGISTRY_FACTORY_CLASS</a></span> - Static variable in interface gobblin.metrics.kafka.<a href="gobblin/metrics/kafka/KafkaSchemaRegistryFactory.html" title="interface in gobblin.metrics.kafka">KafkaSchemaRegistryFactory</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/metrics/kafka/KafkaSchemaRegistry.html#KAFKA_SCHEMA_REGISTRY_MAX_CACHE_SIZE">KAFKA_SCHEMA_REGISTRY_MAX_CACHE_SIZE</a></span> - Static variable in class gobblin.metrics.kafka.<a href="gobblin/metrics/kafka/KafkaSchemaRegistry.html" title="class in gobblin.metrics.kafka">KafkaSchemaRegistry</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/schemareg/KafkaSchemaRegistryConfigurationKeys.html#KAFKA_SCHEMA_REGISTRY_URL">KAFKA_SCHEMA_REGISTRY_URL</a></span> - Static variable in class gobblin.kafka.schemareg.<a href="gobblin/kafka/schemareg/KafkaSchemaRegistryConfigurationKeys.html" title="class in gobblin.kafka.schemareg">KafkaSchemaRegistryConfigurationKeys</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/metrics/kafka/KafkaSchemaRegistry.html#KAFKA_SCHEMA_REGISTRY_URL">KAFKA_SCHEMA_REGISTRY_URL</a></span> - Static variable in class gobblin.metrics.kafka.<a href="gobblin/metrics/kafka/KafkaSchemaRegistry.html" title="class in gobblin.metrics.kafka">KafkaSchemaRegistry</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/writer/KafkaWriterConfigurationKeys.html#KAFKA_TOPIC">KAFKA_TOPIC</a></span> - Static variable in class gobblin.kafka.writer.<a href="gobblin/kafka/writer/KafkaWriterConfigurationKeys.html" title="class in gobblin.kafka.writer">KafkaWriterConfigurationKeys</a></dt>
<dd>
<div class="block">Writer specific configuration keys go here</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/workunit/packer/KafkaWorkUnitPacker.html#KAFKA_WORKUNIT_PACKER_TYPE">KAFKA_WORKUNIT_PACKER_TYPE</a></span> - Static variable in class gobblin.source.extractor.extract.kafka.workunit.packer.<a href="gobblin/source/extractor/extract/kafka/workunit/packer/KafkaWorkUnitPacker.html" title="class in gobblin.source.extractor.extract.kafka.workunit.packer">KafkaWorkUnitPacker</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/workunit/packer/KafkaWorkUnitPacker.html#KAFKA_WORKUNIT_SIZE_ESTIMATOR_TYPE">KAFKA_WORKUNIT_SIZE_ESTIMATOR_TYPE</a></span> - Static variable in class gobblin.source.extractor.extract.kafka.workunit.packer.<a href="gobblin/source/extractor/extract/kafka/workunit/packer/KafkaWorkUnitPacker.html" title="class in gobblin.source.extractor.extract.kafka.workunit.packer">KafkaWorkUnitPacker</a></dt>
<dd>&nbsp;</dd>
<dt><a href="gobblin/source/extractor/extract/kafka/workunit/packer/KafkaAvgRecordSizeBasedWorkUnitSizeEstimator.html" title="class in gobblin.source.extractor.extract.kafka.workunit.packer"><span class="typeNameLink">KafkaAvgRecordSizeBasedWorkUnitSizeEstimator</span></a> - Class in <a href="gobblin/source/extractor/extract/kafka/workunit/packer/package-summary.html">gobblin.source.extractor.extract.kafka.workunit.packer</a></dt>
<dd>
<div class="block">An implementation of <a href="gobblin/source/extractor/extract/kafka/workunit/packer/KafkaWorkUnitSizeEstimator.html" title="interface in gobblin.source.extractor.extract.kafka.workunit.packer"><code>KafkaWorkUnitSizeEstimator</code></a> which uses the average record size of each partition to
estimate the sizes of <code>WorkUnits</code>.</div>
</dd>
<dt><a href="gobblin/source/extractor/extract/kafka/workunit/packer/KafkaAvgRecordTimeBasedWorkUnitSizeEstimator.html" title="class in gobblin.source.extractor.extract.kafka.workunit.packer"><span class="typeNameLink">KafkaAvgRecordTimeBasedWorkUnitSizeEstimator</span></a> - Class in <a href="gobblin/source/extractor/extract/kafka/workunit/packer/package-summary.html">gobblin.source.extractor.extract.kafka.workunit.packer</a></dt>
<dd>
<div class="block">An implementation of <a href="gobblin/source/extractor/extract/kafka/workunit/packer/KafkaWorkUnitSizeEstimator.html" title="interface in gobblin.source.extractor.extract.kafka.workunit.packer"><code>KafkaWorkUnitSizeEstimator</code></a> which uses the average time to pull a record in the
previous run to estimate the sizes of <code>WorkUnits</code>.</div>
</dd>
<dt><a href="gobblin/source/extractor/extract/kafka/KafkaAvroExtractor.html" title="class in gobblin.source.extractor.extract.kafka"><span class="typeNameLink">KafkaAvroExtractor</span></a>&lt;<a href="gobblin/source/extractor/extract/kafka/KafkaAvroExtractor.html" title="type parameter in KafkaAvroExtractor">K</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 abstract implementation of <a href="http://linkedin.github.io/gobblin/javadoc/0.11.0/gobblin-api/gobblin/source/extractor/Extractor.html?is-external=true" title="class or interface in gobblin.source.extractor"><code>Extractor</code></a> for Kafka, where events are in Avro format.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaAvroExtractor.html#KafkaAvroExtractor-gobblin.configuration.WorkUnitState-">KafkaAvroExtractor(WorkUnitState)</a></span> - Constructor for class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaAvroExtractor.html" title="class in gobblin.source.extractor.extract.kafka">KafkaAvroExtractor</a></dt>
<dd>&nbsp;</dd>
<dt><a href="gobblin/metrics/kafka/KafkaAvroSchemaRegistry.html" title="class in gobblin.metrics.kafka"><span class="typeNameLink">KafkaAvroSchemaRegistry</span></a> - Class in <a href="gobblin/metrics/kafka/package-summary.html">gobblin.metrics.kafka</a></dt>
<dd>
<div class="block">An implementation of <a href="gobblin/metrics/kafka/KafkaSchemaRegistry.html" title="class in gobblin.metrics.kafka"><code>KafkaSchemaRegistry</code></a>.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/metrics/kafka/KafkaAvroSchemaRegistry.html#KafkaAvroSchemaRegistry-java.util.Properties-">KafkaAvroSchemaRegistry(Properties)</a></span> - Constructor for class gobblin.metrics.kafka.<a href="gobblin/metrics/kafka/KafkaAvroSchemaRegistry.html" title="class in gobblin.metrics.kafka">KafkaAvroSchemaRegistry</a></dt>
<dd>&nbsp;</dd>
<dt><a href="gobblin/metrics/kafka/KafkaAvroSchemaRegistryFactory.html" title="class in gobblin.metrics.kafka"><span class="typeNameLink">KafkaAvroSchemaRegistryFactory</span></a> - Class in <a href="gobblin/metrics/kafka/package-summary.html">gobblin.metrics.kafka</a></dt>
<dd>
<div class="block">Factory for <a href="gobblin/metrics/kafka/KafkaAvroSchemaRegistry.html" title="class in gobblin.metrics.kafka"><code>KafkaAvroSchemaRegistry</code></a></div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/metrics/kafka/KafkaAvroSchemaRegistryFactory.html#KafkaAvroSchemaRegistryFactory--">KafkaAvroSchemaRegistryFactory()</a></span> - Constructor for class gobblin.metrics.kafka.<a href="gobblin/metrics/kafka/KafkaAvroSchemaRegistryFactory.html" title="class in gobblin.metrics.kafka">KafkaAvroSchemaRegistryFactory</a></dt>
<dd>&nbsp;</dd>
<dt><a href="gobblin/source/extractor/extract/kafka/workunit/packer/KafkaBiLevelWorkUnitPacker.html" title="class in gobblin.source.extractor.extract.kafka.workunit.packer"><span class="typeNameLink">KafkaBiLevelWorkUnitPacker</span></a> - Class in <a href="gobblin/source/extractor/extract/kafka/workunit/packer/package-summary.html">gobblin.source.extractor.extract.kafka.workunit.packer</a></dt>
<dd>
<div class="block">An implementation of <a href="gobblin/source/extractor/extract/kafka/workunit/packer/KafkaWorkUnitPacker.html" title="class in gobblin.source.extractor.extract.kafka.workunit.packer"><code>KafkaWorkUnitPacker</code></a> with two levels of bin packing.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/workunit/packer/KafkaBiLevelWorkUnitPacker.html#KafkaBiLevelWorkUnitPacker-gobblin.source.extractor.extract.AbstractSource-gobblin.configuration.SourceState-">KafkaBiLevelWorkUnitPacker(AbstractSource&lt;?, ?&gt;, SourceState)</a></span> - Constructor for class gobblin.source.extractor.extract.kafka.workunit.packer.<a href="gobblin/source/extractor/extract/kafka/workunit/packer/KafkaBiLevelWorkUnitPacker.html" title="class in gobblin.source.extractor.extract.kafka.workunit.packer">KafkaBiLevelWorkUnitPacker</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaExtractor.html#kafkaConsumerClient">kafkaConsumerClient</a></span> - Variable in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaExtractor.html" title="class in gobblin.source.extractor.extract.kafka">KafkaExtractor</a></dt>
<dd>&nbsp;</dd>
<dt><a href="gobblin/kafka/client/KafkaConsumerRecord.html" title="interface in gobblin.kafka.client"><span class="typeNameLink">KafkaConsumerRecord</span></a> - Interface in <a href="gobblin/kafka/client/package-summary.html">gobblin.kafka.client</a></dt>
<dd>
<div class="block">A kafka message/record consumed from <a href="gobblin/kafka/client/GobblinKafkaConsumerClient.html" title="interface in gobblin.kafka.client"><code>GobblinKafkaConsumerClient</code></a>.</div>
</dd>
<dt><a href="gobblin/source/extractor/extract/kafka/KafkaExtractor.html" title="class in gobblin.source.extractor.extract.kafka"><span class="typeNameLink">KafkaExtractor</span></a>&lt;<a href="gobblin/source/extractor/extract/kafka/KafkaExtractor.html" title="type parameter in KafkaExtractor">S</a>,<a href="gobblin/source/extractor/extract/kafka/KafkaExtractor.html" title="type parameter in KafkaExtractor">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-api/gobblin/source/extractor/Extractor.html?is-external=true" title="class or interface in gobblin.source.extractor"><code>Extractor</code></a> for Apache Kafka.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaExtractor.html#KafkaExtractor-gobblin.configuration.WorkUnitState-">KafkaExtractor(WorkUnitState)</a></span> - Constructor for class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaExtractor.html" title="class in gobblin.source.extractor.extract.kafka">KafkaExtractor</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaPartition.KafkaLeader.html#KafkaLeader-int-com.google.common.net.HostAndPort-">KafkaLeader(int, HostAndPort)</a></span> - Constructor for class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaPartition.KafkaLeader.html" title="class in gobblin.source.extractor.extract.kafka">KafkaPartition.KafkaLeader</a></dt>
<dd>&nbsp;</dd>
<dt><a href="gobblin/source/extractor/extract/kafka/KafkaOffsetRetrievalFailureException.html" title="class in gobblin.source.extractor.extract.kafka"><span class="typeNameLink">KafkaOffsetRetrievalFailureException</span></a> - Exception in <a href="gobblin/source/extractor/extract/kafka/package-summary.html">gobblin.source.extractor.extract.kafka</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaOffsetRetrievalFailureException.html#KafkaOffsetRetrievalFailureException-java.lang.String-">KafkaOffsetRetrievalFailureException(String)</a></span> - Constructor for exception gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaOffsetRetrievalFailureException.html" title="class in gobblin.source.extractor.extract.kafka">KafkaOffsetRetrievalFailureException</a></dt>
<dd>&nbsp;</dd>
<dt><a href="gobblin/source/extractor/extract/kafka/KafkaPartition.html" title="class in gobblin.source.extractor.extract.kafka"><span class="typeNameLink">KafkaPartition</span></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 kafka topic partition.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaPartition.html#KafkaPartition-gobblin.source.extractor.extract.kafka.KafkaPartition-">KafkaPartition(KafkaPartition)</a></span> - Constructor for class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaPartition.html" title="class in gobblin.source.extractor.extract.kafka">KafkaPartition</a></dt>
<dd>&nbsp;</dd>
<dt><a href="gobblin/source/extractor/extract/kafka/KafkaPartition.Builder.html" title="class in gobblin.source.extractor.extract.kafka"><span class="typeNameLink">KafkaPartition.Builder</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/KafkaPartition.KafkaLeader.html" title="class in gobblin.source.extractor.extract.kafka"><span class="typeNameLink">KafkaPartition.KafkaLeader</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/KafkaRecord.html" title="class in gobblin.source.extractor.extract.kafka"><span class="typeNameLink">KafkaRecord</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><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaRecord.html#KafkaRecord-long-java.lang.String-java.lang.String-">KafkaRecord(long, String, String)</a></span> - Constructor for class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaRecord.html" title="class in gobblin.source.extractor.extract.kafka">KafkaRecord</a></dt>
<dd>&nbsp;</dd>
<dt><a href="gobblin/kafka/schemareg/KafkaSchemaRegistry.html" title="interface in gobblin.kafka.schemareg"><span class="typeNameLink">KafkaSchemaRegistry</span></a>&lt;<a href="gobblin/kafka/schemareg/KafkaSchemaRegistry.html" title="type parameter in KafkaSchemaRegistry">K</a>,<a href="gobblin/kafka/schemareg/KafkaSchemaRegistry.html" title="type parameter in KafkaSchemaRegistry">S</a>&gt; - Interface in <a href="gobblin/kafka/schemareg/package-summary.html">gobblin.kafka.schemareg</a></dt>
<dd>
<div class="block">An interface for a Kafka Schema Registry
Classes implementing this interface will typically be constructed by a <a href="gobblin/kafka/schemareg/KafkaSchemaRegistryFactory.html" title="class in gobblin.kafka.schemareg"><code>KafkaSchemaRegistryFactory</code></a>
and should have a constructor that takes a <a href="https://docs.oracle.com/javase/7/docs/api/java/util/Properties.html?is-external=true" title="class or interface in java.util"><code>Properties</code></a> object as a parameter.</div>
</dd>
<dt><a href="gobblin/metrics/kafka/KafkaSchemaRegistry.html" title="class in gobblin.metrics.kafka"><span class="typeNameLink">KafkaSchemaRegistry</span></a>&lt;<a href="gobblin/metrics/kafka/KafkaSchemaRegistry.html" title="type parameter in KafkaSchemaRegistry">K</a>,<a href="gobblin/metrics/kafka/KafkaSchemaRegistry.html" title="type parameter in KafkaSchemaRegistry">S</a>&gt; - Class in <a href="gobblin/metrics/kafka/package-summary.html">gobblin.metrics.kafka</a></dt>
<dd>
<div class="block">A abstract schema registry class for Kafka, which supports fetching schema by key, fetching the latest schema
of a topic, and registering a schema.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/metrics/kafka/KafkaSchemaRegistry.html#KafkaSchemaRegistry-java.util.Properties-">KafkaSchemaRegistry(Properties)</a></span> - Constructor for class gobblin.metrics.kafka.<a href="gobblin/metrics/kafka/KafkaSchemaRegistry.html" title="class in gobblin.metrics.kafka">KafkaSchemaRegistry</a></dt>
<dd>&nbsp;</dd>
<dt><a href="gobblin/kafka/schemareg/KafkaSchemaRegistryConfigurationKeys.html" title="class in gobblin.kafka.schemareg"><span class="typeNameLink">KafkaSchemaRegistryConfigurationKeys</span></a> - Class in <a href="gobblin/kafka/schemareg/package-summary.html">gobblin.kafka.schemareg</a></dt>
<dd>
<div class="block">Configuration keys for a kafka schema registry</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/schemareg/KafkaSchemaRegistryConfigurationKeys.html#KafkaSchemaRegistryConfigurationKeys--">KafkaSchemaRegistryConfigurationKeys()</a></span> - Constructor for class gobblin.kafka.schemareg.<a href="gobblin/kafka/schemareg/KafkaSchemaRegistryConfigurationKeys.html" title="class in gobblin.kafka.schemareg">KafkaSchemaRegistryConfigurationKeys</a></dt>
<dd>&nbsp;</dd>
<dt><a href="gobblin/kafka/schemareg/KafkaSchemaRegistryFactory.html" title="class in gobblin.kafka.schemareg"><span class="typeNameLink">KafkaSchemaRegistryFactory</span></a> - Class in <a href="gobblin/kafka/schemareg/package-summary.html">gobblin.kafka.schemareg</a></dt>
<dd>
<div class="block">A Factory that constructs and hands back <a href="gobblin/kafka/schemareg/KafkaSchemaRegistry.html" title="interface in gobblin.kafka.schemareg"><code>KafkaSchemaRegistry</code></a> implementations.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/schemareg/KafkaSchemaRegistryFactory.html#KafkaSchemaRegistryFactory--">KafkaSchemaRegistryFactory()</a></span> - Constructor for class gobblin.kafka.schemareg.<a href="gobblin/kafka/schemareg/KafkaSchemaRegistryFactory.html" title="class in gobblin.kafka.schemareg">KafkaSchemaRegistryFactory</a></dt>
<dd>&nbsp;</dd>
<dt><a href="gobblin/metrics/kafka/KafkaSchemaRegistryFactory.html" title="interface in gobblin.metrics.kafka"><span class="typeNameLink">KafkaSchemaRegistryFactory</span></a> - Interface in <a href="gobblin/metrics/kafka/package-summary.html">gobblin.metrics.kafka</a></dt>
<dd>
<div class="block">Interface for factories for <a href="gobblin/metrics/kafka/KafkaSchemaRegistry.html" title="class in gobblin.metrics.kafka"><code>KafkaSchemaRegistry</code></a></div>
</dd>
<dt><a href="gobblin/source/extractor/extract/kafka/KafkaSimpleExtractor.html" title="class in gobblin.source.extractor.extract.kafka"><span class="typeNameLink">KafkaSimpleExtractor</span></a> - Class in <a href="gobblin/source/extractor/extract/kafka/package-summary.html">gobblin.source.extractor.extract.kafka</a></dt>
<dd>
<div class="block"><span class="deprecatedLabel">Deprecated.</span>
<div class="block"><span class="deprecationComment">use <code>KafkaDeserializerExtractor</code> and <code>KafkaDeserializerExtractor.Deserializers#BYTE_ARRAY</code> instead</span></div>
</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaSimpleExtractor.html#KafkaSimpleExtractor-gobblin.configuration.WorkUnitState-">KafkaSimpleExtractor(WorkUnitState)</a></span> - Constructor for class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaSimpleExtractor.html" title="class in gobblin.source.extractor.extract.kafka">KafkaSimpleExtractor</a></dt>
<dd>
<div class="block"><span class="deprecatedLabel">Deprecated.</span></div>
&nbsp;</dd>
<dt><a href="gobblin/source/extractor/extract/kafka/KafkaSimpleJsonExtractor.html" title="class in gobblin.source.extractor.extract.kafka"><span class="typeNameLink">KafkaSimpleJsonExtractor</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><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaSimpleJsonExtractor.html#KafkaSimpleJsonExtractor-gobblin.configuration.WorkUnitState-">KafkaSimpleJsonExtractor(WorkUnitState)</a></span> - Constructor for class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaSimpleJsonExtractor.html" title="class in gobblin.source.extractor.extract.kafka">KafkaSimpleJsonExtractor</a></dt>
<dd>&nbsp;</dd>
<dt><a href="gobblin/source/extractor/extract/kafka/KafkaSimpleSource.html" title="class in gobblin.source.extractor.extract.kafka"><span class="typeNameLink">KafkaSimpleSource</span></a> - Class in <a href="gobblin/source/extractor/extract/kafka/package-summary.html">gobblin.source.extractor.extract.kafka</a></dt>
<dd>
<div class="block"><span class="deprecatedLabel">Deprecated.</span>
<div class="block"><span class="deprecationComment">use <code>KafkaDeserializerSource</code> and <code>KafkaDeserializerExtractor.Deserializers#BYTE_ARRAY</code> instead</span></div>
</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaSimpleSource.html#KafkaSimpleSource--">KafkaSimpleSource()</a></span> - Constructor for class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaSimpleSource.html" title="class in gobblin.source.extractor.extract.kafka">KafkaSimpleSource</a></dt>
<dd>
<div class="block"><span class="deprecatedLabel">Deprecated.</span></div>
&nbsp;</dd>
<dt><a href="gobblin/source/extractor/extract/kafka/workunit/packer/KafkaSingleLevelWorkUnitPacker.html" title="class in gobblin.source.extractor.extract.kafka.workunit.packer"><span class="typeNameLink">KafkaSingleLevelWorkUnitPacker</span></a> - Class in <a href="gobblin/source/extractor/extract/kafka/workunit/packer/package-summary.html">gobblin.source.extractor.extract.kafka.workunit.packer</a></dt>
<dd>
<div class="block">An implementation of <a href="gobblin/source/extractor/extract/kafka/workunit/packer/KafkaWorkUnitPacker.html" title="class in gobblin.source.extractor.extract.kafka.workunit.packer"><code>KafkaWorkUnitPacker</code></a> with a single level of bin packing using worst-fit-decreasing.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/workunit/packer/KafkaSingleLevelWorkUnitPacker.html#KafkaSingleLevelWorkUnitPacker-gobblin.source.extractor.extract.AbstractSource-gobblin.configuration.SourceState-">KafkaSingleLevelWorkUnitPacker(AbstractSource&lt;?, ?&gt;, SourceState)</a></span> - Constructor for class gobblin.source.extractor.extract.kafka.workunit.packer.<a href="gobblin/source/extractor/extract/kafka/workunit/packer/KafkaSingleLevelWorkUnitPacker.html" title="class in gobblin.source.extractor.extract.kafka.workunit.packer">KafkaSingleLevelWorkUnitPacker</a></dt>
<dd>&nbsp;</dd>
<dt><a href="gobblin/source/extractor/extract/kafka/KafkaSource.html" title="class in gobblin.source.extractor.extract.kafka"><span class="typeNameLink">KafkaSource</span></a>&lt;<a href="gobblin/source/extractor/extract/kafka/KafkaSource.html" title="type parameter in KafkaSource">S</a>,<a href="gobblin/source/extractor/extract/kafka/KafkaSource.html" title="type parameter in KafkaSource">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-api/gobblin/source/Source.html?is-external=true" title="class or interface in gobblin.source"><code>Source</code></a> implementation for Kafka source.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaSource.html#KafkaSource--">KafkaSource()</a></span> - Constructor for class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaSource.html" title="class in gobblin.source.extractor.extract.kafka">KafkaSource</a></dt>
<dd>&nbsp;</dd>
<dt><a href="gobblin/source/extractor/extract/kafka/KafkaTopic.html" title="class in gobblin.source.extractor.extract.kafka"><span class="typeNameLink">KafkaTopic</span></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 kafka topic is composed of a topic name, and a list of partitions.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaTopic.html#KafkaTopic-java.lang.String-java.util.List-">KafkaTopic(String, List&lt;KafkaPartition&gt;)</a></span> - Constructor for class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaTopic.html" title="class in gobblin.source.extractor.extract.kafka">KafkaTopic</a></dt>
<dd>&nbsp;</dd>
<dt><a href="gobblin/source/extractor/extract/kafka/KafkaUtils.html" title="class in gobblin.source.extractor.extract.kafka"><span class="typeNameLink">KafkaUtils</span></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 Utils class for Kafka.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaUtils.html#KafkaUtils--">KafkaUtils()</a></span> - Constructor for class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaUtils.html" title="class in gobblin.source.extractor.extract.kafka">KafkaUtils</a></dt>
<dd>&nbsp;</dd>
<dt><a href="gobblin/source/extractor/extract/kafka/workunit/packer/KafkaWorkUnitPacker.html" title="class in gobblin.source.extractor.extract.kafka.workunit.packer"><span class="typeNameLink">KafkaWorkUnitPacker</span></a> - Class in <a href="gobblin/source/extractor/extract/kafka/workunit/packer/package-summary.html">gobblin.source.extractor.extract.kafka.workunit.packer</a></dt>
<dd>
<div class="block">An abstract class for packing Kafka <a href="http://linkedin.github.io/gobblin/javadoc/0.11.0/gobblin-api/gobblin/source/workunit/WorkUnit.html?is-external=true" title="class or interface in gobblin.source.workunit"><code>WorkUnit</code></a>s into <a href="http://linkedin.github.io/gobblin/javadoc/0.11.0/gobblin-api/gobblin/source/workunit/MultiWorkUnit.html?is-external=true" title="class or interface in gobblin.source.workunit"><code>MultiWorkUnit</code></a>s
based on the number of containers.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/workunit/packer/KafkaWorkUnitPacker.html#KafkaWorkUnitPacker-gobblin.source.extractor.extract.AbstractSource-gobblin.configuration.SourceState-">KafkaWorkUnitPacker(AbstractSource&lt;?, ?&gt;, SourceState)</a></span> - Constructor for class gobblin.source.extractor.extract.kafka.workunit.packer.<a href="gobblin/source/extractor/extract/kafka/workunit/packer/KafkaWorkUnitPacker.html" title="class in gobblin.source.extractor.extract.kafka.workunit.packer">KafkaWorkUnitPacker</a></dt>
<dd>&nbsp;</dd>
<dt><a href="gobblin/source/extractor/extract/kafka/workunit/packer/KafkaWorkUnitPacker.PackerType.html" title="enum in gobblin.source.extractor.extract.kafka.workunit.packer"><span class="typeNameLink">KafkaWorkUnitPacker.PackerType</span></a> - Enum in <a href="gobblin/source/extractor/extract/kafka/workunit/packer/package-summary.html">gobblin.source.extractor.extract.kafka.workunit.packer</a></dt>
<dd>&nbsp;</dd>
<dt><a href="gobblin/source/extractor/extract/kafka/workunit/packer/KafkaWorkUnitPacker.SizeEstimatorType.html" title="enum in gobblin.source.extractor.extract.kafka.workunit.packer"><span class="typeNameLink">KafkaWorkUnitPacker.SizeEstimatorType</span></a> - Enum in <a href="gobblin/source/extractor/extract/kafka/workunit/packer/package-summary.html">gobblin.source.extractor.extract.kafka.workunit.packer</a></dt>
<dd>&nbsp;</dd>
<dt><a href="gobblin/source/extractor/extract/kafka/workunit/packer/KafkaWorkUnitSizeEstimator.html" title="interface in gobblin.source.extractor.extract.kafka.workunit.packer"><span class="typeNameLink">KafkaWorkUnitSizeEstimator</span></a> - Interface in <a href="gobblin/source/extractor/extract/kafka/workunit/packer/package-summary.html">gobblin.source.extractor.extract.kafka.workunit.packer</a></dt>
<dd>
<div class="block">Estimates the size of a Kafka <a href="http://linkedin.github.io/gobblin/javadoc/0.11.0/gobblin-api/gobblin/source/workunit/WorkUnit.html?is-external=true" title="class or interface in gobblin.source.workunit"><code>WorkUnit</code></a>, which contains one or more partitions of the same topic.</div>
</dd>
<dt><a href="gobblin/kafka/writer/KafkaWriterConfigurationKeys.html" title="class in gobblin.kafka.writer"><span class="typeNameLink">KafkaWriterConfigurationKeys</span></a> - Class in <a href="gobblin/kafka/writer/package-summary.html">gobblin.kafka.writer</a></dt>
<dd>
<div class="block">Configuration keys for a KafkaWriter.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/writer/KafkaWriterConfigurationKeys.html#KafkaWriterConfigurationKeys--">KafkaWriterConfigurationKeys()</a></span> - Constructor for class gobblin.kafka.writer.<a href="gobblin/kafka/writer/KafkaWriterConfigurationKeys.html" title="class in gobblin.kafka.writer">KafkaWriterConfigurationKeys</a></dt>
<dd>&nbsp;</dd>
<dt><a href="gobblin/kafka/writer/KafkaWriterHelper.html" title="class in gobblin.kafka.writer"><span class="typeNameLink">KafkaWriterHelper</span></a> - Class in <a href="gobblin/kafka/writer/package-summary.html">gobblin.kafka.writer</a></dt>
<dd>
<div class="block">Helper class for version-specific Kafka writers</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/writer/KafkaWriterHelper.html#KafkaWriterHelper--">KafkaWriterHelper()</a></span> - Constructor for class gobblin.kafka.writer.<a href="gobblin/kafka/writer/KafkaWriterHelper.html" title="class in gobblin.kafka.writer">KafkaWriterHelper</a></dt>
<dd>&nbsp;</dd>
<dt><a href="gobblin/kafka/writer/KafkaWriterMetricNames.html" title="class in gobblin.kafka.writer"><span class="typeNameLink">KafkaWriterMetricNames</span></a> - Class in <a href="gobblin/kafka/writer/package-summary.html">gobblin.kafka.writer</a></dt>
<dd>
<div class="block">Listing of Metrics names used by the <code>KafkaDataWriter</code></div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/writer/KafkaWriterMetricNames.html#KafkaWriterMetricNames--">KafkaWriterMetricNames()</a></span> - Constructor for class gobblin.kafka.writer.<a href="gobblin/kafka/writer/KafkaWriterMetricNames.html" title="class in gobblin.kafka.writer">KafkaWriterMetricNames</a></dt>
<dd>&nbsp;</dd>
</dl>
<a name="I:L">
<!-- -->
</a>
<h2 class="title">L</h2>
<dl>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaSource.html#LATEST_OFFSET">LATEST_OFFSET</a></span> - Static variable in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaSource.html" title="class in gobblin.source.extractor.extract.kafka">KafkaSource</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaSource.html#LEADER_HOSTANDPORT">LEADER_HOSTANDPORT</a></span> - Static variable in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaSource.html" title="class in gobblin.source.extractor.extract.kafka">KafkaSource</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaSource.html#LEADER_ID">LEADER_ID</a></span> - Static variable in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaSource.html" title="class in gobblin.source.extractor.extract.kafka">KafkaSource</a></dt>
<dd>&nbsp;</dd>
<dt><a href="gobblin/kafka/serialize/LiAvroDeserializerBase.html" title="class in gobblin.kafka.serialize"><span class="typeNameLink">LiAvroDeserializerBase</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/LiAvroSerializerBase.html" title="class in gobblin.kafka.serialize"><code>LiAvroSerializerBase</code></a>)</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/serialize/LiAvroDeserializerBase.html#LiAvroDeserializerBase--">LiAvroDeserializerBase()</a></span> - Constructor for class gobblin.kafka.serialize.<a href="gobblin/kafka/serialize/LiAvroDeserializerBase.html" title="class in gobblin.kafka.serialize">LiAvroDeserializerBase</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/serialize/LiAvroDeserializerBase.html#LiAvroDeserializerBase-gobblin.kafka.schemareg.KafkaSchemaRegistry-">LiAvroDeserializerBase(KafkaSchemaRegistry&lt;MD5Digest, Schema&gt;)</a></span> - Constructor for class gobblin.kafka.serialize.<a href="gobblin/kafka/serialize/LiAvroDeserializerBase.html" title="class in gobblin.kafka.serialize">LiAvroDeserializerBase</a></dt>
<dd>&nbsp;</dd>
<dt><a href="gobblin/kafka/serialize/LiAvroSerDeHelper.html" title="class in gobblin.kafka.serialize"><span class="typeNameLink">LiAvroSerDeHelper</span></a> - Class in <a href="gobblin/kafka/serialize/package-summary.html">gobblin.kafka.serialize</a></dt>
<dd>
<div class="block">Helper class for <code>LiAvroSerializer</code> and <a href="gobblin/kafka/serialize/LiAvroDeserializerBase.html" title="class in gobblin.kafka.serialize"><code>LiAvroDeserializerBase</code></a>.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/serialize/LiAvroSerDeHelper.html#LiAvroSerDeHelper--">LiAvroSerDeHelper()</a></span> - Constructor for class gobblin.kafka.serialize.<a href="gobblin/kafka/serialize/LiAvroSerDeHelper.html" title="class in gobblin.kafka.serialize">LiAvroSerDeHelper</a></dt>
<dd>&nbsp;</dd>
<dt><a href="gobblin/kafka/serialize/LiAvroSerializerBase.html" title="class in gobblin.kafka.serialize"><span class="typeNameLink">LiAvroSerializerBase</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/LiAvroSerializerBase.html#LiAvroSerializerBase--">LiAvroSerializerBase()</a></span> - Constructor for class gobblin.kafka.serialize.<a href="gobblin/kafka/serialize/LiAvroSerializerBase.html" title="class in gobblin.kafka.serialize">LiAvroSerializerBase</a></dt>
<dd>&nbsp;</dd>
<dt><a href="gobblin/converter/LiKafkaByteArrayMsgToAvroConverter.html" title="class in gobblin.converter"><span class="typeNameLink">LiKafkaByteArrayMsgToAvroConverter</span></a>&lt;<a href="gobblin/converter/LiKafkaByteArrayMsgToAvroConverter.html" title="type parameter in LiKafkaByteArrayMsgToAvroConverter">S</a>&gt; - Class in <a href="gobblin/converter/package-summary.html">gobblin.converter</a></dt>
<dd>
<div class="block">Converts LiKafka byte array messages into avro.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/converter/LiKafkaByteArrayMsgToAvroConverter.html#LiKafkaByteArrayMsgToAvroConverter--">LiKafkaByteArrayMsgToAvroConverter()</a></span> - Constructor for class gobblin.converter.<a href="gobblin/converter/LiKafkaByteArrayMsgToAvroConverter.html" title="class in gobblin.converter">LiKafkaByteArrayMsgToAvroConverter</a></dt>
<dd>&nbsp;</dd>
<dt><a href="gobblin/kafka/schemareg/LiKafkaSchemaRegistry.html" title="class in gobblin.kafka.schemareg"><span class="typeNameLink">LiKafkaSchemaRegistry</span></a> - Class in <a href="gobblin/kafka/schemareg/package-summary.html">gobblin.kafka.schemareg</a></dt>
<dd>
<div class="block">Integration with LinkedIn's implementation of a schema registry that uses md5-hash for schema ids.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/schemareg/LiKafkaSchemaRegistry.html#LiKafkaSchemaRegistry-java.util.Properties-">LiKafkaSchemaRegistry(Properties)</a></span> - Constructor for class gobblin.kafka.schemareg.<a href="gobblin/kafka/schemareg/LiKafkaSchemaRegistry.html" title="class in gobblin.kafka.schemareg">LiKafkaSchemaRegistry</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/workunit/packer/KafkaWorkUnitPacker.html#LOAD_ASC_COMPARATOR">LOAD_ASC_COMPARATOR</a></span> - Static variable in class gobblin.source.extractor.extract.kafka.workunit.packer.<a href="gobblin/source/extractor/extract/kafka/workunit/packer/KafkaWorkUnitPacker.html" title="class in gobblin.source.extractor.extract.kafka.workunit.packer">KafkaWorkUnitPacker</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/workunit/packer/KafkaWorkUnitPacker.html#LOAD_DESC_COMPARATOR">LOAD_DESC_COMPARATOR</a></span> - Static variable in class gobblin.source.extractor.extract.kafka.workunit.packer.<a href="gobblin/source/extractor/extract/kafka/workunit/packer/KafkaWorkUnitPacker.html" title="class in gobblin.source.extractor.extract.kafka.workunit.packer">KafkaWorkUnitPacker</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaExtractor.html#LOW_WATERMARK">LOW_WATERMARK</a></span> - Static variable in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaExtractor.html" title="class in gobblin.source.extractor.extract.kafka">KafkaExtractor</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaExtractor.html#lowWatermark">lowWatermark</a></span> - Variable in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaExtractor.html" title="class in gobblin.source.extractor.extract.kafka">KafkaExtractor</a></dt>
<dd>&nbsp;</dd>
</dl>
<a name="I:M">
<!-- -->
</a>
<h2 class="title">M</h2>
<dl>
<dt><span class="memberNameLink"><a href="gobblin/kafka/serialize/LiAvroSerDeHelper.html#MAGIC_BYTE">MAGIC_BYTE</a></span> - Static variable in class gobblin.kafka.serialize.<a href="gobblin/kafka/serialize/LiAvroSerDeHelper.html" title="class in gobblin.kafka.serialize">LiAvroSerDeHelper</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/metrics/kafka/KafkaAvroSchemaRegistry.html#MAGIC_BYTE">MAGIC_BYTE</a></span> - Static variable in class gobblin.metrics.kafka.<a href="gobblin/metrics/kafka/KafkaAvroSchemaRegistry.html" title="class in gobblin.metrics.kafka">KafkaAvroSchemaRegistry</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaExtractor.html#MAX_LOG_DECODING_ERRORS">MAX_LOG_DECODING_ERRORS</a></span> - Static variable in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaExtractor.html" title="class in gobblin.source.extractor.extract.kafka">KafkaExtractor</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/workunit/packer/KafkaWorkUnitPacker.html#MAX_MULTIWORKUNIT_LOAD">MAX_MULTIWORKUNIT_LOAD</a></span> - Static variable in class gobblin.source.extractor.extract.kafka.workunit.packer.<a href="gobblin/source/extractor/extract/kafka/workunit/packer/KafkaWorkUnitPacker.html" title="class in gobblin.source.extractor.extract.kafka.workunit.packer">KafkaWorkUnitPacker</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/serialize/MD5Digest.html#MD5_BYTES_LENGTH">MD5_BYTES_LENGTH</a></span> - Static variable in class gobblin.kafka.serialize.<a href="gobblin/kafka/serialize/MD5Digest.html" title="class in gobblin.kafka.serialize">MD5Digest</a></dt>
<dd>&nbsp;</dd>
<dt><a href="gobblin/kafka/serialize/MD5Digest.html" title="class in gobblin.kafka.serialize"><span class="typeNameLink">MD5Digest</span></a> - Class in <a href="gobblin/kafka/serialize/package-summary.html">gobblin.kafka.serialize</a></dt>
<dd>
<div class="block">A holder for an MD5Digest
Allows for conversion between the human-readable String version and the serializable byte[] version.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/workunit/packer/KafkaWorkUnitPacker.html#MIN_MULTIWORKUNIT_LOAD">MIN_MULTIWORKUNIT_LOAD</a></span> - Static variable in class gobblin.source.extractor.extract.kafka.workunit.packer.<a href="gobblin/source/extractor/extract/kafka/workunit/packer/KafkaWorkUnitPacker.html" title="class in gobblin.source.extractor.extract.kafka.workunit.packer">KafkaWorkUnitPacker</a></dt>
<dd>&nbsp;</dd>
<dt><a href="gobblin/source/extractor/extract/kafka/MultiLongWatermark.html" title="class in gobblin.source.extractor.extract.kafka"><span class="typeNameLink">MultiLongWatermark</span></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-api/gobblin/source/extractor/Watermark.html?is-external=true" title="class or interface in gobblin.source.extractor"><code>Watermark</code></a> that holds multiple long values.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/MultiLongWatermark.html#MultiLongWatermark-gobblin.source.extractor.extract.kafka.MultiLongWatermark-">MultiLongWatermark(MultiLongWatermark)</a></span> - Constructor for class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/MultiLongWatermark.html" title="class in gobblin.source.extractor.extract.kafka">MultiLongWatermark</a></dt>
<dd>
<div class="block">Copy constructor.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/MultiLongWatermark.html#MultiLongWatermark-java.util.List-">MultiLongWatermark(List&lt;Long&gt;)</a></span> - Constructor for class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/MultiLongWatermark.html" title="class in gobblin.source.extractor.extract.kafka">MultiLongWatermark</a></dt>
<dd>&nbsp;</dd>
</dl>
<a name="I:N">
<!-- -->
</a>
<h2 class="title">N</h2>
<dl>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaSource.html#NEAREST_OFFSET">NEAREST_OFFSET</a></span> - Static variable in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaSource.html" title="class in gobblin.source.extractor.extract.kafka">KafkaSource</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaExtractor.html#nextWatermark">nextWatermark</a></span> - Variable in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaExtractor.html" title="class in gobblin.source.extractor.extract.kafka">KafkaExtractor</a></dt>
<dd>&nbsp;</dd>
</dl>
<a name="I:O">
<!-- -->
</a>
<h2 class="title">O</h2>
<dl>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaSource.html#OFFSET_FETCH_TIMER">OFFSET_FETCH_TIMER</a></span> - Static variable in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaSource.html" title="class in gobblin.source.extractor.extract.kafka">KafkaSource</a></dt>
<dd>&nbsp;</dd>
</dl>
<a name="I:P">
<!-- -->
</a>
<h2 class="title">P</h2>
<dl>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/workunit/packer/KafkaBiLevelWorkUnitPacker.html#pack-java.util.Map-int-">pack(Map&lt;String, List&lt;WorkUnit&gt;&gt;, int)</a></span> - Method in class gobblin.source.extractor.extract.kafka.workunit.packer.<a href="gobblin/source/extractor/extract/kafka/workunit/packer/KafkaBiLevelWorkUnitPacker.html" title="class in gobblin.source.extractor.extract.kafka.workunit.packer">KafkaBiLevelWorkUnitPacker</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/workunit/packer/KafkaSingleLevelWorkUnitPacker.html#pack-java.util.Map-int-">pack(Map&lt;String, List&lt;WorkUnit&gt;&gt;, int)</a></span> - Method in class gobblin.source.extractor.extract.kafka.workunit.packer.<a href="gobblin/source/extractor/extract/kafka/workunit/packer/KafkaSingleLevelWorkUnitPacker.html" title="class in gobblin.source.extractor.extract.kafka.workunit.packer">KafkaSingleLevelWorkUnitPacker</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/workunit/packer/KafkaWorkUnitPacker.html#pack-java.util.Map-int-">pack(Map&lt;String, List&lt;WorkUnit&gt;&gt;, int)</a></span> - Method in class gobblin.source.extractor.extract.kafka.workunit.packer.<a href="gobblin/source/extractor/extract/kafka/workunit/packer/KafkaWorkUnitPacker.html" title="class in gobblin.source.extractor.extract.kafka.workunit.packer">KafkaWorkUnitPacker</a></dt>
<dd>
<div class="block">Group <a href="http://linkedin.github.io/gobblin/javadoc/0.11.0/gobblin-api/gobblin/source/workunit/WorkUnit.html?is-external=true" title="class or interface in gobblin.source.workunit"><code>WorkUnit</code></a>s into <a href="http://linkedin.github.io/gobblin/javadoc/0.11.0/gobblin-api/gobblin/source/workunit/MultiWorkUnit.html?is-external=true" title="class or interface in gobblin.source.workunit"><code>MultiWorkUnit</code></a>s.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaExtractor.html#PARTITION">PARTITION</a></span> - Static variable in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaExtractor.html" title="class in gobblin.source.extractor.extract.kafka">KafkaExtractor</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaSource.html#PARTITION_ID">PARTITION_ID</a></span> - Static variable in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaSource.html" title="class in gobblin.source.extractor.extract.kafka">KafkaSource</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaExtractor.html#partitions">partitions</a></span> - Variable in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaExtractor.html" title="class in gobblin.source.extractor.extract.kafka">KafkaExtractor</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/converter/EnvelopeSchemaConverter.html#PAYLOAD_FIELD">PAYLOAD_FIELD</a></span> - Static variable in class gobblin.converter.<a href="gobblin/converter/EnvelopeSchemaConverter.html" title="class in gobblin.converter">EnvelopeSchemaConverter</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/converter/EnvelopeSchemaConverter.html#PAYLOAD_SCHEMA_ID_FIELD">PAYLOAD_SCHEMA_ID_FIELD</a></span> - Static variable in class gobblin.converter.<a href="gobblin/converter/EnvelopeSchemaConverter.html" title="class in gobblin.converter">EnvelopeSchemaConverter</a></dt>
<dd>&nbsp;</dd>
<dt><a href="gobblin/source/extractor/extract/kafka/PreviousOffsetNotFoundException.html" title="class in gobblin.source.extractor.extract.kafka"><span class="typeNameLink">PreviousOffsetNotFoundException</span></a> - Exception in <a href="gobblin/source/extractor/extract/kafka/package-summary.html">gobblin.source.extractor.extract.kafka</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/PreviousOffsetNotFoundException.html#PreviousOffsetNotFoundException-java.lang.String-">PreviousOffsetNotFoundException(String)</a></span> - Constructor for exception gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/PreviousOffsetNotFoundException.html" title="class in gobblin.source.extractor.extract.kafka">PreviousOffsetNotFoundException</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/metrics/kafka/KafkaSchemaRegistry.html#props">props</a></span> - Variable in class gobblin.metrics.kafka.<a href="gobblin/metrics/kafka/KafkaSchemaRegistry.html" title="class in gobblin.metrics.kafka">KafkaSchemaRegistry</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/KafkaAvroExtractor.html#reader">reader</a></span> - Variable in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaAvroExtractor.html" title="class in gobblin.source.extractor.extract.kafka">KafkaAvroExtractor</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaAvroExtractor.html#readRecordImpl-org.apache.avro.generic.GenericRecord-">readRecordImpl(GenericRecord)</a></span> - Method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaAvroExtractor.html" title="class in gobblin.source.extractor.extract.kafka">KafkaAvroExtractor</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaExtractor.html#readRecordImpl-D-">readRecordImpl(D)</a></span> - Method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaExtractor.html" title="class in gobblin.source.extractor.extract.kafka">KafkaExtractor</a></dt>
<dd>
<div class="block">Return the next decodable record from the current partition.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/metrics/reporter/util/SchemaRegistryVersionWriter.html#readSchemaVersioningInformation-java.io.DataInputStream-">readSchemaVersioningInformation(DataInputStream)</a></span> - Method in class gobblin.metrics.reporter.util.<a href="gobblin/metrics/reporter/util/SchemaRegistryVersionWriter.html" title="class in gobblin.metrics.reporter.util">SchemaRegistryVersionWriter</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/writer/KafkaWriterMetricNames.html#RECORDS_FAILED_METER">RECORDS_FAILED_METER</a></span> - Static variable in class gobblin.kafka.writer.<a href="gobblin/kafka/writer/KafkaWriterMetricNames.html" title="class in gobblin.kafka.writer">KafkaWriterMetricNames</a></dt>
<dd>
<div class="block">A <code>Meter</code> measuring the number of records that failed to be written by
<a href="http://linkedin.github.io/gobblin/javadoc/0.11.0/gobblin-api/gobblin/kafka.writer.KafkaDataWriter.html?is-external=true" title="class or interface in gobblin"><code>kafka.writer.KafkaDataWriter</code></a>.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/writer/KafkaWriterMetricNames.html#RECORDS_PRODUCED_METER">RECORDS_PRODUCED_METER</a></span> - Static variable in class gobblin.kafka.writer.<a href="gobblin/kafka/writer/KafkaWriterMetricNames.html" title="class in gobblin.kafka.writer">KafkaWriterMetricNames</a></dt>
<dd>
<div class="block">A <code>Meter</code> measuring the number of records sent to
a <a href="http://linkedin.github.io/gobblin/javadoc/0.11.0/gobblin-api/gobblin/kafka.writer.KafkaDataWriter.html?is-external=true" title="class or interface in gobblin"><code>kafka.writer.KafkaDataWriter</code></a>.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/writer/KafkaWriterMetricNames.html#RECORDS_SUCCESS_METER">RECORDS_SUCCESS_METER</a></span> - Static variable in class gobblin.kafka.writer.<a href="gobblin/kafka/writer/KafkaWriterMetricNames.html" title="class in gobblin.kafka.writer">KafkaWriterMetricNames</a></dt>
<dd>
<div class="block">A <code>Meter</code> measuring the number of records that were successfully written by
<a href="http://linkedin.github.io/gobblin/javadoc/0.11.0/gobblin-api/gobblin/kafka.writer.KafkaDataWriter.html?is-external=true" title="class or interface in gobblin"><code>kafka.writer.KafkaDataWriter</code></a>.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/schemareg/CachingKafkaSchemaRegistry.html#register-java.lang.String-S-">register(String, S)</a></span> - Method in class gobblin.kafka.schemareg.<a href="gobblin/kafka/schemareg/CachingKafkaSchemaRegistry.html" title="class in gobblin.kafka.schemareg">CachingKafkaSchemaRegistry</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/schemareg/ConfigDrivenMd5SchemaRegistry.html#register-java.lang.String-org.apache.avro.Schema-">register(String, Schema)</a></span> - Method in class gobblin.kafka.schemareg.<a href="gobblin/kafka/schemareg/ConfigDrivenMd5SchemaRegistry.html" title="class in gobblin.kafka.schemareg">ConfigDrivenMd5SchemaRegistry</a></dt>
<dd>
<div class="block">Register this schema under the provided name</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/schemareg/KafkaSchemaRegistry.html#register-java.lang.String-S-">register(String, S)</a></span> - Method in interface gobblin.kafka.schemareg.<a href="gobblin/kafka/schemareg/KafkaSchemaRegistry.html" title="interface in gobblin.kafka.schemareg">KafkaSchemaRegistry</a></dt>
<dd>
<div class="block">Register this schema under the provided name</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/schemareg/LiKafkaSchemaRegistry.html#register-java.lang.String-org.apache.avro.Schema-">register(String, Schema)</a></span> - Method in class gobblin.kafka.schemareg.<a href="gobblin/kafka/schemareg/LiKafkaSchemaRegistry.html" title="class in gobblin.kafka.schemareg">LiKafkaSchemaRegistry</a></dt>
<dd>
<div class="block">Register a schema to the Kafka schema registry under the provided input name.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/schemareg/LiKafkaSchemaRegistry.html#register-org.apache.avro.Schema-">register(Schema)</a></span> - Method in class gobblin.kafka.schemareg.<a href="gobblin/kafka/schemareg/LiKafkaSchemaRegistry.html" title="class in gobblin.kafka.schemareg">LiKafkaSchemaRegistry</a></dt>
<dd>
<div class="block">Register a schema to the Kafka schema registry</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/metrics/kafka/KafkaAvroSchemaRegistry.html#register-org.apache.avro.Schema-java.lang.String-">register(Schema, String)</a></span> - Method in class gobblin.metrics.kafka.<a href="gobblin/metrics/kafka/KafkaAvroSchemaRegistry.html" title="class in gobblin.metrics.kafka">KafkaAvroSchemaRegistry</a></dt>
<dd>
<div class="block">Register a schema to the Kafka schema registry under the provided input name.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/metrics/kafka/KafkaAvroSchemaRegistry.html#register-org.apache.avro.Schema-">register(Schema)</a></span> - Method in class gobblin.metrics.kafka.<a href="gobblin/metrics/kafka/KafkaAvroSchemaRegistry.html" title="class in gobblin.metrics.kafka">KafkaAvroSchemaRegistry</a></dt>
<dd>
<div class="block">Register a schema to the Kafka schema registry</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/metrics/kafka/KafkaSchemaRegistry.html#register-S-">register(S)</a></span> - Method in class gobblin.metrics.kafka.<a href="gobblin/metrics/kafka/KafkaSchemaRegistry.html" title="class in gobblin.metrics.kafka">KafkaSchemaRegistry</a></dt>
<dd>
<div class="block">Register a schema to the schema registry</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/metrics/kafka/KafkaSchemaRegistry.html#register-S-java.lang.String-">register(S, String)</a></span> - Method in class gobblin.metrics.kafka.<a href="gobblin/metrics/kafka/KafkaSchemaRegistry.html" title="class in gobblin.metrics.kafka">KafkaSchemaRegistry</a></dt>
<dd>
<div class="block">Register a schema to the schema registry under the given name</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/ConfluentKafkaSchemaRegistry.html#register-org.apache.avro.Schema-">register(Schema)</a></span> - Method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/ConfluentKafkaSchemaRegistry.html" title="class in gobblin.source.extractor.extract.kafka">ConfluentKafkaSchemaRegistry</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/ConfluentKafkaSchemaRegistry.html#register-org.apache.avro.Schema-java.lang.String-">register(Schema, String)</a></span> - Method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/ConfluentKafkaSchemaRegistry.html" title="class in gobblin.source.extractor.extract.kafka">ConfluentKafkaSchemaRegistry</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/SimpleKafkaSchemaRegistry.html#register-java.lang.String-">register(String)</a></span> - Method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/SimpleKafkaSchemaRegistry.html" title="class in gobblin.source.extractor.extract.kafka">SimpleKafkaSchemaRegistry</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/SimpleKafkaSchemaRegistry.html#register-java.lang.String-java.lang.String-">register(String, String)</a></span> - Method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/SimpleKafkaSchemaRegistry.html" title="class in gobblin.source.extractor.extract.kafka">SimpleKafkaSchemaRegistry</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaSource.html#RESET_ON_OFFSET_OUT_OF_RANGE">RESET_ON_OFFSET_OUT_OF_RANGE</a></span> - Static variable in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaSource.html" title="class in gobblin.source.extractor.extract.kafka">KafkaSource</a></dt>
<dd>&nbsp;</dd>
</dl>
<a name="I:S">
<!-- -->
</a>
<h2 class="title">S</h2>
<dl>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaAvroExtractor.html#schema">schema</a></span> - Variable in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaAvroExtractor.html" title="class in gobblin.source.extractor.extract.kafka">KafkaAvroExtractor</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/metrics/kafka/KafkaAvroSchemaRegistry.html#SCHEMA_ID_LENGTH_BYTE">SCHEMA_ID_LENGTH_BYTE</a></span> - Static variable in class gobblin.metrics.kafka.<a href="gobblin/metrics/kafka/KafkaAvroSchemaRegistry.html" title="class in gobblin.metrics.kafka">KafkaAvroSchemaRegistry</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaAvroExtractor.html#schemaRegistry">schemaRegistry</a></span> - Variable in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaAvroExtractor.html" title="class in gobblin.source.extractor.extract.kafka">KafkaAvroExtractor</a></dt>
<dd>&nbsp;</dd>
<dt><a href="gobblin/kafka/schemareg/SchemaRegistryException.html" title="class in gobblin.kafka.schemareg"><span class="typeNameLink">SchemaRegistryException</span></a> - Exception in <a href="gobblin/kafka/schemareg/package-summary.html">gobblin.kafka.schemareg</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/schemareg/SchemaRegistryException.html#SchemaRegistryException-java.lang.String-">SchemaRegistryException(String)</a></span> - Constructor for exception gobblin.kafka.schemareg.<a href="gobblin/kafka/schemareg/SchemaRegistryException.html" title="class in gobblin.kafka.schemareg">SchemaRegistryException</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/schemareg/SchemaRegistryException.html#SchemaRegistryException-java.lang.String-java.lang.Throwable-">SchemaRegistryException(String, Throwable)</a></span> - Constructor for exception gobblin.kafka.schemareg.<a href="gobblin/kafka/schemareg/SchemaRegistryException.html" title="class in gobblin.kafka.schemareg">SchemaRegistryException</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/schemareg/SchemaRegistryException.html#SchemaRegistryException-java.lang.Throwable-">SchemaRegistryException(Throwable)</a></span> - Constructor for exception gobblin.kafka.schemareg.<a href="gobblin/kafka/schemareg/SchemaRegistryException.html" title="class in gobblin.kafka.schemareg">SchemaRegistryException</a></dt>
<dd>&nbsp;</dd>
<dt><a href="gobblin/metrics/kafka/SchemaRegistryException.html" title="class in gobblin.metrics.kafka"><span class="typeNameLink">SchemaRegistryException</span></a> - Exception in <a href="gobblin/metrics/kafka/package-summary.html">gobblin.metrics.kafka</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/metrics/kafka/SchemaRegistryException.html#SchemaRegistryException-java.lang.String-">SchemaRegistryException(String)</a></span> - Constructor for exception gobblin.metrics.kafka.<a href="gobblin/metrics/kafka/SchemaRegistryException.html" title="class in gobblin.metrics.kafka">SchemaRegistryException</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/metrics/kafka/SchemaRegistryException.html#SchemaRegistryException-java.lang.String-java.lang.Throwable-">SchemaRegistryException(String, Throwable)</a></span> - Constructor for exception gobblin.metrics.kafka.<a href="gobblin/metrics/kafka/SchemaRegistryException.html" title="class in gobblin.metrics.kafka">SchemaRegistryException</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/metrics/kafka/SchemaRegistryException.html#SchemaRegistryException-java.lang.Throwable-">SchemaRegistryException(Throwable)</a></span> - Constructor for exception gobblin.metrics.kafka.<a href="gobblin/metrics/kafka/SchemaRegistryException.html" title="class in gobblin.metrics.kafka">SchemaRegistryException</a></dt>
<dd>&nbsp;</dd>
<dt><a href="gobblin/metrics/reporter/util/SchemaRegistryVersionWriter.html" title="class in gobblin.metrics.reporter.util"><span class="typeNameLink">SchemaRegistryVersionWriter</span></a> - Class in <a href="gobblin/metrics/reporter/util/package-summary.html">gobblin.metrics.reporter.util</a></dt>
<dd>
<div class="block">Implementation of <a href="http://linkedin.github.io/gobblin/javadoc/0.11.0/gobblin-metrics-base/gobblin/metrics/reporter/util/SchemaVersionWriter.html?is-external=true" title="class or interface in gobblin.metrics.reporter.util"><code>SchemaVersionWriter</code></a> that uses a
<a href="gobblin/metrics/kafka/KafkaAvroSchemaRegistry.html" title="class in gobblin.metrics.kafka"><code>KafkaAvroSchemaRegistry</code></a> to get Schema version identifier and write it to
<a href="https://docs.oracle.com/javase/7/docs/api/java/io/DataOutputStream.html?is-external=true" title="class or interface in java.io"><code>DataOutputStream</code></a>.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/metrics/reporter/util/SchemaRegistryVersionWriter.html#SchemaRegistryVersionWriter-com.typesafe.config.Config-">SchemaRegistryVersionWriter(Config)</a></span> - Constructor for class gobblin.metrics.reporter.util.<a href="gobblin/metrics/reporter/util/SchemaRegistryVersionWriter.html" title="class in gobblin.metrics.reporter.util">SchemaRegistryVersionWriter</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/metrics/reporter/util/SchemaRegistryVersionWriter.html#SchemaRegistryVersionWriter-gobblin.metrics.kafka.KafkaAvroSchemaRegistry-java.lang.String-">SchemaRegistryVersionWriter(KafkaAvroSchemaRegistry, String)</a></span> - Constructor for class gobblin.metrics.reporter.util.<a href="gobblin/metrics/reporter/util/SchemaRegistryVersionWriter.html" title="class in gobblin.metrics.reporter.util">SchemaRegistryVersionWriter</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/metrics/reporter/util/SchemaRegistryVersionWriter.html#SchemaRegistryVersionWriter-gobblin.metrics.kafka.KafkaAvroSchemaRegistry-java.lang.String-com.google.common.base.Optional-">SchemaRegistryVersionWriter(KafkaAvroSchemaRegistry, String, Optional&lt;Schema&gt;)</a></span> - Constructor for class gobblin.metrics.reporter.util.<a href="gobblin/metrics/reporter/util/SchemaRegistryVersionWriter.html" title="class in gobblin.metrics.reporter.util">SchemaRegistryVersionWriter</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/metrics/reporter/util/SchemaRegistryVersionWriter.html#SchemaRegistryVersionWriter-gobblin.metrics.kafka.KafkaAvroSchemaRegistry-com.google.common.base.Optional-com.google.common.base.Optional-">SchemaRegistryVersionWriter(KafkaAvroSchemaRegistry, Optional&lt;String&gt;, Optional&lt;Schema&gt;)</a></span> - Constructor for class gobblin.metrics.reporter.util.<a href="gobblin/metrics/reporter/util/SchemaRegistryVersionWriter.html" title="class in gobblin.metrics.reporter.util">SchemaRegistryVersionWriter</a></dt>
<dd>&nbsp;</dd>
<dt><a href="gobblin/kafka/serialize/SerializationException.html" title="class in gobblin.kafka.serialize"><span class="typeNameLink">SerializationException</span></a> - Exception in <a href="gobblin/kafka/serialize/package-summary.html">gobblin.kafka.serialize</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/serialize/SerializationException.html#SerializationException-java.lang.String-">SerializationException(String)</a></span> - Constructor for exception gobblin.kafka.serialize.<a href="gobblin/kafka/serialize/SerializationException.html" title="class in gobblin.kafka.serialize">SerializationException</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/serialize/SerializationException.html#SerializationException-java.lang.String-java.lang.Exception-">SerializationException(String, Exception)</a></span> - Constructor for exception gobblin.kafka.serialize.<a href="gobblin/kafka/serialize/SerializationException.html" title="class in gobblin.kafka.serialize">SerializationException</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/serialize/SerializationException.html#SerializationException-java.lang.Exception-">SerializationException(Exception)</a></span> - Constructor for exception gobblin.kafka.serialize.<a href="gobblin/kafka/serialize/SerializationException.html" title="class in gobblin.kafka.serialize">SerializationException</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/serialize/LiAvroSerializerBase.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/LiAvroSerializerBase.html" title="class in gobblin.kafka.serialize">LiAvroSerializerBase</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/MultiLongWatermark.html#set-int-long-">set(int, long)</a></span> - Method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/MultiLongWatermark.html" title="class in gobblin.source.extractor.extract.kafka">MultiLongWatermark</a></dt>
<dd>
<div class="block">Set the idx'th value of this watermark.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaPartition.html#setLeader-int-java.lang.String-int-">setLeader(int, String, int)</a></span> - Method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaPartition.html" title="class in gobblin.source.extractor.extract.kafka">KafkaPartition</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaUtils.html#setPartitionAvgRecordMillis-gobblin.configuration.State-gobblin.source.extractor.extract.kafka.KafkaPartition-double-">setPartitionAvgRecordMillis(State, KafkaPartition, double)</a></span> - Static method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaUtils.html" title="class in gobblin.source.extractor.extract.kafka">KafkaUtils</a></dt>
<dd>
<div class="block">Set the average time in milliseconds to pull a record of a partition, which will be stored in property
"[topicname].[partitionid].avg.record.millis".</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaUtils.html#setPartitionAvgRecordSize-gobblin.configuration.State-gobblin.source.extractor.extract.kafka.KafkaPartition-long-">setPartitionAvgRecordSize(State, KafkaPartition, long)</a></span> - Static method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaUtils.html" title="class in gobblin.source.extractor.extract.kafka">KafkaUtils</a></dt>
<dd>
<div class="block">Set the average record size of a partition, which will be stored in property
"[topicname].[partitionid].avg.record.size".</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/ConfigStoreUtils.html#setTopicsFromConfigStore-java.util.Properties-java.util.Set-java.util.Set-java.lang.String-java.lang.String-">setTopicsFromConfigStore(Properties, Set&lt;String&gt;, Set&lt;String&gt;, String, String)</a></span> - Static method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/ConfigStoreUtils.html" title="class in gobblin.source.extractor.extract.kafka">ConfigStoreUtils</a></dt>
<dd>
<div class="block">Shortlist topics from config store based on whitelist/blacklist tags and
add it to /
If tags are not provided, blacklist and whitelist won't be modified</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/workunit/packer/KafkaWorkUnitPacker.html#setWorkUnitEstSizes-java.util.Map-">setWorkUnitEstSizes(Map&lt;String, List&lt;WorkUnit&gt;&gt;)</a></span> - Method in class gobblin.source.extractor.extract.kafka.workunit.packer.<a href="gobblin/source/extractor/extract/kafka/workunit/packer/KafkaWorkUnitPacker.html" title="class in gobblin.source.extractor.extract.kafka.workunit.packer">KafkaWorkUnitPacker</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaSource.html#shutdown-gobblin.configuration.SourceState-">shutdown(SourceState)</a></span> - Method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaSource.html" title="class in gobblin.source.extractor.extract.kafka">KafkaSource</a></dt>
<dd>&nbsp;</dd>
<dt><a href="gobblin/source/extractor/extract/kafka/SimpleKafkaSchemaRegistry.html" title="class in gobblin.source.extractor.extract.kafka"><span class="typeNameLink">SimpleKafkaSchemaRegistry</span></a> - Class in <a href="gobblin/source/extractor/extract/kafka/package-summary.html">gobblin.source.extractor.extract.kafka</a></dt>
<dd>
<div class="block">Extension of <a href="gobblin/metrics/kafka/KafkaSchemaRegistry.html" title="class in gobblin.metrics.kafka"><code>KafkaSchemaRegistry</code></a> that treats the topic name and the schema as the same string.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/SimpleKafkaSchemaRegistry.html#SimpleKafkaSchemaRegistry-java.util.Properties-">SimpleKafkaSchemaRegistry(Properties)</a></span> - Constructor for class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/SimpleKafkaSchemaRegistry.html" title="class in gobblin.source.extractor.extract.kafka">SimpleKafkaSchemaRegistry</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/MultiLongWatermark.html#size--">size()</a></span> - Method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/MultiLongWatermark.html" title="class in gobblin.source.extractor.extract.kafka">MultiLongWatermark</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/workunit/packer/KafkaWorkUnitPacker.html#sizeEstimator">sizeEstimator</a></span> - Variable in class gobblin.source.extractor.extract.kafka.workunit.packer.<a href="gobblin/source/extractor/extract/kafka/workunit/packer/KafkaWorkUnitPacker.html" title="class in gobblin.source.extractor.extract.kafka.workunit.packer">KafkaWorkUnitPacker</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/client/AbstractBaseKafkaConsumerClient.html#socketTimeoutMillis">socketTimeoutMillis</a></span> - Variable in class gobblin.kafka.client.<a href="gobblin/kafka/client/AbstractBaseKafkaConsumerClient.html" title="class in gobblin.kafka.client">AbstractBaseKafkaConsumerClient</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/workunit/packer/KafkaWorkUnitPacker.html#source">source</a></span> - Variable in class gobblin.source.extractor.extract.kafka.workunit.packer.<a href="gobblin/source/extractor/extract/kafka/workunit/packer/KafkaWorkUnitPacker.html" title="class in gobblin.source.extractor.extract.kafka.workunit.packer">KafkaWorkUnitPacker</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/workunit/packer/KafkaWorkUnitPacker.html#squeezeMultiWorkUnit-gobblin.source.workunit.MultiWorkUnit-">squeezeMultiWorkUnit(MultiWorkUnit)</a></span> - Method in class gobblin.source.extractor.extract.kafka.workunit.packer.<a href="gobblin/source/extractor/extract/kafka/workunit/packer/KafkaWorkUnitPacker.html" title="class in gobblin.source.extractor.extract.kafka.workunit.packer">KafkaWorkUnitPacker</a></dt>
<dd>
<div class="block">Combine all <a href="http://linkedin.github.io/gobblin/javadoc/0.11.0/gobblin-api/gobblin/source/workunit/WorkUnit.html?is-external=true" title="class or interface in gobblin.source.workunit"><code>WorkUnit</code></a>s in the <a href="http://linkedin.github.io/gobblin/javadoc/0.11.0/gobblin-api/gobblin/source/workunit/MultiWorkUnit.html?is-external=true" title="class or interface in gobblin.source.workunit"><code>MultiWorkUnit</code></a> into a single <a href="http://linkedin.github.io/gobblin/javadoc/0.11.0/gobblin-api/gobblin/source/workunit/WorkUnit.html?is-external=true" title="class or interface in gobblin.source.workunit"><code>WorkUnit</code></a>.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/workunit/packer/KafkaWorkUnitPacker.html#squeezeMultiWorkUnits-java.util.List-">squeezeMultiWorkUnits(List&lt;MultiWorkUnit&gt;)</a></span> - Method in class gobblin.source.extractor.extract.kafka.workunit.packer.<a href="gobblin/source/extractor/extract/kafka/workunit/packer/KafkaWorkUnitPacker.html" title="class in gobblin.source.extractor.extract.kafka.workunit.packer">KafkaWorkUnitPacker</a></dt>
<dd>
<div class="block">For each input <a href="http://linkedin.github.io/gobblin/javadoc/0.11.0/gobblin-api/gobblin/source/workunit/MultiWorkUnit.html?is-external=true" title="class or interface in gobblin.source.workunit"><code>MultiWorkUnit</code></a>, combine all <a href="http://linkedin.github.io/gobblin/javadoc/0.11.0/gobblin-api/gobblin/source/workunit/WorkUnit.html?is-external=true" title="class or interface in gobblin.source.workunit"><code>WorkUnit</code></a>s in it into a single <a href="http://linkedin.github.io/gobblin/javadoc/0.11.0/gobblin-api/gobblin/source/workunit/WorkUnit.html?is-external=true" title="class or interface in gobblin.source.workunit"><code>WorkUnit</code></a>.</div>
</dd>
<dt><a href="gobblin/source/extractor/extract/kafka/StartOffsetOutOfRangeException.html" title="class in gobblin.source.extractor.extract.kafka"><span class="typeNameLink">StartOffsetOutOfRangeException</span></a> - Exception in <a href="gobblin/source/extractor/extract/kafka/package-summary.html">gobblin.source.extractor.extract.kafka</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/StartOffsetOutOfRangeException.html#StartOffsetOutOfRangeException-java.lang.String-">StartOffsetOutOfRangeException(String)</a></span> - Constructor for exception gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/StartOffsetOutOfRangeException.html" title="class in gobblin.source.extractor.extract.kafka">StartOffsetOutOfRangeException</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/workunit/packer/KafkaWorkUnitPacker.html#state">state</a></span> - Variable in class gobblin.source.extractor.extract.kafka.workunit.packer.<a href="gobblin/source/extractor/extract/kafka/workunit/packer/KafkaWorkUnitPacker.html" title="class in gobblin.source.extractor.extract.kafka.workunit.packer">KafkaWorkUnitPacker</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/FixedSchemaKafkaAvroExtractor.html#STATIC_SCHEMA_ROOT_KEY">STATIC_SCHEMA_ROOT_KEY</a></span> - Static variable in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/FixedSchemaKafkaAvroExtractor.html" title="class in gobblin.source.extractor.extract.kafka">FixedSchemaKafkaAvroExtractor</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaExtractor.html#stopwatch">stopwatch</a></span> - Variable in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaExtractor.html" title="class in gobblin.source.extractor.extract.kafka">KafkaExtractor</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/workunit/packer/KafkaWorkUnitPacker.html#tableType">tableType</a></span> - Variable in class gobblin.source.extractor.extract.kafka.workunit.packer.<a href="gobblin/source/extractor/extract/kafka/workunit/packer/KafkaWorkUnitPacker.html" title="class in gobblin.source.extractor.extract.kafka.workunit.packer">KafkaWorkUnitPacker</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/MultiLongWatermark.html#toJson--">toJson()</a></span> - Method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/MultiLongWatermark.html" title="class in gobblin.source.extractor.extract.kafka">MultiLongWatermark</a></dt>
<dd>
<div class="block">Serializes the MultiLongWatermark into a JsonElement.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaExtractor.html#TOPIC">TOPIC</a></span> - Static variable in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaExtractor.html" title="class in gobblin.source.extractor.extract.kafka">KafkaExtractor</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaSource.html#TOPIC_BLACKLIST">TOPIC_BLACKLIST</a></span> - Static variable in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaSource.html" title="class in gobblin.source.extractor.extract.kafka">KafkaSource</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaSource.html#TOPIC_NAME">TOPIC_NAME</a></span> - Static variable in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaSource.html" title="class in gobblin.source.extractor.extract.kafka">KafkaSource</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaSource.html#TOPIC_WHITELIST">TOPIC_WHITELIST</a></span> - Static variable in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaSource.html" title="class in gobblin.source.extractor.extract.kafka">KafkaSource</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaExtractor.html#topicName">topicName</a></span> - Variable in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaExtractor.html" title="class in gobblin.source.extractor.extract.kafka">KafkaExtractor</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaSource.html#TOPICS_MOVE_TO_LATEST_OFFSET">TOPICS_MOVE_TO_LATEST_OFFSET</a></span> - Static variable in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaSource.html" title="class in gobblin.source.extractor.extract.kafka">KafkaSource</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaPartition.html#toString--">toString()</a></span> - Method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaPartition.html" title="class in gobblin.source.extractor.extract.kafka">KafkaPartition</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaRecord.html#toString--">toString()</a></span> - Method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaRecord.html" title="class in gobblin.source.extractor.extract.kafka">KafkaRecord</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/MultiLongWatermark.html#toString--">toString()</a></span> - Method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/MultiLongWatermark.html" title="class in gobblin.source.extractor.extract.kafka">MultiLongWatermark</a></dt>
<dd>&nbsp;</dd>
</dl>
<a name="I:U">
<!-- -->
</a>
<h2 class="title">U</h2>
<dl>
<dt><a href="gobblin/source/extractor/extract/kafka/UniversalKafkaSource.html" title="class in gobblin.source.extractor.extract.kafka"><span class="typeNameLink">UniversalKafkaSource</span></a>&lt;<a href="gobblin/source/extractor/extract/kafka/UniversalKafkaSource.html" title="type parameter in UniversalKafkaSource">S</a>,<a href="gobblin/source/extractor/extract/kafka/UniversalKafkaSource.html" title="type parameter in UniversalKafkaSource">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="gobblin/source/extractor/extract/kafka/KafkaSource.html" title="class in gobblin.source.extractor.extract.kafka"><code>KafkaSource</code></a> to use with arbitrary <a href="gobblin/source/extractor/extract/kafka/KafkaExtractor.html" title="class in gobblin.source.extractor.extract.kafka"><code>KafkaExtractor</code></a>.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/UniversalKafkaSource.html#UniversalKafkaSource--">UniversalKafkaSource()</a></span> - Constructor for class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/UniversalKafkaSource.html" title="class in gobblin.source.extractor.extract.kafka">UniversalKafkaSource</a></dt>
<dd>&nbsp;</dd>
</dl>
<a name="I:V">
<!-- -->
</a>
<h2 class="title">V</h2>
<dl>
<dt><span class="memberNameLink"><a href="gobblin/kafka/client/BaseKafkaConsumerRecord.html#VALUE_SIZE_UNAVAILABLE">VALUE_SIZE_UNAVAILABLE</a></span> - Static variable in class gobblin.kafka.client.<a href="gobblin/kafka/client/BaseKafkaConsumerRecord.html" title="class in gobblin.kafka.client">BaseKafkaConsumerRecord</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/workunit/packer/KafkaWorkUnitPacker.PackerType.html#valueOf-java.lang.String-">valueOf(String)</a></span> - Static method in enum gobblin.source.extractor.extract.kafka.workunit.packer.<a href="gobblin/source/extractor/extract/kafka/workunit/packer/KafkaWorkUnitPacker.PackerType.html" title="enum in gobblin.source.extractor.extract.kafka.workunit.packer">KafkaWorkUnitPacker.PackerType</a></dt>
<dd>
<div class="block">Returns the enum constant of this type with the specified name.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/workunit/packer/KafkaWorkUnitPacker.SizeEstimatorType.html#valueOf-java.lang.String-">valueOf(String)</a></span> - Static method in enum gobblin.source.extractor.extract.kafka.workunit.packer.<a href="gobblin/source/extractor/extract/kafka/workunit/packer/KafkaWorkUnitPacker.SizeEstimatorType.html" title="enum in gobblin.source.extractor.extract.kafka.workunit.packer">KafkaWorkUnitPacker.SizeEstimatorType</a></dt>
<dd>
<div class="block">Returns the enum constant of this type with the specified name.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/workunit/packer/KafkaWorkUnitPacker.PackerType.html#values--">values()</a></span> - Static method in enum gobblin.source.extractor.extract.kafka.workunit.packer.<a href="gobblin/source/extractor/extract/kafka/workunit/packer/KafkaWorkUnitPacker.PackerType.html" title="enum in gobblin.source.extractor.extract.kafka.workunit.packer">KafkaWorkUnitPacker.PackerType</a></dt>
<dd>
<div class="block">Returns an array containing the constants of this enum type, in
the order they are declared.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/workunit/packer/KafkaWorkUnitPacker.SizeEstimatorType.html#values--">values()</a></span> - Static method in enum gobblin.source.extractor.extract.kafka.workunit.packer.<a href="gobblin/source/extractor/extract/kafka/workunit/packer/KafkaWorkUnitPacker.SizeEstimatorType.html" title="enum in gobblin.source.extractor.extract.kafka.workunit.packer">KafkaWorkUnitPacker.SizeEstimatorType</a></dt>
<dd>
<div class="block">Returns an array containing the constants of this enum type, in
the order they are declared.</div>
</dd>
</dl>
<a name="I:W">
<!-- -->
</a>
<h2 class="title">W</h2>
<dl>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaPartition.Builder.html#withId-int-">withId(int)</a></span> - Method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaPartition.Builder.html" title="class in gobblin.source.extractor.extract.kafka">KafkaPartition.Builder</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaPartition.Builder.html#withLeaderHostAndPort-java.lang.String-">withLeaderHostAndPort(String)</a></span> - Method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaPartition.Builder.html" title="class in gobblin.source.extractor.extract.kafka">KafkaPartition.Builder</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaPartition.Builder.html#withLeaderHostAndPort-java.lang.String-int-">withLeaderHostAndPort(String, int)</a></span> - Method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaPartition.Builder.html" title="class in gobblin.source.extractor.extract.kafka">KafkaPartition.Builder</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaPartition.Builder.html#withLeaderId-int-">withLeaderId(int)</a></span> - Method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaPartition.Builder.html" title="class in gobblin.source.extractor.extract.kafka">KafkaPartition.Builder</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaPartition.Builder.html#withTopicName-java.lang.String-">withTopicName(String)</a></span> - Method in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaPartition.Builder.html" title="class in gobblin.source.extractor.extract.kafka">KafkaPartition.Builder</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/workunit/packer/KafkaBiLevelWorkUnitPacker.html#WORKUNIT_PRE_GROUPING_SIZE_FACTOR">WORKUNIT_PRE_GROUPING_SIZE_FACTOR</a></span> - Static variable in class gobblin.source.extractor.extract.kafka.workunit.packer.<a href="gobblin/source/extractor/extract/kafka/workunit/packer/KafkaBiLevelWorkUnitPacker.html" title="class in gobblin.source.extractor.extract.kafka.workunit.packer">KafkaBiLevelWorkUnitPacker</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/KafkaExtractor.html#workUnitState">workUnitState</a></span> - Variable in class gobblin.source.extractor.extract.kafka.<a href="gobblin/source/extractor/extract/kafka/KafkaExtractor.html" title="class in gobblin.source.extractor.extract.kafka">KafkaExtractor</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/kafka/workunit/packer/KafkaWorkUnitPacker.html#worstFitDecreasingBinPacking-java.util.List-int-">worstFitDecreasingBinPacking(List&lt;WorkUnit&gt;, int)</a></span> - Method in class gobblin.source.extractor.extract.kafka.workunit.packer.<a href="gobblin/source/extractor/extract/kafka/workunit/packer/KafkaWorkUnitPacker.html" title="class in gobblin.source.extractor.extract.kafka.workunit.packer">KafkaWorkUnitPacker</a></dt>
<dd>
<div class="block">Pack a list of <a href="http://linkedin.github.io/gobblin/javadoc/0.11.0/gobblin-api/gobblin/source/workunit/WorkUnit.html?is-external=true" title="class or interface in gobblin.source.workunit"><code>WorkUnit</code></a>s into a smaller number of <a href="http://linkedin.github.io/gobblin/javadoc/0.11.0/gobblin-api/gobblin/source/workunit/MultiWorkUnit.html?is-external=true" title="class or interface in gobblin.source.workunit"><code>MultiWorkUnit</code></a>s,
using the worst-fit-decreasing algorithm.</div>
</dd>
<dt><span class="memberNameLink"><a href="gobblin/kafka/schemareg/HttpClientFactory.html#wrap-org.apache.commons.httpclient.HttpClient-">wrap(HttpClient)</a></span> - Method in class gobblin.kafka.schemareg.<a href="gobblin/kafka/schemareg/HttpClientFactory.html" title="class in gobblin.kafka.schemareg">HttpClientFactory</a></dt>
<dd>&nbsp;</dd>
<dt><span class="memberNameLink"><a href="gobblin/metrics/reporter/util/SchemaRegistryVersionWriter.html#writeSchemaVersioningInformation-org.apache.avro.Schema-java.io.DataOutputStream-">writeSchemaVersioningInformation(Schema, DataOutputStream)</a></span> - Method in class gobblin.metrics.reporter.util.<a href="gobblin/metrics/reporter/util/SchemaRegistryVersionWriter.html" title="class in gobblin.metrics.reporter.util">SchemaRegistryVersionWriter</a></dt>
<dd>&nbsp;</dd>
</dl>
<a href="#I:A">A</a>&nbsp;<a href="#I:B">B</a>&nbsp;<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:I">I</a>&nbsp;<a href="#I:K">K</a>&nbsp;<a href="#I:L">L</a>&nbsp;<a href="#I:M">M</a>&nbsp;<a href="#I:N">N</a>&nbsp;<a href="#I:O">O</a>&nbsp;<a href="#I:P">P</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:U">U</a>&nbsp;<a href="#I:V">V</a>&nbsp;<a href="#I:W">W</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>