forked from docs/doc-exports
Reviewed-by: Pruthi, Vineet <vineet.pruthi@t-systems.com> Co-authored-by: luhuayi <luhuayi@huawei.com> Co-committed-by: luhuayi <luhuayi@huawei.com>
257 lines
57 KiB
HTML
257 lines
57 KiB
HTML
<a name="EN-US_TOPIC_0000001811609965"></a><a name="EN-US_TOPIC_0000001811609965"></a>
|
|
|
|
<h1 class="topictitle1">Hybrid Data Warehouse Functions</h1>
|
|
<div id="body0000001490854057"><div class="section" id="EN-US_TOPIC_0000001811609965__section111833513559"><h4 class="sectiontitle">hstore_light_merge(rel_name text)</h4><p id="EN-US_TOPIC_0000001811609965__p1570053018110">Description: This function is used to manually perform lightweight cleanup on HStore tables and holds the level-3 lock of the target table.</p>
|
|
<p id="EN-US_TOPIC_0000001811609965__p136441319310">Return type: int</p>
|
|
<p id="EN-US_TOPIC_0000001811609965__p1868611814316">Example:</p>
|
|
<div class="codecoloring" codetype="Sql" id="EN-US_TOPIC_0000001811609965__s6f2a8091f7c749d2b4794a0c2b847f25"><div class="highlight"><table class="highlighttable"><tr><td class="linenos"><div class="linenodiv"><pre><span class="normal">1</span></pre></div></td><td class="code"><div><pre><span></span><span class="k">SELECT</span><span class="w"> </span><span class="n">hstore_light_merge</span><span class="p">(</span><span class="s1">'reason_select'</span><span class="p">);</span>
|
|
</pre></div></td></tr></table></div>
|
|
</div>
|
|
</div>
|
|
<div class="section" id="EN-US_TOPIC_0000001811609965__section299316461039"><h4 class="sectiontitle">hstore_full_merge(rel_name text, partitionName text)</h4><p id="EN-US_TOPIC_0000001811609965__p29931946036">Description: This function is used to manually perform full cleanup on HStore tables. The second input parameter is optional and is used to specify a single partition for operations.</p>
|
|
<p id="EN-US_TOPIC_0000001811609965__p299334617312">Return type: int</p>
|
|
<div class="notice" id="EN-US_TOPIC_0000001811609965__note7302124416519"><span class="noticetitle"><img src="public_sys-resources/notice_3.0-en-us.png"> </span><div class="noticebody"><ul id="EN-US_TOPIC_0000001811609965__ul57954194615"><li id="EN-US_TOPIC_0000001811609965__li187955144617">This operation forcibly merges all the visible operations of the delta table to the primary table, and then creates an empty delta table. During this period, this operation holds the level-8 lock of the table.</li><li id="EN-US_TOPIC_0000001811609965__li12795101164615">The duration of this operation depends on the amount of data in the delta table. You must enable the HStore clearing thread to ensure unnecessary data in the HStore table is cleared in a timely manner.</li><li id="EN-US_TOPIC_0000001811609965__li161659912385">The second parameter <strong id="EN-US_TOPIC_0000001811609965__b471910125263">partitionName</strong> is only supported by clusters of version 9.1.0 and later. However, these versions do not allow calling this function via <strong id="EN-US_TOPIC_0000001811609965__b1171971214269">call</strong> because it lacks reload capability.</li></ul>
|
|
</div></div>
|
|
<p id="EN-US_TOPIC_0000001811609965__p75040406186">Example:</p>
|
|
<div class="codecoloring" codetype="Sql" id="EN-US_TOPIC_0000001811609965__screen89931546336"><div class="highlight"><table class="highlighttable"><tr><td class="linenos"><div class="linenodiv"><pre><span class="normal">1</span></pre></div></td><td class="code"><div><pre><span></span><span class="k">SELECT</span><span class="w"> </span><span class="n">hstore_full_merge</span><span class="p">(</span><span class="s1">'reason_select'</span><span class="p">,</span><span class="w"> </span><span class="s1">'part1'</span><span class="p">);</span>
|
|
</pre></div></td></tr></table></div>
|
|
</div>
|
|
</div>
|
|
<div class="section" id="EN-US_TOPIC_0000001811609965__section143989322016"><h4 class="sectiontitle">pgxc_get_small_cu_info(rel_name text, row_count int)</h4><p id="EN-US_TOPIC_0000001811609965__p33985321901">Description: Obtains the small CU information of the target table. The second parameter <strong id="EN-US_TOPIC_0000001811609965__b7133172819512">row_count</strong> is optional and indicates the small CU threshold. If the number of live tuples in a CU is fewer than the threshold, the CU is considered as a small CU. The default value is <strong id="EN-US_TOPIC_0000001811609965__b04531314869">200</strong>. This function is supported only by clusters of version 8.2.1.200 or later.</p>
|
|
<p id="EN-US_TOPIC_0000001811609965__p53986325017"><strong id="EN-US_TOPIC_0000001811609965__b124741053192">Return type</strong>: record</p>
|
|
<p id="EN-US_TOPIC_0000001811609965__p439843217013">Return value:</p>
|
|
<p id="EN-US_TOPIC_0000001811609965__p103986321907"><strong id="EN-US_TOPIC_0000001811609965__b827090938104127">node_name</strong>: DN name.</p>
|
|
<p id="EN-US_TOPIC_0000001811609965__p1539815321011"><strong id="EN-US_TOPIC_0000001811609965__b662734912914">part_name</strong>: partition name. This column is empty for non-partitioned tables.</p>
|
|
<p id="EN-US_TOPIC_0000001811609965__p93989321012"><strong id="EN-US_TOPIC_0000001811609965__b2704792105">zero_cu_count</strong>: number of 0 CUs. If all data in a CU is deleted, the CU is called 0 CU.</p>
|
|
<p id="EN-US_TOPIC_0000001811609965__p69321828463"><strong id="EN-US_TOPIC_0000001811609965__b124891129181013">small_cu_count</strong>: number of small CUs. When a CU has live data that is less than the threshold, the CU is called a small CU.</p>
|
|
<p id="EN-US_TOPIC_0000001811609965__p102294351167"><strong id="EN-US_TOPIC_0000001811609965__b1190158161111">total_cu_count</strong>: total number of CUs.</p>
|
|
<p id="EN-US_TOPIC_0000001811609965__p15155205313147"><strong id="EN-US_TOPIC_0000001811609965__b1566841171713">sec_part_cu_num</strong>: number of CUs in each level-2 partition. This column is displayed only when <strong id="EN-US_TOPIC_0000001811609965__b029919202176">secondary_part_column</strong> is specified. This field is available only in clusters of version 8.3.0 or later.</p>
|
|
<p id="EN-US_TOPIC_0000001811609965__p865235841018">It should be noted that a CU may contain multiple columns.</p>
|
|
<p id="EN-US_TOPIC_0000001811609965__p1139883210017">Example:</p>
|
|
<div class="codecoloring" codetype="Sql" id="EN-US_TOPIC_0000001811609965__screen15398432002"><div class="highlight"><table class="highlighttable"><tr><td class="linenos"><div class="linenodiv"><pre><span class="normal">1</span>
|
|
<span class="normal">2</span>
|
|
<span class="normal">3</span>
|
|
<span class="normal">4</span>
|
|
<span class="normal">5</span>
|
|
<span class="normal">6</span></pre></div></td><td class="code"><div><pre><span></span><span class="k">SELECT</span><span class="w"> </span><span class="o">*</span><span class="w"> </span><span class="k">FROM</span><span class="w"> </span><span class="n">pgxc_get_small_cu_info</span><span class="p">(</span><span class="s1">'hs'</span><span class="p">);</span>
|
|
<span class="n">node_name</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="n">part_name</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="n">zero_cu_count</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="n">small_cu_count</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="n">total_cu_count</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="n">sec_part_cu_num</span><span class="w"> </span>
|
|
<span class="c1">-----------+-----------+---------------+----------------+----------------+------------------------------------------</span>
|
|
<span class="w"> </span><span class="n">datanode1</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">0</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">4</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">4</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="n">p1</span><span class="p">:</span><span class="mi">1</span><span class="w"> </span><span class="n">p2</span><span class="p">:</span><span class="mi">0</span><span class="w"> </span><span class="n">p3</span><span class="p">:</span><span class="mi">1</span><span class="w"> </span><span class="n">p4</span><span class="p">:</span><span class="mi">0</span><span class="w"> </span><span class="n">p5</span><span class="p">:</span><span class="mi">1</span><span class="w"> </span><span class="n">p6</span><span class="p">:</span><span class="mi">0</span><span class="w"> </span><span class="n">p7</span><span class="p">:</span><span class="mi">1</span><span class="w"> </span><span class="n">p8</span><span class="p">:</span><span class="mi">0</span><span class="w"> </span>
|
|
<span class="w"> </span><span class="n">datanode2</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">0</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">4</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">4</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="n">p1</span><span class="p">:</span><span class="mi">0</span><span class="w"> </span><span class="n">p2</span><span class="p">:</span><span class="mi">1</span><span class="w"> </span><span class="n">p3</span><span class="p">:</span><span class="mi">0</span><span class="w"> </span><span class="n">p4</span><span class="p">:</span><span class="mi">1</span><span class="w"> </span><span class="n">p5</span><span class="p">:</span><span class="mi">0</span><span class="w"> </span><span class="n">p6</span><span class="p">:</span><span class="mi">1</span><span class="w"> </span><span class="n">p7</span><span class="p">:</span><span class="mi">0</span><span class="w"> </span><span class="n">p8</span><span class="p">:</span><span class="mi">1</span><span class="w"> </span>
|
|
<span class="p">(</span><span class="mi">2</span><span class="w"> </span><span class="k">rows</span><span class="p">)</span>
|
|
</pre></div></td></tr></table></div>
|
|
</div>
|
|
</div>
|
|
<div class="section" id="EN-US_TOPIC_0000001811609965__section1337433919496"><h4 class="sectiontitle">gs_hstore_compaction(rel_name text, row_count int)</h4><p id="EN-US_TOPIC_0000001811609965__p143461423494">Description: Merges small CUs of the target table. The second parameter <strong id="EN-US_TOPIC_0000001811609965__b18299131316129">row_count</strong> is optional and indicates the small CU threshold. If the number of live tuples in a CU is fewer than the threshold, the CU is considered as a small CU. The default value is <strong id="EN-US_TOPIC_0000001811609965__b133001313171216">100</strong>. This function is supported only by version 8.2.1.200 or later.</p>
|
|
<p id="EN-US_TOPIC_0000001811609965__p17259115844910">Return type: int</p>
|
|
<p id="EN-US_TOPIC_0000001811609965__p892305213492"><strong id="EN-US_TOPIC_0000001811609965__b183441336181216">Return value</strong>: <strong id="EN-US_TOPIC_0000001811609965__b102213394123">numCompactCU</strong>, which indicates the number of small CUs to be merged.</p>
|
|
</div>
|
|
<div class="note" id="EN-US_TOPIC_0000001811609965__note6798142175910"><img src="public_sys-resources/note_3.0-en-us.png"><span class="notetitle"> </span><div class="notebody"><ul id="EN-US_TOPIC_0000001811609965__ul11722156509"><li id="EN-US_TOPIC_0000001811609965__li1172326208">A CU may contain multiple columns.</li><li id="EN-US_TOPIC_0000001811609965__li1172316002">The partition name cannot be input in the function. Currently, a single partition cannot be specified in this function.</li></ul>
|
|
</div></div>
|
|
<p id="EN-US_TOPIC_0000001811609965__p13991257175614">Example:</p>
|
|
<div class="codecoloring" codetype="Sql" id="EN-US_TOPIC_0000001811609965__screen725501312587"><div class="highlight"><table class="highlighttable"><tr><td class="linenos"><div class="linenodiv"><pre><span class="normal">1</span></pre></div></td><td class="code"><div><pre><span></span><span class="k">SELECT</span><span class="w"> </span><span class="n">gs_hstore_compaction</span><span class="p">(</span><span class="s1">'hs'</span><span class="p">,</span><span class="w"> </span><span class="mi">10</span><span class="p">);</span>
|
|
</pre></div></td></tr></table></div>
|
|
</div>
|
|
<div class="section" id="EN-US_TOPIC_0000001811609965__section983914383316"><h4 class="sectiontitle">pgxc_get_hstore_delta_info(rel_name text)</h4><p id="EN-US_TOPIC_0000001811609965__p13839134393315">Description: This function is used to obtain the delta table information of the target table, including the delta table size and the number of <strong id="EN-US_TOPIC_0000001811609965__b15279663323">INSERT</strong>, <strong id="EN-US_TOPIC_0000001811609965__b1384688322">DELETE</strong>, and <strong id="EN-US_TOPIC_0000001811609965__b13890898326">UPDATE </strong>records. This function is supported only by clusters of version 8.2.1.100 or later.</p>
|
|
<p id="EN-US_TOPIC_0000001811609965__p2083954363315">Return type: record</p>
|
|
<p id="EN-US_TOPIC_0000001811609965__p252285805817">Return value:</p>
|
|
<p id="EN-US_TOPIC_0000001811609965__p94796317591"><strong id="EN-US_TOPIC_0000001811609965__b1804519546">node_name</strong>: DN name.</p>
|
|
<p id="EN-US_TOPIC_0000001811609965__p87271619135910"><strong id="EN-US_TOPIC_0000001811609965__b8345030183313">part_name</strong>: partition name. This column is set to <strong id="EN-US_TOPIC_0000001811609965__b16320195203219">non-partition table</strong> if the table is not a partitioned table.</p>
|
|
<p id="EN-US_TOPIC_0000001811609965__p9257145115916"><strong id="EN-US_TOPIC_0000001811609965__b1433113443311">live_tup</strong>: number of live tuples.</p>
|
|
<p id="EN-US_TOPIC_0000001811609965__p1223014421014"><strong id="EN-US_TOPIC_0000001811609965__b15698191616223">n_ui_type</strong>: number of records with a type of <em id="EN-US_TOPIC_0000001811609965__i19698131682217">ui</em> (small CU combination and upsert insertion through update). An <strong id="EN-US_TOPIC_0000001811609965__b56640068353742">ui</strong> record represents a single or batch insertion. This parameter is supported only by 8.3.0.100 and later versions.</p>
|
|
<p id="EN-US_TOPIC_0000001811609965__p18878921204"><strong id="EN-US_TOPIC_0000001811609965__b1972193811339">n_i_type</strong>: number of records whose type is <strong id="EN-US_TOPIC_0000001811609965__b1988144103312">i</strong> (insert). An <strong id="EN-US_TOPIC_0000001811609965__b848915603318">i</strong> record indicates one insertion, which can be single insertion or batch insertion.</p>
|
|
<p id="EN-US_TOPIC_0000001811609965__p2588311015"><strong id="EN-US_TOPIC_0000001811609965__b468072163414">n_d_type</strong>: number of records whose type is <strong id="EN-US_TOPIC_0000001811609965__b166642073340">d</strong> (delete). One <strong id="EN-US_TOPIC_0000001811609965__b1868061115342">d</strong> record indicates one deletion, which can be single deletion or batch deletion.</p>
|
|
<p id="EN-US_TOPIC_0000001811609965__p16581146208"><strong id="EN-US_TOPIC_0000001811609965__b1161553833419">n_x_type</strong>: number of records whose type is <strong id="EN-US_TOPIC_0000001811609965__b5208182683519">x</strong> (deletions generated by update).</p>
|
|
<p id="EN-US_TOPIC_0000001811609965__p1262461111"><strong id="EN-US_TOPIC_0000001811609965__b13171132018361">n_u_type</strong>: number of records whose type is <strong id="EN-US_TOPIC_0000001811609965__b3285152910369">u</strong> (lightweight update).</p>
|
|
<p id="EN-US_TOPIC_0000001811609965__p157421122410"><strong id="EN-US_TOPIC_0000001811609965__b12884274368">n_m_type</strong>: number of records whose type is <strong id="EN-US_TOPIC_0000001811609965__b11920932203614">m</strong> (merge).</p>
|
|
<p id="EN-US_TOPIC_0000001811609965__p875013713110"><strong id="EN-US_TOPIC_0000001811609965__b2081725294918">data_size</strong>: total size of the <strong id="EN-US_TOPIC_0000001811609965__b1285313011509">delta</strong> table (including the size of the index and <strong id="EN-US_TOPIC_0000001811609965__b08786133504">toast</strong> data on the <strong id="EN-US_TOPIC_0000001811609965__b6272516135013">delta</strong> table).</p>
|
|
<p id="EN-US_TOPIC_0000001811609965__p883974393319">Example:</p>
|
|
<div class="codecoloring" codetype="Sql" id="EN-US_TOPIC_0000001811609965__screen983914434336"><div class="highlight"><table class="highlighttable"><tr><td class="linenos"><div class="linenodiv"><pre><span class="normal">1</span>
|
|
<span class="normal">2</span>
|
|
<span class="normal">3</span>
|
|
<span class="normal">4</span>
|
|
<span class="normal">5</span>
|
|
<span class="normal">6</span>
|
|
<span class="normal">7</span></pre></div></td><td class="code"><div><pre><span></span><span class="k">SELECT</span><span class="w"> </span><span class="o">*</span><span class="w"> </span><span class="k">FROM</span><span class="w"> </span><span class="n">pgxc_get_hstore_delta_info</span><span class="p">(</span><span class="s1">'hs_part'</span><span class="p">);</span>
|
|
<span class="w"> </span><span class="n">node_name</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="n">part_name</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="n">live_tup</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="n">n_ui_type</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="n">n_i_type</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="n">n_d_type</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="n">n_x_type</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="n">n_u_type</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="n">n_m_type</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="n">data_size</span>
|
|
<span class="c1">-----------+-----------+----------+-----------+----------+----------+----------+----------+----------+-----------</span>
|
|
<span class="w"> </span><span class="n">dn_1</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="n">p1</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">2</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">0</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">2</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">0</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">0</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">0</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">0</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">8192</span>
|
|
<span class="w"> </span><span class="n">dn_1</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="n">p2</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">2</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">0</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">2</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">0</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">0</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">0</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">0</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">8192</span>
|
|
<span class="w"> </span><span class="n">dn_1</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="n">p3</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">2</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">0</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">2</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">0</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">0</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">0</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">0</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">8192</span>
|
|
<span class="p">(</span><span class="mi">3</span><span class="w"> </span><span class="k">rows</span><span class="p">)</span>
|
|
</pre></div></td></tr></table></div>
|
|
</div>
|
|
</div>
|
|
<div class="section" id="EN-US_TOPIC_0000001811609965__section1671816452344"><h4 class="sectiontitle">pgxc_get_binlog_sync_point(rel_name text, slot_name text, checkpoint bool, node_id int)</h4><p id="EN-US_TOPIC_0000001811609965__p19610350174017">Description: Obtains the synchronization point information corresponding to a slot from the <strong id="EN-US_TOPIC_0000001811609965__b13741544112416">pg_binlog_slots</strong> system catalog. This function is applicable only to tables with binlog or binlog timestamp enabled. This function is supported only by clusters of version 9.1.0.200 or later.</p>
|
|
<p id="EN-US_TOPIC_0000001811609965__p18719945193416"><strong id="EN-US_TOPIC_0000001811609965__b1819177938">Return type</strong>: record</p>
|
|
<p id="EN-US_TOPIC_0000001811609965__p107197457347">Return value:</p>
|
|
<p id="EN-US_TOPIC_0000001811609965__p35555220427"><strong id="EN-US_TOPIC_0000001811609965__b144215691671857">node_name</strong>: DN name</p>
|
|
<p id="EN-US_TOPIC_0000001811609965__p5314103014212"><strong id="EN-US_TOPIC_0000001811609965__b128981651195018">node_id</strong>: node ID</p>
|
|
<p id="EN-US_TOPIC_0000001811609965__p144817344426"><strong id="EN-US_TOPIC_0000001811609965__b12722859155018">last_sync_point</strong>: last synchronization point</p>
|
|
<p id="EN-US_TOPIC_0000001811609965__p1158213724217"><strong id="EN-US_TOPIC_0000001811609965__b069113172515">latest_sync_point</strong>: latest synchronization point</p>
|
|
<p id="EN-US_TOPIC_0000001811609965__p17164161712421"><strong id="EN-US_TOPIC_0000001811609965__b5656124175112">xmin</strong>: <strong id="EN-US_TOPIC_0000001811609965__b08876281516">xmin</strong> corresponding to the synchronization point</p>
|
|
<p id="EN-US_TOPIC_0000001811609965__p971994511348">Example:</p>
|
|
<div class="codecoloring" codetype="Sql" id="EN-US_TOPIC_0000001811609965__screen671944563414"><div class="highlight"><table class="highlighttable"><tr><td class="linenos"><div class="linenodiv"><pre><span class="normal">1</span>
|
|
<span class="normal">2</span>
|
|
<span class="normal">3</span>
|
|
<span class="normal">4</span>
|
|
<span class="normal">5</span>
|
|
<span class="normal">6</span></pre></div></td><td class="code"><div><pre><span></span><span class="k">SELECT</span><span class="w"> </span><span class="o">*</span><span class="w"> </span><span class="k">FROM</span><span class="w"> </span><span class="n">pg_catalog</span><span class="p">.</span><span class="n">pgxc_get_binlog_sync_point</span><span class="p">(</span><span class="s1">'hstore_binlog_source'</span><span class="p">,</span><span class="w"> </span><span class="s1">'slot1'</span><span class="p">,</span><span class="w"> </span><span class="k">false</span><span class="p">,</span><span class="w"> </span><span class="mi">0</span><span class="p">);</span>
|
|
<span class="w"> </span><span class="n">node_name</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="n">node_id</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="n">last_sync_point</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="n">latest_sync_point</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="n">xmin</span>
|
|
<span class="c1">-----------+-------------+-----------------+-------------------+-------</span>
|
|
<span class="w"> </span><span class="n">dn_2</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="o">-</span><span class="mi">1051926843</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">0</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">10512</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">10507</span>
|
|
<span class="w"> </span><span class="n">dn_1</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="o">-</span><span class="mi">1300059100</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">0</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">10512</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">10508</span>
|
|
<span class="p">(</span><span class="mi">2</span><span class="w"> </span><span class="k">rows</span><span class="p">)</span>
|
|
</pre></div></td></tr></table></div>
|
|
</div>
|
|
</div>
|
|
<div class="section" id="EN-US_TOPIC_0000001811609965__section1564184440"><h4 class="sectiontitle">pgxc_get_binlog_changes(rel_name text, node_id int, start_csn bigint, end_csn bigInt)</h4><p id="EN-US_TOPIC_0000001811609965__p145711844416">Description: Obtains the incremental data of the target table within the specified synchronization point range on a specified DN. If <strong id="EN-US_TOPIC_0000001811609965__b1167614116534">node_id</strong> is set to <strong id="EN-US_TOPIC_0000001811609965__b18194241533">0</strong>, all DNs are specified. This function is applicable only to tables with binlog or binlog timestamp enabled. This function is supported only by clusters of version 9.1.0.200 or later.</p>
|
|
<p id="EN-US_TOPIC_0000001811609965__p15731814444"><strong id="EN-US_TOPIC_0000001811609965__b1626322781">Return type</strong>: record</p>
|
|
<p id="EN-US_TOPIC_0000001811609965__p18571618194417">Return value:</p>
|
|
<p id="EN-US_TOPIC_0000001811609965__p174511225104518"><strong id="EN-US_TOPIC_0000001811609965__b17742131915311">gs_binlog_sync_point</strong>: synchronization point</p>
|
|
<p id="EN-US_TOPIC_0000001811609965__p185769284454"><strong id="EN-US_TOPIC_0000001811609965__b68352715313">gs_binlog_event_sequence</strong>: sequence in the same transaction</p>
|
|
<p id="EN-US_TOPIC_0000001811609965__p183403124511"><strong id="EN-US_TOPIC_0000001811609965__b2290144318531">gs_binlog_event_type</strong>: binlog type</p>
|
|
<p id="EN-US_TOPIC_0000001811609965__p7877192854613"><strong id="EN-US_TOPIC_0000001811609965__b12919125311533">gs_binlog_timestamp_us</strong>: timestamp of the binlog record. For the binlog table whose <strong id="EN-US_TOPIC_0000001811609965__b64355213540">enable_binlog_timestamp</strong> is <strong id="EN-US_TOPIC_0000001811609965__b1097010695410">false</strong>, this column is empty.</p>
|
|
<p id="EN-US_TOPIC_0000001811609965__p32791319174516"><strong id="EN-US_TOPIC_0000001811609965__b67311925165415">value columns</strong>: data of each user field in the target table</p>
|
|
<p id="EN-US_TOPIC_0000001811609965__p75791816448">Example:</p>
|
|
<div class="codecoloring" codetype="Sql" id="EN-US_TOPIC_0000001811609965__screen25721884419"><div class="highlight"><table class="highlighttable"><tr><td class="linenos"><div class="linenodiv"><pre><span class="normal">1</span>
|
|
<span class="normal">2</span>
|
|
<span class="normal">3</span>
|
|
<span class="normal">4</span>
|
|
<span class="normal">5</span>
|
|
<span class="normal">6</span>
|
|
<span class="normal">7</span>
|
|
<span class="normal">8</span></pre></div></td><td class="code"><div><pre><span></span><span class="k">SELECT</span><span class="w"> </span><span class="o">*</span><span class="w"> </span><span class="k">FROM</span><span class="w"> </span><span class="n">pgxc_get_binlog_changes</span><span class="p">(</span><span class="s1">'hstore_binlog_source'</span><span class="p">,</span><span class="w"> </span><span class="mi">0</span><span class="p">,</span><span class="w"> </span><span class="mi">0</span><span class="w"> </span><span class="p">,</span><span class="w"> </span><span class="mi">9999999999</span><span class="p">);</span>
|
|
<span class="w"> </span><span class="n">gs_binlog_sync_point</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="n">gs_binlog_event_sequence</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="n">gs_binlog_event_type</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="n">gs_binlog_timestamp_us</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="n">c1</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="n">c2</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="n">c3</span>
|
|
<span class="c1">----------------------+--------------------------+----------------------+------------------------+-----+----+----</span>
|
|
<span class="w"> </span><span class="mi">10516</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">2</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="n">I</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">1731570520900211</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">100</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">1</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">1</span>
|
|
<span class="w"> </span><span class="mi">10517</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">3</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="n">d</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">1731570520904425</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">100</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">1</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">1</span>
|
|
<span class="w"> </span><span class="mi">10518</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">2</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="n">I</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">1731570520909055</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">200</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">1</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">1</span>
|
|
<span class="w"> </span><span class="mi">10519</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">3</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="n">B</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">1731570520914102</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">200</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">1</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">1</span>
|
|
<span class="w"> </span><span class="mi">10519</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">4</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="n">U</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">1731570520914154</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">200</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">2</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">1</span>
|
|
</pre></div></td></tr></table></div>
|
|
</div>
|
|
</div>
|
|
<div class="section" id="EN-US_TOPIC_0000001811609965__section1670134624711"><h4 class="sectiontitle">pgxc_register_binlog_sync_point(rel_name text, slot_name text, node_id int, end_csn bigInt, checkpoint bool, xmin bigint)</h4><p id="EN-US_TOPIC_0000001811609965__p1170114461475">Description: Registers synchronization points and can be used only for tables with binlog or binlog timestamp enabled. This function is supported only by clusters of version 9.1.0.200 or later.</p>
|
|
<p id="EN-US_TOPIC_0000001811609965__p07011346144720">Return type: int</p>
|
|
<p id="EN-US_TOPIC_0000001811609965__p37011146194718">Return value: number of nodes that are successfully registered</p>
|
|
<p id="EN-US_TOPIC_0000001811609965__p7701154618474">Example:</p>
|
|
<div class="codecoloring" codetype="Sql" id="EN-US_TOPIC_0000001811609965__screen117011846144713"><div class="highlight"><table class="highlighttable"><tr><td class="linenos"><div class="linenodiv"><pre><span class="normal">1</span>
|
|
<span class="normal">2</span>
|
|
<span class="normal">3</span>
|
|
<span class="normal">4</span>
|
|
<span class="normal">5</span></pre></div></td><td class="code"><div><pre><span></span><span class="k">SELECT</span><span class="w"> </span><span class="n">pgxc_register_binlog_sync_point</span><span class="p">(</span><span class="s1">'hstore_binlog_source'</span><span class="p">,</span><span class="w"> </span><span class="s1">'slot1'</span><span class="p">,</span><span class="w"> </span><span class="mi">0</span><span class="p">,</span><span class="w"> </span><span class="mi">9999999999</span><span class="p">,</span><span class="w"> </span><span class="k">false</span><span class="p">,</span><span class="w"> </span><span class="mi">100</span><span class="p">);</span>
|
|
<span class="w"> </span><span class="n">pgxc_register_binlog_sync_point</span>
|
|
<span class="c1">---------------------------------</span>
|
|
<span class="w"> </span><span class="mi">2</span>
|
|
<span class="p">(</span><span class="mi">1</span><span class="w"> </span><span class="k">row</span><span class="p">)</span>
|
|
</pre></div></td></tr></table></div>
|
|
</div>
|
|
</div>
|
|
<div class="section" id="EN-US_TOPIC_0000001811609965__section156601725513"><a name="EN-US_TOPIC_0000001811609965__section156601725513"></a><a name="section156601725513"></a><h4 class="sectiontitle">pgxc_consumed_binlog_records(rel_name text, node_id int)</h4><p id="EN-US_TOPIC_0000001811609965__p1566032115115">Description: Obtains the consumption status of the target table on a specified DN. This function can be used only for tables with binlog or binlog timestamp enabled. This function is supported only by clusters of version 9.1.0.200 or later.</p>
|
|
<p id="EN-US_TOPIC_0000001811609965__p1566019217515">Return type: int</p>
|
|
<p id="EN-US_TOPIC_0000001811609965__p166115255115">Return value: If <strong id="EN-US_TOPIC_0000001811609965__b72463412557">0</strong> is returned, the binlog of the target table is not completely consumed (including all slots and checkpoint synchronization points). If <strong id="EN-US_TOPIC_0000001811609965__b76745116556">1</strong> is returned, the binlog of the target table is completely consumed.</p>
|
|
<p id="EN-US_TOPIC_0000001811609965__p1666120216519">Example:</p>
|
|
<div class="codecoloring" codetype="Sql" id="EN-US_TOPIC_0000001811609965__screen166162155116"><div class="highlight"><table class="highlighttable"><tr><td class="linenos"><div class="linenodiv"><pre><span class="normal">1</span>
|
|
<span class="normal">2</span>
|
|
<span class="normal">3</span>
|
|
<span class="normal">4</span>
|
|
<span class="normal">5</span></pre></div></td><td class="code"><div><pre><span></span><span class="k">SELECT</span><span class="w"> </span><span class="o">*</span><span class="w"> </span><span class="k">FROM</span><span class="w"> </span><span class="n">pgxc_consumed_binlog_records</span><span class="p">(</span><span class="s1">'hstore_binlog_source'</span><span class="p">,</span><span class="mi">0</span><span class="p">);</span>
|
|
<span class="w"> </span><span class="n">pgxc_consumed_binlog_records</span>
|
|
<span class="c1">------------------------------</span>
|
|
<span class="w"> </span><span class="mi">1</span>
|
|
<span class="p">(</span><span class="mi">1</span><span class="w"> </span><span class="k">row</span><span class="p">)</span>
|
|
</pre></div></td></tr></table></div>
|
|
</div>
|
|
</div>
|
|
<div class="section" id="EN-US_TOPIC_0000001811609965__section1384041135416"><h4 class="sectiontitle">pgxc_get_binlog_cursor_by_timestamp(rel_name text, timestamp timestampTz, node_id int)</h4><p id="EN-US_TOPIC_0000001811609965__p1738414145416">Description: Obtains information about the first binlog record after a specified time point in the target table. This function can be used only for tables with the binlog timestamp enabled.</p>
|
|
<p id="EN-US_TOPIC_0000001811609965__p146909715306">This function is supported only by clusters of version 9.1.0.200 or later.</p>
|
|
<p id="EN-US_TOPIC_0000001811609965__p9384541125412"><strong id="EN-US_TOPIC_0000001811609965__b1994935258">Return type</strong>: record</p>
|
|
<p id="EN-US_TOPIC_0000001811609965__p1487794615556">Return value:</p>
|
|
<p id="EN-US_TOPIC_0000001811609965__p7184749145517"><strong id="EN-US_TOPIC_0000001811609965__b1751932516554">node_name</strong>: DN name</p>
|
|
<p id="EN-US_TOPIC_0000001811609965__p15271754125516"><strong id="EN-US_TOPIC_0000001811609965__b19523123019556">node_id</strong>: node ID</p>
|
|
<p id="EN-US_TOPIC_0000001811609965__p8271156165520"><strong id="EN-US_TOPIC_0000001811609965__b16585173255">latest_sync_point</strong>: latest synchronization point</p>
|
|
<p id="EN-US_TOPIC_0000001811609965__p7572155955511"><strong id="EN-US_TOPIC_0000001811609965__b43271120115617">binlog_sync_point</strong>: synchronization point of the first binlog record after the time point</p>
|
|
<p id="EN-US_TOPIC_0000001811609965__p208127295611"><strong id="EN-US_TOPIC_0000001811609965__b156141332185619">binlog_timestamp_us</strong>: timestamp of the first binlog record after the time point</p>
|
|
<p id="EN-US_TOPIC_0000001811609965__p23849417543"><strong id="EN-US_TOPIC_0000001811609965__b2795538135616">binlog_xmin</strong>: <strong id="EN-US_TOPIC_0000001811609965__b1805194314561">xmin</strong> recorded in the first binlog after the time point</p>
|
|
<p id="EN-US_TOPIC_0000001811609965__p1384941205414">Example:</p>
|
|
<div class="codecoloring" codetype="Sql" id="EN-US_TOPIC_0000001811609965__screen1438434116543"><div class="highlight"><table class="highlighttable"><tr><td class="linenos"><div class="linenodiv"><pre><span class="normal">1</span>
|
|
<span class="normal">2</span>
|
|
<span class="normal">3</span>
|
|
<span class="normal">4</span>
|
|
<span class="normal">5</span>
|
|
<span class="normal">6</span></pre></div></td><td class="code"><div><pre><span></span><span class="k">SELECT</span><span class="w"> </span><span class="o">*</span><span class="w"> </span><span class="k">FROM</span><span class="w"> </span><span class="n">pgxc_get_binlog_cursor_by_timestamp</span><span class="p">(</span><span class="s1">'hstore_binlog_source'</span><span class="p">,</span><span class="s1">'2024-11-14 15:48:40.900211+08'</span><span class="p">,</span><span class="w"> </span><span class="mi">0</span><span class="p">);</span>
|
|
<span class="w"> </span><span class="n">node_name</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="n">node_id</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="n">latest_sync_point</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="n">binlog_sync_point</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="n">binlog_timestamp_us</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="n">binlog_xmin</span>
|
|
<span class="c1">-----------+-------------+-------------------+-------------------+---------------------+-------------</span>
|
|
<span class="w"> </span><span class="n">dn_2</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="o">-</span><span class="mi">1051926843</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">10532</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">10516</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">1731570520900211</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">10510</span>
|
|
<span class="w"> </span><span class="n">dn_1</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="o">-</span><span class="mi">1300059100</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">10532</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">10518</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">1731570520909055</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">10510</span>
|
|
<span class="p">(</span><span class="mi">2</span><span class="w"> </span><span class="k">rows</span><span class="p">)</span>
|
|
</pre></div></td></tr></table></div>
|
|
</div>
|
|
</div>
|
|
<div class="section" id="EN-US_TOPIC_0000001811609965__section4312757175612"><h4 class="sectiontitle">pgxc_get_binlog_cursor_by_syncpoint(rel_name text, csn int8, node_id int)</h4><p id="EN-US_TOPIC_0000001811609965__p15312155775612">Description: Obtains the first binlog record after a specified synchronization point on the target table. This function can be used only for tables with the binlog timestamp enabled.</p>
|
|
<p id="EN-US_TOPIC_0000001811609965__p103261929143018">This function is supported only by clusters of version 9.1.0.200 or later.</p>
|
|
<p id="EN-US_TOPIC_0000001811609965__p5312205755619"><strong id="EN-US_TOPIC_0000001811609965__b1479353325">Return type</strong>: record</p>
|
|
<p id="EN-US_TOPIC_0000001811609965__p113127574564">Return value:</p>
|
|
<p id="EN-US_TOPIC_0000001811609965__p1312195725616"><strong id="EN-US_TOPIC_0000001811609965__b822556145611">node_name</strong>: DN name</p>
|
|
<p id="EN-US_TOPIC_0000001811609965__p13121957195613"><strong id="EN-US_TOPIC_0000001811609965__b18695135755613">node_id</strong>: node ID</p>
|
|
<p id="EN-US_TOPIC_0000001811609965__p431285716569"><strong id="EN-US_TOPIC_0000001811609965__b197681818658">latest_sync_point</strong>: latest synchronization point</p>
|
|
<p id="EN-US_TOPIC_0000001811609965__p4312857105619"><strong id="EN-US_TOPIC_0000001811609965__b4302122112577">binlog_sync_point</strong>: synchronization point of the first binlog record after the time point</p>
|
|
<p id="EN-US_TOPIC_0000001811609965__p1831245720569"><strong id="EN-US_TOPIC_0000001811609965__b1138153095717">binlog_timestamp_us</strong>: timestamp of the first binlog record after the time point</p>
|
|
<p id="EN-US_TOPIC_0000001811609965__p1312157145618"><strong id="EN-US_TOPIC_0000001811609965__b13676163520574">binlog_xmin</strong>: <strong id="EN-US_TOPIC_0000001811609965__b7676193512572">xmin</strong> recorded in the first binlog after the time point</p>
|
|
<p id="EN-US_TOPIC_0000001811609965__p5312657105611">Example:</p>
|
|
<div class="codecoloring" codetype="Sql" id="EN-US_TOPIC_0000001811609965__screen1731213577562"><div class="highlight"><table class="highlighttable"><tr><td class="linenos"><div class="linenodiv"><pre><span class="normal">1</span>
|
|
<span class="normal">2</span>
|
|
<span class="normal">3</span>
|
|
<span class="normal">4</span>
|
|
<span class="normal">5</span>
|
|
<span class="normal">6</span></pre></div></td><td class="code"><div><pre><span></span><span class="k">SELECT</span><span class="w"> </span><span class="o">*</span><span class="w"> </span><span class="k">FROM</span><span class="w"> </span><span class="n">pgxc_get_binlog_cursor_by_syncpoint</span><span class="p">(</span><span class="s1">'hstore_binlog_source'</span><span class="p">,</span><span class="mi">10516</span><span class="p">,</span><span class="mi">0</span><span class="p">);</span>
|
|
<span class="w"> </span><span class="n">node_name</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="n">node_id</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="n">latest_sync_point</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="n">binlog_sync_point</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="n">binlog_timestamp_us</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="n">binlog_xmin</span>
|
|
<span class="c1">-----------+-------------+-------------------+-------------------+---------------------+-------------</span>
|
|
<span class="w"> </span><span class="n">dn_1</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="o">-</span><span class="mi">1300059100</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">11187</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">10518</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">1731570520909055</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">10510</span>
|
|
<span class="w"> </span><span class="n">dn_2</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="o">-</span><span class="mi">1051926843</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">11187</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">10516</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">1731570520900211</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">10510</span>
|
|
<span class="p">(</span><span class="mi">2</span><span class="w"> </span><span class="k">rows</span><span class="p">)</span>
|
|
</pre></div></td></tr></table></div>
|
|
</div>
|
|
</div>
|
|
<div class="section" id="EN-US_TOPIC_0000001811609965__section730161305"><h4 class="sectiontitle">pgxc_get_cstore_dirty_ratio(rel_name text, partition_name)</h4><p id="EN-US_TOPIC_0000001811609965__p1034672617118">Description: This function is used to obtain the cu, delta, and cudesc dirty page rates and sizes of the target table on each DN. Only HStore Opt tables are supported.</p>
|
|
<p id="EN-US_TOPIC_0000001811609965__p1634611261512">The <strong id="EN-US_TOPIC_0000001811609965__b12156153102413">partition_name</strong> parameter is optional. If the partition name is specified, only the information about the partition is returned. If the partition name is not specified and the table is a primary table, the information about all partitions is returned. It is supported only by clusters of version 9.1.0.100 or later.</p>
|
|
<p id="EN-US_TOPIC_0000001811609965__p4319168017"><strong id="EN-US_TOPIC_0000001811609965__b1810049114">Return type</strong>: record</p>
|
|
<p id="EN-US_TOPIC_0000001811609965__p531616207">Return value:</p>
|
|
<p id="EN-US_TOPIC_0000001811609965__p131016709"><strong id="EN-US_TOPIC_0000001811609965__b19842163895711">node_name</strong>: DN name</p>
|
|
<p id="EN-US_TOPIC_0000001811609965__p2320165014"><strong id="EN-US_TOPIC_0000001811609965__b210315596242">database_name</strong>: name of the database where the table is located</p>
|
|
<p id="EN-US_TOPIC_0000001811609965__p1431016605"><strong id="EN-US_TOPIC_0000001811609965__b322818418259">rel_name</strong>: primary table name</p>
|
|
<p id="EN-US_TOPIC_0000001811609965__p1431416305"><strong id="EN-US_TOPIC_0000001811609965__b1721922316254">part_name</strong>: partition name</p>
|
|
<p id="EN-US_TOPIC_0000001811609965__p53916402"><strong id="EN-US_TOPIC_0000001811609965__b13386102511251">cu_dirty_ratio</strong>: dirty page rate of CU files</p>
|
|
<p id="EN-US_TOPIC_0000001811609965__p133111616013"><strong id="EN-US_TOPIC_0000001811609965__b786593013250">cu_size</strong>: CU file size</p>
|
|
<p id="EN-US_TOPIC_0000001811609965__p113131620015"><strong id="EN-US_TOPIC_0000001811609965__b25212341255">delta_dirty_ratio</strong>: dirty page rate of the delta table</p>
|
|
<p id="EN-US_TOPIC_0000001811609965__p1735165012"><strong id="EN-US_TOPIC_0000001811609965__b21571337172520">delta_size</strong>: delta table size</p>
|
|
<p id="EN-US_TOPIC_0000001811609965__p1231116409"><strong id="EN-US_TOPIC_0000001811609965__b14540144042519">cudesc_dirty_ratio</strong>: dirty page rate of the cudesc table</p>
|
|
<p id="EN-US_TOPIC_0000001811609965__p835163012"><strong id="EN-US_TOPIC_0000001811609965__b77451303268">cudesc_size</strong>: cudesc table size</p>
|
|
<p id="EN-US_TOPIC_0000001811609965__p1131316503">Example:</p>
|
|
<div class="codecoloring" codetype="Sql" id="EN-US_TOPIC_0000001811609965__screen13242177320"><div class="highlight"><table class="highlighttable"><tr><td class="linenos"><div class="linenodiv"><pre><span class="normal">1</span>
|
|
<span class="normal">2</span>
|
|
<span class="normal">3</span>
|
|
<span class="normal">4</span>
|
|
<span class="normal">5</span>
|
|
<span class="normal">6</span>
|
|
<span class="normal">7</span>
|
|
<span class="normal">8</span></pre></div></td><td class="code"><div><pre><span></span><span class="k">SELECT</span><span class="w"> </span><span class="o">*</span><span class="w"> </span><span class="k">FROM</span><span class="w"> </span><span class="n">pgxc_get_cstore_dirty_ratio</span><span class="p">(</span><span class="s1">'hs_opt_part'</span><span class="p">);</span>
|
|
<span class="w"> </span><span class="n">node_name</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="n">database_name</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="n">rel_name</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="n">partition_name</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="n">cu_dirty_ratio</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="n">cu_size</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="n">delta_dirty_ratio</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="n">delta_size</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="n">cudesc_dirty_ratio</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="n">cudesc_size</span>
|
|
<span class="c1">-----------+---------------+--------------------+----------------+----------------+---------+-------------------+------------+--------------------+-------------</span>
|
|
<span class="w"> </span><span class="n">dn_1</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="n">postgres</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="k">public</span><span class="p">.</span><span class="n">hs_opt_part</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="n">p1</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">0</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">0</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">0</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">16384</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">0</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">24576</span>
|
|
<span class="w"> </span><span class="n">dn_1</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="n">postgres</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="k">public</span><span class="p">.</span><span class="n">hs_opt_part</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="n">p2</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">0</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">0</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">0</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">16384</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">0</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">24576</span>
|
|
<span class="w"> </span><span class="n">dn_1</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="n">postgres</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="k">public</span><span class="p">.</span><span class="n">hs_opt_part</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="n">p3</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">0</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">0</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">0</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">16384</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">0</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">24576</span>
|
|
<span class="w"> </span><span class="n">dn_1</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="n">postgres</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="k">public</span><span class="p">.</span><span class="n">hs_opt_part</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="n">p4</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">0</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">0</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">0</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">16384</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">0</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">24576</span>
|
|
<span class="w"> </span><span class="n">dn_1</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="n">postgres</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="k">public</span><span class="p">.</span><span class="n">hs_opt_part</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="n">other</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">0</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">1105920</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">0</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">524288</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">0</span><span class="w"> </span><span class="o">|</span><span class="w"> </span><span class="mi">40960</span>
|
|
</pre></div></td></tr></table></div>
|
|
</div>
|
|
</div>
|
|
</div>
|
|
<div>
|
|
<div class="familylinks">
|
|
<div class="parentlink"><strong>Parent topic:</strong> <a href="dws_04_1023.html">Hybrid Data Warehouse</a></div>
|
|
</div>
|
|
</div>
|
|
|