Google Git
Sign in
apache / iceberg / refs/heads/asf-site / . / javadoc / 1.5.0 / org / apache / iceberg / flink / source / IcebergSource.Builder.html
blob: 37b3f4cf56438408e8ce85b6e4d520056d15757e [file] [log] [blame]
<!DOCTYPE HTML>
<!-- NewPage -->
<html lang="en">
<head>
<!-- Generated by javadoc -->
<title>IcebergSource.Builder</title>
<meta http-equiv="Content-Type" content="text/html; charset=utf-8">
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
<link rel="stylesheet" type="text/css" href="../../../../../jquery/jquery-ui.min.css" title="Style">
<link rel="stylesheet" type="text/css" href="../../../../../jquery-ui.overrides.css" title="Style">
<script type="text/javascript" src="../../../../../script.js"></script>
<script type="text/javascript" src="../../../../../jquery/jszip/dist/jszip.min.js"></script>
<script type="text/javascript" src="../../../../../jquery/jszip-utils/dist/jszip-utils.min.js"></script>
<!--[if IE]>
<script type="text/javascript" src="../../../../../jquery/jszip-utils/dist/jszip-utils-ie.min.js"></script>
<![endif]-->
<script type="text/javascript" src="../../../../../jquery/jquery-3.6.1.min.js"></script>
<script type="text/javascript" src="../../../../../jquery/jquery-ui.min.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 data = {"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";
var pathtoroot = "../../../../../";
var useModuleDirectories = true;
loadScripts(document, 'script');</script>
<noscript>
<div>JavaScript is disabled on your browser.</div>
</noscript>
<header role="banner">
<nav role="navigation">
<div class="fixedNav">
<!-- ========= START OF TOP NAVBAR ======= -->
<div class="topNav"><a id="navbar.top">
<!-- -->
</a>
<div class="skipNav"><a href="#skip.navbar.top" title="Skip navigation links">Skip navigation links</a></div>
<a id="navbar.top.firstrow">
<!-- -->
</a>
<ul class="navList" title="Navigation">
<li><a href="../../../../../index.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" id="allclasses_navbar_top">
<li><a href="../../../../../allclasses.html">All&nbsp;Classes</a></li>
</ul>
<ul class="navListSearch">
<li><label for="search">SEARCH:</label>
<input type="text" id="search" value="search" disabled="disabled">
<input type="reset" id="reset" value="reset" disabled="disabled">
</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>
<noscript>
<div>JavaScript is disabled on your browser.</div>
</noscript>
</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 id="skip.navbar.top">
<!-- -->
</a></div>
<!-- ========= END OF TOP NAVBAR ========= -->
</div>
<div class="navPadding">&nbsp;</div>
<script type="text/javascript"><!--
$('.navPadding').css('padding-top', $('.fixedNav').css("height"));
//-->
</script>
</nav>
</header>
<!-- ======== START OF CLASS DATA ======== -->
<main role="main">
<div class="header">
<div class="subTitle"><span class="packageLabelInType">Package</span>&nbsp;<a href="package-summary.html">org.apache.iceberg.flink.source</a></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="IcebergSource.html" title="class in org.apache.iceberg.flink.source">IcebergSource</a>&lt;<a href="IcebergSource.html" title="type parameter in IcebergSource">T</a>&gt;</dd>
</dl>
<hr>
<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 =========== -->
<section>
<ul class="blockList">
<li class="blockList"><a id="method.summary">
<!-- -->
</a>
<h3>Method Summary</h3>
<table class="memberSummary">
<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="colSecond" scope="col">Method</th>
<th class="colLast" scope="col">Description</th>
</tr>
<tr id="i0" class="altColor">
<td class="colFirst"><code><a href="IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;</code></td>
<th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#asOfTimestamp(java.lang.Long)">asOfTimestamp</a></span>&#8203;(java.lang.Long&nbsp;newAsOfTimestamp)</code></th>
<td class="colLast">&nbsp;</td>
</tr>
<tr id="i1" class="rowColor">
<td class="colFirst"><code><a href="IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;</code></td>
<th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#assignerFactory(org.apache.iceberg.flink.source.assigner.SplitAssignerFactory)">assignerFactory</a></span>&#8203;(<a href="assigner/SplitAssignerFactory.html" title="interface in org.apache.iceberg.flink.source.assigner">SplitAssignerFactory</a>&nbsp;assignerFactory)</code></th>
<td class="colLast">&nbsp;</td>
</tr>
<tr id="i2" class="altColor">
<td class="colFirst"><code><a href="IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;</code></td>
<th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#branch(java.lang.String)">branch</a></span>&#8203;(java.lang.String&nbsp;branch)</code></th>
<td class="colLast">&nbsp;</td>
</tr>
<tr id="i3" class="rowColor">
<td class="colFirst"><code><a href="IcebergSource.html" title="class in org.apache.iceberg.flink.source">IcebergSource</a>&lt;<a href="IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;</code></td>
<th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#build()">build</a></span>()</code></th>
<td class="colLast">&nbsp;</td>
</tr>
<tr id="i4" class="altColor">
<td class="colFirst"><code><a href="IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;</code></td>
<th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#caseSensitive(boolean)">caseSensitive</a></span>&#8203;(boolean&nbsp;newCaseSensitive)</code></th>
<td class="colLast">&nbsp;</td>
</tr>
<tr id="i5" class="rowColor">
<td class="colFirst"><code><a href="IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;</code></td>
<th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#endSnapshotId(java.lang.Long)">endSnapshotId</a></span>&#8203;(java.lang.Long&nbsp;newEndSnapshotId)</code></th>
<td class="colLast">&nbsp;</td>
</tr>
<tr id="i6" class="altColor">
<td class="colFirst"><code><a href="IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;</code></td>
<th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#endTag(java.lang.String)">endTag</a></span>&#8203;(java.lang.String&nbsp;endTag)</code></th>
<td class="colLast">&nbsp;</td>
</tr>
<tr id="i7" class="rowColor">
<td class="colFirst"><code><a href="IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;</code></td>
<th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#exposeLocality(boolean)">exposeLocality</a></span>&#8203;(boolean&nbsp;newExposeLocality)</code></th>
<td class="colLast">&nbsp;</td>
</tr>
<tr id="i8" class="altColor">
<td class="colFirst"><code><a href="IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;</code></td>
<th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#filters(java.util.List)">filters</a></span>&#8203;(java.util.List&lt;<a href="../../expressions/Expression.html" title="interface in org.apache.iceberg.expressions">Expression</a>&gt;&nbsp;newFilters)</code></th>
<td class="colLast">&nbsp;</td>
</tr>
<tr id="i9" class="rowColor">
<td class="colFirst"><code><a href="IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;</code></td>
<th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#flinkConfig(org.apache.flink.configuration.ReadableConfig)">flinkConfig</a></span>&#8203;(org.apache.flink.configuration.ReadableConfig&nbsp;config)</code></th>
<td class="colLast">&nbsp;</td>
</tr>
<tr id="i10" class="altColor">
<td class="colFirst"><code><a href="IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;</code></td>
<th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#includeColumnStats(boolean)">includeColumnStats</a></span>&#8203;(boolean&nbsp;newIncludeColumnStats)</code></th>
<td class="colLast">&nbsp;</td>
</tr>
<tr id="i11" class="rowColor">
<td class="colFirst"><code><a href="IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;</code></td>
<th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#limit(java.lang.Long)">limit</a></span>&#8203;(java.lang.Long&nbsp;newLimit)</code></th>
<td class="colLast">&nbsp;</td>
</tr>
<tr id="i12" class="altColor">
<td class="colFirst"><code><a href="IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;</code></td>
<th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#maxAllowedPlanningFailures(int)">maxAllowedPlanningFailures</a></span>&#8203;(int&nbsp;maxAllowedPlanningFailures)</code></th>
<td class="colLast">&nbsp;</td>
</tr>
<tr id="i13" class="rowColor">
<td class="colFirst"><code><a href="IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;</code></td>
<th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#monitorInterval(java.time.Duration)">monitorInterval</a></span>&#8203;(java.time.Duration&nbsp;newMonitorInterval)</code></th>
<td class="colLast">&nbsp;</td>
</tr>
<tr id="i14" class="altColor">
<td class="colFirst"><code><a href="IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;</code></td>
<th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#nameMapping(java.lang.String)">nameMapping</a></span>&#8203;(java.lang.String&nbsp;newNameMapping)</code></th>
<td class="colLast">&nbsp;</td>
</tr>
<tr id="i15" class="rowColor">
<td class="colFirst"><code><a href="IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;</code></td>
<th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#planParallelism(int)">planParallelism</a></span>&#8203;(int&nbsp;planParallelism)</code></th>
<td class="colLast">&nbsp;</td>
</tr>
<tr id="i16" class="altColor">
<td class="colFirst"><code><a href="IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;</code></td>
<th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#project(org.apache.flink.table.api.TableSchema)">project</a></span>&#8203;(org.apache.flink.table.api.TableSchema&nbsp;newProjectedFlinkSchema)</code></th>
<td class="colLast">&nbsp;</td>
</tr>
<tr id="i17" class="rowColor">
<td class="colFirst"><code><a href="IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;</code></td>
<th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#project(org.apache.iceberg.Schema)">project</a></span>&#8203;(<a href="../../Schema.html" title="class in org.apache.iceberg">Schema</a>&nbsp;newProjectedSchema)</code></th>
<td class="colLast">&nbsp;</td>
</tr>
<tr id="i18" class="altColor">
<td class="colFirst"><code><a href="IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;</code></td>
<th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#properties(java.util.Map)">properties</a></span>&#8203;(java.util.Map&lt;java.lang.String,&#8203;java.lang.String&gt;&nbsp;properties)</code></th>
<td class="colLast">
<div class="block"><span class="deprecatedLabel">Deprecated.</span>
<div class="deprecationComment">Use <a href="#setAll(java.util.Map)"><code>setAll(java.util.Map&lt;java.lang.String, java.lang.String&gt;)</code></a> instead.</div>
</div>
</td>
</tr>
<tr id="i19" class="rowColor">
<td class="colFirst"><code><a href="IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;</code></td>
<th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#readerFunction(org.apache.iceberg.flink.source.reader.ReaderFunction)">readerFunction</a></span>&#8203;(<a href="reader/ReaderFunction.html" title="interface in org.apache.iceberg.flink.source.reader">ReaderFunction</a>&lt;<a href="IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;&nbsp;newReaderFunction)</code></th>
<td class="colLast">&nbsp;</td>
</tr>
<tr id="i20" class="altColor">
<td class="colFirst"><code><a href="IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;</code></td>
<th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#set(java.lang.String,java.lang.String)">set</a></span>&#8203;(java.lang.String&nbsp;property,
java.lang.String&nbsp;value)</code></th>
<td class="colLast">
<div class="block">Set the read properties for Flink source.</div>
</td>
</tr>
<tr id="i21" class="rowColor">
<td class="colFirst"><code><a href="IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;</code></td>
<th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#setAll(java.util.Map)">setAll</a></span>&#8203;(java.util.Map&lt;java.lang.String,&#8203;java.lang.String&gt;&nbsp;properties)</code></th>
<td class="colLast">
<div class="block">Set the read properties for Flink source.</div>
</td>
</tr>
<tr id="i22" class="altColor">
<td class="colFirst"><code><a href="IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;</code></td>
<th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#splitComparator(org.apache.iceberg.flink.source.split.SerializableComparator)">splitComparator</a></span>&#8203;(<a href="split/SerializableComparator.html" title="interface in org.apache.iceberg.flink.source.split">SerializableComparator</a>&lt;<a href="split/IcebergSourceSplit.html" title="class in org.apache.iceberg.flink.source.split">IcebergSourceSplit</a>&gt;&nbsp;newSplitComparator)</code></th>
<td class="colLast">&nbsp;</td>
</tr>
<tr id="i23" class="rowColor">
<td class="colFirst"><code><a href="IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;</code></td>
<th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#splitLookback(java.lang.Integer)">splitLookback</a></span>&#8203;(java.lang.Integer&nbsp;newSplitLookback)</code></th>
<td class="colLast">&nbsp;</td>
</tr>
<tr id="i24" class="altColor">
<td class="colFirst"><code><a href="IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;</code></td>
<th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#splitOpenFileCost(java.lang.Long)">splitOpenFileCost</a></span>&#8203;(java.lang.Long&nbsp;newSplitOpenFileCost)</code></th>
<td class="colLast">&nbsp;</td>
</tr>
<tr id="i25" class="rowColor">
<td class="colFirst"><code><a href="IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;</code></td>
<th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#splitSize(java.lang.Long)">splitSize</a></span>&#8203;(java.lang.Long&nbsp;newSplitSize)</code></th>
<td class="colLast">&nbsp;</td>
</tr>
<tr id="i26" class="altColor">
<td class="colFirst"><code><a href="IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;</code></td>
<th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#startSnapshotId(java.lang.Long)">startSnapshotId</a></span>&#8203;(java.lang.Long&nbsp;newStartSnapshotId)</code></th>
<td class="colLast">&nbsp;</td>
</tr>
<tr id="i27" class="rowColor">
<td class="colFirst"><code><a href="IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;</code></td>
<th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#startSnapshotTimestamp(java.lang.Long)">startSnapshotTimestamp</a></span>&#8203;(java.lang.Long&nbsp;newStartSnapshotTimestamp)</code></th>
<td class="colLast">&nbsp;</td>
</tr>
<tr id="i28" class="altColor">
<td class="colFirst"><code><a href="IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;</code></td>
<th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#startTag(java.lang.String)">startTag</a></span>&#8203;(java.lang.String&nbsp;startTag)</code></th>
<td class="colLast">&nbsp;</td>
</tr>
<tr id="i29" class="rowColor">
<td class="colFirst"><code><a href="IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;</code></td>
<th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#streaming(boolean)">streaming</a></span>&#8203;(boolean&nbsp;streaming)</code></th>
<td class="colLast">&nbsp;</td>
</tr>
<tr id="i30" class="altColor">
<td class="colFirst"><code><a href="IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;</code></td>
<th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#streamingStartingStrategy(org.apache.iceberg.flink.source.StreamingStartingStrategy)">streamingStartingStrategy</a></span>&#8203;(<a href="StreamingStartingStrategy.html" title="enum in org.apache.iceberg.flink.source">StreamingStartingStrategy</a>&nbsp;newStartingStrategy)</code></th>
<td class="colLast">&nbsp;</td>
</tr>
<tr id="i31" class="rowColor">
<td class="colFirst"><code><a href="IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;</code></td>
<th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#table(org.apache.iceberg.Table)">table</a></span>&#8203;(<a href="../../Table.html" title="interface in org.apache.iceberg">Table</a>&nbsp;newTable)</code></th>
<td class="colLast">&nbsp;</td>
</tr>
<tr id="i32" class="altColor">
<td class="colFirst"><code><a href="IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;</code></td>
<th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#tableLoader(org.apache.iceberg.flink.TableLoader)">tableLoader</a></span>&#8203;(<a href="../TableLoader.html" title="interface in org.apache.iceberg.flink">TableLoader</a>&nbsp;loader)</code></th>
<td class="colLast">&nbsp;</td>
</tr>
<tr id="i33" class="rowColor">
<td class="colFirst"><code><a href="IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;</code></td>
<th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#tag(java.lang.String)">tag</a></span>&#8203;(java.lang.String&nbsp;tag)</code></th>
<td class="colLast">&nbsp;</td>
</tr>
<tr id="i34" class="altColor">
<td class="colFirst"><code><a href="IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;</code></td>
<th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#useSnapshotId(java.lang.Long)">useSnapshotId</a></span>&#8203;(java.lang.Long&nbsp;newSnapshotId)</code></th>
<td class="colLast">&nbsp;</td>
</tr>
<tr id="i35" class="rowColor">
<td class="colFirst"><code><a href="IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;</code></td>
<th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#watermarkColumn(java.lang.String)">watermarkColumn</a></span>&#8203;(java.lang.String&nbsp;columnName)</code></th>
<td class="colLast">
<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="IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;</code></td>
<th class="colSecond" scope="row"><code><span class="memberNameLink"><a href="#watermarkColumnTimeUnit(java.util.concurrent.TimeUnit)">watermarkColumnTimeUnit</a></span>&#8203;(java.util.concurrent.TimeUnit&nbsp;timeUnit)</code></th>
<td class="colLast">
<div class="block">When the type of the <a href="#watermarkColumn(java.lang.String)"><code>watermarkColumn(java.lang.String)</code></a> is <a href="../../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 id="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>
</section>
</li>
</ul>
</div>
<div class="details">
<ul class="blockList">
<li class="blockList">
<!-- ============ METHOD DETAIL ========== -->
<section>
<ul class="blockList">
<li class="blockList"><a id="method.detail">
<!-- -->
</a>
<h3>Method Detail</h3>
<a id="tableLoader(org.apache.iceberg.flink.TableLoader)">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>tableLoader</h4>
<pre class="methodSignature">public&nbsp;<a href="IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;&nbsp;tableLoader&#8203;(<a href="../TableLoader.html" title="interface in org.apache.iceberg.flink">TableLoader</a>&nbsp;loader)</pre>
</li>
</ul>
<a id="table(org.apache.iceberg.Table)">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>table</h4>
<pre class="methodSignature">public&nbsp;<a href="IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;&nbsp;table&#8203;(<a href="../../Table.html" title="interface in org.apache.iceberg">Table</a>&nbsp;newTable)</pre>
</li>
</ul>
<a id="assignerFactory(org.apache.iceberg.flink.source.assigner.SplitAssignerFactory)">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>assignerFactory</h4>
<pre class="methodSignature">public&nbsp;<a href="IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;&nbsp;assignerFactory&#8203;(<a href="assigner/SplitAssignerFactory.html" title="interface in org.apache.iceberg.flink.source.assigner">SplitAssignerFactory</a>&nbsp;assignerFactory)</pre>
</li>
</ul>
<a id="splitComparator(org.apache.iceberg.flink.source.split.SerializableComparator)">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>splitComparator</h4>
<pre class="methodSignature">public&nbsp;<a href="IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;&nbsp;splitComparator&#8203;(<a href="split/SerializableComparator.html" title="interface in org.apache.iceberg.flink.source.split">SerializableComparator</a>&lt;<a href="split/IcebergSourceSplit.html" title="class in org.apache.iceberg.flink.source.split">IcebergSourceSplit</a>&gt;&nbsp;newSplitComparator)</pre>
</li>
</ul>
<a id="readerFunction(org.apache.iceberg.flink.source.reader.ReaderFunction)">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>readerFunction</h4>
<pre class="methodSignature">public&nbsp;<a href="IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;&nbsp;readerFunction&#8203;(<a href="reader/ReaderFunction.html" title="interface in org.apache.iceberg.flink.source.reader">ReaderFunction</a>&lt;<a href="IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;&nbsp;newReaderFunction)</pre>
</li>
</ul>
<a id="flinkConfig(org.apache.flink.configuration.ReadableConfig)">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>flinkConfig</h4>
<pre class="methodSignature">public&nbsp;<a href="IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;&nbsp;flinkConfig&#8203;(org.apache.flink.configuration.ReadableConfig&nbsp;config)</pre>
</li>
</ul>
<a id="caseSensitive(boolean)">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>caseSensitive</h4>
<pre class="methodSignature">public&nbsp;<a href="IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;&nbsp;caseSensitive&#8203;(boolean&nbsp;newCaseSensitive)</pre>
</li>
</ul>
<a id="useSnapshotId(java.lang.Long)">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>useSnapshotId</h4>
<pre class="methodSignature">public&nbsp;<a href="IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;&nbsp;useSnapshotId&#8203;(java.lang.Long&nbsp;newSnapshotId)</pre>
</li>
</ul>
<a id="streamingStartingStrategy(org.apache.iceberg.flink.source.StreamingStartingStrategy)">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>streamingStartingStrategy</h4>
<pre class="methodSignature">public&nbsp;<a href="IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;&nbsp;streamingStartingStrategy&#8203;(<a href="StreamingStartingStrategy.html" title="enum in org.apache.iceberg.flink.source">StreamingStartingStrategy</a>&nbsp;newStartingStrategy)</pre>
</li>
</ul>
<a id="startSnapshotTimestamp(java.lang.Long)">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>startSnapshotTimestamp</h4>
<pre class="methodSignature">public&nbsp;<a href="IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;&nbsp;startSnapshotTimestamp&#8203;(java.lang.Long&nbsp;newStartSnapshotTimestamp)</pre>
</li>
</ul>
<a id="startSnapshotId(java.lang.Long)">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>startSnapshotId</h4>
<pre class="methodSignature">public&nbsp;<a href="IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;&nbsp;startSnapshotId&#8203;(java.lang.Long&nbsp;newStartSnapshotId)</pre>
</li>
</ul>
<a id="tag(java.lang.String)">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>tag</h4>
<pre class="methodSignature">public&nbsp;<a href="IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;&nbsp;tag&#8203;(java.lang.String&nbsp;tag)</pre>
</li>
</ul>
<a id="branch(java.lang.String)">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>branch</h4>
<pre class="methodSignature">public&nbsp;<a href="IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;&nbsp;branch&#8203;(java.lang.String&nbsp;branch)</pre>
</li>
</ul>
<a id="startTag(java.lang.String)">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>startTag</h4>
<pre class="methodSignature">public&nbsp;<a href="IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;&nbsp;startTag&#8203;(java.lang.String&nbsp;startTag)</pre>
</li>
</ul>
<a id="endTag(java.lang.String)">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>endTag</h4>
<pre class="methodSignature">public&nbsp;<a href="IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;&nbsp;endTag&#8203;(java.lang.String&nbsp;endTag)</pre>
</li>
</ul>
<a id="endSnapshotId(java.lang.Long)">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>endSnapshotId</h4>
<pre class="methodSignature">public&nbsp;<a href="IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;&nbsp;endSnapshotId&#8203;(java.lang.Long&nbsp;newEndSnapshotId)</pre>
</li>
</ul>
<a id="asOfTimestamp(java.lang.Long)">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>asOfTimestamp</h4>
<pre class="methodSignature">public&nbsp;<a href="IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;&nbsp;asOfTimestamp&#8203;(java.lang.Long&nbsp;newAsOfTimestamp)</pre>
</li>
</ul>
<a id="splitSize(java.lang.Long)">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>splitSize</h4>
<pre class="methodSignature">public&nbsp;<a href="IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;&nbsp;splitSize&#8203;(java.lang.Long&nbsp;newSplitSize)</pre>
</li>
</ul>
<a id="splitLookback(java.lang.Integer)">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>splitLookback</h4>
<pre class="methodSignature">public&nbsp;<a href="IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;&nbsp;splitLookback&#8203;(java.lang.Integer&nbsp;newSplitLookback)</pre>
</li>
</ul>
<a id="splitOpenFileCost(java.lang.Long)">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>splitOpenFileCost</h4>
<pre class="methodSignature">public&nbsp;<a href="IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;&nbsp;splitOpenFileCost&#8203;(java.lang.Long&nbsp;newSplitOpenFileCost)</pre>
</li>
</ul>
<a id="streaming(boolean)">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>streaming</h4>
<pre class="methodSignature">public&nbsp;<a href="IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;&nbsp;streaming&#8203;(boolean&nbsp;streaming)</pre>
</li>
</ul>
<a id="monitorInterval(java.time.Duration)">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>monitorInterval</h4>
<pre class="methodSignature">public&nbsp;<a href="IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;&nbsp;monitorInterval&#8203;(java.time.Duration&nbsp;newMonitorInterval)</pre>
</li>
</ul>
<a id="nameMapping(java.lang.String)">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>nameMapping</h4>
<pre class="methodSignature">public&nbsp;<a href="IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;&nbsp;nameMapping&#8203;(java.lang.String&nbsp;newNameMapping)</pre>
</li>
</ul>
<a id="project(org.apache.iceberg.Schema)">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>project</h4>
<pre class="methodSignature">public&nbsp;<a href="IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;&nbsp;project&#8203;(<a href="../../Schema.html" title="class in org.apache.iceberg">Schema</a>&nbsp;newProjectedSchema)</pre>
</li>
</ul>
<a id="project(org.apache.flink.table.api.TableSchema)">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>project</h4>
<pre class="methodSignature">public&nbsp;<a href="IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;&nbsp;project&#8203;(org.apache.flink.table.api.TableSchema&nbsp;newProjectedFlinkSchema)</pre>
</li>
</ul>
<a id="filters(java.util.List)">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>filters</h4>
<pre class="methodSignature">public&nbsp;<a href="IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;&nbsp;filters&#8203;(java.util.List&lt;<a href="../../expressions/Expression.html" title="interface in org.apache.iceberg.expressions">Expression</a>&gt;&nbsp;newFilters)</pre>
</li>
</ul>
<a id="limit(java.lang.Long)">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>limit</h4>
<pre class="methodSignature">public&nbsp;<a href="IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;&nbsp;limit&#8203;(java.lang.Long&nbsp;newLimit)</pre>
</li>
</ul>
<a id="includeColumnStats(boolean)">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>includeColumnStats</h4>
<pre class="methodSignature">public&nbsp;<a href="IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;&nbsp;includeColumnStats&#8203;(boolean&nbsp;newIncludeColumnStats)</pre>
</li>
</ul>
<a id="planParallelism(int)">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>planParallelism</h4>
<pre class="methodSignature">public&nbsp;<a href="IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;&nbsp;planParallelism&#8203;(int&nbsp;planParallelism)</pre>
</li>
</ul>
<a id="exposeLocality(boolean)">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>exposeLocality</h4>
<pre class="methodSignature">public&nbsp;<a href="IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;&nbsp;exposeLocality&#8203;(boolean&nbsp;newExposeLocality)</pre>
</li>
</ul>
<a id="maxAllowedPlanningFailures(int)">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>maxAllowedPlanningFailures</h4>
<pre class="methodSignature">public&nbsp;<a href="IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;&nbsp;maxAllowedPlanningFailures&#8203;(int&nbsp;maxAllowedPlanningFailures)</pre>
</li>
</ul>
<a id="set(java.lang.String,java.lang.String)">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>set</h4>
<pre class="methodSignature">public&nbsp;<a href="IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;&nbsp;set&#8203;(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="../FlinkReadOptions.html" title="class in org.apache.iceberg.flink"><code>FlinkReadOptions</code></a></div>
</li>
</ul>
<a id="setAll(java.util.Map)">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>setAll</h4>
<pre class="methodSignature">public&nbsp;<a href="IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;&nbsp;setAll&#8203;(java.util.Map&lt;java.lang.String,&#8203;java.lang.String&gt;&nbsp;properties)</pre>
<div class="block">Set the read properties for Flink source. View the supported properties in <a href="../FlinkReadOptions.html" title="class in org.apache.iceberg.flink"><code>FlinkReadOptions</code></a></div>
</li>
</ul>
<a id="watermarkColumn(java.lang.String)">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>watermarkColumn</h4>
<pre class="methodSignature">public&nbsp;<a href="IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;&nbsp;watermarkColumn&#8203;(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="#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 id="watermarkColumnTimeUnit(java.util.concurrent.TimeUnit)">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>watermarkColumnTimeUnit</h4>
<pre class="methodSignature">public&nbsp;<a href="IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;&nbsp;watermarkColumnTimeUnit&#8203;(java.util.concurrent.TimeUnit&nbsp;timeUnit)</pre>
<div class="block">When the type of the <a href="#watermarkColumn(java.lang.String)"><code>watermarkColumn(java.lang.String)</code></a> is <a href="../../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 id="properties(java.util.Map)">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>properties</h4>
<pre class="methodSignature">@Deprecated
public&nbsp;<a href="IcebergSource.Builder.html" title="class in org.apache.iceberg.flink.source">IcebergSource.Builder</a>&lt;<a href="IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;&nbsp;properties&#8203;(java.util.Map&lt;java.lang.String,&#8203;java.lang.String&gt;&nbsp;properties)</pre>
<div class="deprecationBlock"><span class="deprecatedLabel">Deprecated.</span>
<div class="deprecationComment">Use <a href="#setAll(java.util.Map)"><code>setAll(java.util.Map&lt;java.lang.String, java.lang.String&gt;)</code></a> instead.</div>
</div>
</li>
</ul>
<a id="build()">
<!-- -->
</a>
<ul class="blockListLast">
<li class="blockList">
<h4>build</h4>
<pre class="methodSignature">public&nbsp;<a href="IcebergSource.html" title="class in org.apache.iceberg.flink.source">IcebergSource</a>&lt;<a href="IcebergSource.Builder.html" title="type parameter in IcebergSource.Builder">T</a>&gt;&nbsp;build()</pre>
</li>
</ul>
</li>
</ul>
</section>
</li>
</ul>
</div>
</div>
</main>
<!-- ========= END OF CLASS DATA ========= -->
<footer role="contentinfo">
<nav role="navigation">
<!-- ======= START OF BOTTOM NAVBAR ====== -->
<div class="bottomNav"><a id="navbar.bottom">
<!-- -->
</a>
<div class="skipNav"><a href="#skip.navbar.bottom" title="Skip navigation links">Skip navigation links</a></div>
<a id="navbar.bottom.firstrow">
<!-- -->
</a>
<ul class="navList" title="Navigation">
<li><a href="../../../../../index.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" id="allclasses_navbar_bottom">
<li><a href="../../../../../allclasses.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>
<noscript>
<div>JavaScript is disabled on your browser.</div>
</noscript>
</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 id="skip.navbar.bottom">
<!-- -->
</a></div>
<!-- ======== END OF BOTTOM NAVBAR ======= -->
</nav>
</footer>
</body>
</html>