|
@@ -0,0 +1,786 @@
|
|
|
+<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd">
|
|
|
+<!-- NewPage -->
|
|
|
+<html lang="zh">
|
|
|
+<head>
|
|
|
+<!-- Generated by javadoc (version 1.7.0_40) on Tue Oct 29 14:30:30 CST 2013 -->
|
|
|
+<meta http-equiv="Content-Type" content="text/html" charset="UTF-8">
|
|
|
+<title>ClusterCanalConnector (canal client module for otter 1.0.13 1.0.13 API)</title>
|
|
|
+<meta name="date" content="2013-10-29">
|
|
|
+<link rel="stylesheet" type="text/css" href="../../../../../../stylesheet.css" title="Style">
|
|
|
+</head>
|
|
|
+<body>
|
|
|
+<script type="text/javascript"><!--
|
|
|
+ if (location.href.indexOf('is-external=true') == -1) {
|
|
|
+ parent.document.title="ClusterCanalConnector (canal client module for otter 1.0.13 1.0.13 API)";
|
|
|
+ }
|
|
|
+//-->
|
|
|
+</script>
|
|
|
+<noscript>
|
|
|
+<div>您的浏览器已禁用 JavaScript。</div>
|
|
|
+</noscript>
|
|
|
+<!-- ========= START OF TOP NAVBAR ======= -->
|
|
|
+<div class="topNav"><a name="navbar_top">
|
|
|
+<!-- -->
|
|
|
+</a><a href="#skip-navbar_top" title="跳过导航链接"></a><a name="navbar_top_firstrow">
|
|
|
+<!-- -->
|
|
|
+</a>
|
|
|
+<ul class="navList" title="导航">
|
|
|
+<li><a href="../../../../../../overview-summary.html">概览</a></li>
|
|
|
+<li><a href="package-summary.html">程序包</a></li>
|
|
|
+<li class="navBarCell1Rev">类</li>
|
|
|
+<li><a href="class-use/ClusterCanalConnector.html">使用</a></li>
|
|
|
+<li><a href="package-tree.html">树</a></li>
|
|
|
+<li><a href="../../../../../../deprecated-list.html">已过时</a></li>
|
|
|
+<li><a href="../../../../../../index-all.html">索引</a></li>
|
|
|
+</ul>
|
|
|
+<div class="aboutLanguage"><em>canal.client-1.0.13</em></div>
|
|
|
+</div>
|
|
|
+<div class="subNav">
|
|
|
+<ul class="navList">
|
|
|
+<li>上一个类</li>
|
|
|
+<li><a href="../../../../../../com/alibaba/otter/canal/client/impl/ClusterNodeAccessStrategy.html" title="com.alibaba.otter.canal.client.impl中的类"><span class="strong">下一个类</span></a></li>
|
|
|
+</ul>
|
|
|
+<ul class="navList">
|
|
|
+<li><a href="../../../../../../index.html?com/alibaba/otter/canal/client/impl/ClusterCanalConnector.html" target="_top">框架</a></li>
|
|
|
+<li><a href="ClusterCanalConnector.html" target="_top">无框架</a></li>
|
|
|
+</ul>
|
|
|
+<ul class="navList" id="allclasses_navbar_top">
|
|
|
+<li><a href="../../../../../../allclasses-noframe.html">所有类</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>概要: </li>
|
|
|
+<li>嵌套 | </li>
|
|
|
+<li>字段 | </li>
|
|
|
+<li><a href="#constructor_summary">构造器</a> | </li>
|
|
|
+<li><a href="#method_summary">方法</a></li>
|
|
|
+</ul>
|
|
|
+<ul class="subNavList">
|
|
|
+<li>详细资料: </li>
|
|
|
+<li>字段 | </li>
|
|
|
+<li><a href="#constructor_detail">构造器</a> | </li>
|
|
|
+<li><a href="#method_detail">方法</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">com.alibaba.otter.canal.client.impl</div>
|
|
|
+<h2 title="类 ClusterCanalConnector" class="title">类 ClusterCanalConnector</h2>
|
|
|
+</div>
|
|
|
+<div class="contentContainer">
|
|
|
+<ul class="inheritance">
|
|
|
+<li><a href="http://docs.oracle.com/javase/6/docs/api/java/lang/Object.html?is-external=true" title="java.lang中的类或接口">java.lang.Object</a></li>
|
|
|
+<li>
|
|
|
+<ul class="inheritance">
|
|
|
+<li>com.alibaba.otter.canal.client.impl.ClusterCanalConnector</li>
|
|
|
+</ul>
|
|
|
+</li>
|
|
|
+</ul>
|
|
|
+<div class="description">
|
|
|
+<ul class="blockList">
|
|
|
+<li class="blockList">
|
|
|
+<dl>
|
|
|
+<dt>所有已实现的接口:</dt>
|
|
|
+<dd><a href="../../../../../../com/alibaba/otter/canal/client/CanalConnector.html" title="com.alibaba.otter.canal.client中的接口">CanalConnector</a></dd>
|
|
|
+</dl>
|
|
|
+<hr>
|
|
|
+<br>
|
|
|
+<pre>public class <span class="strong">ClusterCanalConnector</span>
|
|
|
+extends <a href="http://docs.oracle.com/javase/6/docs/api/java/lang/Object.html?is-external=true" title="java.lang中的类或接口">Object</a>
|
|
|
+implements <a href="../../../../../../com/alibaba/otter/canal/client/CanalConnector.html" title="com.alibaba.otter.canal.client中的接口">CanalConnector</a></pre>
|
|
|
+<div class="block">集群版本connector实现,自带了failover功能<br/></div>
|
|
|
+<dl><dt><span class="strong">版本:</span></dt>
|
|
|
+ <dd>1.0.0</dd>
|
|
|
+<dt><span class="strong">作者:</span></dt>
|
|
|
+ <dd>jianghang 2012-10-29 下午08:04:06</dd></dl>
|
|
|
+</li>
|
|
|
+</ul>
|
|
|
+</div>
|
|
|
+<div class="summary">
|
|
|
+<ul class="blockList">
|
|
|
+<li class="blockList">
|
|
|
+<!-- ======== CONSTRUCTOR SUMMARY ======== -->
|
|
|
+<ul class="blockList">
|
|
|
+<li class="blockList"><a name="constructor_summary">
|
|
|
+<!-- -->
|
|
|
+</a>
|
|
|
+<h3>构造器概要</h3>
|
|
|
+<table class="overviewSummary" border="0" cellpadding="3" cellspacing="0" summary="构造器概要表, 列表构造器和解释">
|
|
|
+<caption><span>构造器</span><span class="tabEnd"> </span></caption>
|
|
|
+<tr>
|
|
|
+<th class="colOne" scope="col">构造器和说明</th>
|
|
|
+</tr>
|
|
|
+<tr class="altColor">
|
|
|
+<td class="colOne"><code><strong><a href="../../../../../../com/alibaba/otter/canal/client/impl/ClusterCanalConnector.html#ClusterCanalConnector(java.lang.String, java.lang.String, java.lang.String, com.alibaba.otter.canal.client.CanalNodeAccessStrategy)">ClusterCanalConnector</a></strong>(<a href="http://docs.oracle.com/javase/6/docs/api/java/lang/String.html?is-external=true" title="java.lang中的类或接口">String</a> username,
|
|
|
+ <a href="http://docs.oracle.com/javase/6/docs/api/java/lang/String.html?is-external=true" title="java.lang中的类或接口">String</a> password,
|
|
|
+ <a href="http://docs.oracle.com/javase/6/docs/api/java/lang/String.html?is-external=true" title="java.lang中的类或接口">String</a> destination,
|
|
|
+ <a href="../../../../../../com/alibaba/otter/canal/client/CanalNodeAccessStrategy.html" title="com.alibaba.otter.canal.client中的接口">CanalNodeAccessStrategy</a> accessStrategy)</code> </td>
|
|
|
+</tr>
|
|
|
+</table>
|
|
|
+</li>
|
|
|
+</ul>
|
|
|
+<!-- ========== METHOD SUMMARY =========== -->
|
|
|
+<ul class="blockList">
|
|
|
+<li class="blockList"><a name="method_summary">
|
|
|
+<!-- -->
|
|
|
+</a>
|
|
|
+<h3>方法概要</h3>
|
|
|
+<table class="overviewSummary" border="0" cellpadding="3" cellspacing="0" summary="方法概要表, 列表方法和解释">
|
|
|
+<caption><span>方法</span><span class="tabEnd"> </span></caption>
|
|
|
+<tr>
|
|
|
+<th class="colFirst" scope="col">限定符和类型</th>
|
|
|
+<th class="colLast" scope="col">方法和说明</th>
|
|
|
+</tr>
|
|
|
+<tr class="altColor">
|
|
|
+<td class="colFirst"><code>void</code></td>
|
|
|
+<td class="colLast"><code><strong><a href="../../../../../../com/alibaba/otter/canal/client/impl/ClusterCanalConnector.html#ack(long)">ack</a></strong>(long batchId)</code>
|
|
|
+<div class="block">进行 batch id 的确认。</div>
|
|
|
+</td>
|
|
|
+</tr>
|
|
|
+<tr class="rowColor">
|
|
|
+<td class="colFirst"><code>boolean</code></td>
|
|
|
+<td class="colLast"><code><strong><a href="../../../../../../com/alibaba/otter/canal/client/impl/ClusterCanalConnector.html#checkValid()">checkValid</a></strong>()</code>
|
|
|
+<div class="block">检查下链接是否合法
|
|
|
+
|
|
|
+
|
|
|
+ 几种case下链接不合法:
|
|
|
+ 1.</div>
|
|
|
+</td>
|
|
|
+</tr>
|
|
|
+<tr class="altColor">
|
|
|
+<td class="colFirst"><code>void</code></td>
|
|
|
+<td class="colLast"><code><strong><a href="../../../../../../com/alibaba/otter/canal/client/impl/ClusterCanalConnector.html#connect()">connect</a></strong>()</code>
|
|
|
+<div class="block">链接对应的canal server</div>
|
|
|
+</td>
|
|
|
+</tr>
|
|
|
+<tr class="rowColor">
|
|
|
+<td class="colFirst"><code>void</code></td>
|
|
|
+<td class="colLast"><code><strong><a href="../../../../../../com/alibaba/otter/canal/client/impl/ClusterCanalConnector.html#disconnect()">disconnect</a></strong>()</code>
|
|
|
+<div class="block">释放链接</div>
|
|
|
+</td>
|
|
|
+</tr>
|
|
|
+<tr class="altColor">
|
|
|
+<td class="colFirst"><code>com.alibaba.otter.canal.protocol.Message</code></td>
|
|
|
+<td class="colLast"><code><strong><a href="../../../../../../com/alibaba/otter/canal/client/impl/ClusterCanalConnector.html#get(int)">get</a></strong>(int batchSize)</code>
|
|
|
+<div class="block">获取数据,自动进行确认,该方法返回的条件:尝试拿batchSize条记录,有多少取多少,不会阻塞等待</div>
|
|
|
+</td>
|
|
|
+</tr>
|
|
|
+<tr class="rowColor">
|
|
|
+<td class="colFirst"><code>com.alibaba.otter.canal.protocol.Message</code></td>
|
|
|
+<td class="colLast"><code><strong><a href="../../../../../../com/alibaba/otter/canal/client/impl/ClusterCanalConnector.html#get(int, java.lang.Long, java.util.concurrent.TimeUnit)">get</a></strong>(int batchSize,
|
|
|
+ <a href="http://docs.oracle.com/javase/6/docs/api/java/lang/Long.html?is-external=true" title="java.lang中的类或接口">Long</a> timeout,
|
|
|
+ <a href="http://docs.oracle.com/javase/6/docs/api/java/util/concurrent/TimeUnit.html?is-external=true" title="java.util.concurrent中的类或接口">TimeUnit</a> unit)</code>
|
|
|
+<div class="block">获取数据,自动进行确认
|
|
|
+
|
|
|
+
|
|
|
+ 该方法返回的条件:
|
|
|
+ a.</div>
|
|
|
+</td>
|
|
|
+</tr>
|
|
|
+<tr class="altColor">
|
|
|
+<td class="colFirst"><code><a href="../../../../../../com/alibaba/otter/canal/client/CanalNodeAccessStrategy.html" title="com.alibaba.otter.canal.client中的接口">CanalNodeAccessStrategy</a></code></td>
|
|
|
+<td class="colLast"><code><strong><a href="../../../../../../com/alibaba/otter/canal/client/impl/ClusterCanalConnector.html#getAccessStrategy()">getAccessStrategy</a></strong>()</code> </td>
|
|
|
+</tr>
|
|
|
+<tr class="rowColor">
|
|
|
+<td class="colFirst"><code><a href="../../../../../../com/alibaba/otter/canal/client/impl/SimpleCanalConnector.html" title="com.alibaba.otter.canal.client.impl中的类">SimpleCanalConnector</a></code></td>
|
|
|
+<td class="colLast"><code><strong><a href="../../../../../../com/alibaba/otter/canal/client/impl/ClusterCanalConnector.html#getCurrentConnector()">getCurrentConnector</a></strong>()</code> </td>
|
|
|
+</tr>
|
|
|
+<tr class="altColor">
|
|
|
+<td class="colFirst"><code><a href="http://docs.oracle.com/javase/6/docs/api/java/lang/String.html?is-external=true" title="java.lang中的类或接口">String</a></code></td>
|
|
|
+<td class="colLast"><code><strong><a href="../../../../../../com/alibaba/otter/canal/client/impl/ClusterCanalConnector.html#getPassword()">getPassword</a></strong>()</code> </td>
|
|
|
+</tr>
|
|
|
+<tr class="rowColor">
|
|
|
+<td class="colFirst"><code>int</code></td>
|
|
|
+<td class="colLast"><code><strong><a href="../../../../../../com/alibaba/otter/canal/client/impl/ClusterCanalConnector.html#getRetryInterval()">getRetryInterval</a></strong>()</code> </td>
|
|
|
+</tr>
|
|
|
+<tr class="altColor">
|
|
|
+<td class="colFirst"><code>int</code></td>
|
|
|
+<td class="colLast"><code><strong><a href="../../../../../../com/alibaba/otter/canal/client/impl/ClusterCanalConnector.html#getRetryTimes()">getRetryTimes</a></strong>()</code> </td>
|
|
|
+</tr>
|
|
|
+<tr class="rowColor">
|
|
|
+<td class="colFirst"><code>int</code></td>
|
|
|
+<td class="colLast"><code><strong><a href="../../../../../../com/alibaba/otter/canal/client/impl/ClusterCanalConnector.html#getSoTimeout()">getSoTimeout</a></strong>()</code> </td>
|
|
|
+</tr>
|
|
|
+<tr class="altColor">
|
|
|
+<td class="colFirst"><code><a href="http://docs.oracle.com/javase/6/docs/api/java/lang/String.html?is-external=true" title="java.lang中的类或接口">String</a></code></td>
|
|
|
+<td class="colLast"><code><strong><a href="../../../../../../com/alibaba/otter/canal/client/impl/ClusterCanalConnector.html#getUsername()">getUsername</a></strong>()</code> </td>
|
|
|
+</tr>
|
|
|
+<tr class="rowColor">
|
|
|
+<td class="colFirst"><code>com.alibaba.otter.canal.protocol.Message</code></td>
|
|
|
+<td class="colLast"><code><strong><a href="../../../../../../com/alibaba/otter/canal/client/impl/ClusterCanalConnector.html#getWithoutAck(int)">getWithoutAck</a></strong>(int batchSize)</code>
|
|
|
+<div class="block">不指定 position 获取事件,该方法返回的条件: 尝试拿batchSize条记录,有多少取多少,不会阻塞等待<br/>
|
|
|
+ canal 会记住此 client 最新的position。</div>
|
|
|
+</td>
|
|
|
+</tr>
|
|
|
+<tr class="altColor">
|
|
|
+<td class="colFirst"><code>com.alibaba.otter.canal.protocol.Message</code></td>
|
|
|
+<td class="colLast"><code><strong><a href="../../../../../../com/alibaba/otter/canal/client/impl/ClusterCanalConnector.html#getWithoutAck(int, java.lang.Long, java.util.concurrent.TimeUnit)">getWithoutAck</a></strong>(int batchSize,
|
|
|
+ <a href="http://docs.oracle.com/javase/6/docs/api/java/lang/Long.html?is-external=true" title="java.lang中的类或接口">Long</a> timeout,
|
|
|
+ <a href="http://docs.oracle.com/javase/6/docs/api/java/util/concurrent/TimeUnit.html?is-external=true" title="java.util.concurrent中的类或接口">TimeUnit</a> unit)</code>
|
|
|
+<div class="block">不指定 position 获取事件.</div>
|
|
|
+</td>
|
|
|
+</tr>
|
|
|
+<tr class="rowColor">
|
|
|
+<td class="colFirst"><code>void</code></td>
|
|
|
+<td class="colLast"><code><strong><a href="../../../../../../com/alibaba/otter/canal/client/impl/ClusterCanalConnector.html#rollback()">rollback</a></strong>()</code>
|
|
|
+<div class="block">回滚到未进行 <code>ack</code> 的地方,下次fetch的时候,可以从最后一个没有 <code>ack</code> 的地方开始拿</div>
|
|
|
+</td>
|
|
|
+</tr>
|
|
|
+<tr class="altColor">
|
|
|
+<td class="colFirst"><code>void</code></td>
|
|
|
+<td class="colLast"><code><strong><a href="../../../../../../com/alibaba/otter/canal/client/impl/ClusterCanalConnector.html#rollback(long)">rollback</a></strong>(long batchId)</code>
|
|
|
+<div class="block">回滚到未进行 <code>ack</code> 的地方,指定回滚具体的batchId</div>
|
|
|
+</td>
|
|
|
+</tr>
|
|
|
+<tr class="rowColor">
|
|
|
+<td class="colFirst"><code>void</code></td>
|
|
|
+<td class="colLast"><code><strong><a href="../../../../../../com/alibaba/otter/canal/client/impl/ClusterCanalConnector.html#setAccessStrategy(com.alibaba.otter.canal.client.CanalNodeAccessStrategy)">setAccessStrategy</a></strong>(<a href="../../../../../../com/alibaba/otter/canal/client/CanalNodeAccessStrategy.html" title="com.alibaba.otter.canal.client中的接口">CanalNodeAccessStrategy</a> accessStrategy)</code> </td>
|
|
|
+</tr>
|
|
|
+<tr class="altColor">
|
|
|
+<td class="colFirst"><code>void</code></td>
|
|
|
+<td class="colLast"><code><strong><a href="../../../../../../com/alibaba/otter/canal/client/impl/ClusterCanalConnector.html#setPassword(java.lang.String)">setPassword</a></strong>(<a href="http://docs.oracle.com/javase/6/docs/api/java/lang/String.html?is-external=true" title="java.lang中的类或接口">String</a> password)</code> </td>
|
|
|
+</tr>
|
|
|
+<tr class="rowColor">
|
|
|
+<td class="colFirst"><code>void</code></td>
|
|
|
+<td class="colLast"><code><strong><a href="../../../../../../com/alibaba/otter/canal/client/impl/ClusterCanalConnector.html#setRetryInterval(int)">setRetryInterval</a></strong>(int retryInterval)</code> </td>
|
|
|
+</tr>
|
|
|
+<tr class="altColor">
|
|
|
+<td class="colFirst"><code>void</code></td>
|
|
|
+<td class="colLast"><code><strong><a href="../../../../../../com/alibaba/otter/canal/client/impl/ClusterCanalConnector.html#setRetryTimes(int)">setRetryTimes</a></strong>(int retryTimes)</code> </td>
|
|
|
+</tr>
|
|
|
+<tr class="rowColor">
|
|
|
+<td class="colFirst"><code>void</code></td>
|
|
|
+<td class="colLast"><code><strong><a href="../../../../../../com/alibaba/otter/canal/client/impl/ClusterCanalConnector.html#setSoTimeout(int)">setSoTimeout</a></strong>(int soTimeout)</code> </td>
|
|
|
+</tr>
|
|
|
+<tr class="altColor">
|
|
|
+<td class="colFirst"><code>void</code></td>
|
|
|
+<td class="colLast"><code><strong><a href="../../../../../../com/alibaba/otter/canal/client/impl/ClusterCanalConnector.html#setUsername(java.lang.String)">setUsername</a></strong>(<a href="http://docs.oracle.com/javase/6/docs/api/java/lang/String.html?is-external=true" title="java.lang中的类或接口">String</a> username)</code> </td>
|
|
|
+</tr>
|
|
|
+<tr class="rowColor">
|
|
|
+<td class="colFirst"><code>void</code></td>
|
|
|
+<td class="colLast"><code><strong><a href="../../../../../../com/alibaba/otter/canal/client/impl/ClusterCanalConnector.html#subscribe()">subscribe</a></strong>()</code>
|
|
|
+<div class="block">客户端订阅,不提交客户端filter,以服务端的filter为准</div>
|
|
|
+</td>
|
|
|
+</tr>
|
|
|
+<tr class="altColor">
|
|
|
+<td class="colFirst"><code>void</code></td>
|
|
|
+<td class="colLast"><code><strong><a href="../../../../../../com/alibaba/otter/canal/client/impl/ClusterCanalConnector.html#subscribe(java.lang.String)">subscribe</a></strong>(<a href="http://docs.oracle.com/javase/6/docs/api/java/lang/String.html?is-external=true" title="java.lang中的类或接口">String</a> filter)</code>
|
|
|
+<div class="block">客户端订阅,重复订阅时会更新对应的filter信息
|
|
|
+
|
|
|
+
|
|
|
+ 说明:
|
|
|
+ a.</div>
|
|
|
+</td>
|
|
|
+</tr>
|
|
|
+<tr class="rowColor">
|
|
|
+<td class="colFirst"><code>void</code></td>
|
|
|
+<td class="colLast"><code><strong><a href="../../../../../../com/alibaba/otter/canal/client/impl/ClusterCanalConnector.html#unsubscribe()">unsubscribe</a></strong>()</code>
|
|
|
+<div class="block">取消订阅</div>
|
|
|
+</td>
|
|
|
+</tr>
|
|
|
+</table>
|
|
|
+<ul class="blockList">
|
|
|
+<li class="blockList"><a name="methods_inherited_from_class_java.lang.Object">
|
|
|
+<!-- -->
|
|
|
+</a>
|
|
|
+<h3>从类继承的方法 java.lang.<a href="http://docs.oracle.com/javase/6/docs/api/java/lang/Object.html?is-external=true" title="java.lang中的类或接口">Object</a></h3>
|
|
|
+<code><a href="http://docs.oracle.com/javase/6/docs/api/java/lang/Object.html?is-external=true#equals(java.lang.Object)" title="java.lang中的类或接口">equals</a>, <a href="http://docs.oracle.com/javase/6/docs/api/java/lang/Object.html?is-external=true#getClass()" title="java.lang中的类或接口">getClass</a>, <a href="http://docs.oracle.com/javase/6/docs/api/java/lang/Object.html?is-external=true#hashCode()" title="java.lang中的类或接口">hashCode</a>, <a href="http://docs.oracle.com/javase/6/docs/api/java/lang/Object.html?is-external=true#notify()" title="java.lang中的类或接口">notify</a>, <a href="http://docs.oracle.com/javase/6/docs/api/java/lang/Object.html?is-external=true#notifyAll()" title="java.lang中的类或接口">notifyAll</a>, <a href="http://docs.oracle.com/javase/6/docs/api/java/lang/Object.html?is-external=true#toString()" title="java.lang中的类或接口">toString</a>, <a href="http://docs.oracle.com/javase/6/docs/api/java/lang/Object.html?is-external=true#wait()" title="java.lang中的类或接口">wait</a>, <a href="http://docs.oracle.com/javase/6/docs/api/java/lang/Object.html?is-external=true#wait(long)" title="java.lang中的类或接口">wait</a>, <a href="http://docs.oracle.com/javase/6/docs/api/java/lang/Object.html?is-external=true#wait(long, int)" title="java.lang中的类或接口">wait</a></code></li>
|
|
|
+</ul>
|
|
|
+</li>
|
|
|
+</ul>
|
|
|
+</li>
|
|
|
+</ul>
|
|
|
+</div>
|
|
|
+<div class="details">
|
|
|
+<ul class="blockList">
|
|
|
+<li class="blockList">
|
|
|
+<!-- ========= CONSTRUCTOR DETAIL ======== -->
|
|
|
+<ul class="blockList">
|
|
|
+<li class="blockList"><a name="constructor_detail">
|
|
|
+<!-- -->
|
|
|
+</a>
|
|
|
+<h3>构造器详细资料</h3>
|
|
|
+<a name="ClusterCanalConnector(java.lang.String, java.lang.String, java.lang.String, com.alibaba.otter.canal.client.CanalNodeAccessStrategy)">
|
|
|
+<!-- -->
|
|
|
+</a>
|
|
|
+<ul class="blockListLast">
|
|
|
+<li class="blockList">
|
|
|
+<h4>ClusterCanalConnector</h4>
|
|
|
+<pre>public ClusterCanalConnector(<a href="http://docs.oracle.com/javase/6/docs/api/java/lang/String.html?is-external=true" title="java.lang中的类或接口">String</a> username,
|
|
|
+ <a href="http://docs.oracle.com/javase/6/docs/api/java/lang/String.html?is-external=true" title="java.lang中的类或接口">String</a> password,
|
|
|
+ <a href="http://docs.oracle.com/javase/6/docs/api/java/lang/String.html?is-external=true" title="java.lang中的类或接口">String</a> destination,
|
|
|
+ <a href="../../../../../../com/alibaba/otter/canal/client/CanalNodeAccessStrategy.html" title="com.alibaba.otter.canal.client中的接口">CanalNodeAccessStrategy</a> accessStrategy)</pre>
|
|
|
+</li>
|
|
|
+</ul>
|
|
|
+</li>
|
|
|
+</ul>
|
|
|
+<!-- ============ METHOD DETAIL ========== -->
|
|
|
+<ul class="blockList">
|
|
|
+<li class="blockList"><a name="method_detail">
|
|
|
+<!-- -->
|
|
|
+</a>
|
|
|
+<h3>方法详细资料</h3>
|
|
|
+<a name="connect()">
|
|
|
+<!-- -->
|
|
|
+</a>
|
|
|
+<ul class="blockList">
|
|
|
+<li class="blockList">
|
|
|
+<h4>connect</h4>
|
|
|
+<pre>public void connect()
|
|
|
+ throws com.alibaba.otter.canal.protocol.exception.CanalClientException</pre>
|
|
|
+<div class="block"><strong>从接口复制的说明: <code><a href="../../../../../../com/alibaba/otter/canal/client/CanalConnector.html#connect()">CanalConnector</a></code></strong></div>
|
|
|
+<div class="block">链接对应的canal server</div>
|
|
|
+<dl>
|
|
|
+<dt><strong>指定者:</strong></dt>
|
|
|
+<dd><code><a href="../../../../../../com/alibaba/otter/canal/client/CanalConnector.html#connect()">connect</a></code> 在接口中 <code><a href="../../../../../../com/alibaba/otter/canal/client/CanalConnector.html" title="com.alibaba.otter.canal.client中的接口">CanalConnector</a></code></dd>
|
|
|
+<dt><span class="strong">抛出:</span></dt>
|
|
|
+<dd><code>com.alibaba.otter.canal.protocol.exception.CanalClientException</code></dd></dl>
|
|
|
+</li>
|
|
|
+</ul>
|
|
|
+<a name="checkValid()">
|
|
|
+<!-- -->
|
|
|
+</a>
|
|
|
+<ul class="blockList">
|
|
|
+<li class="blockList">
|
|
|
+<h4>checkValid</h4>
|
|
|
+<pre>public boolean checkValid()</pre>
|
|
|
+<div class="block"><strong>从接口复制的说明: <code><a href="../../../../../../com/alibaba/otter/canal/client/CanalConnector.html#checkValid()">CanalConnector</a></code></strong></div>
|
|
|
+<div class="block">检查下链接是否合法
|
|
|
+
|
|
|
+ <pre>
|
|
|
+ 几种case下链接不合法:
|
|
|
+ 1. 链接canal server失败,一直没有一个可用的链接,返回false
|
|
|
+ 2. 当前客户端在进行running抢占的时候,做为备份节点存在,非处于工作节点,返回false
|
|
|
+
|
|
|
+ 说明:
|
|
|
+ a. 当前客户端一旦做为备份节点存在,当前所有的对<a href="../../../../../../com/alibaba/otter/canal/client/CanalConnector.html" title="com.alibaba.otter.canal.client中的接口">CanalConnector</a>的操作都会处于阻塞状态,直到转为工作节点
|
|
|
+ b. 所以业务方最好定时调用checkValid()方法用,比如调用CanalConnector所在线程的interrupt,直接退出CanalConnector,并根据自己的需要退出自己的资源
|
|
|
+ </pre></div>
|
|
|
+<dl>
|
|
|
+<dt><strong>指定者:</strong></dt>
|
|
|
+<dd><code><a href="../../../../../../com/alibaba/otter/canal/client/CanalConnector.html#checkValid()">checkValid</a></code> 在接口中 <code><a href="../../../../../../com/alibaba/otter/canal/client/CanalConnector.html" title="com.alibaba.otter.canal.client中的接口">CanalConnector</a></code></dd>
|
|
|
+</dl>
|
|
|
+</li>
|
|
|
+</ul>
|
|
|
+<a name="disconnect()">
|
|
|
+<!-- -->
|
|
|
+</a>
|
|
|
+<ul class="blockList">
|
|
|
+<li class="blockList">
|
|
|
+<h4>disconnect</h4>
|
|
|
+<pre>public void disconnect()
|
|
|
+ throws com.alibaba.otter.canal.protocol.exception.CanalClientException</pre>
|
|
|
+<div class="block"><strong>从接口复制的说明: <code><a href="../../../../../../com/alibaba/otter/canal/client/CanalConnector.html#disconnect()">CanalConnector</a></code></strong></div>
|
|
|
+<div class="block">释放链接</div>
|
|
|
+<dl>
|
|
|
+<dt><strong>指定者:</strong></dt>
|
|
|
+<dd><code><a href="../../../../../../com/alibaba/otter/canal/client/CanalConnector.html#disconnect()">disconnect</a></code> 在接口中 <code><a href="../../../../../../com/alibaba/otter/canal/client/CanalConnector.html" title="com.alibaba.otter.canal.client中的接口">CanalConnector</a></code></dd>
|
|
|
+<dt><span class="strong">抛出:</span></dt>
|
|
|
+<dd><code>com.alibaba.otter.canal.protocol.exception.CanalClientException</code></dd></dl>
|
|
|
+</li>
|
|
|
+</ul>
|
|
|
+<a name="subscribe()">
|
|
|
+<!-- -->
|
|
|
+</a>
|
|
|
+<ul class="blockList">
|
|
|
+<li class="blockList">
|
|
|
+<h4>subscribe</h4>
|
|
|
+<pre>public void subscribe()
|
|
|
+ throws com.alibaba.otter.canal.protocol.exception.CanalClientException</pre>
|
|
|
+<div class="block"><strong>从接口复制的说明: <code><a href="../../../../../../com/alibaba/otter/canal/client/CanalConnector.html#subscribe()">CanalConnector</a></code></strong></div>
|
|
|
+<div class="block">客户端订阅,不提交客户端filter,以服务端的filter为准</div>
|
|
|
+<dl>
|
|
|
+<dt><strong>指定者:</strong></dt>
|
|
|
+<dd><code><a href="../../../../../../com/alibaba/otter/canal/client/CanalConnector.html#subscribe()">subscribe</a></code> 在接口中 <code><a href="../../../../../../com/alibaba/otter/canal/client/CanalConnector.html" title="com.alibaba.otter.canal.client中的接口">CanalConnector</a></code></dd>
|
|
|
+<dt><span class="strong">抛出:</span></dt>
|
|
|
+<dd><code>com.alibaba.otter.canal.protocol.exception.CanalClientException</code></dd></dl>
|
|
|
+</li>
|
|
|
+</ul>
|
|
|
+<a name="subscribe(java.lang.String)">
|
|
|
+<!-- -->
|
|
|
+</a>
|
|
|
+<ul class="blockList">
|
|
|
+<li class="blockList">
|
|
|
+<h4>subscribe</h4>
|
|
|
+<pre>public void subscribe(<a href="http://docs.oracle.com/javase/6/docs/api/java/lang/String.html?is-external=true" title="java.lang中的类或接口">String</a> filter)
|
|
|
+ throws com.alibaba.otter.canal.protocol.exception.CanalClientException</pre>
|
|
|
+<div class="block"><strong>从接口复制的说明: <code><a href="../../../../../../com/alibaba/otter/canal/client/CanalConnector.html#subscribe(java.lang.String)">CanalConnector</a></code></strong></div>
|
|
|
+<div class="block">客户端订阅,重复订阅时会更新对应的filter信息
|
|
|
+
|
|
|
+ <pre>
|
|
|
+ 说明:
|
|
|
+ a. 如果本次订阅中filter信息为空,则直接使用canal server服务端配置的filter信息
|
|
|
+ b. 如果本次订阅中filter信息不为空,目前会直接替换canal server服务端配置的filter信息,以本次提交的为准
|
|
|
+
|
|
|
+ TODO: 后续可以考虑,如果本次提交的filter不为空,在执行过滤时,是对canal server filter + 本次filter的交集处理,达到只取1份binlog数据,多个客户端消费不同的表
|
|
|
+ </pre></div>
|
|
|
+<dl>
|
|
|
+<dt><strong>指定者:</strong></dt>
|
|
|
+<dd><code><a href="../../../../../../com/alibaba/otter/canal/client/CanalConnector.html#subscribe(java.lang.String)">subscribe</a></code> 在接口中 <code><a href="../../../../../../com/alibaba/otter/canal/client/CanalConnector.html" title="com.alibaba.otter.canal.client中的接口">CanalConnector</a></code></dd>
|
|
|
+<dt><span class="strong">抛出:</span></dt>
|
|
|
+<dd><code>com.alibaba.otter.canal.protocol.exception.CanalClientException</code></dd></dl>
|
|
|
+</li>
|
|
|
+</ul>
|
|
|
+<a name="unsubscribe()">
|
|
|
+<!-- -->
|
|
|
+</a>
|
|
|
+<ul class="blockList">
|
|
|
+<li class="blockList">
|
|
|
+<h4>unsubscribe</h4>
|
|
|
+<pre>public void unsubscribe()
|
|
|
+ throws com.alibaba.otter.canal.protocol.exception.CanalClientException</pre>
|
|
|
+<div class="block"><strong>从接口复制的说明: <code><a href="../../../../../../com/alibaba/otter/canal/client/CanalConnector.html#unsubscribe()">CanalConnector</a></code></strong></div>
|
|
|
+<div class="block">取消订阅</div>
|
|
|
+<dl>
|
|
|
+<dt><strong>指定者:</strong></dt>
|
|
|
+<dd><code><a href="../../../../../../com/alibaba/otter/canal/client/CanalConnector.html#unsubscribe()">unsubscribe</a></code> 在接口中 <code><a href="../../../../../../com/alibaba/otter/canal/client/CanalConnector.html" title="com.alibaba.otter.canal.client中的接口">CanalConnector</a></code></dd>
|
|
|
+<dt><span class="strong">抛出:</span></dt>
|
|
|
+<dd><code>com.alibaba.otter.canal.protocol.exception.CanalClientException</code></dd></dl>
|
|
|
+</li>
|
|
|
+</ul>
|
|
|
+<a name="get(int)">
|
|
|
+<!-- -->
|
|
|
+</a>
|
|
|
+<ul class="blockList">
|
|
|
+<li class="blockList">
|
|
|
+<h4>get</h4>
|
|
|
+<pre>public com.alibaba.otter.canal.protocol.Message get(int batchSize)
|
|
|
+ throws com.alibaba.otter.canal.protocol.exception.CanalClientException</pre>
|
|
|
+<div class="block"><strong>从接口复制的说明: <code><a href="../../../../../../com/alibaba/otter/canal/client/CanalConnector.html#get(int)">CanalConnector</a></code></strong></div>
|
|
|
+<div class="block">获取数据,自动进行确认,该方法返回的条件:尝试拿batchSize条记录,有多少取多少,不会阻塞等待</div>
|
|
|
+<dl>
|
|
|
+<dt><strong>指定者:</strong></dt>
|
|
|
+<dd><code><a href="../../../../../../com/alibaba/otter/canal/client/CanalConnector.html#get(int)">get</a></code> 在接口中 <code><a href="../../../../../../com/alibaba/otter/canal/client/CanalConnector.html" title="com.alibaba.otter.canal.client中的接口">CanalConnector</a></code></dd>
|
|
|
+<dt><span class="strong">返回:</span></dt><dd></dd>
|
|
|
+<dt><span class="strong">抛出:</span></dt>
|
|
|
+<dd><code>com.alibaba.otter.canal.protocol.exception.CanalClientException</code></dd></dl>
|
|
|
+</li>
|
|
|
+</ul>
|
|
|
+<a name="get(int, java.lang.Long, java.util.concurrent.TimeUnit)">
|
|
|
+<!-- -->
|
|
|
+</a>
|
|
|
+<ul class="blockList">
|
|
|
+<li class="blockList">
|
|
|
+<h4>get</h4>
|
|
|
+<pre>public com.alibaba.otter.canal.protocol.Message get(int batchSize,
|
|
|
+ <a href="http://docs.oracle.com/javase/6/docs/api/java/lang/Long.html?is-external=true" title="java.lang中的类或接口">Long</a> timeout,
|
|
|
+ <a href="http://docs.oracle.com/javase/6/docs/api/java/util/concurrent/TimeUnit.html?is-external=true" title="java.util.concurrent中的类或接口">TimeUnit</a> unit)
|
|
|
+ throws com.alibaba.otter.canal.protocol.exception.CanalClientException</pre>
|
|
|
+<div class="block"><strong>从接口复制的说明: <code><a href="../../../../../../com/alibaba/otter/canal/client/CanalConnector.html#get(int, java.lang.Long, java.util.concurrent.TimeUnit)">CanalConnector</a></code></strong></div>
|
|
|
+<div class="block">获取数据,自动进行确认
|
|
|
+
|
|
|
+ <pre>
|
|
|
+ 该方法返回的条件:
|
|
|
+ a. 拿够batchSize条记录或者超过timeout时间
|
|
|
+ b. 如果timeout=0,则阻塞至拿到batchSize记录才返回
|
|
|
+ </pre></div>
|
|
|
+<dl>
|
|
|
+<dt><strong>指定者:</strong></dt>
|
|
|
+<dd><code><a href="../../../../../../com/alibaba/otter/canal/client/CanalConnector.html#get(int, java.lang.Long, java.util.concurrent.TimeUnit)">get</a></code> 在接口中 <code><a href="../../../../../../com/alibaba/otter/canal/client/CanalConnector.html" title="com.alibaba.otter.canal.client中的接口">CanalConnector</a></code></dd>
|
|
|
+<dt><span class="strong">返回:</span></dt><dd></dd>
|
|
|
+<dt><span class="strong">抛出:</span></dt>
|
|
|
+<dd><code>com.alibaba.otter.canal.protocol.exception.CanalClientException</code></dd></dl>
|
|
|
+</li>
|
|
|
+</ul>
|
|
|
+<a name="getWithoutAck(int)">
|
|
|
+<!-- -->
|
|
|
+</a>
|
|
|
+<ul class="blockList">
|
|
|
+<li class="blockList">
|
|
|
+<h4>getWithoutAck</h4>
|
|
|
+<pre>public com.alibaba.otter.canal.protocol.Message getWithoutAck(int batchSize)
|
|
|
+ throws com.alibaba.otter.canal.protocol.exception.CanalClientException</pre>
|
|
|
+<div class="block"><strong>从接口复制的说明: <code><a href="../../../../../../com/alibaba/otter/canal/client/CanalConnector.html#getWithoutAck(int)">CanalConnector</a></code></strong></div>
|
|
|
+<div class="block">不指定 position 获取事件,该方法返回的条件: 尝试拿batchSize条记录,有多少取多少,不会阻塞等待<br/>
|
|
|
+ canal 会记住此 client 最新的position。 <br/>
|
|
|
+ 如果是第一次 fetch,则会从 canal 中保存的最老一条数据开始输出。</div>
|
|
|
+<dl>
|
|
|
+<dt><strong>指定者:</strong></dt>
|
|
|
+<dd><code><a href="../../../../../../com/alibaba/otter/canal/client/CanalConnector.html#getWithoutAck(int)">getWithoutAck</a></code> 在接口中 <code><a href="../../../../../../com/alibaba/otter/canal/client/CanalConnector.html" title="com.alibaba.otter.canal.client中的接口">CanalConnector</a></code></dd>
|
|
|
+<dt><span class="strong">抛出:</span></dt>
|
|
|
+<dd><code>com.alibaba.otter.canal.protocol.exception.CanalClientException</code></dd></dl>
|
|
|
+</li>
|
|
|
+</ul>
|
|
|
+<a name="getWithoutAck(int, java.lang.Long, java.util.concurrent.TimeUnit)">
|
|
|
+<!-- -->
|
|
|
+</a>
|
|
|
+<ul class="blockList">
|
|
|
+<li class="blockList">
|
|
|
+<h4>getWithoutAck</h4>
|
|
|
+<pre>public com.alibaba.otter.canal.protocol.Message getWithoutAck(int batchSize,
|
|
|
+ <a href="http://docs.oracle.com/javase/6/docs/api/java/lang/Long.html?is-external=true" title="java.lang中的类或接口">Long</a> timeout,
|
|
|
+ <a href="http://docs.oracle.com/javase/6/docs/api/java/util/concurrent/TimeUnit.html?is-external=true" title="java.util.concurrent中的类或接口">TimeUnit</a> unit)
|
|
|
+ throws com.alibaba.otter.canal.protocol.exception.CanalClientException</pre>
|
|
|
+<div class="block"><strong>从接口复制的说明: <code><a href="../../../../../../com/alibaba/otter/canal/client/CanalConnector.html#getWithoutAck(int, java.lang.Long, java.util.concurrent.TimeUnit)">CanalConnector</a></code></strong></div>
|
|
|
+<div class="block">不指定 position 获取事件.
|
|
|
+
|
|
|
+ <pre>
|
|
|
+ 该方法返回的条件:
|
|
|
+ a. 拿够batchSize条记录或者超过timeout时间
|
|
|
+ b. 如果timeout=0,则阻塞至拿到batchSize记录才返回
|
|
|
+ </pre>
|
|
|
+
|
|
|
+ canal 会记住此 client 最新的position。 <br/>
|
|
|
+ 如果是第一次 fetch,则会从 canal 中保存的最老一条数据开始输出。</div>
|
|
|
+<dl>
|
|
|
+<dt><strong>指定者:</strong></dt>
|
|
|
+<dd><code><a href="../../../../../../com/alibaba/otter/canal/client/CanalConnector.html#getWithoutAck(int, java.lang.Long, java.util.concurrent.TimeUnit)">getWithoutAck</a></code> 在接口中 <code><a href="../../../../../../com/alibaba/otter/canal/client/CanalConnector.html" title="com.alibaba.otter.canal.client中的接口">CanalConnector</a></code></dd>
|
|
|
+<dt><span class="strong">返回:</span></dt><dd></dd>
|
|
|
+<dt><span class="strong">抛出:</span></dt>
|
|
|
+<dd><code>com.alibaba.otter.canal.protocol.exception.CanalClientException</code></dd></dl>
|
|
|
+</li>
|
|
|
+</ul>
|
|
|
+<a name="rollback(long)">
|
|
|
+<!-- -->
|
|
|
+</a>
|
|
|
+<ul class="blockList">
|
|
|
+<li class="blockList">
|
|
|
+<h4>rollback</h4>
|
|
|
+<pre>public void rollback(long batchId)
|
|
|
+ throws com.alibaba.otter.canal.protocol.exception.CanalClientException</pre>
|
|
|
+<div class="block"><strong>从接口复制的说明: <code><a href="../../../../../../com/alibaba/otter/canal/client/CanalConnector.html#rollback(long)">CanalConnector</a></code></strong></div>
|
|
|
+<div class="block">回滚到未进行 <code>ack</code> 的地方,指定回滚具体的batchId</div>
|
|
|
+<dl>
|
|
|
+<dt><strong>指定者:</strong></dt>
|
|
|
+<dd><code><a href="../../../../../../com/alibaba/otter/canal/client/CanalConnector.html#rollback(long)">rollback</a></code> 在接口中 <code><a href="../../../../../../com/alibaba/otter/canal/client/CanalConnector.html" title="com.alibaba.otter.canal.client中的接口">CanalConnector</a></code></dd>
|
|
|
+<dt><span class="strong">抛出:</span></dt>
|
|
|
+<dd><code>com.alibaba.otter.canal.protocol.exception.CanalClientException</code></dd></dl>
|
|
|
+</li>
|
|
|
+</ul>
|
|
|
+<a name="rollback()">
|
|
|
+<!-- -->
|
|
|
+</a>
|
|
|
+<ul class="blockList">
|
|
|
+<li class="blockList">
|
|
|
+<h4>rollback</h4>
|
|
|
+<pre>public void rollback()
|
|
|
+ throws com.alibaba.otter.canal.protocol.exception.CanalClientException</pre>
|
|
|
+<div class="block"><strong>从接口复制的说明: <code><a href="../../../../../../com/alibaba/otter/canal/client/CanalConnector.html#rollback()">CanalConnector</a></code></strong></div>
|
|
|
+<div class="block">回滚到未进行 <code>ack</code> 的地方,下次fetch的时候,可以从最后一个没有 <code>ack</code> 的地方开始拿</div>
|
|
|
+<dl>
|
|
|
+<dt><strong>指定者:</strong></dt>
|
|
|
+<dd><code><a href="../../../../../../com/alibaba/otter/canal/client/CanalConnector.html#rollback()">rollback</a></code> 在接口中 <code><a href="../../../../../../com/alibaba/otter/canal/client/CanalConnector.html" title="com.alibaba.otter.canal.client中的接口">CanalConnector</a></code></dd>
|
|
|
+<dt><span class="strong">抛出:</span></dt>
|
|
|
+<dd><code>com.alibaba.otter.canal.protocol.exception.CanalClientException</code></dd></dl>
|
|
|
+</li>
|
|
|
+</ul>
|
|
|
+<a name="ack(long)">
|
|
|
+<!-- -->
|
|
|
+</a>
|
|
|
+<ul class="blockList">
|
|
|
+<li class="blockList">
|
|
|
+<h4>ack</h4>
|
|
|
+<pre>public void ack(long batchId)
|
|
|
+ throws com.alibaba.otter.canal.protocol.exception.CanalClientException</pre>
|
|
|
+<div class="block"><strong>从接口复制的说明: <code><a href="../../../../../../com/alibaba/otter/canal/client/CanalConnector.html#ack(long)">CanalConnector</a></code></strong></div>
|
|
|
+<div class="block">进行 batch id 的确认。确认之后,小于等于此 batchId 的 Message 都会被确认。</div>
|
|
|
+<dl>
|
|
|
+<dt><strong>指定者:</strong></dt>
|
|
|
+<dd><code><a href="../../../../../../com/alibaba/otter/canal/client/CanalConnector.html#ack(long)">ack</a></code> 在接口中 <code><a href="../../../../../../com/alibaba/otter/canal/client/CanalConnector.html" title="com.alibaba.otter.canal.client中的接口">CanalConnector</a></code></dd>
|
|
|
+<dt><span class="strong">抛出:</span></dt>
|
|
|
+<dd><code>com.alibaba.otter.canal.protocol.exception.CanalClientException</code></dd></dl>
|
|
|
+</li>
|
|
|
+</ul>
|
|
|
+<a name="getUsername()">
|
|
|
+<!-- -->
|
|
|
+</a>
|
|
|
+<ul class="blockList">
|
|
|
+<li class="blockList">
|
|
|
+<h4>getUsername</h4>
|
|
|
+<pre>public <a href="http://docs.oracle.com/javase/6/docs/api/java/lang/String.html?is-external=true" title="java.lang中的类或接口">String</a> getUsername()</pre>
|
|
|
+</li>
|
|
|
+</ul>
|
|
|
+<a name="setUsername(java.lang.String)">
|
|
|
+<!-- -->
|
|
|
+</a>
|
|
|
+<ul class="blockList">
|
|
|
+<li class="blockList">
|
|
|
+<h4>setUsername</h4>
|
|
|
+<pre>public void setUsername(<a href="http://docs.oracle.com/javase/6/docs/api/java/lang/String.html?is-external=true" title="java.lang中的类或接口">String</a> username)</pre>
|
|
|
+</li>
|
|
|
+</ul>
|
|
|
+<a name="getPassword()">
|
|
|
+<!-- -->
|
|
|
+</a>
|
|
|
+<ul class="blockList">
|
|
|
+<li class="blockList">
|
|
|
+<h4>getPassword</h4>
|
|
|
+<pre>public <a href="http://docs.oracle.com/javase/6/docs/api/java/lang/String.html?is-external=true" title="java.lang中的类或接口">String</a> getPassword()</pre>
|
|
|
+</li>
|
|
|
+</ul>
|
|
|
+<a name="setPassword(java.lang.String)">
|
|
|
+<!-- -->
|
|
|
+</a>
|
|
|
+<ul class="blockList">
|
|
|
+<li class="blockList">
|
|
|
+<h4>setPassword</h4>
|
|
|
+<pre>public void setPassword(<a href="http://docs.oracle.com/javase/6/docs/api/java/lang/String.html?is-external=true" title="java.lang中的类或接口">String</a> password)</pre>
|
|
|
+</li>
|
|
|
+</ul>
|
|
|
+<a name="getSoTimeout()">
|
|
|
+<!-- -->
|
|
|
+</a>
|
|
|
+<ul class="blockList">
|
|
|
+<li class="blockList">
|
|
|
+<h4>getSoTimeout</h4>
|
|
|
+<pre>public int getSoTimeout()</pre>
|
|
|
+</li>
|
|
|
+</ul>
|
|
|
+<a name="setSoTimeout(int)">
|
|
|
+<!-- -->
|
|
|
+</a>
|
|
|
+<ul class="blockList">
|
|
|
+<li class="blockList">
|
|
|
+<h4>setSoTimeout</h4>
|
|
|
+<pre>public void setSoTimeout(int soTimeout)</pre>
|
|
|
+</li>
|
|
|
+</ul>
|
|
|
+<a name="getRetryTimes()">
|
|
|
+<!-- -->
|
|
|
+</a>
|
|
|
+<ul class="blockList">
|
|
|
+<li class="blockList">
|
|
|
+<h4>getRetryTimes</h4>
|
|
|
+<pre>public int getRetryTimes()</pre>
|
|
|
+</li>
|
|
|
+</ul>
|
|
|
+<a name="setRetryTimes(int)">
|
|
|
+<!-- -->
|
|
|
+</a>
|
|
|
+<ul class="blockList">
|
|
|
+<li class="blockList">
|
|
|
+<h4>setRetryTimes</h4>
|
|
|
+<pre>public void setRetryTimes(int retryTimes)</pre>
|
|
|
+</li>
|
|
|
+</ul>
|
|
|
+<a name="getRetryInterval()">
|
|
|
+<!-- -->
|
|
|
+</a>
|
|
|
+<ul class="blockList">
|
|
|
+<li class="blockList">
|
|
|
+<h4>getRetryInterval</h4>
|
|
|
+<pre>public int getRetryInterval()</pre>
|
|
|
+</li>
|
|
|
+</ul>
|
|
|
+<a name="setRetryInterval(int)">
|
|
|
+<!-- -->
|
|
|
+</a>
|
|
|
+<ul class="blockList">
|
|
|
+<li class="blockList">
|
|
|
+<h4>setRetryInterval</h4>
|
|
|
+<pre>public void setRetryInterval(int retryInterval)</pre>
|
|
|
+</li>
|
|
|
+</ul>
|
|
|
+<a name="getAccessStrategy()">
|
|
|
+<!-- -->
|
|
|
+</a>
|
|
|
+<ul class="blockList">
|
|
|
+<li class="blockList">
|
|
|
+<h4>getAccessStrategy</h4>
|
|
|
+<pre>public <a href="../../../../../../com/alibaba/otter/canal/client/CanalNodeAccessStrategy.html" title="com.alibaba.otter.canal.client中的接口">CanalNodeAccessStrategy</a> getAccessStrategy()</pre>
|
|
|
+</li>
|
|
|
+</ul>
|
|
|
+<a name="setAccessStrategy(com.alibaba.otter.canal.client.CanalNodeAccessStrategy)">
|
|
|
+<!-- -->
|
|
|
+</a>
|
|
|
+<ul class="blockList">
|
|
|
+<li class="blockList">
|
|
|
+<h4>setAccessStrategy</h4>
|
|
|
+<pre>public void setAccessStrategy(<a href="../../../../../../com/alibaba/otter/canal/client/CanalNodeAccessStrategy.html" title="com.alibaba.otter.canal.client中的接口">CanalNodeAccessStrategy</a> accessStrategy)</pre>
|
|
|
+</li>
|
|
|
+</ul>
|
|
|
+<a name="getCurrentConnector()">
|
|
|
+<!-- -->
|
|
|
+</a>
|
|
|
+<ul class="blockListLast">
|
|
|
+<li class="blockList">
|
|
|
+<h4>getCurrentConnector</h4>
|
|
|
+<pre>public <a href="../../../../../../com/alibaba/otter/canal/client/impl/SimpleCanalConnector.html" title="com.alibaba.otter.canal.client.impl中的类">SimpleCanalConnector</a> getCurrentConnector()</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><a href="#skip-navbar_bottom" title="跳过导航链接"></a><a name="navbar_bottom_firstrow">
|
|
|
+<!-- -->
|
|
|
+</a>
|
|
|
+<ul class="navList" title="导航">
|
|
|
+<li><a href="../../../../../../overview-summary.html">概览</a></li>
|
|
|
+<li><a href="package-summary.html">程序包</a></li>
|
|
|
+<li class="navBarCell1Rev">类</li>
|
|
|
+<li><a href="class-use/ClusterCanalConnector.html">使用</a></li>
|
|
|
+<li><a href="package-tree.html">树</a></li>
|
|
|
+<li><a href="../../../../../../deprecated-list.html">已过时</a></li>
|
|
|
+<li><a href="../../../../../../index-all.html">索引</a></li>
|
|
|
+</ul>
|
|
|
+<div class="aboutLanguage"><em>canal.client-1.0.13</em></div>
|
|
|
+</div>
|
|
|
+<div class="subNav">
|
|
|
+<ul class="navList">
|
|
|
+<li>上一个类</li>
|
|
|
+<li><a href="../../../../../../com/alibaba/otter/canal/client/impl/ClusterNodeAccessStrategy.html" title="com.alibaba.otter.canal.client.impl中的类"><span class="strong">下一个类</span></a></li>
|
|
|
+</ul>
|
|
|
+<ul class="navList">
|
|
|
+<li><a href="../../../../../../index.html?com/alibaba/otter/canal/client/impl/ClusterCanalConnector.html" target="_top">框架</a></li>
|
|
|
+<li><a href="ClusterCanalConnector.html" target="_top">无框架</a></li>
|
|
|
+</ul>
|
|
|
+<ul class="navList" id="allclasses_navbar_bottom">
|
|
|
+<li><a href="../../../../../../allclasses-noframe.html">所有类</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>概要: </li>
|
|
|
+<li>嵌套 | </li>
|
|
|
+<li>字段 | </li>
|
|
|
+<li><a href="#constructor_summary">构造器</a> | </li>
|
|
|
+<li><a href="#method_summary">方法</a></li>
|
|
|
+</ul>
|
|
|
+<ul class="subNavList">
|
|
|
+<li>详细资料: </li>
|
|
|
+<li>字段 | </li>
|
|
|
+<li><a href="#constructor_detail">构造器</a> | </li>
|
|
|
+<li><a href="#method_detail">方法</a></li>
|
|
|
+</ul>
|
|
|
+</div>
|
|
|
+<a name="skip-navbar_bottom">
|
|
|
+<!-- -->
|
|
|
+</a></div>
|
|
|
+<!-- ======== END OF BOTTOM NAVBAR ======= -->
|
|
|
+<p class="legalCopy"><small>Copyright © 2013. All rights reserved.</small></p>
|
|
|
+</body>
|
|
|
+</html>
|