Google Git
Sign in
apache / iceberg / refs/heads/asf-site / . / javadoc / 1.5.2 / org / apache / iceberg / flink / source / IcebergSource.Builder.html
blob: f580f4bf77228695a79f8504f137d064efe8f2b7 [file] [log] [blame]
<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd">
<!-- NewPage -->
<html lang="en">
<head>
<!-- Generated by javadoc -->
<title>IcebergSource.Builder</title>
<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="IcebergSource.Builder";
}
}
catch(err) {
}
//-->
var methods = {"i0":10,"i1":10,"i2":10,"i3":10,"i4":10,"i5":10,"i6":10,"i7":10,"i8":10,"i9":10,"i10":10,"i11":10,"i12":10,"i13":10,"i14":10,"i15":10,"i16":10,"i17":10,"i18":42,"i19":10,"i20":10,"i21":10,"i22":10,"i23":10,"i24":10,"i25":10,"i26":10,"i27":10,"i28":10,"i29":10,"i30":10,"i31":10,"i32":10,"i33":10,"i34":10,"i35":10,"i36":10};
var tabs = {65535:["t0","All Methods"],2:["t2","Instance Methods"],8:["t4","Concrete Methods"],32:["t6","Deprecated Methods"]};
var altColor = "altColor";
var rowColor = "rowColor";
var tableTab = "tableTab";
var activeTableTab = "activeTableTab";
</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><a href="package-summary.html">Package</a></li>
<li class="navBarCell1Rev">Class</li>
<li><a href="package-tree.html">Tree</a></li>
<li><a href="../../../../../deprecated-list.html">Deprecated</a></li>
<li><a href="../../../../../index-all.html">Index</a></li>
<li><a href="../../../../../help-doc.html">Help</a></li>
</ul>
</div>
<div class="subNav">
<ul class="navList">
<li><a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.html" title="class in org.apache.iceberg.flink.source"><span class="typeNameLink">Prev&nbsp;Class</span></a></li>
<li><a href="../../../../../org/apache/iceberg/flink/source/IcebergTableSource.html" title="class in org.apache.iceberg.flink.source"><span class="typeNameLink">Next&nbsp;Class</span></a></li>
</ul>
<ul class="navList">
<li><a href="../../../../../index.html?org/apache/iceberg/flink/source/IcebergSource.Builder.html" target="_top">Frames</a></li>
<li><a href="IcebergSource.Builder.html" target="_top">No&nbsp;Frames</a></li>
</ul>
<ul class="navList" id="allclasses_navbar_top">
<li><a href="../../../../../allclasses-noframe.html">All&nbsp;Classes</a></li>
</ul>
<div>
<script type="text/javascript"><!--
allClassesLink = document.getElementById("allclasses_navbar_top");
if(window==top) {
allClassesLink.style.display = "block";
}
else {
allClassesLink.style.display = "none";
}
//-->
</script>
</div>
<div>
<ul class="subNavList">
<li>Summary:&nbsp;</li>
<li>Nested&nbsp;|&nbsp;</li>
<li>Field&nbsp;|&nbsp;</li>
<li>Constr&nbsp;|&nbsp;</li>
<li><a href="#method.summary">Method</a></li>
</ul>
<ul class="subNavList">
<li>Detail:&nbsp;</li>
<li>Field&nbsp;|&nbsp;</li>
<li>Constr&nbsp;|&nbsp;</li>
<li><a href="#method.detail">Method</a></li>
</ul>
</div>
<a name="skip.navbar.top">
<!-- -->
</a></div>
<!-- ========= END OF TOP NAVBAR ========= -->
<!-- ======== START OF CLASS DATA ======== -->
<div class="header">
<div class="subTitle">org.apache.iceberg.flink.source</div>
<h2 title="Class IcebergSource.Builder" class="title">Class IcebergSource.Builder&lt;T&gt;</h2>
</div>
<div class="contentContainer">
<ul class="inheritance">
<li>java.lang.Object</li>
<li>
<ul class="inheritance">
<li>org.apache.iceberg.flink.source.IcebergSource.Builder&lt;T&gt;</li>
</ul>
</li>
</ul>
<div class="description">
<ul class="blockList">
<li class="blockList">
<dl>
<dt>Enclosing class:</dt>
<dd><a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.html" title="class in org.apache.iceberg.flink.source">IcebergSource</a>&lt;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.html" title="type parameter in IcebergSource">T</a>&gt;</dd>
</dl>
<hr>
<br>
<pre>public static class <span class="typeNameLabel">IcebergSource.Builder&lt;T&gt;</span>
extends java.lang.Object</pre>
</li>
</ul>
</div>
<div class="summary">
<ul class="blockList">
<li class="blockList">
<!-- ========== METHOD SUMMARY =========== -->
<ul class="blockList">
<li class="blockList"><a name="method.summary">
<!-- -->
</a>
<h3>Method Summary</h3>
<table class="memberSummary" border="0" cellpadding="3" cellspacing="0" summary="Method Summary table, listing methods, and an explanation">
<caption><span id="t0" class="activeTableTab"><span>All Methods</span><span class="tabEnd">&nbsp;</span></span><span id="t2" class="tableTab"><span><a href="javascript:show(2);">Instance Methods</a></span><span class="tabEnd">&nbsp;</span></span><span id="t4" class="tableTab"><span><a href="javascript:show(8);">Concrete Methods</a></span><span class="tabEnd">&nbsp;</span></span><span id="t6" class="tableTab"><span><a href="javascript:show(32);">Deprecated Methods</a></span><span class="tabEnd">&nbsp;</span></span></caption>
<tr>
<th class="colFirst" scope="col">Modifier and Type</th>
<th class="colLast" scope="col">Method and Description</th>
</tr>
<tr id="i0" class="altColor">
<td class="colFirst"><code><a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html#asOfTimestamp-java.lang.Long-">asOfTimestamp</a></span>(java.lang.Long&nbsp;newAsOfTimestamp)</code>&nbsp;</td>
</tr>
<tr id="i1" class="rowColor">
<td class="colFirst"><code><a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html#assignerFactory-org.apache.iceberg.flink.source.assigner.SplitAssignerFactory-">assignerFactory</a></span>(<a href="../../../../../org/apache/iceberg/flink/source/assigner/SplitAssignerFactory.html" title="interface in org.apache.iceberg.flink.source.assigner">SplitAssignerFactory</a>&nbsp;assignerFactory)</code>&nbsp;</td>
</tr>
<tr id="i2" class="altColor">
<td class="colFirst"><code><a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html#branch-java.lang.String-">branch</a></span>(java.lang.String&nbsp;branch)</code>&nbsp;</td>
</tr>
<tr id="i3" class="rowColor">
<td class="colFirst"><code><a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.html" title="class in org.apache.iceberg.flink.source">IcebergSource</a>&lt;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html#build--">build</a></span>()</code>&nbsp;</td>
</tr>
<tr id="i4" class="altColor">
<td class="colFirst"><code><a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html#caseSensitive-boolean-">caseSensitive</a></span>(boolean&nbsp;newCaseSensitive)</code>&nbsp;</td>
</tr>
<tr id="i5" class="rowColor">
<td class="colFirst"><code><a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html#endSnapshotId-java.lang.Long-">endSnapshotId</a></span>(java.lang.Long&nbsp;newEndSnapshotId)</code>&nbsp;</td>
</tr>
<tr id="i6" class="altColor">
<td class="colFirst"><code><a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html#endTag-java.lang.String-">endTag</a></span>(java.lang.String&nbsp;endTag)</code>&nbsp;</td>
</tr>
<tr id="i7" class="rowColor">
<td class="colFirst"><code><a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html#exposeLocality-boolean-">exposeLocality</a></span>(boolean&nbsp;newExposeLocality)</code>&nbsp;</td>
</tr>
<tr id="i8" class="altColor">
<td class="colFirst"><code><a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html#filters-java.util.List-">filters</a></span>(java.util.List&lt;<a href="../../../../../org/apache/iceberg/expressions/Expression.html" title="interface in org.apache.iceberg.expressions">Expression</a>&gt;&nbsp;newFilters)</code>&nbsp;</td>
</tr>
<tr id="i9" class="rowColor">
<td class="colFirst"><code><a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html#flinkConfig-org.apache.flink.configuration.ReadableConfig-">flinkConfig</a></span>(org.apache.flink.configuration.ReadableConfig&nbsp;config)</code>&nbsp;</td>
</tr>
<tr id="i10" class="altColor">
<td class="colFirst"><code><a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html#includeColumnStats-boolean-">includeColumnStats</a></span>(boolean&nbsp;newIncludeColumnStats)</code>&nbsp;</td>
</tr>
<tr id="i11" class="rowColor">
<td class="colFirst"><code><a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html#limit-java.lang.Long-">limit</a></span>(java.lang.Long&nbsp;newLimit)</code>&nbsp;</td>
</tr>
<tr id="i12" class="altColor">
<td class="colFirst"><code><a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html#maxAllowedPlanningFailures-int-">maxAllowedPlanningFailures</a></span>(int&nbsp;maxAllowedPlanningFailures)</code>&nbsp;</td>
</tr>
<tr id="i13" class="rowColor">
<td class="colFirst"><code><a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html#monitorInterval-java.time.Duration-">monitorInterval</a></span>(java.time.Duration&nbsp;newMonitorInterval)</code>&nbsp;</td>
</tr>
<tr id="i14" class="altColor">
<td class="colFirst"><code><a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html#nameMapping-java.lang.String-">nameMapping</a></span>(java.lang.String&nbsp;newNameMapping)</code>&nbsp;</td>
</tr>
<tr id="i15" class="rowColor">
<td class="colFirst"><code><a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html#planParallelism-int-">planParallelism</a></span>(int&nbsp;planParallelism)</code>&nbsp;</td>
</tr>
<tr id="i16" class="altColor">
<td class="colFirst"><code><a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html#project-org.apache.iceberg.Schema-">project</a></span>(<a href="../../../../../org/apache/iceberg/Schema.html" title="class in org.apache.iceberg">Schema</a>&nbsp;newProjectedSchema)</code>&nbsp;</td>
</tr>
<tr id="i17" class="rowColor">
<td class="colFirst"><code><a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html#project-org.apache.flink.table.api.TableSchema-">project</a></span>(org.apache.flink.table.api.TableSchema&nbsp;newProjectedFlinkSchema)</code>&nbsp;</td>
</tr>
<tr id="i18" class="altColor">
<td class="colFirst"><code><a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html#properties-java.util.Map-">properties</a></span>(java.util.Map&lt;java.lang.String,java.lang.String&gt;&nbsp;properties)</code>
<div class="block"><span class="deprecatedLabel">Deprecated.</span>&nbsp;
<div class="block"><span class="deprecationComment">Use <a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html#setAll-java.util.Map-"><code>setAll(java.util.Map&lt;java.lang.String, java.lang.String&gt;)</code></a> instead.</span></div>
</div>
</td>
</tr>
<tr id="i19" class="rowColor">
<td class="colFirst"><code><a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html#readerFunction-org.apache.iceberg.flink.source.reader.ReaderFunction-">readerFunction</a></span>(<a href="../../../../../org/apache/iceberg/flink/source/reader/ReaderFunction.html" title="interface in org.apache.iceberg.flink.source.reader">ReaderFunction</a>&lt;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;&nbsp;newReaderFunction)</code>&nbsp;</td>
</tr>
<tr id="i20" class="altColor">
<td class="colFirst"><code><a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html#set-java.lang.String-java.lang.String-">set</a></span>(java.lang.String&nbsp;property,
java.lang.String&nbsp;value)</code>
<div class="block">Set the read properties for Flink source.</div>
</td>
</tr>
<tr id="i21" class="rowColor">
<td class="colFirst"><code><a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html#setAll-java.util.Map-">setAll</a></span>(java.util.Map&lt;java.lang.String,java.lang.String&gt;&nbsp;properties)</code>
<div class="block">Set the read properties for Flink source.</div>
</td>
</tr>
<tr id="i22" class="altColor">
<td class="colFirst"><code><a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html#splitComparator-org.apache.iceberg.flink.source.split.SerializableComparator-">splitComparator</a></span>(<a href="../../../../../org/apache/iceberg/flink/source/split/SerializableComparator.html" title="interface in org.apache.iceberg.flink.source.split">SerializableComparator</a>&lt;<a href="../../../../../org/apache/iceberg/flink/source/split/IcebergSourceSplit.html" title="class in org.apache.iceberg.flink.source.split">IcebergSourceSplit</a>&gt;&nbsp;newSplitComparator)</code>&nbsp;</td>
</tr>
<tr id="i23" class="rowColor">
<td class="colFirst"><code><a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html#splitLookback-java.lang.Integer-">splitLookback</a></span>(java.lang.Integer&nbsp;newSplitLookback)</code>&nbsp;</td>
</tr>
<tr id="i24" class="altColor">
<td class="colFirst"><code><a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html#splitOpenFileCost-java.lang.Long-">splitOpenFileCost</a></span>(java.lang.Long&nbsp;newSplitOpenFileCost)</code>&nbsp;</td>
</tr>
<tr id="i25" class="rowColor">
<td class="colFirst"><code><a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html#splitSize-java.lang.Long-">splitSize</a></span>(java.lang.Long&nbsp;newSplitSize)</code>&nbsp;</td>
</tr>
<tr id="i26" class="altColor">
<td class="colFirst"><code><a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html#startSnapshotId-java.lang.Long-">startSnapshotId</a></span>(java.lang.Long&nbsp;newStartSnapshotId)</code>&nbsp;</td>
</tr>
<tr id="i27" class="rowColor">
<td class="colFirst"><code><a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html#startSnapshotTimestamp-java.lang.Long-">startSnapshotTimestamp</a></span>(java.lang.Long&nbsp;newStartSnapshotTimestamp)</code>&nbsp;</td>
</tr>
<tr id="i28" class="altColor">
<td class="colFirst"><code><a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html#startTag-java.lang.String-">startTag</a></span>(java.lang.String&nbsp;startTag)</code>&nbsp;</td>
</tr>
<tr id="i29" class="rowColor">
<td class="colFirst"><code><a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html#streaming-boolean-">streaming</a></span>(boolean&nbsp;streaming)</code>&nbsp;</td>
</tr>
<tr id="i30" class="altColor">
<td class="colFirst"><code><a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html#streamingStartingStrategy-org.apache.iceberg.flink.source.StreamingStartingStrategy-">streamingStartingStrategy</a></span>(<a href="../../../../../org/apache/iceberg/flink/source/StreamingStartingStrategy.html" title="enum in org.apache.iceberg.flink.source">StreamingStartingStrategy</a>&nbsp;newStartingStrategy)</code>&nbsp;</td>
</tr>
<tr id="i31" class="rowColor">
<td class="colFirst"><code><a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html#table-org.apache.iceberg.Table-">table</a></span>(<a href="../../../../../org/apache/iceberg/Table.html" title="interface in org.apache.iceberg">Table</a>&nbsp;newTable)</code>&nbsp;</td>
</tr>
<tr id="i32" class="altColor">
<td class="colFirst"><code><a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html#tableLoader-org.apache.iceberg.flink.TableLoader-">tableLoader</a></span>(<a href="../../../../../org/apache/iceberg/flink/TableLoader.html" title="interface in org.apache.iceberg.flink">TableLoader</a>&nbsp;loader)</code>&nbsp;</td>
</tr>
<tr id="i33" class="rowColor">
<td class="colFirst"><code><a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html#tag-java.lang.String-">tag</a></span>(java.lang.String&nbsp;tag)</code>&nbsp;</td>
</tr>
<tr id="i34" class="altColor">
<td class="colFirst"><code><a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html#useSnapshotId-java.lang.Long-">useSnapshotId</a></span>(java.lang.Long&nbsp;newSnapshotId)</code>&nbsp;</td>
</tr>
<tr id="i35" class="rowColor">
<td class="colFirst"><code><a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html#watermarkColumn-java.lang.String-">watermarkColumn</a></span>(java.lang.String&nbsp;columnName)</code>
<div class="block">Emits watermarks once per split based on the min value of column statistics from files
metadata in the given split.</div>
</td>
</tr>
<tr id="i36" class="altColor">
<td class="colFirst"><code><a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;</code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html#watermarkColumnTimeUnit-java.util.concurrent.TimeUnit-">watermarkColumnTimeUnit</a></span>(java.util.concurrent.TimeUnit&nbsp;timeUnit)</code>
<div class="block">When the type of the <a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html#watermarkColumn-java.lang.String-"><code>watermarkColumn(java.lang.String)</code></a> is <a href="../../../../../org/apache/iceberg/types/Types.LongType.html" title="class in org.apache.iceberg.types"><code>Types.LongType</code></a>, then sets the <code>TimeUnit</code> to convert the
value.</div>
</td>
</tr>
</table>
<ul class="blockList">
<li class="blockList"><a name="methods.inherited.from.class.java.lang.Object">
<!-- -->
</a>
<h3>Methods inherited from class&nbsp;java.lang.Object</h3>
<code>clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait</code></li>
</ul>
</li>
</ul>
</li>
</ul>
</div>
<div class="details">
<ul class="blockList">
<li class="blockList">
<!-- ============ METHOD DETAIL ========== -->
<ul class="blockList">
<li class="blockList"><a name="method.detail">
<!-- -->
</a>
<h3>Method Detail</h3>
<a name="tableLoader-org.apache.iceberg.flink.TableLoader-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>tableLoader</h4>
<pre>public&nbsp;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;&nbsp;tableLoader(<a href="../../../../../org/apache/iceberg/flink/TableLoader.html" title="interface in org.apache.iceberg.flink">TableLoader</a>&nbsp;loader)</pre>
</li>
</ul>
<a name="table-org.apache.iceberg.Table-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>table</h4>
<pre>public&nbsp;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;&nbsp;table(<a href="../../../../../org/apache/iceberg/Table.html" title="interface in org.apache.iceberg">Table</a>&nbsp;newTable)</pre>
</li>
</ul>
<a name="assignerFactory-org.apache.iceberg.flink.source.assigner.SplitAssignerFactory-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>assignerFactory</h4>
<pre>public&nbsp;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;&nbsp;assignerFactory(<a href="../../../../../org/apache/iceberg/flink/source/assigner/SplitAssignerFactory.html" title="interface in org.apache.iceberg.flink.source.assigner">SplitAssignerFactory</a>&nbsp;assignerFactory)</pre>
</li>
</ul>
<a name="splitComparator-org.apache.iceberg.flink.source.split.SerializableComparator-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>splitComparator</h4>
<pre>public&nbsp;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;&nbsp;splitComparator(<a href="../../../../../org/apache/iceberg/flink/source/split/SerializableComparator.html" title="interface in org.apache.iceberg.flink.source.split">SerializableComparator</a>&lt;<a href="../../../../../org/apache/iceberg/flink/source/split/IcebergSourceSplit.html" title="class in org.apache.iceberg.flink.source.split">IcebergSourceSplit</a>&gt;&nbsp;newSplitComparator)</pre>
</li>
</ul>
<a name="readerFunction-org.apache.iceberg.flink.source.reader.ReaderFunction-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>readerFunction</h4>
<pre>public&nbsp;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;&nbsp;readerFunction(<a href="../../../../../org/apache/iceberg/flink/source/reader/ReaderFunction.html" title="interface in org.apache.iceberg.flink.source.reader">ReaderFunction</a>&lt;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;&nbsp;newReaderFunction)</pre>
</li>
</ul>
<a name="flinkConfig-org.apache.flink.configuration.ReadableConfig-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>flinkConfig</h4>
<pre>public&nbsp;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;&nbsp;flinkConfig(org.apache.flink.configuration.ReadableConfig&nbsp;config)</pre>
</li>
</ul>
<a name="caseSensitive-boolean-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>caseSensitive</h4>
<pre>public&nbsp;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;&nbsp;caseSensitive(boolean&nbsp;newCaseSensitive)</pre>
</li>
</ul>
<a name="useSnapshotId-java.lang.Long-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>useSnapshotId</h4>
<pre>public&nbsp;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;&nbsp;useSnapshotId(java.lang.Long&nbsp;newSnapshotId)</pre>
</li>
</ul>
<a name="streamingStartingStrategy-org.apache.iceberg.flink.source.StreamingStartingStrategy-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>streamingStartingStrategy</h4>
<pre>public&nbsp;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;&nbsp;streamingStartingStrategy(<a href="../../../../../org/apache/iceberg/flink/source/StreamingStartingStrategy.html" title="enum in org.apache.iceberg.flink.source">StreamingStartingStrategy</a>&nbsp;newStartingStrategy)</pre>
</li>
</ul>
<a name="startSnapshotTimestamp-java.lang.Long-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>startSnapshotTimestamp</h4>
<pre>public&nbsp;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;&nbsp;startSnapshotTimestamp(java.lang.Long&nbsp;newStartSnapshotTimestamp)</pre>
</li>
</ul>
<a name="startSnapshotId-java.lang.Long-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>startSnapshotId</h4>
<pre>public&nbsp;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;&nbsp;startSnapshotId(java.lang.Long&nbsp;newStartSnapshotId)</pre>
</li>
</ul>
<a name="tag-java.lang.String-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>tag</h4>
<pre>public&nbsp;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;&nbsp;tag(java.lang.String&nbsp;tag)</pre>
</li>
</ul>
<a name="branch-java.lang.String-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>branch</h4>
<pre>public&nbsp;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;&nbsp;branch(java.lang.String&nbsp;branch)</pre>
</li>
</ul>
<a name="startTag-java.lang.String-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>startTag</h4>
<pre>public&nbsp;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;&nbsp;startTag(java.lang.String&nbsp;startTag)</pre>
</li>
</ul>
<a name="endTag-java.lang.String-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>endTag</h4>
<pre>public&nbsp;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;&nbsp;endTag(java.lang.String&nbsp;endTag)</pre>
</li>
</ul>
<a name="endSnapshotId-java.lang.Long-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>endSnapshotId</h4>
<pre>public&nbsp;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;&nbsp;endSnapshotId(java.lang.Long&nbsp;newEndSnapshotId)</pre>
</li>
</ul>
<a name="asOfTimestamp-java.lang.Long-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>asOfTimestamp</h4>
<pre>public&nbsp;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;&nbsp;asOfTimestamp(java.lang.Long&nbsp;newAsOfTimestamp)</pre>
</li>
</ul>
<a name="splitSize-java.lang.Long-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>splitSize</h4>
<pre>public&nbsp;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;&nbsp;splitSize(java.lang.Long&nbsp;newSplitSize)</pre>
</li>
</ul>
<a name="splitLookback-java.lang.Integer-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>splitLookback</h4>
<pre>public&nbsp;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;&nbsp;splitLookback(java.lang.Integer&nbsp;newSplitLookback)</pre>
</li>
</ul>
<a name="splitOpenFileCost-java.lang.Long-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>splitOpenFileCost</h4>
<pre>public&nbsp;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;&nbsp;splitOpenFileCost(java.lang.Long&nbsp;newSplitOpenFileCost)</pre>
</li>
</ul>
<a name="streaming-boolean-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>streaming</h4>
<pre>public&nbsp;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;&nbsp;streaming(boolean&nbsp;streaming)</pre>
</li>
</ul>
<a name="monitorInterval-java.time.Duration-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>monitorInterval</h4>
<pre>public&nbsp;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;&nbsp;monitorInterval(java.time.Duration&nbsp;newMonitorInterval)</pre>
</li>
</ul>
<a name="nameMapping-java.lang.String-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>nameMapping</h4>
<pre>public&nbsp;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;&nbsp;nameMapping(java.lang.String&nbsp;newNameMapping)</pre>
</li>
</ul>
<a name="project-org.apache.iceberg.Schema-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>project</h4>
<pre>public&nbsp;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;&nbsp;project(<a href="../../../../../org/apache/iceberg/Schema.html" title="class in org.apache.iceberg">Schema</a>&nbsp;newProjectedSchema)</pre>
</li>
</ul>
<a name="project-org.apache.flink.table.api.TableSchema-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>project</h4>
<pre>public&nbsp;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;&nbsp;project(org.apache.flink.table.api.TableSchema&nbsp;newProjectedFlinkSchema)</pre>
</li>
</ul>
<a name="filters-java.util.List-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>filters</h4>
<pre>public&nbsp;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;&nbsp;filters(java.util.List&lt;<a href="../../../../../org/apache/iceberg/expressions/Expression.html" title="interface in org.apache.iceberg.expressions">Expression</a>&gt;&nbsp;newFilters)</pre>
</li>
</ul>
<a name="limit-java.lang.Long-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>limit</h4>
<pre>public&nbsp;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;&nbsp;limit(java.lang.Long&nbsp;newLimit)</pre>
</li>
</ul>
<a name="includeColumnStats-boolean-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>includeColumnStats</h4>
<pre>public&nbsp;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;&nbsp;includeColumnStats(boolean&nbsp;newIncludeColumnStats)</pre>
</li>
</ul>
<a name="planParallelism-int-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>planParallelism</h4>
<pre>public&nbsp;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;&nbsp;planParallelism(int&nbsp;planParallelism)</pre>
</li>
</ul>
<a name="exposeLocality-boolean-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>exposeLocality</h4>
<pre>public&nbsp;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;&nbsp;exposeLocality(boolean&nbsp;newExposeLocality)</pre>
</li>
</ul>
<a name="maxAllowedPlanningFailures-int-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>maxAllowedPlanningFailures</h4>
<pre>public&nbsp;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;&nbsp;maxAllowedPlanningFailures(int&nbsp;maxAllowedPlanningFailures)</pre>
</li>
</ul>
<a name="set-java.lang.String-java.lang.String-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>set</h4>
<pre>public&nbsp;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;&nbsp;set(java.lang.String&nbsp;property,
java.lang.String&nbsp;value)</pre>
<div class="block">Set the read properties for Flink source. View the supported properties in <a href="../../../../../org/apache/iceberg/flink/FlinkReadOptions.html" title="class in org.apache.iceberg.flink"><code>FlinkReadOptions</code></a></div>
</li>
</ul>
<a name="setAll-java.util.Map-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>setAll</h4>
<pre>public&nbsp;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;&nbsp;setAll(java.util.Map&lt;java.lang.String,java.lang.String&gt;&nbsp;properties)</pre>
<div class="block">Set the read properties for Flink source. View the supported properties in <a href="../../../../../org/apache/iceberg/flink/FlinkReadOptions.html" title="class in org.apache.iceberg.flink"><code>FlinkReadOptions</code></a></div>
</li>
</ul>
<a name="watermarkColumn-java.lang.String-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>watermarkColumn</h4>
<pre>public&nbsp;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;&nbsp;watermarkColumn(java.lang.String&nbsp;columnName)</pre>
<div class="block">Emits watermarks once per split based on the min value of column statistics from files
metadata in the given split. The generated watermarks are also used for ordering the splits
for read. Accepted column types are timestamp/timestamptz/long. For long columns consider
setting <a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html#watermarkColumnTimeUnit-java.util.concurrent.TimeUnit-"><code>watermarkColumnTimeUnit(TimeUnit)</code></a>.
<p>Consider setting `read.split.open-file-cost` to prevent combining small files to a single
split when the watermark is used for watermark alignment.</div>
</li>
</ul>
<a name="watermarkColumnTimeUnit-java.util.concurrent.TimeUnit-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>watermarkColumnTimeUnit</h4>
<pre>public&nbsp;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;&nbsp;watermarkColumnTimeUnit(java.util.concurrent.TimeUnit&nbsp;timeUnit)</pre>
<div class="block">When the type of the <a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html#watermarkColumn-java.lang.String-"><code>watermarkColumn(java.lang.String)</code></a> is <a href="../../../../../org/apache/iceberg/types/Types.LongType.html" title="class in org.apache.iceberg.types"><code>Types.LongType</code></a>, then sets the <code>TimeUnit</code> to convert the
value. The default value is <code>TimeUnit.MICROSECONDS</code>.</div>
</li>
</ul>
<a name="properties-java.util.Map-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>properties</h4>
<pre>@Deprecated
public&nbsp;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;&nbsp;properties(java.util.Map&lt;java.lang.String,java.lang.String&gt;&nbsp;properties)</pre>
<div class="block"><span class="deprecatedLabel">Deprecated.</span>&nbsp;<span class="deprecationComment">Use <a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html#setAll-java.util.Map-"><code>setAll(java.util.Map&lt;java.lang.String, java.lang.String&gt;)</code></a> instead.</span></div>
</li>
</ul>
<a name="build--">
<!-- -->
</a>
<ul class="blockListLast">
<li class="blockList">
<h4>build</h4>
<pre>public&nbsp;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.html" title="class in org.apache.iceberg.flink.source">IcebergSource</a>&lt;<a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;&nbsp;build()</pre>
</li>
</ul>
</li>
</ul>
</li>
</ul>
</div>
</div>
<!-- ========= END OF CLASS DATA ========= -->
<!-- ======= 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><a href="package-summary.html">Package</a></li>
<li class="navBarCell1Rev">Class</li>
<li><a href="package-tree.html">Tree</a></li>
<li><a href="../../../../../deprecated-list.html">Deprecated</a></li>
<li><a href="../../../../../index-all.html">Index</a></li>
<li><a href="../../../../../help-doc.html">Help</a></li>
</ul>
</div>
<div class="subNav">
<ul class="navList">
<li><a href="../../../../../org/apache/iceberg/flink/source/IcebergSource.html" title="class in org.apache.iceberg.flink.source"><span class="typeNameLink">Prev&nbsp;Class</span></a></li>
<li><a href="../../../../../org/apache/iceberg/flink/source/IcebergTableSource.html" title="class in org.apache.iceberg.flink.source"><span class="typeNameLink">Next&nbsp;Class</span></a></li>
</ul>
<ul class="navList">
<li><a href="../../../../../index.html?org/apache/iceberg/flink/source/IcebergSource.Builder.html" target="_top">Frames</a></li>
<li><a href="IcebergSource.Builder.html" target="_top">No&nbsp;Frames</a></li>
</ul>
<ul class="navList" id="allclasses_navbar_bottom">
<li><a href="../../../../../allclasses-noframe.html">All&nbsp;Classes</a></li>
</ul>
<div>
<script type="text/javascript"><!--
allClassesLink = document.getElementById("allclasses_navbar_bottom");
if(window==top) {
allClassesLink.style.display = "block";
}
else {
allClassesLink.style.display = "none";
}
//-->
</script>
</div>
<div>
<ul class="subNavList">
<li>Summary:&nbsp;</li>
<li>Nested&nbsp;|&nbsp;</li>
<li>Field&nbsp;|&nbsp;</li>
<li>Constr&nbsp;|&nbsp;</li>
<li><a href="#method.summary">Method</a></li>
</ul>
<ul class="subNavList">
<li>Detail:&nbsp;</li>
<li>Field&nbsp;|&nbsp;</li>
<li>Constr&nbsp;|&nbsp;</li>
<li><a href="#method.detail">Method</a></li>
</ul>
</div>
<a name="skip.navbar.bottom">
<!-- -->
</a></div>
<!-- ======== END OF BOTTOM NAVBAR ======= -->
</body>
</html>