| <!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:22 PDT 2017 --> |
| <title>Index (gobblin-core-base 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-core-base 0.11.0 API)"; |
| } |
| } |
| catch(err) { |
| } |
| //--> |
| </script> |
| <noscript> |
| <div>JavaScript is disabled on your browser.</div> |
| </noscript> |
| <!-- ========= START OF TOP NAVBAR ======= --> |
| <div class="topNav"><a name="navbar.top"> |
| <!-- --> |
| </a> |
| <div class="skipNav"><a href="#skip.navbar.top" title="Skip navigation links">Skip navigation links</a></div> |
| <a name="navbar.top.firstrow"> |
| <!-- --> |
| </a> |
| <ul class="navList" title="Navigation"> |
| <li><a href="overview-summary.html">Overview</a></li> |
| <li>Package</li> |
| <li>Class</li> |
| <li><a href="overview-tree.html">Tree</a></li> |
| <li><a href="deprecated-list.html">Deprecated</a></li> |
| <li class="navBarCell1Rev">Index</li> |
| <li><a href="help-doc.html">Help</a></li> |
| </ul> |
| </div> |
| <div class="subNav"> |
| <ul class="navList"> |
| <li>Prev</li> |
| <li>Next</li> |
| </ul> |
| <ul class="navList"> |
| <li><a href="index.html?index-all.html" target="_top">Frames</a></li> |
| <li><a href="index-all.html" target="_top">No Frames</a></li> |
| </ul> |
| <ul class="navList" id="allclasses_navbar_top"> |
| <li><a href="allclasses-noframe.html">All Classes</a></li> |
| </ul> |
| <div> |
| <script type="text/javascript"><!-- |
| allClassesLink = document.getElementById("allclasses_navbar_top"); |
| if(window==top) { |
| allClassesLink.style.display = "block"; |
| } |
| else { |
| allClassesLink.style.display = "none"; |
| } |
| //--> |
| </script> |
| </div> |
| <a name="skip.navbar.top"> |
| <!-- --> |
| </a></div> |
| <!-- ========= END OF TOP NAVBAR ========= --> |
| <div class="contentContainer"><a href="#I:A">A</a> <a href="#I:B">B</a> <a href="#I:C">C</a> <a href="#I:D">D</a> <a href="#I:E">E</a> <a href="#I:F">F</a> <a href="#I:G">G</a> <a href="#I:H">H</a> <a href="#I:I">I</a> <a href="#I:J">J</a> <a href="#I:L">L</a> <a href="#I:M">M</a> <a href="#I:N">N</a> <a href="#I:O">O</a> <a href="#I:P">P</a> <a href="#I:R">R</a> <a href="#I:S">S</a> <a href="#I:T">T</a> <a href="#I:U">U</a> <a href="#I:V">V</a> <a href="#I:W">W</a> <a href="#I:Z:Z_">_</a> <a name="I:A"> |
| <!-- --> |
| </a> |
| <h2 class="title">A</h2> |
| <dl> |
| <dt><a href="gobblin/source/extractor/extract/AbstractSource.html" title="class in gobblin.source.extractor.extract"><span class="typeNameLink">AbstractSource</span></a><<a href="gobblin/source/extractor/extract/AbstractSource.html" title="type parameter in AbstractSource">S</a>,<a href="gobblin/source/extractor/extract/AbstractSource.html" title="type parameter in AbstractSource">D</a>> - Class in <a href="gobblin/source/extractor/extract/package-summary.html">gobblin.source.extractor.extract</a></dt> |
| <dd> |
| <div class="block">A base implementation of <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> that provides default behavior.</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/AbstractSource.html#AbstractSource--">AbstractSource()</a></span> - Constructor for class gobblin.source.extractor.extract.<a href="gobblin/source/extractor/extract/AbstractSource.html" title="class in gobblin.source.extractor.extract">AbstractSource</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/AcknowledgableRecordEnvelope.html#ack--">ack()</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/AcknowledgableRecordEnvelope.html" title="class in gobblin.writer">AcknowledgableRecordEnvelope</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/AcknowledgableWatermark.html#ack--">ack()</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/AcknowledgableWatermark.html" title="class in gobblin.writer">AcknowledgableWatermark</a></dt> |
| <dd> </dd> |
| <dt><a href="gobblin/writer/AcknowledgableRecordEnvelope.html" title="class in gobblin.writer"><span class="typeNameLink">AcknowledgableRecordEnvelope</span></a><<a href="gobblin/writer/AcknowledgableRecordEnvelope.html" title="type parameter in AcknowledgableRecordEnvelope">D</a>> - Class in <a href="gobblin/writer/package-summary.html">gobblin.writer</a></dt> |
| <dd> |
| <div class="block">An envelope for record, watermark pairs that need to be acknowledged.</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/AcknowledgableRecordEnvelope.html#AcknowledgableRecordEnvelope-D-gobblin.writer.AcknowledgableWatermark-">AcknowledgableRecordEnvelope(D, AcknowledgableWatermark)</a></span> - Constructor for class gobblin.writer.<a href="gobblin/writer/AcknowledgableRecordEnvelope.html" title="class in gobblin.writer">AcknowledgableRecordEnvelope</a></dt> |
| <dd> </dd> |
| <dt><a href="gobblin/writer/AcknowledgableWatermark.html" title="class in gobblin.writer"><span class="typeNameLink">AcknowledgableWatermark</span></a> - Class in <a href="gobblin/writer/package-summary.html">gobblin.writer</a></dt> |
| <dd> |
| <div class="block">A Checkpointable Watermark that can be acknowledged.</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/AcknowledgableWatermark.html#AcknowledgableWatermark-gobblin.source.extractor.CheckpointableWatermark-">AcknowledgableWatermark(CheckpointableWatermark)</a></span> - Constructor for class gobblin.writer.<a href="gobblin/writer/AcknowledgableWatermark.html" title="class in gobblin.writer">AcknowledgableWatermark</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/extractor/InstrumentedExtractorBase.html#afterRead-D-long-">afterRead(D, long)</a></span> - Method in class gobblin.instrumented.extractor.<a href="gobblin/instrumented/extractor/InstrumentedExtractorBase.html" title="class in gobblin.instrumented.extractor">InstrumentedExtractorBase</a></dt> |
| <dd> |
| <div class="block">Called after each record is read.</div> |
| </dd> |
| <dt><a href="gobblin/test/AnyToJsonConverter.html" title="class in gobblin.test"><span class="typeNameLink">AnyToJsonConverter</span></a> - Class in <a href="gobblin/test/package-summary.html">gobblin.test</a></dt> |
| <dd> |
| <div class="block">Converts any Object into a Json object</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/test/AnyToJsonConverter.html#AnyToJsonConverter--">AnyToJsonConverter()</a></span> - Constructor for class gobblin.test.<a href="gobblin/test/AnyToJsonConverter.html" title="class in gobblin.test">AnyToJsonConverter</a></dt> |
| <dd> </dd> |
| <dt><a href="gobblin/test/AnyToStringConverter.html" title="class in gobblin.test"><span class="typeNameLink">AnyToStringConverter</span></a> - Class in <a href="gobblin/test/package-summary.html">gobblin.test</a></dt> |
| <dd> |
| <div class="block">Converts any Object into a String</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/test/AnyToStringConverter.html#AnyToStringConverter--">AnyToStringConverter()</a></span> - Constructor for class gobblin.test.<a href="gobblin/test/AnyToStringConverter.html" title="class in gobblin.test">AnyToStringConverter</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/Batch.html#append-D-">append(D)</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/Batch.html" title="class in gobblin.writer">Batch</a></dt> |
| <dd> |
| <div class="block">Add a record to this batch</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/BatchAccumulator.html#append-D-gobblin.writer.WriteCallback-">append(D, WriteCallback)</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/BatchAccumulator.html" title="class in gobblin.writer">BatchAccumulator</a></dt> |
| <dd> |
| <div class="block">Append a record to this accumulator</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/BytesBoundedBatch.html#append-D-">append(D)</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/BytesBoundedBatch.html" title="class in gobblin.writer">BytesBoundedBatch</a></dt> |
| <dd> </dd> |
| <dt><a href="gobblin/converter/AsyncConverter1to1.html" title="class in gobblin.converter"><span class="typeNameLink">AsyncConverter1to1</span></a><<a href="gobblin/converter/AsyncConverter1to1.html" title="type parameter in AsyncConverter1to1">SI</a>,<a href="gobblin/converter/AsyncConverter1to1.html" title="type parameter in AsyncConverter1to1">SO</a>,<a href="gobblin/converter/AsyncConverter1to1.html" title="type parameter in AsyncConverter1to1">DI</a>,<a href="gobblin/converter/AsyncConverter1to1.html" title="type parameter in AsyncConverter1to1">DO</a>> - Class in <a href="gobblin/converter/package-summary.html">gobblin.converter</a></dt> |
| <dd> |
| <div class="block">A <a href="http://linkedin.github.io/gobblin/javadoc/0.11.0/gobblin-api/gobblin/converter/Converter.html?is-external=true" title="class or interface in gobblin.converter"><code>Converter</code></a> that allows for pipelining asynchronous conversions.</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/converter/AsyncConverter1to1.html#AsyncConverter1to1--">AsyncConverter1to1()</a></span> - Constructor for class gobblin.converter.<a href="gobblin/converter/AsyncConverter1to1.html" title="class in gobblin.converter">AsyncConverter1to1</a></dt> |
| <dd> </dd> |
| <dt><a href="gobblin/writer/AsyncDataWriter.html" title="interface in gobblin.writer"><span class="typeNameLink">AsyncDataWriter</span></a><<a href="gobblin/writer/AsyncDataWriter.html" title="type parameter in AsyncDataWriter">D</a>> - Interface in <a href="gobblin/writer/package-summary.html">gobblin.writer</a></dt> |
| <dd> |
| <div class="block">An interface for implementing Async Writers for Gobblin.</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/AsyncWriterManager.AsyncWriterManagerBuilder.html#asyncDataWriter-gobblin.writer.AsyncDataWriter-">asyncDataWriter(AsyncDataWriter)</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/AsyncWriterManager.AsyncWriterManagerBuilder.html" title="class in gobblin.writer">AsyncWriterManager.AsyncWriterManagerBuilder</a></dt> |
| <dd> </dd> |
| <dt><a href="gobblin/writer/AsyncWriterManager.html" title="class in gobblin.writer"><span class="typeNameLink">AsyncWriterManager</span></a><<a href="gobblin/writer/AsyncWriterManager.html" title="type parameter in AsyncWriterManager">D</a>> - Class in <a href="gobblin/writer/package-summary.html">gobblin.writer</a></dt> |
| <dd> |
| <div class="block">A Data Writer to use as a base for writing async writers.</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/AsyncWriterManager.html#AsyncWriterManager-com.typesafe.config.Config-long-long-double-boolean-int-int-int-gobblin.writer.AsyncDataWriter-com.google.common.base.Optional-">AsyncWriterManager(Config, long, long, double, boolean, int, int, int, AsyncDataWriter, Optional<Logger>)</a></span> - Constructor for class gobblin.writer.<a href="gobblin/writer/AsyncWriterManager.html" title="class in gobblin.writer">AsyncWriterManager</a></dt> |
| <dd> </dd> |
| <dt><a href="gobblin/writer/AsyncWriterManager.AsyncWriterManagerBuilder.html" title="class in gobblin.writer"><span class="typeNameLink">AsyncWriterManager.AsyncWriterManagerBuilder</span></a> - Class in <a href="gobblin/writer/package-summary.html">gobblin.writer</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/AsyncWriterManager.AsyncWriterManagerBuilder.html#AsyncWriterManagerBuilder--">AsyncWriterManagerBuilder()</a></span> - Constructor for class gobblin.writer.<a href="gobblin/writer/AsyncWriterManager.AsyncWriterManagerBuilder.html" title="class in gobblin.writer">AsyncWriterManager.AsyncWriterManagerBuilder</a></dt> |
| <dd> </dd> |
| <dt><a href="gobblin/converter/filter/AvroProjectionConverter.html" title="class in gobblin.converter.filter"><span class="typeNameLink">AvroProjectionConverter</span></a> - Class in <a href="gobblin/converter/filter/package-summary.html">gobblin.converter.filter</a></dt> |
| <dd> |
| <div class="block">A <a href="http://linkedin.github.io/gobblin/javadoc/0.11.0/gobblin-api/gobblin/converter/Converter.html?is-external=true" title="class or interface in gobblin.converter"><code>Converter</code></a> that removes certain fields from an Avro schema or an Avro record.</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/converter/filter/AvroProjectionConverter.html#AvroProjectionConverter--">AvroProjectionConverter()</a></span> - Constructor for class gobblin.converter.filter.<a href="gobblin/converter/filter/AvroProjectionConverter.html" title="class in gobblin.converter.filter">AvroProjectionConverter</a></dt> |
| <dd> </dd> |
| <dt><a href="gobblin/converter/filter/AvroSchemaFieldRemover.html" title="class in gobblin.converter.filter"><span class="typeNameLink">AvroSchemaFieldRemover</span></a> - Class in <a href="gobblin/converter/filter/package-summary.html">gobblin.converter.filter</a></dt> |
| <dd> |
| <div class="block">A class that removes specific fields from a (possibly recursive) Avro schema.</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/converter/filter/AvroSchemaFieldRemover.html#AvroSchemaFieldRemover-java.lang.String-">AvroSchemaFieldRemover(String)</a></span> - Constructor for class gobblin.converter.filter.<a href="gobblin/converter/filter/AvroSchemaFieldRemover.html" title="class in gobblin.converter.filter">AvroSchemaFieldRemover</a></dt> |
| <dd> </dd> |
| <dt><a href="gobblin/converter/AvroToAvroConverterBase.html" title="class in gobblin.converter"><span class="typeNameLink">AvroToAvroConverterBase</span></a> - Class in <a href="gobblin/converter/package-summary.html">gobblin.converter</a></dt> |
| <dd> |
| <div class="block">A base abstract <a href="http://linkedin.github.io/gobblin/javadoc/0.11.0/gobblin-api/gobblin/converter/Converter.html?is-external=true" title="class or interface in gobblin.converter"><code>Converter</code></a> class for data transformation from Avro to Avro.</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/converter/AvroToAvroConverterBase.html#AvroToAvroConverterBase--">AvroToAvroConverterBase()</a></span> - Constructor for class gobblin.converter.<a href="gobblin/converter/AvroToAvroConverterBase.html" title="class in gobblin.converter">AvroToAvroConverterBase</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/Batch.html#await--">await()</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/Batch.html" title="class in gobblin.writer">Batch</a></dt> |
| <dd> </dd> |
| </dl> |
| <a name="I:B"> |
| <!-- --> |
| </a> |
| <h2 class="title">B</h2> |
| <dl> |
| <dt><a href="gobblin/writer/Batch.html" title="class in gobblin.writer"><span class="typeNameLink">Batch</span></a><<a href="gobblin/writer/Batch.html" title="type parameter in Batch">D</a>> - Class in <a href="gobblin/writer/package-summary.html">gobblin.writer</a></dt> |
| <dd> |
| <div class="block">An Batch class that contains all the records pushed by <a href="gobblin/writer/BatchAccumulator.html" title="class in gobblin.writer"><code>BatchAccumulator</code></a>.</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/Batch.html#Batch--">Batch()</a></span> - Constructor for class gobblin.writer.<a href="gobblin/writer/Batch.html" title="class in gobblin.writer">Batch</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/Batch.html#BATCH_QUEUE_CAPACITY">BATCH_QUEUE_CAPACITY</a></span> - Static variable in class gobblin.writer.<a href="gobblin/writer/Batch.html" title="class in gobblin.writer">Batch</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/Batch.html#BATCH_QUEUE_CAPACITY_DEFAULT">BATCH_QUEUE_CAPACITY_DEFAULT</a></span> - Static variable in class gobblin.writer.<a href="gobblin/writer/Batch.html" title="class in gobblin.writer">Batch</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/Batch.html#BATCH_SIZE">BATCH_SIZE</a></span> - Static variable in class gobblin.writer.<a href="gobblin/writer/Batch.html" title="class in gobblin.writer">Batch</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/Batch.html#BATCH_SIZE_DEFAULT">BATCH_SIZE_DEFAULT</a></span> - Static variable in class gobblin.writer.<a href="gobblin/writer/Batch.html" title="class in gobblin.writer">Batch</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/Batch.html#BATCH_TTL">BATCH_TTL</a></span> - Static variable in class gobblin.writer.<a href="gobblin/writer/Batch.html" title="class in gobblin.writer">Batch</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/Batch.html#BATCH_TTL_DEFAULT">BATCH_TTL_DEFAULT</a></span> - Static variable in class gobblin.writer.<a href="gobblin/writer/Batch.html" title="class in gobblin.writer">Batch</a></dt> |
| <dd> </dd> |
| <dt><a href="gobblin/writer/BatchAccumulator.html" title="class in gobblin.writer"><span class="typeNameLink">BatchAccumulator</span></a><<a href="gobblin/writer/BatchAccumulator.html" title="type parameter in BatchAccumulator">D</a>> - Class in <a href="gobblin/writer/package-summary.html">gobblin.writer</a></dt> |
| <dd> |
| <div class="block">An accumulator which groups multiple records into a batch |
| How batching strategy works depends on the real implementation |
| One way to do this is scanning all the internal batches through an iterator</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/BatchAccumulator.html#BatchAccumulator--">BatchAccumulator()</a></span> - Constructor for class gobblin.writer.<a href="gobblin/writer/BatchAccumulator.html" title="class in gobblin.writer">BatchAccumulator</a></dt> |
| <dd> </dd> |
| <dt><a href="gobblin/writer/BatchAsyncDataWriter.html" title="interface in gobblin.writer"><span class="typeNameLink">BatchAsyncDataWriter</span></a><<a href="gobblin/writer/BatchAsyncDataWriter.html" title="type parameter in BatchAsyncDataWriter">D</a>> - Interface in <a href="gobblin/writer/package-summary.html">gobblin.writer</a></dt> |
| <dd> |
| <div class="block">An interface for implementing Async Writers for Gobblin.</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/extractor/InstrumentedExtractorBase.html#beforeRead--">beforeRead()</a></span> - Method in class gobblin.instrumented.extractor.<a href="gobblin/instrumented/extractor/InstrumentedExtractorBase.html" title="class in gobblin.instrumented.extractor">InstrumentedExtractorBase</a></dt> |
| <dd> |
| <div class="block">Called before each record is read.</div> |
| </dd> |
| <dt><a href="gobblin/writer/BufferedAsyncDataWriter.html" title="class in gobblin.writer"><span class="typeNameLink">BufferedAsyncDataWriter</span></a><<a href="gobblin/writer/BufferedAsyncDataWriter.html" title="type parameter in BufferedAsyncDataWriter">D</a>> - Class in <a href="gobblin/writer/package-summary.html">gobblin.writer</a></dt> |
| <dd> |
| <div class="block">An async data writer which can achieve the buffering and batching capability.</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/BufferedAsyncDataWriter.html#BufferedAsyncDataWriter-gobblin.writer.BatchAccumulator-gobblin.writer.BatchAsyncDataWriter-">BufferedAsyncDataWriter(BatchAccumulator<D>, BatchAsyncDataWriter<D>)</a></span> - Constructor for class gobblin.writer.<a href="gobblin/writer/BufferedAsyncDataWriter.html" title="class in gobblin.writer">BufferedAsyncDataWriter</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/AsyncWriterManager.AsyncWriterManagerBuilder.html#build--">build()</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/AsyncWriterManager.AsyncWriterManagerBuilder.html" title="class in gobblin.writer">AsyncWriterManager.AsyncWriterManagerBuilder</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/crypto/CredentialStoreFactory.html#buildCredentialStore-java.util.Map-">buildCredentialStore(Map<String, Object>)</a></span> - Static method in class gobblin.crypto.<a href="gobblin/crypto/CredentialStoreFactory.html" title="class in gobblin.crypto">CredentialStoreFactory</a></dt> |
| <dd> |
| <div class="block">Build a CredentialStore with the given config parameters.</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/AsyncWriterManager.html#builder--">builder()</a></span> - Static method in class gobblin.writer.<a href="gobblin/writer/AsyncWriterManager.html" title="class in gobblin.writer">AsyncWriterManager</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/compression/CompressionFactory.html#buildStreamCompressor-java.util.Map-">buildStreamCompressor(Map<String, Object>)</a></span> - Static method in class gobblin.compression.<a href="gobblin/compression/CompressionFactory.html" title="class in gobblin.compression">CompressionFactory</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/crypto/EncryptionFactory.html#buildStreamCryptoProvider-java.util.Map-">buildStreamCryptoProvider(Map<String, Object>)</a></span> - Static method in class gobblin.crypto.<a href="gobblin/crypto/EncryptionFactory.html" title="class in gobblin.crypto">EncryptionFactory</a></dt> |
| <dd> |
| <div class="block">Build a StreamCodec with the given config parameters.</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/crypto/EncryptionFactory.html#buildStreamCryptoProvider-java.lang.String-java.util.Map-">buildStreamCryptoProvider(String, Map<String, Object>)</a></span> - Static method in class gobblin.crypto.<a href="gobblin/crypto/EncryptionFactory.html" title="class in gobblin.crypto">EncryptionFactory</a></dt> |
| <dd> |
| <div class="block">Return a StreamEncryptor for the given algorithm and with appropriate parameters.</div> |
| </dd> |
| <dt><a href="gobblin/writer/BytesBoundedBatch.html" title="class in gobblin.writer"><span class="typeNameLink">BytesBoundedBatch</span></a><<a href="gobblin/writer/BytesBoundedBatch.html" title="type parameter in BytesBoundedBatch">D</a>> - Class in <a href="gobblin/writer/package-summary.html">gobblin.writer</a></dt> |
| <dd> |
| <div class="block">A batch which internally saves each record in memory with bounded size limit |
| Also a TTL value is configured, so that an eviction policy can be applied form upper layer.</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/BytesBoundedBatch.html#BytesBoundedBatch-long-long-">BytesBoundedBatch(long, long)</a></span> - Constructor for class gobblin.writer.<a href="gobblin/writer/BytesBoundedBatch.html" title="class in gobblin.writer">BytesBoundedBatch</a></dt> |
| <dd> </dd> |
| <dt><a href="gobblin/writer/BytesBoundedBatch.RecordMemory.html" title="class in gobblin.writer"><span class="typeNameLink">BytesBoundedBatch.RecordMemory</span></a> - Class in <a href="gobblin/writer/package-summary.html">gobblin.writer</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/writer/InstrumentedDataWriterDecorator.html#bytesWritten--">bytesWritten()</a></span> - Method in class gobblin.instrumented.writer.<a href="gobblin/instrumented/writer/InstrumentedDataWriterDecorator.html" title="class in gobblin.instrumented.writer">InstrumentedDataWriterDecorator</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/AsyncWriterManager.html#bytesWritten--">bytesWritten()</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/AsyncWriterManager.html" title="class in gobblin.writer">AsyncWriterManager</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/GenericWriteResponse.html#bytesWritten--">bytesWritten()</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/GenericWriteResponse.html" title="class in gobblin.writer">GenericWriteResponse</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/WriteResponse.html#bytesWritten--">bytesWritten()</a></span> - Method in interface gobblin.writer.<a href="gobblin/writer/WriteResponse.html" title="interface in gobblin.writer">WriteResponse</a></dt> |
| <dd> |
| <div class="block">The number of bytes written as part of this write.</div> |
| </dd> |
| </dl> |
| <a name="I:C"> |
| <!-- --> |
| </a> |
| <h2 class="title">C</h2> |
| <dl> |
| <dt><span class="memberNameLink"><a href="gobblin/source/extractor/DefaultCheckpointableWatermark.html#calculatePercentCompletion-gobblin.source.extractor.Watermark-gobblin.source.extractor.Watermark-">calculatePercentCompletion(Watermark, Watermark)</a></span> - Method in class gobblin.source.extractor.<a href="gobblin/source/extractor/DefaultCheckpointableWatermark.html" title="class in gobblin.source.extractor">DefaultCheckpointableWatermark</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/LongWatermark.html#calculatePercentCompletion-gobblin.source.extractor.Watermark-gobblin.source.extractor.Watermark-">calculatePercentCompletion(Watermark, Watermark)</a></span> - Method in class gobblin.source.extractor.extract.<a href="gobblin/source/extractor/extract/LongWatermark.html" title="class in gobblin.source.extractor.extract">LongWatermark</a></dt> |
| <dd> </dd> |
| <dt><a href="gobblin/async/Callback.html" title="interface in gobblin.async"><span class="typeNameLink">Callback</span></a><<a href="gobblin/async/Callback.html" title="type parameter in Callback">T</a>> - Interface in <a href="gobblin/async/package-summary.html">gobblin.async</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/FutureWrappedWriteCallback.html#cancel-boolean-">cancel(boolean)</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/FutureWrappedWriteCallback.html" title="class in gobblin.writer">FutureWrappedWriteCallback</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/RecordFuture.html#cancel-boolean-">cancel(boolean)</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/RecordFuture.html" title="class in gobblin.writer">RecordFuture</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/WriteResponseFuture.html#cancel-boolean-">cancel(boolean)</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/WriteResponseFuture.html" title="class in gobblin.writer">WriteResponseFuture</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/GobblinMetricsKeys.html#CLASS_META">CLASS_META</a></span> - Static variable in class gobblin.instrumented.<a href="gobblin/instrumented/GobblinMetricsKeys.html" title="class in gobblin.instrumented">GobblinMetricsKeys</a></dt> |
| <dd> |
| <div class="block">The FQN of the class that emitted a tracking event</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/writer/InstrumentedDataWriterDecorator.html#cleanup--">cleanup()</a></span> - Method in class gobblin.instrumented.writer.<a href="gobblin/instrumented/writer/InstrumentedDataWriterDecorator.html" title="class in gobblin.instrumented.writer">InstrumentedDataWriterDecorator</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/AsyncWriterManager.html#cleanup--">cleanup()</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/AsyncWriterManager.html" title="class in gobblin.writer">AsyncWriterManager</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/SyncDataWriter.html#cleanup--">cleanup()</a></span> - Method in interface gobblin.writer.<a href="gobblin/writer/SyncDataWriter.html" title="interface in gobblin.writer">SyncDataWriter</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/converter/InstrumentedConverterDecorator.html#close--">close()</a></span> - Method in class gobblin.instrumented.converter.<a href="gobblin/instrumented/converter/InstrumentedConverterDecorator.html" title="class in gobblin.instrumented.converter">InstrumentedConverterDecorator</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/extractor/InstrumentedExtractorBase.html#close--">close()</a></span> - Method in class gobblin.instrumented.extractor.<a href="gobblin/instrumented/extractor/InstrumentedExtractorBase.html" title="class in gobblin.instrumented.extractor">InstrumentedExtractorBase</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/Instrumented.html#close--">close()</a></span> - Method in class gobblin.instrumented.<a href="gobblin/instrumented/Instrumented.html" title="class in gobblin.instrumented">Instrumented</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/qualitychecker/InstrumentedRowLevelPolicyDecorator.html#close--">close()</a></span> - Method in class gobblin.instrumented.qualitychecker.<a href="gobblin/instrumented/qualitychecker/InstrumentedRowLevelPolicyDecorator.html" title="class in gobblin.instrumented.qualitychecker">InstrumentedRowLevelPolicyDecorator</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/AsyncWriterManager.html#close--">close()</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/AsyncWriterManager.html" title="class in gobblin.writer">AsyncWriterManager</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/BatchAccumulator.html#close--">close()</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/BatchAccumulator.html" title="class in gobblin.writer">BatchAccumulator</a></dt> |
| <dd> |
| <div class="block">When close is invoked, all new coming records will be rejected |
| Add a busy loop here to ensure all the ongoing appends are completed</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/BufferedAsyncDataWriter.html#close--">close()</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/BufferedAsyncDataWriter.html" title="class in gobblin.writer">BufferedAsyncDataWriter</a></dt> |
| <dd> |
| <div class="block">Close all the resources, this will be blocked until all the request are sent and gets acknowledged</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/FineGrainedWatermarkTracker.html#close--">close()</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/FineGrainedWatermarkTracker.html" title="class in gobblin.writer">FineGrainedWatermarkTracker</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/MultiWriterWatermarkManager.html#close--">close()</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/MultiWriterWatermarkManager.html" title="class in gobblin.writer">MultiWriterWatermarkManager</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/SequentialBasedBatchAccumulator.html#close--">close()</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/SequentialBasedBatchAccumulator.html" title="class in gobblin.writer">SequentialBasedBatchAccumulator</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/TrackerBasedWatermarkManager.html#close--">close()</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/TrackerBasedWatermarkManager.html" title="class in gobblin.writer">TrackerBasedWatermarkManager</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/extractor/InstrumentedExtractorBase.html#closer">closer</a></span> - Variable in class gobblin.instrumented.extractor.<a href="gobblin/instrumented/extractor/InstrumentedExtractorBase.html" title="class in gobblin.instrumented.extractor">InstrumentedExtractorBase</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/Instrumented.html#closer">closer</a></span> - Variable in class gobblin.instrumented.<a href="gobblin/instrumented/Instrumented.html" title="class in gobblin.instrumented">Instrumented</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/AsyncWriterManager.html#closer">closer</a></span> - Variable in class gobblin.writer.<a href="gobblin/writer/AsyncWriterManager.html" title="class in gobblin.writer">AsyncWriterManager</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/writer/InstrumentedDataWriterDecorator.html#commit--">commit()</a></span> - Method in class gobblin.instrumented.writer.<a href="gobblin/instrumented/writer/InstrumentedDataWriterDecorator.html" title="class in gobblin.instrumented.writer">InstrumentedDataWriterDecorator</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/AsyncWriterManager.html#commit--">commit()</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/AsyncWriterManager.html" title="class in gobblin.writer">AsyncWriterManager</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/AsyncWriterManager.html#COMMIT_STEP_WAITTIME_MILLIS_DEFAULT">COMMIT_STEP_WAITTIME_MILLIS_DEFAULT</a></span> - Static variable in class gobblin.writer.<a href="gobblin/writer/AsyncWriterManager.html" title="class in gobblin.writer">AsyncWriterManager</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/AsyncWriterManager.html#COMMIT_TIMEOUT_MILLIS_DEFAULT">COMMIT_TIMEOUT_MILLIS_DEFAULT</a></span> - Static variable in class gobblin.writer.<a href="gobblin/writer/AsyncWriterManager.html" title="class in gobblin.writer">AsyncWriterManager</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/WatermarkManager.CommitStatus.html#CommitStatus--">CommitStatus()</a></span> - Constructor for class gobblin.writer.<a href="gobblin/writer/WatermarkManager.CommitStatus.html" title="class in gobblin.writer">WatermarkManager.CommitStatus</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/AsyncWriterManager.AsyncWriterManagerBuilder.html#commitStepWaitTimeInMillis-long-">commitStepWaitTimeInMillis(long)</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/AsyncWriterManager.AsyncWriterManagerBuilder.html" title="class in gobblin.writer">AsyncWriterManager.AsyncWriterManagerBuilder</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/LastWatermarkTracker.html#committedWatermark-gobblin.source.extractor.CheckpointableWatermark-">committedWatermark(CheckpointableWatermark)</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/LastWatermarkTracker.html" title="class in gobblin.writer">LastWatermarkTracker</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/MultiWriterWatermarkTracker.html#committedWatermark-gobblin.source.extractor.CheckpointableWatermark-">committedWatermark(CheckpointableWatermark)</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/MultiWriterWatermarkTracker.html" title="class in gobblin.writer">MultiWriterWatermarkTracker</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/WatermarkTracker.html#committedWatermark-gobblin.source.extractor.CheckpointableWatermark-">committedWatermark(CheckpointableWatermark)</a></span> - Method in interface gobblin.writer.<a href="gobblin/writer/WatermarkTracker.html" title="interface in gobblin.writer">WatermarkTracker</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/LastWatermarkTracker.html#committedWatermarks-java.util.Map-">committedWatermarks(Map<String, CheckpointableWatermark>)</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/LastWatermarkTracker.html" title="class in gobblin.writer">LastWatermarkTracker</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/MultiWriterWatermarkTracker.html#committedWatermarks-java.util.Map-">committedWatermarks(Map<String, CheckpointableWatermark>)</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/MultiWriterWatermarkTracker.html" title="class in gobblin.writer">MultiWriterWatermarkTracker</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/MultiWriterWatermarkTracker.html#committedWatermarks-java.lang.Iterable-">committedWatermarks(Iterable<CheckpointableWatermark>)</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/MultiWriterWatermarkTracker.html" title="class in gobblin.writer">MultiWriterWatermarkTracker</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/WatermarkTracker.html#committedWatermarks-java.util.Map-">committedWatermarks(Map<String, CheckpointableWatermark>)</a></span> - Method in interface gobblin.writer.<a href="gobblin/writer/WatermarkTracker.html" title="interface in gobblin.writer">WatermarkTracker</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/AsyncWriterManager.AsyncWriterManagerBuilder.html#commitTimeoutMillis-long-">commitTimeoutMillis(long)</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/AsyncWriterManager.AsyncWriterManagerBuilder.html" title="class in gobblin.writer">AsyncWriterManager.AsyncWriterManagerBuilder</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/source/extractor/DefaultCheckpointableWatermark.html#compareTo-gobblin.source.extractor.CheckpointableWatermark-">compareTo(CheckpointableWatermark)</a></span> - Method in class gobblin.source.extractor.<a href="gobblin/source/extractor/DefaultCheckpointableWatermark.html" title="class in gobblin.source.extractor">DefaultCheckpointableWatermark</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/LongWatermark.html#compareTo-gobblin.source.extractor.ComparableWatermark-">compareTo(ComparableWatermark)</a></span> - Method in class gobblin.source.extractor.extract.<a href="gobblin/source/extractor/extract/LongWatermark.html" title="class in gobblin.source.extractor.extract">LongWatermark</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/AcknowledgableWatermark.html#compareTo-gobblin.writer.AcknowledgableWatermark-">compareTo(AcknowledgableWatermark)</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/AcknowledgableWatermark.html" title="class in gobblin.writer">AcknowledgableWatermark</a></dt> |
| <dd> </dd> |
| <dt><a href="gobblin/compression/CompressionConfigParser.html" title="class in gobblin.compression"><span class="typeNameLink">CompressionConfigParser</span></a> - Class in <a href="gobblin/compression/package-summary.html">gobblin.compression</a></dt> |
| <dd> |
| <div class="block">Functions for parsing compression configuration</div> |
| </dd> |
| <dt><a href="gobblin/compression/CompressionFactory.html" title="class in gobblin.compression"><span class="typeNameLink">CompressionFactory</span></a> - Class in <a href="gobblin/compression/package-summary.html">gobblin.compression</a></dt> |
| <dd> |
| <div class="block">This class has logic to create compression stream codecs based on configuration parameters.</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/AsyncWriterManager.AsyncWriterManagerBuilder.html#config-com.typesafe.config.Config-">config(Config)</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/AsyncWriterManager.AsyncWriterManagerBuilder.html" title="class in gobblin.writer">AsyncWriterManager.AsyncWriterManagerBuilder</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/GobblinMetricsKeys.html#CONSTRUCT_META">CONSTRUCT_META</a></span> - Static variable in class gobblin.instrumented.<a href="gobblin/instrumented/GobblinMetricsKeys.html" title="class in gobblin.instrumented">GobblinMetricsKeys</a></dt> |
| <dd> |
| <div class="block">The gobblin construct that emitted the event</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/converter/AsyncConverter1to1.html#convertRecord-SO-DI-gobblin.configuration.WorkUnitState-">convertRecord(SO, DI, WorkUnitState)</a></span> - Method in class gobblin.converter.<a href="gobblin/converter/AsyncConverter1to1.html" title="class in gobblin.converter">AsyncConverter1to1</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/converter/AvroToAvroConverterBase.html#convertRecord-org.apache.avro.Schema-org.apache.avro.generic.GenericRecord-gobblin.configuration.WorkUnitState-">convertRecord(Schema, GenericRecord, WorkUnitState)</a></span> - Method in class gobblin.converter.<a href="gobblin/converter/AvroToAvroConverterBase.html" title="class in gobblin.converter">AvroToAvroConverterBase</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/converter/filter/AvroProjectionConverter.html#convertRecord-org.apache.avro.Schema-org.apache.avro.generic.GenericRecord-gobblin.configuration.WorkUnitState-">convertRecord(Schema, GenericRecord, WorkUnitState)</a></span> - Method in class gobblin.converter.filter.<a href="gobblin/converter/filter/AvroProjectionConverter.html" title="class in gobblin.converter.filter">AvroProjectionConverter</a></dt> |
| <dd> |
| <div class="block">Convert the schema of inputRecord to outputSchema.</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/converter/filter/GobblinTrackingEventFlattenFilterConverter.html#convertRecord-org.apache.avro.Schema-org.apache.avro.generic.GenericRecord-gobblin.configuration.WorkUnitState-">convertRecord(Schema, GenericRecord, WorkUnitState)</a></span> - Method in class gobblin.converter.filter.<a href="gobblin/converter/filter/GobblinTrackingEventFlattenFilterConverter.html" title="class in gobblin.converter.filter">GobblinTrackingEventFlattenFilterConverter</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/converter/IdentityConverter.html#convertRecord-java.lang.Object-java.lang.Object-gobblin.configuration.WorkUnitState-">convertRecord(Object, Object, WorkUnitState)</a></span> - Method in class gobblin.converter.<a href="gobblin/converter/IdentityConverter.html" title="class in gobblin.converter">IdentityConverter</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/converter/SamplingConverter.html#convertRecord-java.lang.Object-java.lang.Object-gobblin.configuration.WorkUnitState-">convertRecord(Object, Object, WorkUnitState)</a></span> - Method in class gobblin.converter.<a href="gobblin/converter/SamplingConverter.html" title="class in gobblin.converter">SamplingConverter</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/converter/ToAvroConverterBase.html#convertRecord-org.apache.avro.Schema-DI-gobblin.configuration.WorkUnitState-">convertRecord(Schema, DI, WorkUnitState)</a></span> - Method in class gobblin.converter.<a href="gobblin/converter/ToAvroConverterBase.html" title="class in gobblin.converter">ToAvroConverterBase</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/converter/InstrumentedConverter.html#convertRecord-SO-DI-gobblin.configuration.WorkUnitState-">convertRecord(SO, DI, WorkUnitState)</a></span> - Method in class gobblin.instrumented.converter.<a href="gobblin/instrumented/converter/InstrumentedConverter.html" title="class in gobblin.instrumented.converter">InstrumentedConverter</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/converter/InstrumentedConverterDecorator.html#convertRecord-SO-DI-gobblin.configuration.WorkUnitState-">convertRecord(SO, DI, WorkUnitState)</a></span> - Method in class gobblin.instrumented.converter.<a href="gobblin/instrumented/converter/InstrumentedConverterDecorator.html" title="class in gobblin.instrumented.converter">InstrumentedConverterDecorator</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/test/AnyToJsonConverter.html#convertRecord-java.lang.String-java.lang.Object-gobblin.configuration.WorkUnitState-">convertRecord(String, Object, WorkUnitState)</a></span> - Method in class gobblin.test.<a href="gobblin/test/AnyToJsonConverter.html" title="class in gobblin.test">AnyToJsonConverter</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/test/AnyToStringConverter.html#convertRecord-java.lang.String-java.lang.Object-gobblin.configuration.WorkUnitState-">convertRecord(String, Object, WorkUnitState)</a></span> - Method in class gobblin.test.<a href="gobblin/test/AnyToStringConverter.html" title="class in gobblin.test">AnyToStringConverter</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/converter/AsyncConverter1to1.html#convertRecordAsync-SO-DI-gobblin.configuration.WorkUnitState-">convertRecordAsync(SO, DI, WorkUnitState)</a></span> - Method in class gobblin.converter.<a href="gobblin/converter/AsyncConverter1to1.html" title="class in gobblin.converter">AsyncConverter1to1</a></dt> |
| <dd> |
| <div class="block">Convert the input record asynchronously.</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/converter/InstrumentedConverterDecorator.html#convertRecordImpl-SO-DI-gobblin.configuration.WorkUnitState-">convertRecordImpl(SO, DI, WorkUnitState)</a></span> - Method in class gobblin.instrumented.converter.<a href="gobblin/instrumented/converter/InstrumentedConverterDecorator.html" title="class in gobblin.instrumented.converter">InstrumentedConverterDecorator</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/converter/AsyncConverter1to1.html#convertSchema-SI-gobblin.configuration.WorkUnitState-">convertSchema(SI, WorkUnitState)</a></span> - Method in class gobblin.converter.<a href="gobblin/converter/AsyncConverter1to1.html" title="class in gobblin.converter">AsyncConverter1to1</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/converter/AvroToAvroConverterBase.html#convertSchema-org.apache.avro.Schema-gobblin.configuration.WorkUnitState-">convertSchema(Schema, WorkUnitState)</a></span> - Method in class gobblin.converter.<a href="gobblin/converter/AvroToAvroConverterBase.html" title="class in gobblin.converter">AvroToAvroConverterBase</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/converter/filter/AvroProjectionConverter.html#convertSchema-org.apache.avro.Schema-gobblin.configuration.WorkUnitState-">convertSchema(Schema, WorkUnitState)</a></span> - Method in class gobblin.converter.filter.<a href="gobblin/converter/filter/AvroProjectionConverter.html" title="class in gobblin.converter.filter">AvroProjectionConverter</a></dt> |
| <dd> |
| <div class="block">Remove the specified fields from inputSchema.</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/converter/filter/GobblinTrackingEventFlattenFilterConverter.html#convertSchema-org.apache.avro.Schema-gobblin.configuration.WorkUnitState-">convertSchema(Schema, WorkUnitState)</a></span> - Method in class gobblin.converter.filter.<a href="gobblin/converter/filter/GobblinTrackingEventFlattenFilterConverter.html" title="class in gobblin.converter.filter">GobblinTrackingEventFlattenFilterConverter</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/converter/IdentityConverter.html#convertSchema-java.lang.Object-gobblin.configuration.WorkUnitState-">convertSchema(Object, WorkUnitState)</a></span> - Method in class gobblin.converter.<a href="gobblin/converter/IdentityConverter.html" title="class in gobblin.converter">IdentityConverter</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/converter/SamplingConverter.html#convertSchema-java.lang.Object-gobblin.configuration.WorkUnitState-">convertSchema(Object, WorkUnitState)</a></span> - Method in class gobblin.converter.<a href="gobblin/converter/SamplingConverter.html" title="class in gobblin.converter">SamplingConverter</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/converter/ToAvroConverterBase.html#convertSchema-SI-gobblin.configuration.WorkUnitState-">convertSchema(SI, WorkUnitState)</a></span> - Method in class gobblin.converter.<a href="gobblin/converter/ToAvroConverterBase.html" title="class in gobblin.converter">ToAvroConverterBase</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/converter/InstrumentedConverterDecorator.html#convertSchema-SI-gobblin.configuration.WorkUnitState-">convertSchema(SI, WorkUnitState)</a></span> - Method in class gobblin.instrumented.converter.<a href="gobblin/instrumented/converter/InstrumentedConverterDecorator.html" title="class in gobblin.instrumented.converter">InstrumentedConverterDecorator</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/test/AnyToJsonConverter.html#convertSchema-java.lang.String-gobblin.configuration.WorkUnitState-">convertSchema(String, WorkUnitState)</a></span> - Method in class gobblin.test.<a href="gobblin/test/AnyToJsonConverter.html" title="class in gobblin.test">AnyToJsonConverter</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/test/AnyToStringConverter.html#convertSchema-java.lang.String-gobblin.configuration.WorkUnitState-">convertSchema(String, WorkUnitState)</a></span> - Method in class gobblin.test.<a href="gobblin/test/AnyToStringConverter.html" title="class in gobblin.test">AnyToStringConverter</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/AbstractSource.html#createExtract-gobblin.source.workunit.Extract.TableType-java.lang.String-java.lang.String-">createExtract(Extract.TableType, String, String)</a></span> - Method in class gobblin.source.extractor.extract.<a href="gobblin/source/extractor/extract/AbstractSource.html" title="class in gobblin.source.extractor.extract">AbstractSource</a></dt> |
| <dd> </dd> |
| <dt><a href="gobblin/crypto/CredentialStoreFactory.html" title="class in gobblin.crypto"><span class="typeNameLink">CredentialStoreFactory</span></a> - Class in <a href="gobblin/crypto/package-summary.html">gobblin.crypto</a></dt> |
| <dd> |
| <div class="block">This class knows how to build encryption algorithms based on configuration parameters.</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/crypto/CredentialStoreFactory.html#CredentialStoreFactory--">CredentialStoreFactory()</a></span> - Constructor for class gobblin.crypto.<a href="gobblin/crypto/CredentialStoreFactory.html" title="class in gobblin.crypto">CredentialStoreFactory</a></dt> |
| <dd> </dd> |
| </dl> |
| <a name="I:D"> |
| <!-- --> |
| </a> |
| <h2 class="title">D</h2> |
| <dl> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/BatchAccumulator.html#deallocate-gobblin.writer.Batch-">deallocate(Batch<D>)</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/BatchAccumulator.html" title="class in gobblin.writer">BatchAccumulator</a></dt> |
| <dd> |
| <div class="block">Release some resource current batch is allocated</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/SequentialBasedBatchAccumulator.html#deallocate-gobblin.writer.Batch-">deallocate(Batch<D>)</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/SequentialBasedBatchAccumulator.html" title="class in gobblin.writer">SequentialBasedBatchAccumulator</a></dt> |
| <dd> |
| <div class="block">Once batch is acknowledged, remove it from incomplete list</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/source/extractor/limiter/LimiterConfigurationKeys.html#DEFAULT_LIMITER_REPORT_KEY_LIST">DEFAULT_LIMITER_REPORT_KEY_LIST</a></span> - Static variable in class gobblin.source.extractor.limiter.<a href="gobblin/source/extractor/limiter/LimiterConfigurationKeys.html" title="class in gobblin.source.extractor.limiter">LimiterConfigurationKeys</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/converter/AsyncConverter1to1.html#DEFAULT_MAX_CONCURRENT_ASYNC_CONVERSIONS">DEFAULT_MAX_CONCURRENT_ASYNC_CONVERSIONS</a></span> - Static variable in class gobblin.converter.<a href="gobblin/converter/AsyncConverter1to1.html" title="class in gobblin.converter">AsyncConverter1to1</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/converter/SamplingConverter.html#DEFAULT_SAMPLE_RATIO">DEFAULT_SAMPLE_RATIO</a></span> - Static variable in class gobblin.converter.<a href="gobblin/converter/SamplingConverter.html" title="class in gobblin.converter">SamplingConverter</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/WatermarkTrackerFactory.TrackerBehavior.html#defaultBehavior--">defaultBehavior()</a></span> - Static method in class gobblin.writer.<a href="gobblin/writer/WatermarkTrackerFactory.TrackerBehavior.html" title="class in gobblin.writer">WatermarkTrackerFactory.TrackerBehavior</a></dt> |
| <dd> </dd> |
| <dt><a href="gobblin/source/extractor/DefaultCheckpointableWatermark.html" title="class in gobblin.source.extractor"><span class="typeNameLink">DefaultCheckpointableWatermark</span></a> - Class in <a href="gobblin/source/extractor/package-summary.html">gobblin.source.extractor</a></dt> |
| <dd> |
| <div class="block">A <a href="http://linkedin.github.io/gobblin/javadoc/0.11.0/gobblin-api/gobblin/source/extractor/CheckpointableWatermark.html?is-external=true" title="class or interface in gobblin.source.extractor"><code>CheckpointableWatermark</code></a> that wraps a <a href="http://linkedin.github.io/gobblin/javadoc/0.11.0/gobblin-api/gobblin/source/extractor/ComparableWatermark.html?is-external=true" title="class or interface in gobblin.source.extractor"><code>ComparableWatermark</code></a> specific to a source.</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/source/extractor/DefaultCheckpointableWatermark.html#DefaultCheckpointableWatermark-java.lang.String-gobblin.source.extractor.ComparableWatermark-">DefaultCheckpointableWatermark(String, ComparableWatermark)</a></span> - Constructor for class gobblin.source.extractor.<a href="gobblin/source/extractor/DefaultCheckpointableWatermark.html" title="class in gobblin.source.extractor">DefaultCheckpointableWatermark</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/AcknowledgableRecordEnvelope.html#derivedEnvelope-D-">derivedEnvelope(D)</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/AcknowledgableRecordEnvelope.html" title="class in gobblin.writer">AcknowledgableRecordEnvelope</a></dt> |
| <dd> |
| <div class="block">Create a derived record envelope from this one.</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/Batch.html#done--">done()</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/Batch.html" title="class in gobblin.writer">Batch</a></dt> |
| <dd> </dd> |
| </dl> |
| <a name="I:E"> |
| <!-- --> |
| </a> |
| <h2 class="title">E</h2> |
| <dl> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/WriteCallback.html#EMPTY">EMPTY</a></span> - Static variable in interface gobblin.writer.<a href="gobblin/writer/WriteCallback.html" title="interface in gobblin.writer">WriteCallback</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/WriteResponse.html#EMPTY">EMPTY</a></span> - Static variable in interface gobblin.writer.<a href="gobblin/writer/WriteResponse.html" title="interface in gobblin.writer">WriteResponse</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/crypto/EncryptionConfigParser.html#ENCRYPTION_ALGORITHM_KEY">ENCRYPTION_ALGORITHM_KEY</a></span> - Static variable in class gobblin.crypto.<a href="gobblin/crypto/EncryptionConfigParser.html" title="class in gobblin.crypto">EncryptionConfigParser</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/crypto/EncryptionConfigParser.html#ENCRYPTION_KEY_NAME">ENCRYPTION_KEY_NAME</a></span> - Static variable in class gobblin.crypto.<a href="gobblin/crypto/EncryptionConfigParser.html" title="class in gobblin.crypto">EncryptionConfigParser</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/crypto/EncryptionConfigParser.html#ENCRYPTION_KEYSTORE_ENCODING_DEFAULT">ENCRYPTION_KEYSTORE_ENCODING_DEFAULT</a></span> - Static variable in class gobblin.crypto.<a href="gobblin/crypto/EncryptionConfigParser.html" title="class in gobblin.crypto">EncryptionConfigParser</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/crypto/EncryptionConfigParser.html#ENCRYPTION_KEYSTORE_ENCODING_KEY">ENCRYPTION_KEYSTORE_ENCODING_KEY</a></span> - Static variable in class gobblin.crypto.<a href="gobblin/crypto/EncryptionConfigParser.html" title="class in gobblin.crypto">EncryptionConfigParser</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/crypto/EncryptionConfigParser.html#ENCRYPTION_KEYSTORE_PASSWORD_KEY">ENCRYPTION_KEYSTORE_PASSWORD_KEY</a></span> - Static variable in class gobblin.crypto.<a href="gobblin/crypto/EncryptionConfigParser.html" title="class in gobblin.crypto">EncryptionConfigParser</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/crypto/EncryptionConfigParser.html#ENCRYPTION_KEYSTORE_PATH_KEY">ENCRYPTION_KEYSTORE_PATH_KEY</a></span> - Static variable in class gobblin.crypto.<a href="gobblin/crypto/EncryptionConfigParser.html" title="class in gobblin.crypto">EncryptionConfigParser</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/crypto/EncryptionConfigParser.html#ENCRYPTION_KEYSTORE_TYPE_KEY">ENCRYPTION_KEYSTORE_TYPE_KEY</a></span> - Static variable in class gobblin.crypto.<a href="gobblin/crypto/EncryptionConfigParser.html" title="class in gobblin.crypto">EncryptionConfigParser</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/crypto/EncryptionConfigParser.html#ENCRYPTION_KEYSTORE_TYPE_KEY_DEFAULT">ENCRYPTION_KEYSTORE_TYPE_KEY_DEFAULT</a></span> - Static variable in class gobblin.crypto.<a href="gobblin/crypto/EncryptionConfigParser.html" title="class in gobblin.crypto">EncryptionConfigParser</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/crypto/EncryptionConfigParser.html#ENCRYPTION_TYPE_ANY">ENCRYPTION_TYPE_ANY</a></span> - Static variable in class gobblin.crypto.<a href="gobblin/crypto/EncryptionConfigParser.html" title="class in gobblin.crypto">EncryptionConfigParser</a></dt> |
| <dd> </dd> |
| <dt><a href="gobblin/crypto/EncryptionConfigParser.html" title="class in gobblin.crypto"><span class="typeNameLink">EncryptionConfigParser</span></a> - Class in <a href="gobblin/crypto/package-summary.html">gobblin.crypto</a></dt> |
| <dd> |
| <div class="block">Extract encryption related information from taskState</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/crypto/EncryptionConfigParser.html#EncryptionConfigParser--">EncryptionConfigParser()</a></span> - Constructor for class gobblin.crypto.<a href="gobblin/crypto/EncryptionConfigParser.html" title="class in gobblin.crypto">EncryptionConfigParser</a></dt> |
| <dd> </dd> |
| <dt><a href="gobblin/crypto/EncryptionConfigParser.EntityType.html" title="enum in gobblin.crypto"><span class="typeNameLink">EncryptionConfigParser.EntityType</span></a> - Enum in <a href="gobblin/crypto/package-summary.html">gobblin.crypto</a></dt> |
| <dd> |
| <div class="block">Represents the entity we are trying to retrieve configuration for.</div> |
| </dd> |
| <dt><a href="gobblin/crypto/EncryptionFactory.html" title="class in gobblin.crypto"><span class="typeNameLink">EncryptionFactory</span></a> - Class in <a href="gobblin/crypto/package-summary.html">gobblin.crypto</a></dt> |
| <dd> |
| <div class="block">This class knows how to build encryption algorithms based on configuration parameters.</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/crypto/EncryptionFactory.html#EncryptionFactory--">EncryptionFactory()</a></span> - Constructor for class gobblin.crypto.<a href="gobblin/crypto/EncryptionFactory.html" title="class in gobblin.crypto">EncryptionFactory</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/Instrumented.html#endTimer-com.google.common.base.Optional-">endTimer(Optional<Timer.Context>)</a></span> - Static method in class gobblin.instrumented.<a href="gobblin/instrumented/Instrumented.html" title="class in gobblin.instrumented">Instrumented</a></dt> |
| <dd> |
| <div class="block">Ends a <code>Timer.Context</code> only if it exists.</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/BatchAccumulator.html#enqueue-D-gobblin.writer.WriteCallback-">enqueue(D, WriteCallback)</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/BatchAccumulator.html" title="class in gobblin.writer">BatchAccumulator</a></dt> |
| <dd> |
| <div class="block">Add a record to this accumulator</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/SequentialBasedBatchAccumulator.html#enqueue-D-gobblin.writer.WriteCallback-">enqueue(D, WriteCallback)</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/SequentialBasedBatchAccumulator.html" title="class in gobblin.writer">SequentialBasedBatchAccumulator</a></dt> |
| <dd> |
| <div class="block">Add a data to internal deque data structure</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/AcknowledgableWatermark.html#equals-java.lang.Object-">equals(Object)</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/AcknowledgableWatermark.html" title="class in gobblin.writer">AcknowledgableWatermark</a></dt> |
| <dd> </dd> |
| <dt><a href="gobblin/source/extractor/extract/EventBasedExtractor.html" title="class in gobblin.source.extractor.extract"><span class="typeNameLink">EventBasedExtractor</span></a><<a href="gobblin/source/extractor/extract/EventBasedExtractor.html" title="type parameter in EventBasedExtractor">S</a>,<a href="gobblin/source/extractor/extract/EventBasedExtractor.html" title="type parameter in EventBasedExtractor">D</a>> - Class in <a href="gobblin/source/extractor/extract/package-summary.html">gobblin.source.extractor.extract</a></dt> |
| <dd> |
| <div class="block">A base <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> class for |
| event-based sources.</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/EventBasedExtractor.html#EventBasedExtractor-gobblin.configuration.WorkUnitState-">EventBasedExtractor(WorkUnitState)</a></span> - Constructor for class gobblin.source.extractor.extract.<a href="gobblin/source/extractor/extract/EventBasedExtractor.html" title="class in gobblin.source.extractor.extract">EventBasedExtractor</a></dt> |
| <dd> </dd> |
| <dt><a href="gobblin/source/extractor/extract/EventBasedSource.html" title="class in gobblin.source.extractor.extract"><span class="typeNameLink">EventBasedSource</span></a><<a href="gobblin/source/extractor/extract/EventBasedSource.html" title="type parameter in EventBasedSource">S</a>,<a href="gobblin/source/extractor/extract/EventBasedSource.html" title="type parameter in EventBasedSource">D</a>> - Class in <a href="gobblin/source/extractor/extract/package-summary.html">gobblin.source.extractor.extract</a></dt> |
| <dd> |
| <div class="block">A base implementation of <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> for |
| event-based sources.</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/EventBasedSource.html#EventBasedSource--">EventBasedSource()</a></span> - Constructor for class gobblin.source.extractor.extract.<a href="gobblin/source/extractor/extract/EventBasedSource.html" title="class in gobblin.source.extractor.extract">EventBasedSource</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/qualitychecker/InstrumentedRowLevelPolicy.html#executePolicy-java.lang.Object-">executePolicy(Object)</a></span> - Method in class gobblin.instrumented.qualitychecker.<a href="gobblin/instrumented/qualitychecker/InstrumentedRowLevelPolicy.html" title="class in gobblin.instrumented.qualitychecker">InstrumentedRowLevelPolicy</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/qualitychecker/InstrumentedRowLevelPolicyDecorator.html#executePolicy-java.lang.Object-">executePolicy(Object)</a></span> - Method in class gobblin.instrumented.qualitychecker.<a href="gobblin/instrumented/qualitychecker/InstrumentedRowLevelPolicyDecorator.html" title="class in gobblin.instrumented.qualitychecker">InstrumentedRowLevelPolicyDecorator</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/qualitychecker/InstrumentedRowLevelPolicyDecorator.html#executePolicyImpl-java.lang.Object-">executePolicyImpl(Object)</a></span> - Method in class gobblin.instrumented.qualitychecker.<a href="gobblin/instrumented/qualitychecker/InstrumentedRowLevelPolicyDecorator.html" title="class in gobblin.instrumented.qualitychecker">InstrumentedRowLevelPolicyDecorator</a></dt> |
| <dd> </dd> |
| </dl> |
| <a name="I:F"> |
| <!-- --> |
| </a> |
| <h2 class="title">F</h2> |
| <dl> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/AsyncWriterManager.html#FAILURE_ALLOWANCE_RATIO_DEFAULT">FAILURE_ALLOWANCE_RATIO_DEFAULT</a></span> - Static variable in class gobblin.writer.<a href="gobblin/writer/AsyncWriterManager.html" title="class in gobblin.writer">AsyncWriterManager</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/AsyncWriterManager.AsyncWriterManagerBuilder.html#failureAllowanceRatio-double-">failureAllowanceRatio(double)</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/AsyncWriterManager.AsyncWriterManagerBuilder.html" title="class in gobblin.writer">AsyncWriterManager.AsyncWriterManagerBuilder</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/converter/filter/GobblinTrackingEventFlattenFilterConverter.html#FIELDS_RENAME_MAP">FIELDS_RENAME_MAP</a></span> - Static variable in class gobblin.converter.filter.<a href="gobblin/converter/filter/GobblinTrackingEventFlattenFilterConverter.html" title="class in gobblin.converter.filter">GobblinTrackingEventFlattenFilterConverter</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/converter/filter/GobblinTrackingEventFlattenFilterConverter.html#FIELDS_TO_FLATTEN">FIELDS_TO_FLATTEN</a></span> - Static variable in class gobblin.converter.filter.<a href="gobblin/converter/filter/GobblinTrackingEventFlattenFilterConverter.html" title="class in gobblin.converter.filter">GobblinTrackingEventFlattenFilterConverter</a></dt> |
| <dd> </dd> |
| <dt><a href="gobblin/writer/FineGrainedWatermarkTracker.html" title="class in gobblin.writer"><span class="typeNameLink">FineGrainedWatermarkTracker</span></a> - Class in <a href="gobblin/writer/package-summary.html">gobblin.writer</a></dt> |
| <dd> |
| <div class="block">A class to handle fine-grain watermarks.</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/FineGrainedWatermarkTracker.html#FineGrainedWatermarkTracker-com.typesafe.config.Config-">FineGrainedWatermarkTracker(Config)</a></span> - Constructor for class gobblin.writer.<a href="gobblin/writer/FineGrainedWatermarkTracker.html" title="class in gobblin.writer">FineGrainedWatermarkTracker</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/AsyncDataWriter.html#flush--">flush()</a></span> - Method in interface gobblin.writer.<a href="gobblin/writer/AsyncDataWriter.html" title="interface in gobblin.writer">AsyncDataWriter</a></dt> |
| <dd> |
| <div class="block">Flushes all pending writes</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/BatchAccumulator.html#flush--">flush()</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/BatchAccumulator.html" title="class in gobblin.writer">BatchAccumulator</a></dt> |
| <dd> |
| <div class="block">Wait until all the incomplete batches to be acknowledged</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/BatchAsyncDataWriter.html#flush--">flush()</a></span> - Method in interface gobblin.writer.<a href="gobblin/writer/BatchAsyncDataWriter.html" title="interface in gobblin.writer">BatchAsyncDataWriter</a></dt> |
| <dd> |
| <div class="block">Flushes all pending batches</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/BufferedAsyncDataWriter.html#flush--">flush()</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/BufferedAsyncDataWriter.html" title="class in gobblin.writer">BufferedAsyncDataWriter</a></dt> |
| <dd> |
| <div class="block">Flushes all pending writes</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/SequentialBasedBatchAccumulator.html#flush--">flush()</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/SequentialBasedBatchAccumulator.html" title="class in gobblin.writer">SequentialBasedBatchAccumulator</a></dt> |
| <dd> |
| <div class="block">This will block until all the incomplete batches are acknowledged</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/BufferedAsyncDataWriter.html#forceClose--">forceClose()</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/BufferedAsyncDataWriter.html" title="class in gobblin.writer">BufferedAsyncDataWriter</a></dt> |
| <dd> |
| <div class="block">Force to close all the resources and drop all the pending requests</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/fork/InstrumentedForkOperator.html#forkDataRecord-gobblin.configuration.WorkUnitState-D-">forkDataRecord(WorkUnitState, D)</a></span> - Method in class gobblin.instrumented.fork.<a href="gobblin/instrumented/fork/InstrumentedForkOperator.html" title="class in gobblin.instrumented.fork">InstrumentedForkOperator</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/fork/InstrumentedForkOperatorDecorator.html#forkDataRecord-gobblin.configuration.WorkUnitState-D-">forkDataRecord(WorkUnitState, D)</a></span> - Method in class gobblin.instrumented.fork.<a href="gobblin/instrumented/fork/InstrumentedForkOperatorDecorator.html" title="class in gobblin.instrumented.fork">InstrumentedForkOperatorDecorator</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/fork/InstrumentedForkOperatorDecorator.html#forkDataRecordImpl-gobblin.configuration.WorkUnitState-D-">forkDataRecordImpl(WorkUnitState, D)</a></span> - Method in class gobblin.instrumented.fork.<a href="gobblin/instrumented/fork/InstrumentedForkOperatorDecorator.html" title="class in gobblin.instrumented.fork">InstrumentedForkOperatorDecorator</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/fork/InstrumentedForkOperatorDecorator.html#forkSchema-gobblin.configuration.WorkUnitState-S-">forkSchema(WorkUnitState, S)</a></span> - Method in class gobblin.instrumented.fork.<a href="gobblin/instrumented/fork/InstrumentedForkOperatorDecorator.html" title="class in gobblin.instrumented.fork">InstrumentedForkOperatorDecorator</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/source/extractor/JobCommitPolicy.html#forName-java.lang.String-">forName(String)</a></span> - Static method in enum gobblin.source.extractor.<a href="gobblin/source/extractor/JobCommitPolicy.html" title="enum in gobblin.source.extractor">JobCommitPolicy</a></dt> |
| <dd> |
| <div class="block">Get a <a href="gobblin/source/extractor/JobCommitPolicy.html" title="enum in gobblin.source.extractor"><code>JobCommitPolicy</code></a> for the given job commit policy name.</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/source/extractor/WorkUnitRetryPolicy.html#forName-java.lang.String-">forName(String)</a></span> - Static method in enum gobblin.source.extractor.<a href="gobblin/source/extractor/WorkUnitRetryPolicy.html" title="enum in gobblin.source.extractor">WorkUnitRetryPolicy</a></dt> |
| <dd> |
| <div class="block">Get a <a href="gobblin/source/extractor/WorkUnitRetryPolicy.html" title="enum in gobblin.source.extractor"><code>WorkUnitRetryPolicy</code></a> of the given name.</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/PartitionAwareDataWriterBuilder.html#forPartition-org.apache.avro.generic.GenericRecord-">forPartition(GenericRecord)</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/PartitionAwareDataWriterBuilder.html" title="class in gobblin.writer">PartitionAwareDataWriterBuilder</a></dt> |
| <dd> |
| <div class="block">Sets the partition that the build <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> will handle.</div> |
| </dd> |
| <dt><a href="gobblin/writer/FutureWrappedWriteCallback.html" title="class in gobblin.writer"><span class="typeNameLink">FutureWrappedWriteCallback</span></a> - Class in <a href="gobblin/writer/package-summary.html">gobblin.writer</a></dt> |
| <dd> |
| <div class="block">A helper class that makes it easy to implement a future that is updated by a callback.</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/FutureWrappedWriteCallback.html#FutureWrappedWriteCallback-gobblin.writer.WriteCallback-">FutureWrappedWriteCallback(WriteCallback)</a></span> - Constructor for class gobblin.writer.<a href="gobblin/writer/FutureWrappedWriteCallback.html" title="class in gobblin.writer">FutureWrappedWriteCallback</a></dt> |
| <dd> </dd> |
| </dl> |
| <a name="I:G"> |
| <!-- --> |
| </a> |
| <h2 class="title">G</h2> |
| <dl> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/extractor/InstrumentedExtractorBase.html#generateTags-gobblin.configuration.State-">generateTags(State)</a></span> - Method in class gobblin.instrumented.extractor.<a href="gobblin/instrumented/extractor/InstrumentedExtractorBase.html" title="class in gobblin.instrumented.extractor">InstrumentedExtractorBase</a></dt> |
| <dd> |
| <div class="block">Default with no additional tags</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/Instrumentable.html#generateTags-gobblin.configuration.State-">generateTags(State)</a></span> - Method in interface gobblin.instrumented.<a href="gobblin/instrumented/Instrumentable.html" title="interface in gobblin.instrumented">Instrumentable</a></dt> |
| <dd> |
| <div class="block">Generate tags that should be added to the <a href="http://linkedin.github.io/gobblin/javadoc/0.11.0/gobblin-metrics/gobblin/metrics/MetricContext.html?is-external=true" title="class or interface in gobblin.metrics"><code>MetricContext</code></a>.</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/Instrumented.html#generateTags-gobblin.configuration.State-">generateTags(State)</a></span> - Method in class gobblin.instrumented.<a href="gobblin/instrumented/Instrumented.html" title="class in gobblin.instrumented">Instrumented</a></dt> |
| <dd> |
| <div class="block">Default with no additional tags</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/writer/InstrumentedPartitionedDataWriterDecorator.html#generateTags-gobblin.configuration.State-">generateTags(State)</a></span> - Method in class gobblin.instrumented.writer.<a href="gobblin/instrumented/writer/InstrumentedPartitionedDataWriterDecorator.html" title="class in gobblin.instrumented.writer">InstrumentedPartitionedDataWriterDecorator</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/AsyncWriterManager.html#generateTags-gobblin.configuration.State-">generateTags(State)</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/AsyncWriterManager.html" title="class in gobblin.writer">AsyncWriterManager</a></dt> |
| <dd> |
| <div class="block">Default with no additional tags</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/FineGrainedWatermarkTracker.html#generateTags-gobblin.configuration.State-">generateTags(State)</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/FineGrainedWatermarkTracker.html" title="class in gobblin.writer">FineGrainedWatermarkTracker</a></dt> |
| <dd> |
| <div class="block">Default with no additional tags</div> |
| </dd> |
| <dt><a href="gobblin/writer/GenericWriteResponse.html" title="class in gobblin.writer"><span class="typeNameLink">GenericWriteResponse</span></a><<a href="gobblin/writer/GenericWriteResponse.html" title="type parameter in GenericWriteResponse">T</a>> - Class in <a href="gobblin/writer/package-summary.html">gobblin.writer</a></dt> |
| <dd> |
| <div class="block">A generic write response to wrap responses from other systems.</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/GenericWriteResponse.html#GenericWriteResponse-T-">GenericWriteResponse(T)</a></span> - Constructor for class gobblin.writer.<a href="gobblin/writer/GenericWriteResponse.html" title="class in gobblin.writer">GenericWriteResponse</a></dt> |
| <dd> </dd> |
| <dt><a href="gobblin/writer/GenericWriteResponseWrapper.html" title="class in gobblin.writer"><span class="typeNameLink">GenericWriteResponseWrapper</span></a><<a href="gobblin/writer/GenericWriteResponseWrapper.html" title="type parameter in GenericWriteResponseWrapper">T</a>> - Class in <a href="gobblin/writer/package-summary.html">gobblin.writer</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/GenericWriteResponseWrapper.html#GenericWriteResponseWrapper--">GenericWriteResponseWrapper()</a></span> - Constructor for class gobblin.writer.<a href="gobblin/writer/GenericWriteResponseWrapper.html" title="class in gobblin.writer">GenericWriteResponseWrapper</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/FutureWrappedWriteCallback.html#get--">get()</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/FutureWrappedWriteCallback.html" title="class in gobblin.writer">FutureWrappedWriteCallback</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/FutureWrappedWriteCallback.html#get-long-java.util.concurrent.TimeUnit-">get(long, TimeUnit)</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/FutureWrappedWriteCallback.html" title="class in gobblin.writer">FutureWrappedWriteCallback</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/RecordFuture.html#get--">get()</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/RecordFuture.html" title="class in gobblin.writer">RecordFuture</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/RecordFuture.html#get-long-java.util.concurrent.TimeUnit-">get(long, TimeUnit)</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/RecordFuture.html" title="class in gobblin.writer">RecordFuture</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/WriteResponseFuture.html#get--">get()</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/WriteResponseFuture.html" title="class in gobblin.writer">WriteResponseFuture</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/WriteResponseFuture.html#get-long-java.util.concurrent.TimeUnit-">get(long, TimeUnit)</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/WriteResponseFuture.html" title="class in gobblin.writer">WriteResponseFuture</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/LastWatermarkTracker.html#getAllCommitableWatermarks--">getAllCommitableWatermarks()</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/LastWatermarkTracker.html" title="class in gobblin.writer">LastWatermarkTracker</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/MultiWriterWatermarkTracker.html#getAllCommitableWatermarks--">getAllCommitableWatermarks()</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/MultiWriterWatermarkTracker.html" title="class in gobblin.writer">MultiWriterWatermarkTracker</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/WatermarkTracker.html#getAllCommitableWatermarks--">getAllCommitableWatermarks()</a></span> - Method in interface gobblin.writer.<a href="gobblin/writer/WatermarkTracker.html" title="interface in gobblin.writer">WatermarkTracker</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/LastWatermarkTracker.html#getAllUnacknowledgedWatermarks--">getAllUnacknowledgedWatermarks()</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/LastWatermarkTracker.html" title="class in gobblin.writer">LastWatermarkTracker</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/MultiWriterWatermarkTracker.html#getAllUnacknowledgedWatermarks--">getAllUnacknowledgedWatermarks()</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/MultiWriterWatermarkTracker.html" title="class in gobblin.writer">MultiWriterWatermarkTracker</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/WatermarkTracker.html#getAllUnacknowledgedWatermarks--">getAllUnacknowledgedWatermarks()</a></span> - Method in interface gobblin.writer.<a href="gobblin/writer/WatermarkTracker.html" title="interface in gobblin.writer">WatermarkTracker</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/fork/InstrumentedForkOperatorDecorator.html#getBranches-gobblin.configuration.WorkUnitState-">getBranches(WorkUnitState)</a></span> - Method in class gobblin.instrumented.fork.<a href="gobblin/instrumented/fork/InstrumentedForkOperatorDecorator.html" title="class in gobblin.instrumented.fork">InstrumentedForkOperatorDecorator</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/AcknowledgableWatermark.html#getCheckpointableWatermark--">getCheckpointableWatermark()</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/AcknowledgableWatermark.html" title="class in gobblin.writer">AcknowledgableWatermark</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/source/extractor/JobCommitPolicy.html#getCommitPolicy-java.util.Properties-">getCommitPolicy(Properties)</a></span> - Static method in enum gobblin.source.extractor.<a href="gobblin/source/extractor/JobCommitPolicy.html" title="enum in gobblin.source.extractor">JobCommitPolicy</a></dt> |
| <dd> |
| <div class="block">Get a <a href="gobblin/source/extractor/JobCommitPolicy.html" title="enum in gobblin.source.extractor"><code>JobCommitPolicy</code></a> through its name specified in configuration property |
| <a href="http://linkedin.github.io/gobblin/javadoc/0.11.0/gobblin-api/gobblin/configuration/ConfigurationKeys.html?is-external=true#JOB_COMMIT_POLICY_KEY" title="class or interface in gobblin.configuration"><code>ConfigurationKeys.JOB_COMMIT_POLICY_KEY</code></a>.</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/source/extractor/JobCommitPolicy.html#getCommitPolicy-gobblin.configuration.State-">getCommitPolicy(State)</a></span> - Static method in enum gobblin.source.extractor.<a href="gobblin/source/extractor/JobCommitPolicy.html" title="enum in gobblin.source.extractor">JobCommitPolicy</a></dt> |
| <dd> |
| <div class="block">Get a <a href="gobblin/source/extractor/JobCommitPolicy.html" title="enum in gobblin.source.extractor"><code>JobCommitPolicy</code></a> through its name specified in configuration property |
| <a href="http://linkedin.github.io/gobblin/javadoc/0.11.0/gobblin-api/gobblin/configuration/ConfigurationKeys.html?is-external=true#JOB_COMMIT_POLICY_KEY" title="class or interface in gobblin.configuration"><code>ConfigurationKeys.JOB_COMMIT_POLICY_KEY</code></a>.</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/MultiWriterWatermarkManager.html#getCommitStatus--">getCommitStatus()</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/MultiWriterWatermarkManager.html" title="class in gobblin.writer">MultiWriterWatermarkManager</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/TrackerBasedWatermarkManager.html#getCommitStatus--">getCommitStatus()</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/TrackerBasedWatermarkManager.html" title="class in gobblin.writer">TrackerBasedWatermarkManager</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/WatermarkManager.html#getCommitStatus--">getCommitStatus()</a></span> - Method in interface gobblin.writer.<a href="gobblin/writer/WatermarkManager.html" title="interface in gobblin.writer">WatermarkManager</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/writer/InstrumentedDataWriterDecorator.html#getCommittableWatermark--">getCommittableWatermark()</a></span> - Method in class gobblin.instrumented.writer.<a href="gobblin/instrumented/writer/InstrumentedDataWriterDecorator.html" title="class in gobblin.instrumented.writer">InstrumentedDataWriterDecorator</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/AsyncWriterManager.html#getCommittableWatermark--">getCommittableWatermark()</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/AsyncWriterManager.html" title="class in gobblin.writer">AsyncWriterManager</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/MultiWriterWatermarkTracker.html#getCommittableWatermark-java.lang.String-">getCommittableWatermark(String)</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/MultiWriterWatermarkTracker.html" title="class in gobblin.writer">MultiWriterWatermarkTracker</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/WatermarkAwareWriter.html#getCommittableWatermark--">getCommittableWatermark()</a></span> - Method in interface gobblin.writer.<a href="gobblin/writer/WatermarkAwareWriter.html" title="interface in gobblin.writer">WatermarkAwareWriter</a></dt> |
| <dd> |
| <div class="block"><span class="deprecatedLabel">Deprecated.</span></div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/WatermarkAwareWriterWrapper.html#getCommittableWatermark--">getCommittableWatermark()</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/WatermarkAwareWriterWrapper.html" title="class in gobblin.writer">WatermarkAwareWriterWrapper</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/FineGrainedWatermarkTracker.html#getCommittableWatermarks--">getCommittableWatermarks()</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/FineGrainedWatermarkTracker.html" title="class in gobblin.writer">FineGrainedWatermarkTracker</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/compression/CompressionConfigParser.html#getCompressionType-java.util.Map-">getCompressionType(Map<String, Object>)</a></span> - Static method in class gobblin.compression.<a href="gobblin/compression/CompressionConfigParser.html" title="class in gobblin.compression">CompressionConfigParser</a></dt> |
| <dd> |
| <div class="block">Return compression type</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/compression/CompressionConfigParser.html#getConfigForBranch-gobblin.configuration.State-int-int-">getConfigForBranch(State, int, int)</a></span> - Static method in class gobblin.compression.<a href="gobblin/compression/CompressionConfigParser.html" title="class in gobblin.compression">CompressionConfigParser</a></dt> |
| <dd> |
| <div class="block">Retrieve configuration settings for a given branch.</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/crypto/EncryptionConfigParser.html#getConfigForBranch-gobblin.crypto.EncryptionConfigParser.EntityType-gobblin.configuration.WorkUnitState-">getConfigForBranch(EncryptionConfigParser.EntityType, WorkUnitState)</a></span> - Static method in class gobblin.crypto.<a href="gobblin/crypto/EncryptionConfigParser.html" title="class in gobblin.crypto">EncryptionConfigParser</a></dt> |
| <dd> |
| <div class="block">Retrieve encryption configuration for the branch the WorKUnitState represents</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/crypto/EncryptionConfigParser.html#getConfigForBranch-gobblin.crypto.EncryptionConfigParser.EntityType-java.lang.String-gobblin.configuration.WorkUnitState-">getConfigForBranch(EncryptionConfigParser.EntityType, String, WorkUnitState)</a></span> - Static method in class gobblin.crypto.<a href="gobblin/crypto/EncryptionConfigParser.html" title="class in gobblin.crypto">EncryptionConfigParser</a></dt> |
| <dd> |
| <div class="block">Retrieve encryption configuration for the branch the WorKUnitState represents.</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/crypto/EncryptionConfigParser.html#getConfigForBranch-gobblin.crypto.EncryptionConfigParser.EntityType-gobblin.configuration.State-int-int-">getConfigForBranch(EncryptionConfigParser.EntityType, State, int, int)</a></span> - Static method in class gobblin.crypto.<a href="gobblin/crypto/EncryptionConfigParser.html" title="class in gobblin.crypto">EncryptionConfigParser</a></dt> |
| <dd> |
| <div class="block">Retrieve encryption config for a given branch of a task</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/crypto/EncryptionConfigParser.EntityType.html#getConfigPrefix--">getConfigPrefix()</a></span> - Method in enum gobblin.crypto.<a href="gobblin/crypto/EncryptionConfigParser.EntityType.html" title="enum in gobblin.crypto">EncryptionConfigParser.EntityType</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/Batch.html#getCurrentSizeInByte--">getCurrentSizeInByte()</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/Batch.html" title="class in gobblin.writer">Batch</a></dt> |
| <dd> |
| <div class="block">Return current batch size in bytes</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/BytesBoundedBatch.html#getCurrentSizeInByte--">getCurrentSizeInByte()</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/BytesBoundedBatch.html" title="class in gobblin.writer">BytesBoundedBatch</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/converter/InstrumentedConverterDecorator.html#getDecoratedObject--">getDecoratedObject()</a></span> - Method in class gobblin.instrumented.converter.<a href="gobblin/instrumented/converter/InstrumentedConverterDecorator.html" title="class in gobblin.instrumented.converter">InstrumentedConverterDecorator</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/extractor/InstrumentedExtractorDecorator.html#getDecoratedObject--">getDecoratedObject()</a></span> - Method in class gobblin.instrumented.extractor.<a href="gobblin/instrumented/extractor/InstrumentedExtractorDecorator.html" title="class in gobblin.instrumented.extractor">InstrumentedExtractorDecorator</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/fork/InstrumentedForkOperatorDecorator.html#getDecoratedObject--">getDecoratedObject()</a></span> - Method in class gobblin.instrumented.fork.<a href="gobblin/instrumented/fork/InstrumentedForkOperatorDecorator.html" title="class in gobblin.instrumented.fork">InstrumentedForkOperatorDecorator</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/qualitychecker/InstrumentedRowLevelPolicyDecorator.html#getDecoratedObject--">getDecoratedObject()</a></span> - Method in class gobblin.instrumented.qualitychecker.<a href="gobblin/instrumented/qualitychecker/InstrumentedRowLevelPolicyDecorator.html" title="class in gobblin.instrumented.qualitychecker">InstrumentedRowLevelPolicyDecorator</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/writer/InstrumentedDataWriterDecorator.html#getDecoratedObject--">getDecoratedObject()</a></span> - Method in class gobblin.instrumented.writer.<a href="gobblin/instrumented/writer/InstrumentedDataWriterDecorator.html" title="class in gobblin.instrumented.writer">InstrumentedDataWriterDecorator</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/crypto/EncryptionConfigParser.html#getEncryptionType-java.util.Map-">getEncryptionType(Map<String, Object>)</a></span> - Static method in class gobblin.crypto.<a href="gobblin/crypto/EncryptionConfigParser.html" title="class in gobblin.crypto">EncryptionConfigParser</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/extractor/InstrumentedExtractorDecorator.html#getExpectedRecordCount--">getExpectedRecordCount()</a></span> - Method in class gobblin.instrumented.extractor.<a href="gobblin/instrumented/extractor/InstrumentedExtractorDecorator.html" title="class in gobblin.instrumented.extractor">InstrumentedExtractorDecorator</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/test/SequentialTestSource.html#getExtractor-gobblin.configuration.WorkUnitState-">getExtractor(WorkUnitState)</a></span> - Method in class gobblin.test.<a href="gobblin/test/SequentialTestSource.html" title="class in gobblin.test">SequentialTestSource</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/converter/InstrumentedConverterDecorator.html#getFinalState--">getFinalState()</a></span> - Method in class gobblin.instrumented.converter.<a href="gobblin/instrumented/converter/InstrumentedConverterDecorator.html" title="class in gobblin.instrumented.converter">InstrumentedConverterDecorator</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/extractor/InstrumentedExtractorBase.html#getFinalState--">getFinalState()</a></span> - Method in class gobblin.instrumented.extractor.<a href="gobblin/instrumented/extractor/InstrumentedExtractorBase.html" title="class in gobblin.instrumented.extractor">InstrumentedExtractorBase</a></dt> |
| <dd> |
| <div class="block">Get final state for this object.</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/extractor/InstrumentedExtractorDecorator.html#getFinalState--">getFinalState()</a></span> - Method in class gobblin.instrumented.extractor.<a href="gobblin/instrumented/extractor/InstrumentedExtractorDecorator.html" title="class in gobblin.instrumented.extractor">InstrumentedExtractorDecorator</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/qualitychecker/InstrumentedRowLevelPolicyDecorator.html#getFinalState--">getFinalState()</a></span> - Method in class gobblin.instrumented.qualitychecker.<a href="gobblin/instrumented/qualitychecker/InstrumentedRowLevelPolicyDecorator.html" title="class in gobblin.instrumented.qualitychecker">InstrumentedRowLevelPolicyDecorator</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/writer/InstrumentedDataWriterDecorator.html#getFinalState--">getFinalState()</a></span> - Method in class gobblin.instrumented.writer.<a href="gobblin/instrumented/writer/InstrumentedDataWriterDecorator.html" title="class in gobblin.instrumented.writer">InstrumentedDataWriterDecorator</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/AsyncWriterManager.html#getFinalState--">getFinalState()</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/AsyncWriterManager.html" title="class in gobblin.writer">AsyncWriterManager</a></dt> |
| <dd> |
| <div class="block">TODO: Figure out what this means for checkpointing.</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/extractor/InstrumentedExtractorDecorator.html#getHighWatermark--">getHighWatermark()</a></span> - Method in class gobblin.instrumented.extractor.<a href="gobblin/instrumented/extractor/InstrumentedExtractorDecorator.html" title="class in gobblin.instrumented.extractor">InstrumentedExtractorDecorator</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/Batch.html#getId--">getId()</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/Batch.html" title="class in gobblin.writer">Batch</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/WatermarkTrackerFactory.html#getInstance-gobblin.writer.WatermarkTrackerFactory.TrackerBehavior-">getInstance(WatermarkTrackerFactory.TrackerBehavior)</a></span> - Static method in class gobblin.writer.<a href="gobblin/writer/WatermarkTrackerFactory.html" title="class in gobblin.writer">WatermarkTrackerFactory</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/crypto/EncryptionConfigParser.html#getKeyName-java.util.Map-">getKeyName(Map<String, Object>)</a></span> - Static method in class gobblin.crypto.<a href="gobblin/crypto/EncryptionConfigParser.html" title="class in gobblin.crypto">EncryptionConfigParser</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/crypto/EncryptionConfigParser.html#getKeystoreEncoding-java.util.Map-">getKeystoreEncoding(Map<String, Object>)</a></span> - Static method in class gobblin.crypto.<a href="gobblin/crypto/EncryptionConfigParser.html" title="class in gobblin.crypto">EncryptionConfigParser</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/crypto/EncryptionConfigParser.html#getKeystorePassword-java.util.Map-">getKeystorePassword(Map<String, Object>)</a></span> - Static method in class gobblin.crypto.<a href="gobblin/crypto/EncryptionConfigParser.html" title="class in gobblin.crypto">EncryptionConfigParser</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/crypto/EncryptionConfigParser.html#getKeystorePath-java.util.Map-">getKeystorePath(Map<String, Object>)</a></span> - Static method in class gobblin.crypto.<a href="gobblin/crypto/EncryptionConfigParser.html" title="class in gobblin.crypto">EncryptionConfigParser</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/crypto/EncryptionConfigParser.html#getKeystoreType-java.util.Map-">getKeystoreType(Map<String, Object>)</a></span> - Static method in class gobblin.crypto.<a href="gobblin/crypto/EncryptionConfigParser.html" title="class in gobblin.crypto">EncryptionConfigParser</a></dt> |
| <dd> |
| <div class="block">Get the type of keystore to instantiate</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/converter/InstrumentedConverterDecorator.html#getMessageHandler--">getMessageHandler()</a></span> - Method in class gobblin.instrumented.converter.<a href="gobblin/instrumented/converter/InstrumentedConverterDecorator.html" title="class in gobblin.instrumented.converter">InstrumentedConverterDecorator</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/writer/InstrumentedDataWriterDecorator.html#getMessageHandler--">getMessageHandler()</a></span> - Method in class gobblin.instrumented.writer.<a href="gobblin/instrumented/writer/InstrumentedDataWriterDecorator.html" title="class in gobblin.instrumented.writer">InstrumentedDataWriterDecorator</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/converter/InstrumentedConverterDecorator.html#getMetricContext--">getMetricContext()</a></span> - Method in class gobblin.instrumented.converter.<a href="gobblin/instrumented/converter/InstrumentedConverterDecorator.html" title="class in gobblin.instrumented.converter">InstrumentedConverterDecorator</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/extractor/InstrumentedExtractorBase.html#getMetricContext--">getMetricContext()</a></span> - Method in class gobblin.instrumented.extractor.<a href="gobblin/instrumented/extractor/InstrumentedExtractorBase.html" title="class in gobblin.instrumented.extractor">InstrumentedExtractorBase</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/extractor/InstrumentedExtractorDecorator.html#getMetricContext--">getMetricContext()</a></span> - Method in class gobblin.instrumented.extractor.<a href="gobblin/instrumented/extractor/InstrumentedExtractorDecorator.html" title="class in gobblin.instrumented.extractor">InstrumentedExtractorDecorator</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/fork/InstrumentedForkOperatorDecorator.html#getMetricContext--">getMetricContext()</a></span> - Method in class gobblin.instrumented.fork.<a href="gobblin/instrumented/fork/InstrumentedForkOperatorDecorator.html" title="class in gobblin.instrumented.fork">InstrumentedForkOperatorDecorator</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/Instrumentable.html#getMetricContext--">getMetricContext()</a></span> - Method in interface gobblin.instrumented.<a href="gobblin/instrumented/Instrumentable.html" title="interface in gobblin.instrumented">Instrumentable</a></dt> |
| <dd> |
| <div class="block">Get <a href="http://linkedin.github.io/gobblin/javadoc/0.11.0/gobblin-metrics/gobblin/metrics/MetricContext.html?is-external=true" title="class or interface in gobblin.metrics"><code>MetricContext</code></a> containing metrics related to this Instrumentable.</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/Instrumented.html#getMetricContext-gobblin.configuration.State-java.lang.Class-">getMetricContext(State, Class<?>)</a></span> - Static method in class gobblin.instrumented.<a href="gobblin/instrumented/Instrumented.html" title="class in gobblin.instrumented">Instrumented</a></dt> |
| <dd> |
| <div class="block">Gets metric context with no additional tags.</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/Instrumented.html#getMetricContext-gobblin.configuration.State-java.lang.Class-java.util.List-">getMetricContext(State, Class<?>, List<Tag<?>>)</a></span> - Static method in class gobblin.instrumented.<a href="gobblin/instrumented/Instrumented.html" title="class in gobblin.instrumented">Instrumented</a></dt> |
| <dd> |
| <div class="block">Get a <a href="http://linkedin.github.io/gobblin/javadoc/0.11.0/gobblin-metrics/gobblin/metrics/MetricContext.html?is-external=true" title="class or interface in gobblin.metrics"><code>MetricContext</code></a> to be used by an object needing instrumentation.</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/Instrumented.html#getMetricContext--">getMetricContext()</a></span> - Method in class gobblin.instrumented.<a href="gobblin/instrumented/Instrumented.html" title="class in gobblin.instrumented">Instrumented</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/qualitychecker/InstrumentedRowLevelPolicyDecorator.html#getMetricContext--">getMetricContext()</a></span> - Method in class gobblin.instrumented.qualitychecker.<a href="gobblin/instrumented/qualitychecker/InstrumentedRowLevelPolicyDecorator.html" title="class in gobblin.instrumented.qualitychecker">InstrumentedRowLevelPolicyDecorator</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/writer/InstrumentedDataWriterDecorator.html#getMetricContext--">getMetricContext()</a></span> - Method in class gobblin.instrumented.writer.<a href="gobblin/instrumented/writer/InstrumentedDataWriterDecorator.html" title="class in gobblin.instrumented.writer">InstrumentedDataWriterDecorator</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/AsyncWriterManager.html#getMetricContext--">getMetricContext()</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/AsyncWriterManager.html" title="class in gobblin.writer">AsyncWriterManager</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/FineGrainedWatermarkTracker.html#getMetricContext--">getMetricContext()</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/FineGrainedWatermarkTracker.html" title="class in gobblin.writer">FineGrainedWatermarkTracker</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/BatchAccumulator.html#getNextAvailableBatch--">getNextAvailableBatch()</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/BatchAccumulator.html" title="class in gobblin.writer">BatchAccumulator</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/SequentialBasedBatchAccumulator.html#getNextAvailableBatch--">getNextAvailableBatch()</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/SequentialBasedBatchAccumulator.html" title="class in gobblin.writer">SequentialBasedBatchAccumulator</a></dt> |
| <dd> |
| <div class="block">If accumulator has been closed, below actions are performed: |
| 1) remove and return the first batch if available.</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/SequentialBasedBatchAccumulator.html#getNumOfBatches--">getNumOfBatches()</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/SequentialBasedBatchAccumulator.html" title="class in gobblin.writer">SequentialBasedBatchAccumulator</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/RecordMetadata.html#getOffset--">getOffset()</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/RecordMetadata.html" title="class in gobblin.writer">RecordMetadata</a></dt> |
| <dd> |
| <div class="block">Get the offset of current record inside of its wrapping batch</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/AbstractSource.html#getPreviousWorkUnitsForRetry-gobblin.configuration.SourceState-">getPreviousWorkUnitsForRetry(SourceState)</a></span> - Method in class gobblin.source.extractor.extract.<a href="gobblin/source/extractor/extract/AbstractSource.html" title="class in gobblin.source.extractor.extract">AbstractSource</a></dt> |
| <dd> |
| <div class="block">Get a list of previous <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 subject for retries.</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/AbstractSource.html#getPreviousWorkUnitStatesForRetry-gobblin.configuration.SourceState-">getPreviousWorkUnitStatesForRetry(SourceState)</a></span> - Method in class gobblin.source.extractor.extract.<a href="gobblin/source/extractor/extract/AbstractSource.html" title="class in gobblin.source.extractor.extract">AbstractSource</a></dt> |
| <dd> |
| <div class="block">Get a list of <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>s of previous <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 subject for retries.</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/GenericWriteResponse.html#getRawResponse--">getRawResponse()</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/GenericWriteResponse.html" title="class in gobblin.writer">GenericWriteResponse</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/WriteResponse.html#getRawResponse--">getRawResponse()</a></span> - Method in interface gobblin.writer.<a href="gobblin/writer/WriteResponse.html" title="interface in gobblin.writer">WriteResponse</a></dt> |
| <dd> |
| <div class="block">Get the raw response returned by the underlying write system</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/AcknowledgableRecordEnvelope.html#getRecord--">getRecord()</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/AcknowledgableRecordEnvelope.html" title="class in gobblin.writer">AcknowledgableRecordEnvelope</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/Batch.html#getRecords--">getRecords()</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/Batch.html" title="class in gobblin.writer">Batch</a></dt> |
| <dd> |
| <div class="block">Return all the added records</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/BytesBoundedBatch.html#getRecords--">getRecords()</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/BytesBoundedBatch.html" title="class in gobblin.writer">BytesBoundedBatch</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/Batch.html#getRecordSizeInByte-D-">getRecordSizeInByte(D)</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/Batch.html" title="class in gobblin.writer">Batch</a></dt> |
| <dd> |
| <div class="block">Get input record size in bytes</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/BytesBoundedBatch.html#getRecordSizeInByte-D-">getRecordSizeInByte(D)</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/BytesBoundedBatch.html" title="class in gobblin.writer">BytesBoundedBatch</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/MultiWriterWatermarkManager.html#getRetrievalStatus--">getRetrievalStatus()</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/MultiWriterWatermarkManager.html" title="class in gobblin.writer">MultiWriterWatermarkManager</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/TrackerBasedWatermarkManager.html#getRetrievalStatus--">getRetrievalStatus()</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/TrackerBasedWatermarkManager.html" title="class in gobblin.writer">TrackerBasedWatermarkManager</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/WatermarkManager.html#getRetrievalStatus--">getRetrievalStatus()</a></span> - Method in interface gobblin.writer.<a href="gobblin/writer/WatermarkManager.html" title="interface in gobblin.writer">WatermarkManager</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/extractor/InstrumentedExtractorDecorator.html#getSchema--">getSchema()</a></span> - Method in class gobblin.instrumented.extractor.<a href="gobblin/instrumented/extractor/InstrumentedExtractorDecorator.html" title="class in gobblin.instrumented.extractor">InstrumentedExtractorDecorator</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/source/extractor/DefaultCheckpointableWatermark.html#getSource--">getSource()</a></span> - Method in class gobblin.source.extractor.<a href="gobblin/source/extractor/DefaultCheckpointableWatermark.html" title="class in gobblin.source.extractor">DefaultCheckpointableWatermark</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/GenericWriteResponse.html#getStringResponse--">getStringResponse()</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/GenericWriteResponse.html" title="class in gobblin.writer">GenericWriteResponse</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/WriteResponse.html#getStringResponse--">getStringResponse()</a></span> - Method in interface gobblin.writer.<a href="gobblin/writer/WriteResponse.html" title="interface in gobblin.writer">WriteResponse</a></dt> |
| <dd> |
| <div class="block">Get a String representation of the response.</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/writer/InstrumentedDataWriterDecorator.html#getUnacknowledgedWatermark--">getUnacknowledgedWatermark()</a></span> - Method in class gobblin.instrumented.writer.<a href="gobblin/instrumented/writer/InstrumentedDataWriterDecorator.html" title="class in gobblin.instrumented.writer">InstrumentedDataWriterDecorator</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/AsyncWriterManager.html#getUnacknowledgedWatermark--">getUnacknowledgedWatermark()</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/AsyncWriterManager.html" title="class in gobblin.writer">AsyncWriterManager</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/MultiWriterWatermarkTracker.html#getUnacknowledgedWatermark-java.lang.String-">getUnacknowledgedWatermark(String)</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/MultiWriterWatermarkTracker.html" title="class in gobblin.writer">MultiWriterWatermarkTracker</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/WatermarkAwareWriter.html#getUnacknowledgedWatermark--">getUnacknowledgedWatermark()</a></span> - Method in interface gobblin.writer.<a href="gobblin/writer/WatermarkAwareWriter.html" title="interface in gobblin.writer">WatermarkAwareWriter</a></dt> |
| <dd> |
| <div class="block"><span class="deprecatedLabel">Deprecated.</span></div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/WatermarkAwareWriterWrapper.html#getUnacknowledgedWatermark--">getUnacknowledgedWatermark()</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/WatermarkAwareWriterWrapper.html" title="class in gobblin.writer">WatermarkAwareWriterWrapper</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/FineGrainedWatermarkTracker.html#getUnacknowledgedWatermarks--">getUnacknowledgedWatermarks()</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/FineGrainedWatermarkTracker.html" title="class in gobblin.writer">FineGrainedWatermarkTracker</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/source/extractor/DefaultCheckpointableWatermark.html#getWatermark--">getWatermark()</a></span> - Method in class gobblin.source.extractor.<a href="gobblin/source/extractor/DefaultCheckpointableWatermark.html" title="class in gobblin.source.extractor">DefaultCheckpointableWatermark</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/AcknowledgableRecordEnvelope.html#getWatermark--">getWatermark()</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/AcknowledgableRecordEnvelope.html" title="class in gobblin.writer">AcknowledgableRecordEnvelope</a></dt> |
| <dd> |
| <div class="block">Get the original watermark that was attached to this record, |
| typically by a <a href="http://linkedin.github.io/gobblin/javadoc/0.11.0/gobblin-api/gobblin/source/extractor/StreamingExtractor.html?is-external=true" title="class or interface in gobblin.source.extractor"><code>StreamingExtractor</code></a></div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/test/SequentialTestSource.html#getWorkunits-gobblin.configuration.SourceState-">getWorkunits(SourceState)</a></span> - Method in class gobblin.test.<a href="gobblin/test/SequentialTestSource.html" title="class in gobblin.test">SequentialTestSource</a></dt> |
| <dd> </dd> |
| <dt><a href="gobblin/async/package-summary.html">gobblin.async</a> - package gobblin.async</dt> |
| <dd> </dd> |
| <dt><a href="gobblin/compression/package-summary.html">gobblin.compression</a> - package gobblin.compression</dt> |
| <dd> </dd> |
| <dt><a href="gobblin/converter/package-summary.html">gobblin.converter</a> - package gobblin.converter</dt> |
| <dd> </dd> |
| <dt><a href="gobblin/converter/filter/package-summary.html">gobblin.converter.filter</a> - package gobblin.converter.filter</dt> |
| <dd> </dd> |
| <dt><a href="gobblin/crypto/package-summary.html">gobblin.crypto</a> - package gobblin.crypto</dt> |
| <dd> </dd> |
| <dt><a href="gobblin/instrumented/package-summary.html">gobblin.instrumented</a> - package gobblin.instrumented</dt> |
| <dd> </dd> |
| <dt><a href="gobblin/instrumented/converter/package-summary.html">gobblin.instrumented.converter</a> - package gobblin.instrumented.converter</dt> |
| <dd> </dd> |
| <dt><a href="gobblin/instrumented/extractor/package-summary.html">gobblin.instrumented.extractor</a> - package gobblin.instrumented.extractor</dt> |
| <dd> </dd> |
| <dt><a href="gobblin/instrumented/fork/package-summary.html">gobblin.instrumented.fork</a> - package gobblin.instrumented.fork</dt> |
| <dd> </dd> |
| <dt><a href="gobblin/instrumented/qualitychecker/package-summary.html">gobblin.instrumented.qualitychecker</a> - package gobblin.instrumented.qualitychecker</dt> |
| <dd> </dd> |
| <dt><a href="gobblin/instrumented/writer/package-summary.html">gobblin.instrumented.writer</a> - package gobblin.instrumented.writer</dt> |
| <dd> </dd> |
| <dt><a href="gobblin/source/extractor/package-summary.html">gobblin.source.extractor</a> - package gobblin.source.extractor</dt> |
| <dd> </dd> |
| <dt><a href="gobblin/source/extractor/extract/package-summary.html">gobblin.source.extractor.extract</a> - package gobblin.source.extractor.extract</dt> |
| <dd> </dd> |
| <dt><a href="gobblin/source/extractor/limiter/package-summary.html">gobblin.source.extractor.limiter</a> - package gobblin.source.extractor.limiter</dt> |
| <dd> </dd> |
| <dt><a href="gobblin/test/package-summary.html">gobblin.test</a> - package gobblin.test</dt> |
| <dd> </dd> |
| <dt><a href="gobblin/writer/package-summary.html">gobblin.writer</a> - package gobblin.writer</dt> |
| <dd> </dd> |
| <dt><a href="gobblin/writer/exception/package-summary.html">gobblin.writer.exception</a> - package gobblin.writer.exception</dt> |
| <dd> </dd> |
| <dt><a href="gobblin/writer/partitioner/package-summary.html">gobblin.writer.partitioner</a> - package gobblin.writer.partitioner</dt> |
| <dd> </dd> |
| <dt><a href="gobblin/instrumented/GobblinMetricsKeys.html" title="class in gobblin.instrumented"><span class="typeNameLink">GobblinMetricsKeys</span></a> - Class in <a href="gobblin/instrumented/package-summary.html">gobblin.instrumented</a></dt> |
| <dd> |
| <div class="block">Shared constants related to gobblin metrics</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/GobblinMetricsKeys.html#GobblinMetricsKeys--">GobblinMetricsKeys()</a></span> - Constructor for class gobblin.instrumented.<a href="gobblin/instrumented/GobblinMetricsKeys.html" title="class in gobblin.instrumented">GobblinMetricsKeys</a></dt> |
| <dd> </dd> |
| <dt><a href="gobblin/converter/filter/GobblinTrackingEventFlattenFilterConverter.html" title="class in gobblin.converter.filter"><span class="typeNameLink">GobblinTrackingEventFlattenFilterConverter</span></a> - Class in <a href="gobblin/converter/filter/package-summary.html">gobblin.converter.filter</a></dt> |
| <dd> |
| <div class="block">Flatten and filter the map field in GobblinTrackingEvent.</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/converter/filter/GobblinTrackingEventFlattenFilterConverter.html#GobblinTrackingEventFlattenFilterConverter--">GobblinTrackingEventFlattenFilterConverter()</a></span> - Constructor for class gobblin.converter.filter.<a href="gobblin/converter/filter/GobblinTrackingEventFlattenFilterConverter.html" title="class in gobblin.converter.filter">GobblinTrackingEventFlattenFilterConverter</a></dt> |
| <dd> </dd> |
| </dl> |
| <a name="I:H"> |
| <!-- --> |
| </a> |
| <h2 class="title">H</h2> |
| <dl> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/AcknowledgableWatermark.html#hashCode--">hashCode()</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/AcknowledgableWatermark.html" title="class in gobblin.writer">AcknowledgableWatermark</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/Batch.html#hasRoom-D-">hasRoom(D)</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/Batch.html" title="class in gobblin.writer">Batch</a></dt> |
| <dd> |
| <div class="block">A method to check if the batch has the room to add a new record</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/BytesBoundedBatch.html#hasRoom-D-">hasRoom(D)</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/BytesBoundedBatch.html" title="class in gobblin.writer">BytesBoundedBatch</a></dt> |
| <dd> </dd> |
| </dl> |
| <a name="I:I"> |
| <!-- --> |
| </a> |
| <h2 class="title">I</h2> |
| <dl> |
| <dt><a href="gobblin/converter/IdentityConverter.html" title="class in gobblin.converter"><span class="typeNameLink">IdentityConverter</span></a> - Class in <a href="gobblin/converter/package-summary.html">gobblin.converter</a></dt> |
| <dd> |
| <div class="block">Implementation of <a href="http://linkedin.github.io/gobblin/javadoc/0.11.0/gobblin-api/gobblin/converter/Converter.html?is-external=true" title="class or interface in gobblin.converter"><code>Converter</code></a> that returns the inputSchema unmodified and each inputRecord unmodified</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/converter/IdentityConverter.html#IdentityConverter--">IdentityConverter()</a></span> - Constructor for class gobblin.converter.<a href="gobblin/converter/IdentityConverter.html" title="class in gobblin.converter">IdentityConverter</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/LongWatermark.html#increment--">increment()</a></span> - Method in class gobblin.source.extractor.extract.<a href="gobblin/source/extractor/extract/LongWatermark.html" title="class in gobblin.source.extractor.extract">LongWatermark</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/AcknowledgableWatermark.html#incrementAck--">incrementAck()</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/AcknowledgableWatermark.html" title="class in gobblin.writer">AcknowledgableWatermark</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/converter/filter/AvroProjectionConverter.html#init-gobblin.configuration.WorkUnitState-">init(WorkUnitState)</a></span> - Method in class gobblin.converter.filter.<a href="gobblin/converter/filter/AvroProjectionConverter.html" title="class in gobblin.converter.filter">AvroProjectionConverter</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/filter/GobblinTrackingEventFlattenFilterConverter.html#init-gobblin.configuration.WorkUnitState-">init(WorkUnitState)</a></span> - Method in class gobblin.converter.filter.<a href="gobblin/converter/filter/GobblinTrackingEventFlattenFilterConverter.html" title="class in gobblin.converter.filter">GobblinTrackingEventFlattenFilterConverter</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/converter/SamplingConverter.html#init-gobblin.configuration.WorkUnitState-">init(WorkUnitState)</a></span> - Method in class gobblin.converter.<a href="gobblin/converter/SamplingConverter.html" title="class in gobblin.converter">SamplingConverter</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/converter/InstrumentedConverterDecorator.html#init-gobblin.configuration.WorkUnitState-">init(WorkUnitState)</a></span> - Method in class gobblin.instrumented.converter.<a href="gobblin/instrumented/converter/InstrumentedConverterDecorator.html" title="class in gobblin.instrumented.converter">InstrumentedConverterDecorator</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/fork/InstrumentedForkOperatorDecorator.html#init-gobblin.configuration.WorkUnitState-">init(WorkUnitState)</a></span> - Method in class gobblin.instrumented.fork.<a href="gobblin/instrumented/fork/InstrumentedForkOperatorDecorator.html" title="class in gobblin.instrumented.fork">InstrumentedForkOperatorDecorator</a></dt> |
| <dd> </dd> |
| <dt><a href="gobblin/instrumented/Instrumentable.html" title="interface in gobblin.instrumented"><span class="typeNameLink">Instrumentable</span></a> - Interface in <a href="gobblin/instrumented/package-summary.html">gobblin.instrumented</a></dt> |
| <dd> |
| <div class="block">Interface for classes instrumenting their execution into a <a href="http://linkedin.github.io/gobblin/javadoc/0.11.0/gobblin-metrics/gobblin/metrics/MetricContext.html?is-external=true" title="class or interface in gobblin.metrics"><code>MetricContext</code></a>.</div> |
| </dd> |
| <dt><a href="gobblin/instrumented/Instrumented.html" title="class in gobblin.instrumented"><span class="typeNameLink">Instrumented</span></a> - Class in <a href="gobblin/instrumented/package-summary.html">gobblin.instrumented</a></dt> |
| <dd> |
| <div class="block">Provides simple instrumentation for gobblin-core components.</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/Instrumented.html#Instrumented-gobblin.configuration.State-java.lang.Class-">Instrumented(State, Class<?>)</a></span> - Constructor for class gobblin.instrumented.<a href="gobblin/instrumented/Instrumented.html" title="class in gobblin.instrumented">Instrumented</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/Instrumented.html#Instrumented-gobblin.configuration.State-java.lang.Class-java.util.List-">Instrumented(State, Class<?>, List<Tag<?>>)</a></span> - Constructor for class gobblin.instrumented.<a href="gobblin/instrumented/Instrumented.html" title="class in gobblin.instrumented">Instrumented</a></dt> |
| <dd> </dd> |
| <dt><a href="gobblin/instrumented/converter/InstrumentedConverter.html" title="class in gobblin.instrumented.converter"><span class="typeNameLink">InstrumentedConverter</span></a><<a href="gobblin/instrumented/converter/InstrumentedConverter.html" title="type parameter in InstrumentedConverter">SI</a>,<a href="gobblin/instrumented/converter/InstrumentedConverter.html" title="type parameter in InstrumentedConverter">SO</a>,<a href="gobblin/instrumented/converter/InstrumentedConverter.html" title="type parameter in InstrumentedConverter">DI</a>,<a href="gobblin/instrumented/converter/InstrumentedConverter.html" title="type parameter in InstrumentedConverter">DO</a>> - Class in <a href="gobblin/instrumented/converter/package-summary.html">gobblin.instrumented.converter</a></dt> |
| <dd> |
| <div class="block">Instrumented converter that automatically captures certain metrics.</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/converter/InstrumentedConverter.html#InstrumentedConverter--">InstrumentedConverter()</a></span> - Constructor for class gobblin.instrumented.converter.<a href="gobblin/instrumented/converter/InstrumentedConverter.html" title="class in gobblin.instrumented.converter">InstrumentedConverter</a></dt> |
| <dd> </dd> |
| <dt><a href="gobblin/instrumented/converter/InstrumentedConverterDecorator.html" title="class in gobblin.instrumented.converter"><span class="typeNameLink">InstrumentedConverterDecorator</span></a><<a href="gobblin/instrumented/converter/InstrumentedConverterDecorator.html" title="type parameter in InstrumentedConverterDecorator">SI</a>,<a href="gobblin/instrumented/converter/InstrumentedConverterDecorator.html" title="type parameter in InstrumentedConverterDecorator">SO</a>,<a href="gobblin/instrumented/converter/InstrumentedConverterDecorator.html" title="type parameter in InstrumentedConverterDecorator">DI</a>,<a href="gobblin/instrumented/converter/InstrumentedConverterDecorator.html" title="type parameter in InstrumentedConverterDecorator">DO</a>> - Class in <a href="gobblin/instrumented/converter/package-summary.html">gobblin.instrumented.converter</a></dt> |
| <dd> |
| <div class="block">Decorator that automatically instruments <a href="http://linkedin.github.io/gobblin/javadoc/0.11.0/gobblin-api/gobblin/converter/Converter.html?is-external=true" title="class or interface in gobblin.converter"><code>Converter</code></a>.</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/converter/InstrumentedConverterDecorator.html#InstrumentedConverterDecorator-gobblin.converter.Converter-">InstrumentedConverterDecorator(Converter<SI, SO, DI, DO>)</a></span> - Constructor for class gobblin.instrumented.converter.<a href="gobblin/instrumented/converter/InstrumentedConverterDecorator.html" title="class in gobblin.instrumented.converter">InstrumentedConverterDecorator</a></dt> |
| <dd> </dd> |
| <dt><a href="gobblin/instrumented/writer/InstrumentedDataWriter.html" title="class in gobblin.instrumented.writer"><span class="typeNameLink">InstrumentedDataWriter</span></a><<a href="gobblin/instrumented/writer/InstrumentedDataWriter.html" title="type parameter in InstrumentedDataWriter">D</a>> - Class in <a href="gobblin/instrumented/writer/package-summary.html">gobblin.instrumented.writer</a></dt> |
| <dd> |
| <div class="block">Instrumented version of <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> automatically capturing certain metrics.</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/writer/InstrumentedDataWriter.html#InstrumentedDataWriter-gobblin.configuration.State-">InstrumentedDataWriter(State)</a></span> - Constructor for class gobblin.instrumented.writer.<a href="gobblin/instrumented/writer/InstrumentedDataWriter.html" title="class in gobblin.instrumented.writer">InstrumentedDataWriter</a></dt> |
| <dd> </dd> |
| <dt><a href="gobblin/instrumented/writer/InstrumentedDataWriterDecorator.html" title="class in gobblin.instrumented.writer"><span class="typeNameLink">InstrumentedDataWriterDecorator</span></a><<a href="gobblin/instrumented/writer/InstrumentedDataWriterDecorator.html" title="type parameter in InstrumentedDataWriterDecorator">D</a>> - Class in <a href="gobblin/instrumented/writer/package-summary.html">gobblin.instrumented.writer</a></dt> |
| <dd> |
| <div class="block">Decorator that automatically instruments <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/instrumented/writer/InstrumentedDataWriterDecorator.html#InstrumentedDataWriterDecorator-gobblin.writer.DataWriter-gobblin.configuration.State-">InstrumentedDataWriterDecorator(DataWriter<D>, State)</a></span> - Constructor for class gobblin.instrumented.writer.<a href="gobblin/instrumented/writer/InstrumentedDataWriterDecorator.html" title="class in gobblin.instrumented.writer">InstrumentedDataWriterDecorator</a></dt> |
| <dd> </dd> |
| <dt><a href="gobblin/instrumented/extractor/InstrumentedExtractor.html" title="class in gobblin.instrumented.extractor"><span class="typeNameLink">InstrumentedExtractor</span></a><<a href="gobblin/instrumented/extractor/InstrumentedExtractor.html" title="type parameter in InstrumentedExtractor">S</a>,<a href="gobblin/instrumented/extractor/InstrumentedExtractor.html" title="type parameter in InstrumentedExtractor">D</a>> - Class in <a href="gobblin/instrumented/extractor/package-summary.html">gobblin.instrumented.extractor</a></dt> |
| <dd> |
| <div class="block">Instrumented version 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> automatically captures certain metrics.</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/extractor/InstrumentedExtractor.html#InstrumentedExtractor-gobblin.configuration.WorkUnitState-">InstrumentedExtractor(WorkUnitState)</a></span> - Constructor for class gobblin.instrumented.extractor.<a href="gobblin/instrumented/extractor/InstrumentedExtractor.html" title="class in gobblin.instrumented.extractor">InstrumentedExtractor</a></dt> |
| <dd> </dd> |
| <dt><a href="gobblin/instrumented/extractor/InstrumentedExtractorBase.html" title="class in gobblin.instrumented.extractor"><span class="typeNameLink">InstrumentedExtractorBase</span></a><<a href="gobblin/instrumented/extractor/InstrumentedExtractorBase.html" title="type parameter in InstrumentedExtractorBase">S</a>,<a href="gobblin/instrumented/extractor/InstrumentedExtractorBase.html" title="type parameter in InstrumentedExtractorBase">D</a>> - Class in <a href="gobblin/instrumented/extractor/package-summary.html">gobblin.instrumented.extractor</a></dt> |
| <dd> |
| <div class="block">package-private implementation of instrumentation for <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>.</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/extractor/InstrumentedExtractorBase.html#InstrumentedExtractorBase-gobblin.configuration.WorkUnitState-">InstrumentedExtractorBase(WorkUnitState)</a></span> - Constructor for class gobblin.instrumented.extractor.<a href="gobblin/instrumented/extractor/InstrumentedExtractorBase.html" title="class in gobblin.instrumented.extractor">InstrumentedExtractorBase</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/extractor/InstrumentedExtractorBase.html#InstrumentedExtractorBase-gobblin.configuration.WorkUnitState-com.google.common.base.Optional-">InstrumentedExtractorBase(WorkUnitState, Optional<Class<?>>)</a></span> - Constructor for class gobblin.instrumented.extractor.<a href="gobblin/instrumented/extractor/InstrumentedExtractorBase.html" title="class in gobblin.instrumented.extractor">InstrumentedExtractorBase</a></dt> |
| <dd> </dd> |
| <dt><a href="gobblin/instrumented/extractor/InstrumentedExtractorDecorator.html" title="class in gobblin.instrumented.extractor"><span class="typeNameLink">InstrumentedExtractorDecorator</span></a><<a href="gobblin/instrumented/extractor/InstrumentedExtractorDecorator.html" title="type parameter in InstrumentedExtractorDecorator">S</a>,<a href="gobblin/instrumented/extractor/InstrumentedExtractorDecorator.html" title="type parameter in InstrumentedExtractorDecorator">D</a>> - Class in <a href="gobblin/instrumented/extractor/package-summary.html">gobblin.instrumented.extractor</a></dt> |
| <dd> |
| <div class="block">Decorator that automatically instruments <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>.</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/extractor/InstrumentedExtractorDecorator.html#InstrumentedExtractorDecorator-gobblin.configuration.WorkUnitState-gobblin.source.extractor.Extractor-">InstrumentedExtractorDecorator(WorkUnitState, Extractor<S, D>)</a></span> - Constructor for class gobblin.instrumented.extractor.<a href="gobblin/instrumented/extractor/InstrumentedExtractorDecorator.html" title="class in gobblin.instrumented.extractor">InstrumentedExtractorDecorator</a></dt> |
| <dd> </dd> |
| <dt><a href="gobblin/instrumented/fork/InstrumentedForkOperator.html" title="class in gobblin.instrumented.fork"><span class="typeNameLink">InstrumentedForkOperator</span></a><<a href="gobblin/instrumented/fork/InstrumentedForkOperator.html" title="type parameter in InstrumentedForkOperator">S</a>,<a href="gobblin/instrumented/fork/InstrumentedForkOperator.html" title="type parameter in InstrumentedForkOperator">D</a>> - Class in <a href="gobblin/instrumented/fork/package-summary.html">gobblin.instrumented.fork</a></dt> |
| <dd> |
| <div class="block">Instrumented <a href="http://linkedin.github.io/gobblin/javadoc/0.11.0/gobblin-api/gobblin/fork/ForkOperator.html?is-external=true" title="class or interface in gobblin.fork"><code>ForkOperator</code></a> automatically capturing certain metrics.</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/fork/InstrumentedForkOperator.html#InstrumentedForkOperator--">InstrumentedForkOperator()</a></span> - Constructor for class gobblin.instrumented.fork.<a href="gobblin/instrumented/fork/InstrumentedForkOperator.html" title="class in gobblin.instrumented.fork">InstrumentedForkOperator</a></dt> |
| <dd> </dd> |
| <dt><a href="gobblin/instrumented/fork/InstrumentedForkOperatorDecorator.html" title="class in gobblin.instrumented.fork"><span class="typeNameLink">InstrumentedForkOperatorDecorator</span></a><<a href="gobblin/instrumented/fork/InstrumentedForkOperatorDecorator.html" title="type parameter in InstrumentedForkOperatorDecorator">S</a>,<a href="gobblin/instrumented/fork/InstrumentedForkOperatorDecorator.html" title="type parameter in InstrumentedForkOperatorDecorator">D</a>> - Class in <a href="gobblin/instrumented/fork/package-summary.html">gobblin.instrumented.fork</a></dt> |
| <dd> |
| <div class="block">Decorator that automatically instruments <a href="http://linkedin.github.io/gobblin/javadoc/0.11.0/gobblin-api/gobblin/fork/ForkOperator.html?is-external=true" title="class or interface in gobblin.fork"><code>ForkOperator</code></a>.</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/fork/InstrumentedForkOperatorDecorator.html#InstrumentedForkOperatorDecorator-gobblin.fork.ForkOperator-">InstrumentedForkOperatorDecorator(ForkOperator<S, D>)</a></span> - Constructor for class gobblin.instrumented.fork.<a href="gobblin/instrumented/fork/InstrumentedForkOperatorDecorator.html" title="class in gobblin.instrumented.fork">InstrumentedForkOperatorDecorator</a></dt> |
| <dd> </dd> |
| <dt><a href="gobblin/instrumented/writer/InstrumentedPartitionedDataWriterDecorator.html" title="class in gobblin.instrumented.writer"><span class="typeNameLink">InstrumentedPartitionedDataWriterDecorator</span></a><<a href="gobblin/instrumented/writer/InstrumentedPartitionedDataWriterDecorator.html" title="type parameter in InstrumentedPartitionedDataWriterDecorator">D</a>> - Class in <a href="gobblin/instrumented/writer/package-summary.html">gobblin.instrumented.writer</a></dt> |
| <dd> |
| <div class="block"><a href="gobblin/instrumented/writer/InstrumentedDataWriterDecorator.html" title="class in gobblin.instrumented.writer"><code>InstrumentedDataWriterDecorator</code></a> which add partition tags to the metric context.</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/writer/InstrumentedPartitionedDataWriterDecorator.html#InstrumentedPartitionedDataWriterDecorator-gobblin.writer.DataWriter-gobblin.configuration.State-org.apache.avro.generic.GenericRecord-">InstrumentedPartitionedDataWriterDecorator(DataWriter<D>, State, GenericRecord)</a></span> - Constructor for class gobblin.instrumented.writer.<a href="gobblin/instrumented/writer/InstrumentedPartitionedDataWriterDecorator.html" title="class in gobblin.instrumented.writer">InstrumentedPartitionedDataWriterDecorator</a></dt> |
| <dd> </dd> |
| <dt><a href="gobblin/instrumented/qualitychecker/InstrumentedRowLevelPolicy.html" title="class in gobblin.instrumented.qualitychecker"><span class="typeNameLink">InstrumentedRowLevelPolicy</span></a> - Class in <a href="gobblin/instrumented/qualitychecker/package-summary.html">gobblin.instrumented.qualitychecker</a></dt> |
| <dd> |
| <div class="block">Instrumented <a href="http://linkedin.github.io/gobblin/javadoc/0.11.0/gobblin-api/gobblin/qualitychecker/row/RowLevelPolicy.html?is-external=true" title="class or interface in gobblin.qualitychecker.row"><code>RowLevelPolicy</code></a> automatically capturing certain metrics.</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/qualitychecker/InstrumentedRowLevelPolicy.html#InstrumentedRowLevelPolicy-gobblin.configuration.State-gobblin.qualitychecker.row.RowLevelPolicy.Type-">InstrumentedRowLevelPolicy(State, RowLevelPolicy.Type)</a></span> - Constructor for class gobblin.instrumented.qualitychecker.<a href="gobblin/instrumented/qualitychecker/InstrumentedRowLevelPolicy.html" title="class in gobblin.instrumented.qualitychecker">InstrumentedRowLevelPolicy</a></dt> |
| <dd> </dd> |
| <dt><a href="gobblin/instrumented/qualitychecker/InstrumentedRowLevelPolicyDecorator.html" title="class in gobblin.instrumented.qualitychecker"><span class="typeNameLink">InstrumentedRowLevelPolicyDecorator</span></a> - Class in <a href="gobblin/instrumented/qualitychecker/package-summary.html">gobblin.instrumented.qualitychecker</a></dt> |
| <dd> |
| <div class="block">Decorator that automatically instruments <a href="http://linkedin.github.io/gobblin/javadoc/0.11.0/gobblin-api/gobblin/qualitychecker/row/RowLevelPolicy.html?is-external=true" title="class or interface in gobblin.qualitychecker.row"><code>RowLevelPolicy</code></a>.</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/qualitychecker/InstrumentedRowLevelPolicyDecorator.html#InstrumentedRowLevelPolicyDecorator-gobblin.qualitychecker.row.RowLevelPolicy-">InstrumentedRowLevelPolicyDecorator(RowLevelPolicy)</a></span> - Constructor for class gobblin.instrumented.qualitychecker.<a href="gobblin/instrumented/qualitychecker/InstrumentedRowLevelPolicyDecorator.html" title="class in gobblin.instrumented.qualitychecker">InstrumentedRowLevelPolicyDecorator</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/AcknowledgableWatermark.html#isAcked--">isAcked()</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/AcknowledgableWatermark.html" title="class in gobblin.writer">AcknowledgableWatermark</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/FutureWrappedWriteCallback.html#isCancelled--">isCancelled()</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/FutureWrappedWriteCallback.html" title="class in gobblin.writer">FutureWrappedWriteCallback</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/RecordFuture.html#isCancelled--">isCancelled()</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/RecordFuture.html" title="class in gobblin.writer">RecordFuture</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/WriteResponseFuture.html#isCancelled--">isCancelled()</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/WriteResponseFuture.html" title="class in gobblin.writer">WriteResponseFuture</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/BatchAccumulator.html#isClosed--">isClosed()</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/BatchAccumulator.html" title="class in gobblin.writer">BatchAccumulator</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/FutureWrappedWriteCallback.html#isDone--">isDone()</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/FutureWrappedWriteCallback.html" title="class in gobblin.writer">FutureWrappedWriteCallback</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/RecordFuture.html#isDone--">isDone()</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/RecordFuture.html" title="class in gobblin.writer">RecordFuture</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/WriteResponseFuture.html#isDone--">isDone()</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/WriteResponseFuture.html" title="class in gobblin.writer">WriteResponseFuture</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/extractor/InstrumentedExtractorBase.html#isInstrumentationEnabled--">isInstrumentationEnabled()</a></span> - Method in class gobblin.instrumented.extractor.<a href="gobblin/instrumented/extractor/InstrumentedExtractorBase.html" title="class in gobblin.instrumented.extractor">InstrumentedExtractorBase</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/Instrumentable.html#isInstrumentationEnabled--">isInstrumentationEnabled()</a></span> - Method in interface gobblin.instrumented.<a href="gobblin/instrumented/Instrumentable.html" title="interface in gobblin.instrumented">Instrumentable</a></dt> |
| <dd> |
| <div class="block">Returns true if instrumentation is activated.</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/Instrumented.html#isInstrumentationEnabled--">isInstrumentationEnabled()</a></span> - Method in class gobblin.instrumented.<a href="gobblin/instrumented/Instrumented.html" title="class in gobblin.instrumented">Instrumented</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/AsyncWriterManager.html#isInstrumentationEnabled--">isInstrumentationEnabled()</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/AsyncWriterManager.html" title="class in gobblin.writer">AsyncWriterManager</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/FineGrainedWatermarkTracker.html#isInstrumentationEnabled--">isInstrumentationEnabled()</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/FineGrainedWatermarkTracker.html" title="class in gobblin.writer">FineGrainedWatermarkTracker</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/Instrumented.html#isLineageInstrumented-java.lang.Object-">isLineageInstrumented(Object)</a></span> - Static method in class gobblin.instrumented.<a href="gobblin/instrumented/Instrumented.html" title="class in gobblin.instrumented">Instrumented</a></dt> |
| <dd> |
| <div class="block">Determines whether an object or, if it is a <a href="http://linkedin.github.io/gobblin/javadoc/0.11.0/gobblin-api/gobblin/util/Decorator.html?is-external=true" title="class or interface in gobblin.util"><code>Decorator</code></a>, any object on its lineage, |
| is of class <a href="gobblin/instrumented/Instrumentable.html" title="interface in gobblin.instrumented"><code>Instrumentable</code></a>.</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/BytesBoundedBatch.html#isTTLExpire--">isTTLExpire()</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/BytesBoundedBatch.html" title="class in gobblin.writer">BytesBoundedBatch</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/writer/InstrumentedDataWriterDecorator.html#isWatermarkCapable--">isWatermarkCapable()</a></span> - Method in class gobblin.instrumented.writer.<a href="gobblin/instrumented/writer/InstrumentedDataWriterDecorator.html" title="class in gobblin.instrumented.writer">InstrumentedDataWriterDecorator</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/AsyncWriterManager.html#isWatermarkCapable--">isWatermarkCapable()</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/AsyncWriterManager.html" title="class in gobblin.writer">AsyncWriterManager</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/WatermarkAwareWriter.html#isWatermarkCapable--">isWatermarkCapable()</a></span> - Method in interface gobblin.writer.<a href="gobblin/writer/WatermarkAwareWriter.html" title="interface in gobblin.writer">WatermarkAwareWriter</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/WatermarkAwareWriterWrapper.html#isWatermarkCapable--">isWatermarkCapable()</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/WatermarkAwareWriterWrapper.html" title="class in gobblin.writer">WatermarkAwareWriterWrapper</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/converter/SingleRecordIterable.html#iterator--">iterator()</a></span> - Method in class gobblin.converter.<a href="gobblin/converter/SingleRecordIterable.html" title="class in gobblin.converter">SingleRecordIterable</a></dt> |
| <dd> </dd> |
| </dl> |
| <a name="I:J"> |
| <!-- --> |
| </a> |
| <h2 class="title">J</h2> |
| <dl> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/GobblinMetricsKeys.html#JOB_SPEC_URI_META">JOB_SPEC_URI_META</a></span> - Static variable in class gobblin.instrumented.<a href="gobblin/instrumented/GobblinMetricsKeys.html" title="class in gobblin.instrumented">GobblinMetricsKeys</a></dt> |
| <dd> |
| <div class="block">The JobSpec URI for which the tracking event is</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/GobblinMetricsKeys.html#JOB_SPEC_VERSION_META">JOB_SPEC_VERSION_META</a></span> - Static variable in class gobblin.instrumented.<a href="gobblin/instrumented/GobblinMetricsKeys.html" title="class in gobblin.instrumented">GobblinMetricsKeys</a></dt> |
| <dd> |
| <div class="block">The version of the JobSpec for which the tracking event is</div> |
| </dd> |
| <dt><a href="gobblin/source/extractor/JobCommitPolicy.html" title="enum in gobblin.source.extractor"><span class="typeNameLink">JobCommitPolicy</span></a> - Enum in <a href="gobblin/source/extractor/package-summary.html">gobblin.source.extractor</a></dt> |
| <dd> |
| <div class="block">An enumeration of policies on how output data of jobs/tasks should be committed.</div> |
| </dd> |
| </dl> |
| <a name="I:L"> |
| <!-- --> |
| </a> |
| <h2 class="title">L</h2> |
| <dl> |
| <dt><a href="gobblin/writer/LastWatermarkTracker.html" title="class in gobblin.writer"><span class="typeNameLink">LastWatermarkTracker</span></a> - Class in <a href="gobblin/writer/package-summary.html">gobblin.writer</a></dt> |
| <dd> |
| <div class="block">A <a href="gobblin/writer/WatermarkTracker.html" title="interface in gobblin.writer"><code>WatermarkTracker</code></a> that only tracks the last committed watermark and doesn't compare |
| previous existing watermarks.</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/LastWatermarkTracker.html#LastWatermarkTracker-boolean-">LastWatermarkTracker(boolean)</a></span> - Constructor for class gobblin.writer.<a href="gobblin/writer/LastWatermarkTracker.html" title="class in gobblin.writer">LastWatermarkTracker</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/source/extractor/limiter/LimiterConfigurationKeys.html#LIMITER_REPORT_KEY_LIST">LIMITER_REPORT_KEY_LIST</a></span> - Static variable in class gobblin.source.extractor.limiter.<a href="gobblin/source/extractor/limiter/LimiterConfigurationKeys.html" title="class in gobblin.source.extractor.limiter">LimiterConfigurationKeys</a></dt> |
| <dd> |
| <div class="block">Configuration properties used by the LimitingExtractorDecorator</div> |
| </dd> |
| <dt><a href="gobblin/source/extractor/limiter/LimiterConfigurationKeys.html" title="class in gobblin.source.extractor.limiter"><span class="typeNameLink">LimiterConfigurationKeys</span></a> - Class in <a href="gobblin/source/extractor/limiter/package-summary.html">gobblin.source.extractor.limiter</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/source/extractor/limiter/LimiterConfigurationKeys.html#LimiterConfigurationKeys--">LimiterConfigurationKeys()</a></span> - Constructor for class gobblin.source.extractor.limiter.<a href="gobblin/source/extractor/limiter/LimiterConfigurationKeys.html" title="class in gobblin.source.extractor.limiter">LimiterConfigurationKeys</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/AsyncWriterManager.AsyncWriterManagerBuilder.html#logger-com.google.common.base.Optional-">logger(Optional<Logger>)</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/AsyncWriterManager.AsyncWriterManagerBuilder.html" title="class in gobblin.writer">AsyncWriterManager.AsyncWriterManagerBuilder</a></dt> |
| <dd> </dd> |
| <dt><a href="gobblin/source/extractor/extract/LongWatermark.html" title="class in gobblin.source.extractor.extract"><span class="typeNameLink">LongWatermark</span></a> - Class in <a href="gobblin/source/extractor/extract/package-summary.html">gobblin.source.extractor.extract</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/LongWatermark.html#LongWatermark-long-">LongWatermark(long)</a></span> - Constructor for class gobblin.source.extractor.extract.<a href="gobblin/source/extractor/extract/LongWatermark.html" title="class in gobblin.source.extractor.extract">LongWatermark</a></dt> |
| <dd> </dd> |
| </dl> |
| <a name="I:M"> |
| <!-- --> |
| </a> |
| <h2 class="title">M</h2> |
| <dl> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/Instrumented.html#markMeter-com.google.common.base.Optional-">markMeter(Optional<Meter>)</a></span> - Static method in class gobblin.instrumented.<a href="gobblin/instrumented/Instrumented.html" title="class in gobblin.instrumented">Instrumented</a></dt> |
| <dd> |
| <div class="block">Marks a meter only if it is defined.</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/Instrumented.html#markMeter-com.google.common.base.Optional-long-">markMeter(Optional<Meter>, long)</a></span> - Static method in class gobblin.instrumented.<a href="gobblin/instrumented/Instrumented.html" title="class in gobblin.instrumented">Instrumented</a></dt> |
| <dd> |
| <div class="block">Marks a meter only if it is defined.</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/converter/AsyncConverter1to1.html#MAX_CONCURRENT_ASYNC_CONVERSIONS_KEY">MAX_CONCURRENT_ASYNC_CONVERSIONS_KEY</a></span> - Static variable in class gobblin.converter.<a href="gobblin/converter/AsyncConverter1to1.html" title="class in gobblin.converter">AsyncConverter1to1</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/AsyncWriterManager.html#MAX_OUTSTANDING_WRITES_DEFAULT">MAX_OUTSTANDING_WRITES_DEFAULT</a></span> - Static variable in class gobblin.writer.<a href="gobblin/writer/AsyncWriterManager.html" title="class in gobblin.writer">AsyncWriterManager</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/AsyncWriterManager.AsyncWriterManagerBuilder.html#maxOutstandingWrites-int-">maxOutstandingWrites(int)</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/AsyncWriterManager.AsyncWriterManagerBuilder.html" title="class in gobblin.writer">AsyncWriterManager.AsyncWriterManagerBuilder</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/Instrumented.html#METRIC_CONTEXT_NAME_KEY">METRIC_CONTEXT_NAME_KEY</a></span> - Static variable in class gobblin.instrumented.<a href="gobblin/instrumented/Instrumented.html" title="class in gobblin.instrumented">Instrumented</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/Instrumented.html#metricContext">metricContext</a></span> - Variable in class gobblin.instrumented.<a href="gobblin/instrumented/Instrumented.html" title="class in gobblin.instrumented">Instrumented</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/AsyncWriterManager.html#MIN_RETRY_INTERVAL_MILLIS_DEFAULT">MIN_RETRY_INTERVAL_MILLIS_DEFAULT</a></span> - Static variable in class gobblin.writer.<a href="gobblin/writer/AsyncWriterManager.html" title="class in gobblin.writer">AsyncWriterManager</a></dt> |
| <dd> </dd> |
| <dt><a href="gobblin/writer/MultiWriterWatermarkManager.html" title="class in gobblin.writer"><span class="typeNameLink">MultiWriterWatermarkManager</span></a> - Class in <a href="gobblin/writer/package-summary.html">gobblin.writer</a></dt> |
| <dd> |
| <div class="block">Responsible for managing continuous commit of watermarks.</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/MultiWriterWatermarkManager.html#MultiWriterWatermarkManager-gobblin.writer.WatermarkStorage-long-com.google.common.base.Optional-">MultiWriterWatermarkManager(WatermarkStorage, long, Optional<Logger>)</a></span> - Constructor for class gobblin.writer.<a href="gobblin/writer/MultiWriterWatermarkManager.html" title="class in gobblin.writer">MultiWriterWatermarkManager</a></dt> |
| <dd> </dd> |
| <dt><a href="gobblin/writer/MultiWriterWatermarkTracker.html" title="class in gobblin.writer"><span class="typeNameLink">MultiWriterWatermarkTracker</span></a> - Class in <a href="gobblin/writer/package-summary.html">gobblin.writer</a></dt> |
| <dd> |
| <div class="block">A helper class that tracks committed and uncommitted watermarks.</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/MultiWriterWatermarkTracker.html#MultiWriterWatermarkTracker--">MultiWriterWatermarkTracker()</a></span> - Constructor for class gobblin.writer.<a href="gobblin/writer/MultiWriterWatermarkTracker.html" title="class in gobblin.writer">MultiWriterWatermarkTracker</a></dt> |
| <dd> </dd> |
| </dl> |
| <a name="I:N"> |
| <!-- --> |
| </a> |
| <h2 class="title">N</h2> |
| <dl> |
| <dt><span class="memberNameLink"><a href="gobblin/converter/filter/GobblinTrackingEventFlattenFilterConverter.html#NEW_SCHEMA_NAME">NEW_SCHEMA_NAME</a></span> - Static variable in class gobblin.converter.filter.<a href="gobblin/converter/filter/GobblinTrackingEventFlattenFilterConverter.html" title="class in gobblin.converter.filter">GobblinTrackingEventFlattenFilterConverter</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/Instrumented.html#newContextFromReferenceContext-gobblin.metrics.MetricContext-java.util.List-com.google.common.base.Optional-">newContextFromReferenceContext(MetricContext, List<Tag<?>>, Optional<String>)</a></span> - Static method in class gobblin.instrumented.<a href="gobblin/instrumented/Instrumented.html" title="class in gobblin.instrumented">Instrumented</a></dt> |
| <dd> |
| <div class="block">Generates a new <a href="http://linkedin.github.io/gobblin/javadoc/0.11.0/gobblin-metrics/gobblin/metrics/MetricContext.html?is-external=true" title="class or interface in gobblin.metrics"><code>MetricContext</code></a> with the parent and tags taken from the reference context.</div> |
| </dd> |
| <dt><a href="gobblin/writer/exception/NonTransientException.html" title="class in gobblin.writer.exception"><span class="typeNameLink">NonTransientException</span></a> - Exception in <a href="gobblin/writer/exception/package-summary.html">gobblin.writer.exception</a></dt> |
| <dd> |
| <div class="block">NonTransientException that shows this is a permanent failure where retry cannot solve.</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/exception/NonTransientException.html#NonTransientException--">NonTransientException()</a></span> - Constructor for exception gobblin.writer.exception.<a href="gobblin/writer/exception/NonTransientException.html" title="class in gobblin.writer.exception">NonTransientException</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/exception/NonTransientException.html#NonTransientException-java.lang.String-">NonTransientException(String)</a></span> - Constructor for exception gobblin.writer.exception.<a href="gobblin/writer/exception/NonTransientException.html" title="class in gobblin.writer.exception">NonTransientException</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/exception/NonTransientException.html#NonTransientException-java.lang.String-java.lang.Throwable-">NonTransientException(String, Throwable)</a></span> - Constructor for exception gobblin.writer.exception.<a href="gobblin/writer/exception/NonTransientException.html" title="class in gobblin.writer.exception">NonTransientException</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/exception/NonTransientException.html#NonTransientException-java.lang.Throwable-">NonTransientException(Throwable)</a></span> - Constructor for exception gobblin.writer.exception.<a href="gobblin/writer/exception/NonTransientException.html" title="class in gobblin.writer.exception">NonTransientException</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/AsyncWriterManager.html#NUM_RETRIES_DEFAULT">NUM_RETRIES_DEFAULT</a></span> - Static variable in class gobblin.writer.<a href="gobblin/writer/AsyncWriterManager.html" title="class in gobblin.writer">AsyncWriterManager</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/AsyncWriterManager.AsyncWriterManagerBuilder.html#numRetries-int-">numRetries(int)</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/AsyncWriterManager.AsyncWriterManagerBuilder.html" title="class in gobblin.writer">AsyncWriterManager.AsyncWriterManagerBuilder</a></dt> |
| <dd> </dd> |
| </dl> |
| <a name="I:O"> |
| <!-- --> |
| </a> |
| <h2 class="title">O</h2> |
| <dl> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/extractor/InstrumentedExtractorBase.html#onException-java.lang.Exception-">onException(Exception)</a></span> - Method in class gobblin.instrumented.extractor.<a href="gobblin/instrumented/extractor/InstrumentedExtractorBase.html" title="class in gobblin.instrumented.extractor">InstrumentedExtractorBase</a></dt> |
| <dd> |
| <div class="block">Called on exception when trying to read.</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/async/Callback.html#onFailure-java.lang.Throwable-">onFailure(Throwable)</a></span> - Method in interface gobblin.async.<a href="gobblin/async/Callback.html" title="interface in gobblin.async">Callback</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/Batch.html#onFailure-java.lang.Throwable-">onFailure(Throwable)</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/Batch.html" title="class in gobblin.writer">Batch</a></dt> |
| <dd> |
| <div class="block">When batch is sent with an error return, this method will be invoked</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/FutureWrappedWriteCallback.html#onFailure-java.lang.Throwable-">onFailure(Throwable)</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/FutureWrappedWriteCallback.html" title="class in gobblin.writer">FutureWrappedWriteCallback</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/async/Callback.html#onSuccess-T-">onSuccess(T)</a></span> - Method in interface gobblin.async.<a href="gobblin/async/Callback.html" title="interface in gobblin.async">Callback</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/Batch.html#onSuccess-gobblin.writer.WriteResponse-">onSuccess(WriteResponse)</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/Batch.html" title="class in gobblin.writer">Batch</a></dt> |
| <dd> |
| <div class="block">After batch is sent and get acknowledged successfully, this method will be invoked</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/FutureWrappedWriteCallback.html#onSuccess-gobblin.writer.WriteResponse-">onSuccess(WriteResponse)</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/FutureWrappedWriteCallback.html" title="class in gobblin.writer">FutureWrappedWriteCallback</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/GobblinMetricsKeys.html#OPERATION_TYPE_META">OPERATION_TYPE_META</a></span> - Static variable in class gobblin.instrumented.<a href="gobblin/instrumented/GobblinMetricsKeys.html" title="class in gobblin.instrumented">GobblinMetricsKeys</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/BytesBoundedBatch.html#OVERHEAD_SIZE_IN_BYTES">OVERHEAD_SIZE_IN_BYTES</a></span> - Static variable in class gobblin.writer.<a href="gobblin/writer/BytesBoundedBatch.html" title="class in gobblin.writer">BytesBoundedBatch</a></dt> |
| <dd> </dd> |
| </dl> |
| <a name="I:P"> |
| <!-- --> |
| </a> |
| <h2 class="title">P</h2> |
| <dl> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/writer/InstrumentedPartitionedDataWriterDecorator.html#PARTITION">PARTITION</a></span> - Static variable in class gobblin.instrumented.writer.<a href="gobblin/instrumented/writer/InstrumentedPartitionedDataWriterDecorator.html" title="class in gobblin.instrumented.writer">InstrumentedPartitionedDataWriterDecorator</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/PartitionAwareDataWriterBuilder.html#partition">partition</a></span> - Variable in class gobblin.writer.<a href="gobblin/writer/PartitionAwareDataWriterBuilder.html" title="class in gobblin.writer">PartitionAwareDataWriterBuilder</a></dt> |
| <dd> </dd> |
| <dt><a href="gobblin/writer/PartitionAwareDataWriterBuilder.html" title="class in gobblin.writer"><span class="typeNameLink">PartitionAwareDataWriterBuilder</span></a><<a href="gobblin/writer/PartitionAwareDataWriterBuilder.html" title="type parameter in PartitionAwareDataWriterBuilder">S</a>,<a href="gobblin/writer/PartitionAwareDataWriterBuilder.html" title="type parameter in PartitionAwareDataWriterBuilder">D</a>> - Class in <a href="gobblin/writer/package-summary.html">gobblin.writer</a></dt> |
| <dd> |
| <div class="block">A <a href="http://linkedin.github.io/gobblin/javadoc/0.11.0/gobblin-api/gobblin/writer/DataWriterBuilder.html?is-external=true" title="class or interface in gobblin.writer"><code>DataWriterBuilder</code></a> used with a <a href="gobblin/writer/partitioner/WriterPartitioner.html" title="interface in gobblin.writer.partitioner"><code>WriterPartitioner</code></a>.</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/PartitionAwareDataWriterBuilder.html#PartitionAwareDataWriterBuilder--">PartitionAwareDataWriterBuilder()</a></span> - Constructor for class gobblin.writer.<a href="gobblin/writer/PartitionAwareDataWriterBuilder.html" title="class in gobblin.writer">PartitionAwareDataWriterBuilder</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/partitioner/WriterPartitioner.html#partitionForRecord-D-">partitionForRecord(D)</a></span> - Method in interface gobblin.writer.partitioner.<a href="gobblin/writer/partitioner/WriterPartitioner.html" title="interface in gobblin.writer.partitioner">WriterPartitioner</a></dt> |
| <dd> |
| <div class="block">Returns the partition that the input record belongs to.</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/partitioner/WriterPartitioner.html#partitionSchema--">partitionSchema()</a></span> - Method in interface gobblin.writer.partitioner.<a href="gobblin/writer/partitioner/WriterPartitioner.html" title="interface in gobblin.writer.partitioner">WriterPartitioner</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/converter/AsyncConverter1to1.html#processStream-gobblin.records.RecordStreamWithMetadata-gobblin.configuration.WorkUnitState-">processStream(RecordStreamWithMetadata<DI, SI>, WorkUnitState)</a></span> - Method in class gobblin.converter.<a href="gobblin/converter/AsyncConverter1to1.html" title="class in gobblin.converter">AsyncConverter1to1</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/converter/InstrumentedConverterDecorator.html#processStream-gobblin.records.RecordStreamWithMetadata-gobblin.configuration.WorkUnitState-">processStream(RecordStreamWithMetadata<DI, SI>, WorkUnitState)</a></span> - Method in class gobblin.instrumented.converter.<a href="gobblin/instrumented/converter/InstrumentedConverterDecorator.html" title="class in gobblin.instrumented.converter">InstrumentedConverterDecorator</a></dt> |
| <dd> |
| <div class="block">This workarounds the issue that <a href="http://linkedin.github.io/gobblin/javadoc/0.11.0/gobblin-api/gobblin/converter/Converter.html?is-external=true#processStream-gobblin.records.RecordStreamWithMetadata-gobblin.configuration.WorkUnitState-" title="class or interface in gobblin.converter"><code>Converter.processStream(RecordStreamWithMetadata, WorkUnitState)</code></a> will invoke |
| <a href="gobblin/converter/AsyncConverter1to1.html#convertRecord-SO-DI-gobblin.configuration.WorkUnitState-"><code>AsyncConverter1to1.convertRecord(Object, Object, WorkUnitState)</code></a> directly, which is an unsupported method.</div> |
| </dd> |
| </dl> |
| <a name="I:R"> |
| <!-- --> |
| </a> |
| <h2 class="title">R</h2> |
| <dl> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/Instrumented.html#RAND">RAND</a></span> - Static variable in class gobblin.instrumented.<a href="gobblin/instrumented/Instrumented.html" title="class in gobblin.instrumented">Instrumented</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/extractor/InstrumentedExtractor.html#readRecord-D-">readRecord(D)</a></span> - Method in class gobblin.instrumented.extractor.<a href="gobblin/instrumented/extractor/InstrumentedExtractor.html" title="class in gobblin.instrumented.extractor">InstrumentedExtractor</a></dt> |
| <dd> |
| <div class="block"><span class="deprecatedLabel">Deprecated.</span> |
| <div class="block"><span class="deprecationComment">provided for test compatibility.</span></div> |
| </div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/extractor/InstrumentedExtractor.html#readRecordEnvelope--">readRecordEnvelope()</a></span> - Method in class gobblin.instrumented.extractor.<a href="gobblin/instrumented/extractor/InstrumentedExtractor.html" title="class in gobblin.instrumented.extractor">InstrumentedExtractor</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/extractor/InstrumentedExtractorBase.html#readRecordEnvelope--">readRecordEnvelope()</a></span> - Method in class gobblin.instrumented.extractor.<a href="gobblin/instrumented/extractor/InstrumentedExtractorBase.html" title="class in gobblin.instrumented.extractor">InstrumentedExtractorBase</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/extractor/InstrumentedExtractorDecorator.html#readRecordEnvelope--">readRecordEnvelope()</a></span> - Method in class gobblin.instrumented.extractor.<a href="gobblin/instrumented/extractor/InstrumentedExtractorDecorator.html" title="class in gobblin.instrumented.extractor">InstrumentedExtractorDecorator</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/extractor/InstrumentedExtractorBase.html#readRecordEnvelopeImpl--">readRecordEnvelopeImpl()</a></span> - Method in class gobblin.instrumented.extractor.<a href="gobblin/instrumented/extractor/InstrumentedExtractorBase.html" title="class in gobblin.instrumented.extractor">InstrumentedExtractorBase</a></dt> |
| <dd> |
| <div class="block">Subclasses should implement this or <a href="gobblin/instrumented/extractor/InstrumentedExtractorBase.html#readRecordImpl-D-"><code>InstrumentedExtractorBase.readRecordImpl(Object)</code></a> |
| instead of <a href="http://linkedin.github.io/gobblin/javadoc/0.11.0/gobblin-api/gobblin/source/extractor/Extractor.html?is-external=true#readRecord-D-" title="class or interface in gobblin.source.extractor"><code>Extractor.readRecord(D)</code></a></div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/extractor/InstrumentedExtractorDecorator.html#readRecordEnvelopeImpl--">readRecordEnvelopeImpl()</a></span> - Method in class gobblin.instrumented.extractor.<a href="gobblin/instrumented/extractor/InstrumentedExtractorDecorator.html" title="class in gobblin.instrumented.extractor">InstrumentedExtractorDecorator</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/extractor/InstrumentedExtractorBase.html#readRecordImpl-D-">readRecordImpl(D)</a></span> - Method in class gobblin.instrumented.extractor.<a href="gobblin/instrumented/extractor/InstrumentedExtractorBase.html" title="class in gobblin.instrumented.extractor">InstrumentedExtractorBase</a></dt> |
| <dd> |
| <div class="block">Subclasses should implement this or <a href="gobblin/instrumented/extractor/InstrumentedExtractorBase.html#readRecordEnvelopeImpl--"><code>InstrumentedExtractorBase.readRecordEnvelopeImpl()</code></a> |
| instead of <a href="http://linkedin.github.io/gobblin/javadoc/0.11.0/gobblin-api/gobblin/source/extractor/Extractor.html?is-external=true#readRecord-D-" title="class or interface in gobblin.source.extractor"><code>Extractor.readRecord(D)</code></a></div> |
| </dd> |
| <dt><a href="gobblin/writer/RecordFuture.html" title="class in gobblin.writer"><span class="typeNameLink">RecordFuture</span></a> - Class in <a href="gobblin/writer/package-summary.html">gobblin.writer</a></dt> |
| <dd> |
| <div class="block">A future object generated after a record was inserted into a batch |
| We can include more meta data about this record in the future</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/RecordFuture.html#RecordFuture-java.util.concurrent.CountDownLatch-long-">RecordFuture(CountDownLatch, long)</a></span> - Constructor for class gobblin.writer.<a href="gobblin/writer/RecordFuture.html" title="class in gobblin.writer">RecordFuture</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/BytesBoundedBatch.RecordMemory.html#RecordMemory--">RecordMemory()</a></span> - Constructor for class gobblin.writer.<a href="gobblin/writer/BytesBoundedBatch.RecordMemory.html" title="class in gobblin.writer">BytesBoundedBatch.RecordMemory</a></dt> |
| <dd> </dd> |
| <dt><a href="gobblin/writer/RecordMetadata.html" title="class in gobblin.writer"><span class="typeNameLink">RecordMetadata</span></a> - Class in <a href="gobblin/writer/package-summary.html">gobblin.writer</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/RecordMetadata.html#RecordMetadata-long-">RecordMetadata(long)</a></span> - Constructor for class gobblin.writer.<a href="gobblin/writer/RecordMetadata.html" title="class in gobblin.writer">RecordMetadata</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/extractor/InstrumentedExtractorDecorator.html#recordStream-java.util.concurrent.atomic.AtomicBoolean-">recordStream(AtomicBoolean)</a></span> - Method in class gobblin.instrumented.extractor.<a href="gobblin/instrumented/extractor/InstrumentedExtractorDecorator.html" title="class in gobblin.instrumented.extractor">InstrumentedExtractorDecorator</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/writer/InstrumentedDataWriterDecorator.html#recordsWritten--">recordsWritten()</a></span> - Method in class gobblin.instrumented.writer.<a href="gobblin/instrumented/writer/InstrumentedDataWriterDecorator.html" title="class in gobblin.instrumented.writer">InstrumentedDataWriterDecorator</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/AsyncWriterManager.html#recordsWritten--">recordsWritten()</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/AsyncWriterManager.html" title="class in gobblin.writer">AsyncWriterManager</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/extractor/InstrumentedExtractorBase.html#regenerateMetrics--">regenerateMetrics()</a></span> - Method in class gobblin.instrumented.extractor.<a href="gobblin/instrumented/extractor/InstrumentedExtractorBase.html" title="class in gobblin.instrumented.extractor">InstrumentedExtractorBase</a></dt> |
| <dd> |
| <div class="block">Generates metrics for the instrumentation of this class.</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/AsyncWriterManager.html#regenerateMetrics--">regenerateMetrics()</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/AsyncWriterManager.html" title="class in gobblin.writer">AsyncWriterManager</a></dt> |
| <dd> |
| <div class="block">Generates metrics for the instrumentation of this class.</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/FineGrainedWatermarkTracker.html#regenerateMetrics--">regenerateMetrics()</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/FineGrainedWatermarkTracker.html" title="class in gobblin.writer">FineGrainedWatermarkTracker</a></dt> |
| <dd> |
| <div class="block">Generates metrics for the instrumentation of this class.</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/MultiWriterWatermarkManager.html#registerWriter-gobblin.writer.WatermarkAwareWriter-">registerWriter(WatermarkAwareWriter)</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/MultiWriterWatermarkManager.html" title="class in gobblin.writer">MultiWriterWatermarkManager</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/converter/filter/AvroProjectionConverter.html#REMOVE_FIELDS">REMOVE_FIELDS</a></span> - Static variable in class gobblin.converter.filter.<a href="gobblin/converter/filter/AvroProjectionConverter.html" title="class in gobblin.converter.filter">AvroProjectionConverter</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/converter/filter/AvroSchemaFieldRemover.html#removeFields-org.apache.avro.Schema-">removeFields(Schema)</a></span> - Method in class gobblin.converter.filter.<a href="gobblin/converter/filter/AvroSchemaFieldRemover.html" title="class in gobblin.converter.filter">AvroSchemaFieldRemover</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/LastWatermarkTracker.html#reset--">reset()</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/LastWatermarkTracker.html" title="class in gobblin.writer">LastWatermarkTracker</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/MultiWriterWatermarkTracker.html#reset--">reset()</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/MultiWriterWatermarkTracker.html" title="class in gobblin.writer">MultiWriterWatermarkTracker</a></dt> |
| <dd> |
| <div class="block">Reset current state</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/WatermarkTracker.html#reset--">reset()</a></span> - Method in interface gobblin.writer.<a href="gobblin/writer/WatermarkTracker.html" title="interface in gobblin.writer">WatermarkTracker</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/AsyncWriterManager.html#RETRIES_ENABLED_DEFAULT">RETRIES_ENABLED_DEFAULT</a></span> - Static variable in class gobblin.writer.<a href="gobblin/writer/AsyncWriterManager.html" title="class in gobblin.writer">AsyncWriterManager</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/AsyncWriterManager.AsyncWriterManagerBuilder.html#retriesEnabled-boolean-">retriesEnabled(boolean)</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/AsyncWriterManager.AsyncWriterManagerBuilder.html" title="class in gobblin.writer">AsyncWriterManager.AsyncWriterManagerBuilder</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/WatermarkManager.RetrievalStatus.html#RetrievalStatus--">RetrievalStatus()</a></span> - Constructor for class gobblin.writer.<a href="gobblin/writer/WatermarkManager.RetrievalStatus.html" title="class in gobblin.writer">WatermarkManager.RetrievalStatus</a></dt> |
| <dd> </dd> |
| </dl> |
| <a name="I:S"> |
| <!-- --> |
| </a> |
| <h2 class="title">S</h2> |
| <dl> |
| <dt><span class="memberNameLink"><a href="gobblin/converter/SamplingConverter.html#SAMPLE_RATIO_KEY">SAMPLE_RATIO_KEY</a></span> - Static variable in class gobblin.converter.<a href="gobblin/converter/SamplingConverter.html" title="class in gobblin.converter">SamplingConverter</a></dt> |
| <dd> </dd> |
| <dt><a href="gobblin/converter/SamplingConverter.html" title="class in gobblin.converter"><span class="typeNameLink">SamplingConverter</span></a> - Class in <a href="gobblin/converter/package-summary.html">gobblin.converter</a></dt> |
| <dd> |
| <div class="block">A converter that samples records based on a configured sampling ratio.</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/converter/SamplingConverter.html#SamplingConverter--">SamplingConverter()</a></span> - Constructor for class gobblin.converter.<a href="gobblin/converter/SamplingConverter.html" title="class in gobblin.converter">SamplingConverter</a></dt> |
| <dd> </dd> |
| <dt><a href="gobblin/writer/SequentialBasedBatchAccumulator.html" title="class in gobblin.writer"><span class="typeNameLink">SequentialBasedBatchAccumulator</span></a><<a href="gobblin/writer/SequentialBasedBatchAccumulator.html" title="type parameter in SequentialBasedBatchAccumulator">D</a>> - Class in <a href="gobblin/writer/package-summary.html">gobblin.writer</a></dt> |
| <dd> |
| <div class="block">Sequential and TTL based accumulator |
| A producer can add a record to this accumulator.</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/SequentialBasedBatchAccumulator.html#SequentialBasedBatchAccumulator--">SequentialBasedBatchAccumulator()</a></span> - Constructor for class gobblin.writer.<a href="gobblin/writer/SequentialBasedBatchAccumulator.html" title="class in gobblin.writer">SequentialBasedBatchAccumulator</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/SequentialBasedBatchAccumulator.html#SequentialBasedBatchAccumulator-java.util.Properties-">SequentialBasedBatchAccumulator(Properties)</a></span> - Constructor for class gobblin.writer.<a href="gobblin/writer/SequentialBasedBatchAccumulator.html" title="class in gobblin.writer">SequentialBasedBatchAccumulator</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/SequentialBasedBatchAccumulator.html#SequentialBasedBatchAccumulator-long-long-long-">SequentialBasedBatchAccumulator(long, long, long)</a></span> - Constructor for class gobblin.writer.<a href="gobblin/writer/SequentialBasedBatchAccumulator.html" title="class in gobblin.writer">SequentialBasedBatchAccumulator</a></dt> |
| <dd> </dd> |
| <dt><a href="gobblin/test/SequentialTestSource.html" title="class in gobblin.test"><span class="typeNameLink">SequentialTestSource</span></a> - Class in <a href="gobblin/test/package-summary.html">gobblin.test</a></dt> |
| <dd> |
| <div class="block">A Test source that generates a sequence of records, works in batch and streaming mode.</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/test/SequentialTestSource.html#SequentialTestSource--">SequentialTestSource()</a></span> - Constructor for class gobblin.test.<a href="gobblin/test/SequentialTestSource.html" title="class in gobblin.test">SequentialTestSource</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/Instrumented.html#setMetricContextName-gobblin.configuration.State-java.lang.String-">setMetricContextName(State, String)</a></span> - Static method in class gobblin.instrumented.<a href="gobblin/instrumented/Instrumented.html" title="class in gobblin.instrumented">Instrumented</a></dt> |
| <dd> |
| <div class="block">Sets the key <a href="gobblin/instrumented/Instrumented.html#METRIC_CONTEXT_NAME_KEY"><code>Instrumented.METRIC_CONTEXT_NAME_KEY</code></a> to the specified name, in 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>.</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/WatermarkAwareWriterWrapper.html#setWatermarkAwareWriter-gobblin.writer.WatermarkAwareWriter-">setWatermarkAwareWriter(WatermarkAwareWriter)</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/WatermarkAwareWriterWrapper.html" title="class in gobblin.writer">WatermarkAwareWriterWrapper</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/EventBasedSource.html#shutdown-gobblin.configuration.SourceState-">shutdown(SourceState)</a></span> - Method in class gobblin.source.extractor.extract.<a href="gobblin/source/extractor/extract/EventBasedSource.html" title="class in gobblin.source.extractor.extract">EventBasedSource</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/test/SequentialTestSource.html#shutdown-gobblin.configuration.SourceState-">shutdown(SourceState)</a></span> - Method in class gobblin.test.<a href="gobblin/test/SequentialTestSource.html" title="class in gobblin.test">SequentialTestSource</a></dt> |
| <dd> </dd> |
| <dt><a href="gobblin/converter/SingleRecordIterable.html" title="class in gobblin.converter"><span class="typeNameLink">SingleRecordIterable</span></a><<a href="gobblin/converter/SingleRecordIterable.html" title="type parameter in SingleRecordIterable">T</a>> - Class in <a href="gobblin/converter/package-summary.html">gobblin.converter</a></dt> |
| <dd> |
| <div class="block">A type of <a href="https://docs.oracle.com/javase/7/docs/api/java/lang/Iterable.html?is-external=true" title="class or interface in java.lang"><code>Iterable</code></a>s for a single non-nullable record.</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/converter/SingleRecordIterable.html#SingleRecordIterable-T-">SingleRecordIterable(T)</a></span> - Constructor for class gobblin.converter.<a href="gobblin/converter/SingleRecordIterable.html" title="class in gobblin.converter">SingleRecordIterable</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/GobblinMetricsKeys.html#SPEC_URI_META">SPEC_URI_META</a></span> - Static variable in class gobblin.instrumented.<a href="gobblin/instrumented/GobblinMetricsKeys.html" title="class in gobblin.instrumented">GobblinMetricsKeys</a></dt> |
| <dd> |
| <div class="block">The FlowSpec URI for which the tracking event is</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/GobblinMetricsKeys.html#SPEC_VERSION_META">SPEC_VERSION_META</a></span> - Static variable in class gobblin.instrumented.<a href="gobblin/instrumented/GobblinMetricsKeys.html" title="class in gobblin.instrumented">GobblinMetricsKeys</a></dt> |
| <dd> |
| <div class="block">The version of the FlowSpec for which the tracking event is</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/FineGrainedWatermarkTracker.html#start--">start()</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/FineGrainedWatermarkTracker.html" title="class in gobblin.writer">FineGrainedWatermarkTracker</a></dt> |
| <dd> |
| <div class="block">Schedule the sweeper and stability checkers</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/MultiWriterWatermarkManager.html#start--">start()</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/MultiWriterWatermarkManager.html" title="class in gobblin.writer">MultiWriterWatermarkManager</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/TrackerBasedWatermarkManager.html#start--">start()</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/TrackerBasedWatermarkManager.html" title="class in gobblin.writer">TrackerBasedWatermarkManager</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/WatermarkManager.html#start--">start()</a></span> - Method in interface gobblin.writer.<a href="gobblin/writer/WatermarkManager.html" title="interface in gobblin.writer">WatermarkManager</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/extractor/InstrumentedExtractorBase.html#switchMetricContext-java.util.List-">switchMetricContext(List<Tag<?>>)</a></span> - Method in class gobblin.instrumented.extractor.<a href="gobblin/instrumented/extractor/InstrumentedExtractorBase.html" title="class in gobblin.instrumented.extractor">InstrumentedExtractorBase</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/extractor/InstrumentedExtractorBase.html#switchMetricContext-gobblin.metrics.MetricContext-">switchMetricContext(MetricContext)</a></span> - Method in class gobblin.instrumented.extractor.<a href="gobblin/instrumented/extractor/InstrumentedExtractorBase.html" title="class in gobblin.instrumented.extractor">InstrumentedExtractorBase</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/Instrumentable.html#switchMetricContext-java.util.List-">switchMetricContext(List<Tag<?>>)</a></span> - Method in interface gobblin.instrumented.<a href="gobblin/instrumented/Instrumentable.html" title="interface in gobblin.instrumented">Instrumentable</a></dt> |
| <dd> |
| <div class="block">Generate a new <a href="http://linkedin.github.io/gobblin/javadoc/0.11.0/gobblin-metrics/gobblin/metrics/MetricContext.html?is-external=true" title="class or interface in gobblin.metrics"><code>MetricContext</code></a> replacing old <a href="http://linkedin.github.io/gobblin/javadoc/0.11.0/gobblin-metrics/gobblin/metrics/Tag.html?is-external=true" title="class or interface in gobblin.metrics"><code>Tag</code></a> with input |
| <a href="http://linkedin.github.io/gobblin/javadoc/0.11.0/gobblin-metrics/gobblin/metrics/Tag.html?is-external=true" title="class or interface in gobblin.metrics"><code>Tag</code></a> (only tags with the same keys will be replaced), |
| and recreate all metrics in this new context.</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/Instrumentable.html#switchMetricContext-gobblin.metrics.MetricContext-">switchMetricContext(MetricContext)</a></span> - Method in interface gobblin.instrumented.<a href="gobblin/instrumented/Instrumentable.html" title="interface in gobblin.instrumented">Instrumentable</a></dt> |
| <dd> |
| <div class="block">Switches the existing <a href="http://linkedin.github.io/gobblin/javadoc/0.11.0/gobblin-metrics/gobblin/metrics/MetricContext.html?is-external=true" title="class or interface in gobblin.metrics"><code>MetricContext</code></a> with the supplied metric context and regenerates |
| <a href="http://linkedin.github.io/gobblin/javadoc/0.11.0/gobblin-metrics/gobblin/metrics/Metric.html?is-external=true" title="class or interface in gobblin.metrics"><code>Metric</code></a>.</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/Instrumented.html#switchMetricContext-java.util.List-">switchMetricContext(List<Tag<?>>)</a></span> - Method in class gobblin.instrumented.<a href="gobblin/instrumented/Instrumented.html" title="class in gobblin.instrumented">Instrumented</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/Instrumented.html#switchMetricContext-gobblin.metrics.MetricContext-">switchMetricContext(MetricContext)</a></span> - Method in class gobblin.instrumented.<a href="gobblin/instrumented/Instrumented.html" title="class in gobblin.instrumented">Instrumented</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/AsyncWriterManager.html#switchMetricContext-java.util.List-">switchMetricContext(List<Tag<?>>)</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/AsyncWriterManager.html" title="class in gobblin.writer">AsyncWriterManager</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/AsyncWriterManager.html#switchMetricContext-gobblin.metrics.MetricContext-">switchMetricContext(MetricContext)</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/AsyncWriterManager.html" title="class in gobblin.writer">AsyncWriterManager</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/FineGrainedWatermarkTracker.html#switchMetricContext-java.util.List-">switchMetricContext(List<Tag<?>>)</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/FineGrainedWatermarkTracker.html" title="class in gobblin.writer">FineGrainedWatermarkTracker</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/FineGrainedWatermarkTracker.html#switchMetricContext-gobblin.metrics.MetricContext-">switchMetricContext(MetricContext)</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/FineGrainedWatermarkTracker.html" title="class in gobblin.writer">FineGrainedWatermarkTracker</a></dt> |
| <dd> </dd> |
| <dt><a href="gobblin/writer/SyncDataWriter.html" title="interface in gobblin.writer"><span class="typeNameLink">SyncDataWriter</span></a><<a href="gobblin/writer/SyncDataWriter.html" title="type parameter in SyncDataWriter">D</a>> - Interface in <a href="gobblin/writer/package-summary.html">gobblin.writer</a></dt> |
| <dd> |
| <div class="block">An interface to implement Synchronous (Blocking) Data writers</div> |
| </dd> |
| </dl> |
| <a name="I:T"> |
| <!-- --> |
| </a> |
| <h2 class="title">T</h2> |
| <dl> |
| <dt><a href="gobblin/test/TestRecord.html" title="class in gobblin.test"><span class="typeNameLink">TestRecord</span></a> - Class in <a href="gobblin/test/package-summary.html">gobblin.test</a></dt> |
| <dd> |
| <div class="block">A Test record</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/test/TestRecord.html#TestRecord--">TestRecord()</a></span> - Constructor for class gobblin.test.<a href="gobblin/test/TestRecord.html" title="class in gobblin.test">TestRecord</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/Instrumented.html#timerContext-com.google.common.base.Optional-java.lang.String-">timerContext(Optional<MetricContext>, String)</a></span> - Static method in class gobblin.instrumented.<a href="gobblin/instrumented/Instrumented.html" title="class in gobblin.instrumented">Instrumented</a></dt> |
| <dd> |
| <div class="block">Returns a <code>Timer.Context</code> only if <a href="http://linkedin.github.io/gobblin/javadoc/0.11.0/gobblin-metrics/gobblin/metrics/MetricContext.html?is-external=true" title="class or interface in gobblin.metrics"><code>MetricContext</code></a> is defined.</div> |
| </dd> |
| <dt><a href="gobblin/converter/ToAvroConverterBase.html" title="class in gobblin.converter"><span class="typeNameLink">ToAvroConverterBase</span></a><<a href="gobblin/converter/ToAvroConverterBase.html" title="type parameter in ToAvroConverterBase">SI</a>,<a href="gobblin/converter/ToAvroConverterBase.html" title="type parameter in ToAvroConverterBase">DI</a>> - Class in <a href="gobblin/converter/package-summary.html">gobblin.converter</a></dt> |
| <dd> |
| <div class="block">A base abstract <a href="http://linkedin.github.io/gobblin/javadoc/0.11.0/gobblin-api/gobblin/converter/Converter.html?is-external=true" title="class or interface in gobblin.converter"><code>Converter</code></a> class for data transformation to Avro.</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/converter/ToAvroConverterBase.html#ToAvroConverterBase--">ToAvroConverterBase()</a></span> - Constructor for class gobblin.converter.<a href="gobblin/converter/ToAvroConverterBase.html" title="class in gobblin.converter">ToAvroConverterBase</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/source/extractor/DefaultCheckpointableWatermark.html#toJson--">toJson()</a></span> - Method in class gobblin.source.extractor.<a href="gobblin/source/extractor/DefaultCheckpointableWatermark.html" title="class in gobblin.source.extractor">DefaultCheckpointableWatermark</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/source/extractor/extract/LongWatermark.html#toJson--">toJson()</a></span> - Method in class gobblin.source.extractor.extract.<a href="gobblin/source/extractor/extract/LongWatermark.html" title="class in gobblin.source.extractor.extract">LongWatermark</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/source/extractor/DefaultCheckpointableWatermark.html#toString--">toString()</a></span> - Method in class gobblin.source.extractor.<a href="gobblin/source/extractor/DefaultCheckpointableWatermark.html" title="class in gobblin.source.extractor">DefaultCheckpointableWatermark</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/FineGrainedWatermarkTracker.html#track-gobblin.writer.AcknowledgableWatermark-">track(AcknowledgableWatermark)</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/FineGrainedWatermarkTracker.html" title="class in gobblin.writer">FineGrainedWatermarkTracker</a></dt> |
| <dd> |
| <div class="block">Track a watermark.</div> |
| </dd> |
| <dt><a href="gobblin/writer/TrackerBasedWatermarkManager.html" title="class in gobblin.writer"><span class="typeNameLink">TrackerBasedWatermarkManager</span></a> - Class in <a href="gobblin/writer/package-summary.html">gobblin.writer</a></dt> |
| <dd> |
| <div class="block">Responsible for managing continuous commit of watermarks.</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/TrackerBasedWatermarkManager.html#TrackerBasedWatermarkManager-gobblin.writer.WatermarkStorage-gobblin.writer.FineGrainedWatermarkTracker-long-com.google.common.base.Optional-">TrackerBasedWatermarkManager(WatermarkStorage, FineGrainedWatermarkTracker, long, Optional<Logger>)</a></span> - Constructor for class gobblin.writer.<a href="gobblin/writer/TrackerBasedWatermarkManager.html" title="class in gobblin.writer">TrackerBasedWatermarkManager</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/Batch.html#tryAppend-D-gobblin.writer.WriteCallback-">tryAppend(D, WriteCallback)</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/Batch.html" title="class in gobblin.writer">Batch</a></dt> |
| <dd> |
| <div class="block">Try to add a record to this batch</div> |
| </dd> |
| </dl> |
| <a name="I:U"> |
| <!-- --> |
| </a> |
| <h2 class="title">U</h2> |
| <dl> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/LastWatermarkTracker.html#unacknowledgedWatermark-gobblin.source.extractor.CheckpointableWatermark-">unacknowledgedWatermark(CheckpointableWatermark)</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/LastWatermarkTracker.html" title="class in gobblin.writer">LastWatermarkTracker</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/MultiWriterWatermarkTracker.html#unacknowledgedWatermark-gobblin.source.extractor.CheckpointableWatermark-">unacknowledgedWatermark(CheckpointableWatermark)</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/MultiWriterWatermarkTracker.html" title="class in gobblin.writer">MultiWriterWatermarkTracker</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/WatermarkTracker.html#unacknowledgedWatermark-gobblin.source.extractor.CheckpointableWatermark-">unacknowledgedWatermark(CheckpointableWatermark)</a></span> - Method in interface gobblin.writer.<a href="gobblin/writer/WatermarkTracker.html" title="interface in gobblin.writer">WatermarkTracker</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/LastWatermarkTracker.html#unacknowledgedWatermarks-java.util.Map-">unacknowledgedWatermarks(Map<String, CheckpointableWatermark>)</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/LastWatermarkTracker.html" title="class in gobblin.writer">LastWatermarkTracker</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/MultiWriterWatermarkTracker.html#unacknowledgedWatermarks-java.util.Map-">unacknowledgedWatermarks(Map<String, CheckpointableWatermark>)</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/MultiWriterWatermarkTracker.html" title="class in gobblin.writer">MultiWriterWatermarkTracker</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/WatermarkTracker.html#unacknowledgedWatermarks-java.util.Map-">unacknowledgedWatermarks(Map<String, CheckpointableWatermark>)</a></span> - Method in interface gobblin.writer.<a href="gobblin/writer/WatermarkTracker.html" title="interface in gobblin.writer">WatermarkTracker</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/Instrumented.html#updateTimer-com.google.common.base.Optional-long-java.util.concurrent.TimeUnit-">updateTimer(Optional<Timer>, long, TimeUnit)</a></span> - Static method in class gobblin.instrumented.<a href="gobblin/instrumented/Instrumented.html" title="class in gobblin.instrumented">Instrumented</a></dt> |
| <dd> |
| <div class="block">Updates a timer only if it is defined.</div> |
| </dd> |
| </dl> |
| <a name="I:V"> |
| <!-- --> |
| </a> |
| <h2 class="title">V</h2> |
| <dl> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/PartitionAwareDataWriterBuilder.html#validatePartitionSchema-org.apache.avro.Schema-">validatePartitionSchema(Schema)</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/PartitionAwareDataWriterBuilder.html" title="class in gobblin.writer">PartitionAwareDataWriterBuilder</a></dt> |
| <dd> |
| <div class="block">Checks whether the <a href="gobblin/writer/PartitionAwareDataWriterBuilder.html" title="class in gobblin.writer"><code>PartitionAwareDataWriterBuilder</code></a> is compatible with a given partition <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>.</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/crypto/EncryptionConfigParser.EntityType.html#valueOf-java.lang.String-">valueOf(String)</a></span> - Static method in enum gobblin.crypto.<a href="gobblin/crypto/EncryptionConfigParser.EntityType.html" title="enum in gobblin.crypto">EncryptionConfigParser.EntityType</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/JobCommitPolicy.html#valueOf-java.lang.String-">valueOf(String)</a></span> - Static method in enum gobblin.source.extractor.<a href="gobblin/source/extractor/JobCommitPolicy.html" title="enum in gobblin.source.extractor">JobCommitPolicy</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/WorkUnitRetryPolicy.html#valueOf-java.lang.String-">valueOf(String)</a></span> - Static method in enum gobblin.source.extractor.<a href="gobblin/source/extractor/WorkUnitRetryPolicy.html" title="enum in gobblin.source.extractor">WorkUnitRetryPolicy</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/crypto/EncryptionConfigParser.EntityType.html#values--">values()</a></span> - Static method in enum gobblin.crypto.<a href="gobblin/crypto/EncryptionConfigParser.EntityType.html" title="enum in gobblin.crypto">EncryptionConfigParser.EntityType</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/JobCommitPolicy.html#values--">values()</a></span> - Static method in enum gobblin.source.extractor.<a href="gobblin/source/extractor/JobCommitPolicy.html" title="enum in gobblin.source.extractor">JobCommitPolicy</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/WorkUnitRetryPolicy.html#values--">values()</a></span> - Static method in enum gobblin.source.extractor.<a href="gobblin/source/extractor/WorkUnitRetryPolicy.html" title="enum in gobblin.source.extractor">WorkUnitRetryPolicy</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/writer/BatchAccumulator.html#waitClose--">waitClose()</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/BatchAccumulator.html" title="class in gobblin.writer">BatchAccumulator</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/FineGrainedWatermarkTracker.html#WATERMARK_TRACKER_SWEEP_INTERVAL_MS">WATERMARK_TRACKER_SWEEP_INTERVAL_MS</a></span> - Static variable in class gobblin.writer.<a href="gobblin/writer/FineGrainedWatermarkTracker.html" title="class in gobblin.writer">FineGrainedWatermarkTracker</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/FineGrainedWatermarkTracker.html#WATERMARK_TRACKER_SWEEP_INTERVAL_MS_DEFAULT">WATERMARK_TRACKER_SWEEP_INTERVAL_MS_DEFAULT</a></span> - Static variable in class gobblin.writer.<a href="gobblin/writer/FineGrainedWatermarkTracker.html" title="class in gobblin.writer">FineGrainedWatermarkTracker</a></dt> |
| <dd> </dd> |
| <dt><a href="gobblin/writer/WatermarkAwareWriter.html" title="interface in gobblin.writer"><span class="typeNameLink">WatermarkAwareWriter</span></a><<a href="gobblin/writer/WatermarkAwareWriter.html" title="type parameter in WatermarkAwareWriter">D</a>> - Interface in <a href="gobblin/writer/package-summary.html">gobblin.writer</a></dt> |
| <dd> |
| <div class="block">A DataWriter that is WatermarkAware.</div> |
| </dd> |
| <dt><a href="gobblin/writer/WatermarkAwareWriterWrapper.html" title="class in gobblin.writer"><span class="typeNameLink">WatermarkAwareWriterWrapper</span></a><<a href="gobblin/writer/WatermarkAwareWriterWrapper.html" title="type parameter in WatermarkAwareWriterWrapper">D</a>> - Class in <a href="gobblin/writer/package-summary.html">gobblin.writer</a></dt> |
| <dd> |
| <div class="block">A convenience wrapper class for WatermarkAware writers.</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/WatermarkAwareWriterWrapper.html#WatermarkAwareWriterWrapper--">WatermarkAwareWriterWrapper()</a></span> - Constructor for class gobblin.writer.<a href="gobblin/writer/WatermarkAwareWriterWrapper.html" title="class in gobblin.writer">WatermarkAwareWriterWrapper</a></dt> |
| <dd> </dd> |
| <dt><a href="gobblin/writer/WatermarkManager.html" title="interface in gobblin.writer"><span class="typeNameLink">WatermarkManager</span></a> - Interface in <a href="gobblin/writer/package-summary.html">gobblin.writer</a></dt> |
| <dd> |
| <div class="block">An interface for WatermarkManagers: classes that can keep track of watermarks and commit them to watermark storage.</div> |
| </dd> |
| <dt><a href="gobblin/writer/WatermarkManager.CommitStatus.html" title="class in gobblin.writer"><span class="typeNameLink">WatermarkManager.CommitStatus</span></a> - Class in <a href="gobblin/writer/package-summary.html">gobblin.writer</a></dt> |
| <dd> </dd> |
| <dt><a href="gobblin/writer/WatermarkManager.RetrievalStatus.html" title="class in gobblin.writer"><span class="typeNameLink">WatermarkManager.RetrievalStatus</span></a> - Class in <a href="gobblin/writer/package-summary.html">gobblin.writer</a></dt> |
| <dd> </dd> |
| <dt><a href="gobblin/writer/WatermarkTracker.html" title="interface in gobblin.writer"><span class="typeNameLink">WatermarkTracker</span></a> - Interface in <a href="gobblin/writer/package-summary.html">gobblin.writer</a></dt> |
| <dd> |
| <div class="block">An interface for a WatermarkTracker.</div> |
| </dd> |
| <dt><a href="gobblin/writer/WatermarkTrackerFactory.html" title="class in gobblin.writer"><span class="typeNameLink">WatermarkTrackerFactory</span></a> - Class in <a href="gobblin/writer/package-summary.html">gobblin.writer</a></dt> |
| <dd> |
| <div class="block">A Factory for handing out WatermarkTracker instances</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/WatermarkTrackerFactory.html#WatermarkTrackerFactory--">WatermarkTrackerFactory()</a></span> - Constructor for class gobblin.writer.<a href="gobblin/writer/WatermarkTrackerFactory.html" title="class in gobblin.writer">WatermarkTrackerFactory</a></dt> |
| <dd> </dd> |
| <dt><a href="gobblin/writer/WatermarkTrackerFactory.TrackerBehavior.html" title="class in gobblin.writer"><span class="typeNameLink">WatermarkTrackerFactory.TrackerBehavior</span></a> - Class in <a href="gobblin/writer/package-summary.html">gobblin.writer</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/test/SequentialTestSource.html#WORK_UNIT_INDEX">WORK_UNIT_INDEX</a></span> - Static variable in class gobblin.test.<a href="gobblin/test/SequentialTestSource.html" title="class in gobblin.test">SequentialTestSource</a></dt> |
| <dd> </dd> |
| <dt><a href="gobblin/source/extractor/WorkUnitRetryPolicy.html" title="enum in gobblin.source.extractor"><span class="typeNameLink">WorkUnitRetryPolicy</span></a> - Enum in <a href="gobblin/source/extractor/package-summary.html">gobblin.source.extractor</a></dt> |
| <dd> |
| <div class="block">An enumeration of retry policies determining under what conditions the failed work unit should retry</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/GenericWriteResponseWrapper.html#wrap-T-">wrap(T)</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/GenericWriteResponseWrapper.html" title="class in gobblin.writer">GenericWriteResponseWrapper</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/WriteResponseMapper.html#wrap-InnerType-">wrap(InnerType)</a></span> - Method in interface gobblin.writer.<a href="gobblin/writer/WriteResponseMapper.html" title="interface in gobblin.writer">WriteResponseMapper</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/writer/InstrumentedDataWriter.html#write-D-">write(D)</a></span> - Method in class gobblin.instrumented.writer.<a href="gobblin/instrumented/writer/InstrumentedDataWriter.html" title="class in gobblin.instrumented.writer">InstrumentedDataWriter</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/writer/InstrumentedDataWriterDecorator.html#write-D-">write(D)</a></span> - Method in class gobblin.instrumented.writer.<a href="gobblin/instrumented/writer/InstrumentedDataWriterDecorator.html" title="class in gobblin.instrumented.writer">InstrumentedDataWriterDecorator</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/AsyncDataWriter.html#write-D-gobblin.writer.WriteCallback-">write(D, WriteCallback)</a></span> - Method in interface gobblin.writer.<a href="gobblin/writer/AsyncDataWriter.html" title="interface in gobblin.writer">AsyncDataWriter</a></dt> |
| <dd> |
| <div class="block">Asynchronously write a record, execute the callback on success/failure</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/AsyncWriterManager.html#write-D-">write(D)</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/AsyncWriterManager.html" title="class in gobblin.writer">AsyncWriterManager</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/BatchAsyncDataWriter.html#write-gobblin.writer.Batch-gobblin.writer.WriteCallback-">write(Batch<D>, WriteCallback)</a></span> - Method in interface gobblin.writer.<a href="gobblin/writer/BatchAsyncDataWriter.html" title="interface in gobblin.writer">BatchAsyncDataWriter</a></dt> |
| <dd> |
| <div class="block">Asynchronously write a record, execute the callback on success/failure</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/BufferedAsyncDataWriter.html#write-D-gobblin.writer.WriteCallback-">write(D, WriteCallback)</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/BufferedAsyncDataWriter.html" title="class in gobblin.writer">BufferedAsyncDataWriter</a></dt> |
| <dd> |
| <div class="block">Asynchronously write a record, execute the callback on success/failure</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/SyncDataWriter.html#write-D-">write(D)</a></span> - Method in interface gobblin.writer.<a href="gobblin/writer/SyncDataWriter.html" title="interface in gobblin.writer">SyncDataWriter</a></dt> |
| <dd> |
| <div class="block">Synchronously write a record</div> |
| </dd> |
| <dt><a href="gobblin/writer/WriteCallback.html" title="interface in gobblin.writer"><span class="typeNameLink">WriteCallback</span></a><<a href="gobblin/writer/WriteCallback.html" title="type parameter in WriteCallback">T</a>> - Interface in <a href="gobblin/writer/package-summary.html">gobblin.writer</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/writer/InstrumentedDataWriterDecorator.html#writeEnvelope-gobblin.stream.RecordEnvelope-">writeEnvelope(RecordEnvelope<D>)</a></span> - Method in class gobblin.instrumented.writer.<a href="gobblin/instrumented/writer/InstrumentedDataWriterDecorator.html" title="class in gobblin.instrumented.writer">InstrumentedDataWriterDecorator</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/AsyncWriterManager.html#writeEnvelope-gobblin.stream.RecordEnvelope-">writeEnvelope(RecordEnvelope<D>)</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/AsyncWriterManager.html" title="class in gobblin.writer">AsyncWriterManager</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/WatermarkAwareWriter.html#writeEnvelope-gobblin.stream.RecordEnvelope-">writeEnvelope(RecordEnvelope<D>)</a></span> - Method in interface gobblin.writer.<a href="gobblin/writer/WatermarkAwareWriter.html" title="interface in gobblin.writer">WatermarkAwareWriter</a></dt> |
| <dd> |
| <div class="block">Write a record (possibly asynchronously), ack the envelope on success.</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/WatermarkAwareWriterWrapper.html#writeEnvelope-gobblin.stream.RecordEnvelope-">writeEnvelope(RecordEnvelope<D>)</a></span> - Method in class gobblin.writer.<a href="gobblin/writer/WatermarkAwareWriterWrapper.html" title="class in gobblin.writer">WatermarkAwareWriterWrapper</a></dt> |
| <dd> </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/instrumented/writer/InstrumentedDataWriterDecorator.html#writeImpl-D-">writeImpl(D)</a></span> - Method in class gobblin.instrumented.writer.<a href="gobblin/instrumented/writer/InstrumentedDataWriterDecorator.html" title="class in gobblin.instrumented.writer">InstrumentedDataWriterDecorator</a></dt> |
| <dd> </dd> |
| <dt><a href="gobblin/writer/WriteResponse.html" title="interface in gobblin.writer"><span class="typeNameLink">WriteResponse</span></a><<a href="gobblin/writer/WriteResponse.html" title="type parameter in WriteResponse">T</a>> - Interface in <a href="gobblin/writer/package-summary.html">gobblin.writer</a></dt> |
| <dd> |
| <div class="block">A class for encapsulating the system-native response and general statistics from a write</div> |
| </dd> |
| <dt><a href="gobblin/writer/WriteResponseFuture.html" title="class in gobblin.writer"><span class="typeNameLink">WriteResponseFuture</span></a><<a href="gobblin/writer/WriteResponseFuture.html" title="type parameter in WriteResponseFuture">InnerType</a>> - Class in <a href="gobblin/writer/package-summary.html">gobblin.writer</a></dt> |
| <dd> |
| <div class="block">Wraps a Future<InnerType> and implements a Future<WriteResponse> when provided with a wrapper class</div> |
| </dd> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/WriteResponseFuture.html#WriteResponseFuture-java.util.concurrent.Future-gobblin.writer.WriteResponseMapper-">WriteResponseFuture(Future<InnerType>, WriteResponseMapper<InnerType>)</a></span> - Constructor for class gobblin.writer.<a href="gobblin/writer/WriteResponseFuture.html" title="class in gobblin.writer">WriteResponseFuture</a></dt> |
| <dd> </dd> |
| <dt><a href="gobblin/writer/WriteResponseMapper.html" title="interface in gobblin.writer"><span class="typeNameLink">WriteResponseMapper</span></a><<a href="gobblin/writer/WriteResponseMapper.html" title="type parameter in WriteResponseMapper">InnerType</a>> - Interface in <a href="gobblin/writer/package-summary.html">gobblin.writer</a></dt> |
| <dd> |
| <div class="block">An interface to implement a transformer from a system-native response type into a <a href="gobblin/writer/WriteResponse.html" title="interface in gobblin.writer"><code>WriteResponse</code></a>.</div> |
| </dd> |
| <dt><a href="gobblin/writer/partitioner/WriterPartitioner.html" title="interface in gobblin.writer.partitioner"><span class="typeNameLink">WriterPartitioner</span></a><<a href="gobblin/writer/partitioner/WriterPartitioner.html" title="type parameter in WriterPartitioner">D</a>> - Interface in <a href="gobblin/writer/partitioner/package-summary.html">gobblin.writer.partitioner</a></dt> |
| <dd> |
| <div class="block">Partitions records in the writer phase.</div> |
| </dd> |
| </dl> |
| <a name="I:Z:Z_"> |
| <!-- --> |
| </a> |
| <h2 class="title">_</h2> |
| <dl> |
| <dt><span class="memberNameLink"><a href="gobblin/writer/FineGrainedWatermarkTracker.html#Z:Z_closer">_closer</a></span> - Variable in class gobblin.writer.<a href="gobblin/writer/FineGrainedWatermarkTracker.html" title="class in gobblin.writer">FineGrainedWatermarkTracker</a></dt> |
| <dd> </dd> |
| </dl> |
| <a href="#I:A">A</a> <a href="#I:B">B</a> <a href="#I:C">C</a> <a href="#I:D">D</a> <a href="#I:E">E</a> <a href="#I:F">F</a> <a href="#I:G">G</a> <a href="#I:H">H</a> <a href="#I:I">I</a> <a href="#I:J">J</a> <a href="#I:L">L</a> <a href="#I:M">M</a> <a href="#I:N">N</a> <a href="#I:O">O</a> <a href="#I:P">P</a> <a href="#I:R">R</a> <a href="#I:S">S</a> <a href="#I:T">T</a> <a href="#I:U">U</a> <a href="#I:V">V</a> <a href="#I:W">W</a> <a href="#I:Z:Z_">_</a> </div> |
| <!-- ======= START OF BOTTOM NAVBAR ====== --> |
| <div class="bottomNav"><a name="navbar.bottom"> |
| <!-- --> |
| </a> |
| <div class="skipNav"><a href="#skip.navbar.bottom" title="Skip navigation links">Skip navigation links</a></div> |
| <a name="navbar.bottom.firstrow"> |
| <!-- --> |
| </a> |
| <ul class="navList" title="Navigation"> |
| <li><a href="overview-summary.html">Overview</a></li> |
| <li>Package</li> |
| <li>Class</li> |
| <li><a href="overview-tree.html">Tree</a></li> |
| <li><a href="deprecated-list.html">Deprecated</a></li> |
| <li class="navBarCell1Rev">Index</li> |
| <li><a href="help-doc.html">Help</a></li> |
| </ul> |
| </div> |
| <div class="subNav"> |
| <ul class="navList"> |
| <li>Prev</li> |
| <li>Next</li> |
| </ul> |
| <ul class="navList"> |
| <li><a href="index.html?index-all.html" target="_top">Frames</a></li> |
| <li><a href="index-all.html" target="_top">No Frames</a></li> |
| </ul> |
| <ul class="navList" id="allclasses_navbar_bottom"> |
| <li><a href="allclasses-noframe.html">All Classes</a></li> |
| </ul> |
| <div> |
| <script type="text/javascript"><!-- |
| allClassesLink = document.getElementById("allclasses_navbar_bottom"); |
| if(window==top) { |
| allClassesLink.style.display = "block"; |
| } |
| else { |
| allClassesLink.style.display = "none"; |
| } |
| //--> |
| </script> |
| </div> |
| <a name="skip.navbar.bottom"> |
| <!-- --> |
| </a></div> |
| <!-- ======== END OF BOTTOM NAVBAR ======= --> |
| </body> |
| </html> |
