http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/a0a7d7d7/blur-thrift/src/main/java/org/apache/blur/thrift/generated/SafeClientGen.java ---------------------------------------------------------------------- diff --git a/blur-thrift/src/main/java/org/apache/blur/thrift/generated/SafeClientGen.java b/blur-thrift/src/main/java/org/apache/blur/thrift/generated/SafeClientGen.java index ed1a526..e8c4c63 100644 --- a/blur-thrift/src/main/java/org/apache/blur/thrift/generated/SafeClientGen.java +++ b/blur-thrift/src/main/java/org/apache/blur/thrift/generated/SafeClientGen.java @@ -69,6 +69,27 @@ public boolean addColumnDefinition(java.lang.String arg0, org.apache.blur.thrift } @Override +public void bulkMutateAdd(java.lang.String arg0, java.lang.String arg1, org.apache.blur.thrift.generated.RowMutation arg2) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { + _lock.errorFailLock(); try { + super.bulkMutateAdd(arg0, arg1, arg2); + } finally {_lock.unlock();} +} + +@Override +public void bulkMutateFinish(java.lang.String arg0, java.lang.String arg1, boolean arg2, boolean arg3) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { + _lock.errorFailLock(); try { + super.bulkMutateFinish(arg0, arg1, arg2, arg3); + } finally {_lock.unlock();} +} + +@Override +public void bulkMutateStart(java.lang.String arg0, java.lang.String arg1) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { + _lock.errorFailLock(); try { + super.bulkMutateStart(arg0, arg1); + } finally {_lock.unlock();} +} + +@Override public void cancelQuery(java.lang.String arg0, java.lang.String arg1) throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { _lock.errorFailLock(); try { super.cancelQuery(arg0, arg1); @@ -300,6 +321,27 @@ public boolean recv_addColumnDefinition() throws org.apache.blur.thrift.generate } @Override +public void recv_bulkMutateAdd() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { + _lock.errorFailLock(); try { + super.recv_bulkMutateAdd(); + } finally {_lock.unlock();} +} + +@Override +public void recv_bulkMutateFinish() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { + _lock.errorFailLock(); try { + super.recv_bulkMutateFinish(); + } finally {_lock.unlock();} +} + +@Override +public void recv_bulkMutateStart() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { + _lock.errorFailLock(); try { + super.recv_bulkMutateStart(); + } finally {_lock.unlock();} +} + +@Override public void recv_cancelQuery() throws org.apache.blur.thrift.generated.BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException { _lock.errorFailLock(); try { super.recv_cancelQuery(); @@ -678,6 +720,27 @@ public void send_addColumnDefinition(java.lang.String arg0, org.apache.blur.thri } @Override +public void send_bulkMutateAdd(java.lang.String arg0, java.lang.String arg1, org.apache.blur.thrift.generated.RowMutation arg2) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + _lock.errorFailLock(); try { + super.send_bulkMutateAdd(arg0, arg1, arg2); + } finally {_lock.unlock();} +} + +@Override +public void send_bulkMutateFinish(java.lang.String arg0, java.lang.String arg1, boolean arg2, boolean arg3) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + _lock.errorFailLock(); try { + super.send_bulkMutateFinish(arg0, arg1, arg2, arg3); + } finally {_lock.unlock();} +} + +@Override +public void send_bulkMutateStart(java.lang.String arg0, java.lang.String arg1) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { + _lock.errorFailLock(); try { + super.send_bulkMutateStart(arg0, arg1); + } finally {_lock.unlock();} +} + +@Override public void send_cancelQuery(java.lang.String arg0, java.lang.String arg1) throws org.apache.blur.thirdparty.thrift_0_9_0.TException { _lock.errorFailLock(); try { super.send_cancelQuery(arg0, arg1);
http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/a0a7d7d7/distribution/src/main/scripts/interface/gen-html/Blur.html ---------------------------------------------------------------------- diff --git a/distribution/src/main/scripts/interface/gen-html/Blur.html b/distribution/src/main/scripts/interface/gen-html/Blur.html index cffe15c..04d4e39 100644 --- a/distribution/src/main/scripts/interface/gen-html/Blur.html +++ b/distribution/src/main/scripts/interface/gen-html/Blur.html @@ -12,6 +12,9 @@ <td>Blur</td><td><a href="Blur.html#Svc_Blur">Blur</a><br/> <ul> <li><a href="Blur.html#Fn_Blur_addColumnDefinition">addColumnDefinition</a></li> +<li><a href="Blur.html#Fn_Blur_bulkMutateAdd">bulkMutateAdd</a></li> +<li><a href="Blur.html#Fn_Blur_bulkMutateFinish">bulkMutateFinish</a></li> +<li><a href="Blur.html#Fn_Blur_bulkMutateStart">bulkMutateStart</a></li> <li><a href="Blur.html#Fn_Blur_cancelQuery">cancelQuery</a></li> <li><a href="Blur.html#Fn_Blur_commandCancel">commandCancel</a></li> <li><a href="Blur.html#Fn_Blur_commandStatus">commandStatus</a></li> @@ -901,6 +904,45 @@ the shard server, if any. <br/><br/><h4 id="Parameters_Blur_enqueueMutateBatch">Parameters</h4> <table class="table-bordered table-striped table-condensed"><thead><th>Name</th><th>Description</th></thead><tr><td>mutations</td><td>the batch of RowMutations. </td></tr> +</table></div><div class="definition"><h4 id="Fn_Blur_bulkMutateStart">Function: Blur.bulkMutateStart</h4> +<pre><code>void</code> bulkMutateStart(<code>string</code> table, + <code>string</code> bulkId) + throws <code><a href="Blur.html#Struct_BlurException">BlurException</a></code> +</pre>Starts a transaction for update (e.g. Mutate). Returns a transaction id. +<br/><br/><h4 id="Parameters_Blur_bulkMutateStart">Parameters</h4> +<table class="table-bordered table-striped table-condensed"><thead><th>Name</th><th>Description</th></thead><tr><td>table</td><td>The table name. +</td></tr> +<tr><td>bulkId</td><td>The bulk id. +</td></tr> +</table></div><div class="definition"><h4 id="Fn_Blur_bulkMutateAdd">Function: Blur.bulkMutateAdd</h4> +<pre><code>void</code> bulkMutateAdd(<code>string</code> table, + <code>string</code> bulkId, + <code><a href="Blur.html#Struct_RowMutation">RowMutation</a></code> rowMutation) + throws <code><a href="Blur.html#Struct_BlurException">BlurException</a></code> +</pre>Adds to the specified transaction. The +<br/><br/><h4 id="Parameters_Blur_bulkMutateAdd">Parameters</h4> +<table class="table-bordered table-striped table-condensed"><thead><th>Name</th><th>Description</th></thead><tr><td>table</td><td>The table name. +</td></tr> +<tr><td>bulkId</td><td>The bulk id. +</td></tr> +<tr><td>rowMutation</td><td>The row mutation. +</td></tr> +</table></div><div class="definition"><h4 id="Fn_Blur_bulkMutateFinish">Function: Blur.bulkMutateFinish</h4> +<pre><code>void</code> bulkMutateFinish(<code>string</code> table, + <code>string</code> bulkId, + <code>bool</code> apply, + <code>bool</code> blockUntilComplete) + throws <code><a href="Blur.html#Struct_BlurException">BlurException</a></code> +</pre>Finishes the bulk mutate. If apply is true the mutations are applied and committed. If false the bulk mutate is deleted and not applied. +<br/><br/><h4 id="Parameters_Blur_bulkMutateFinish">Parameters</h4> +<table class="table-bordered table-striped table-condensed"><thead><th>Name</th><th>Description</th></thead><tr><td>table</td><td>The table name. +</td></tr> +<tr><td>bulkId</td><td>The bulk id. +</td></tr> +<tr><td>apply</td><td>Apply the bulk mutate flag. +</td></tr> +<tr><td>blockUntilComplete</td><td>If true this call will not block on bulk completion. This may be required for loader bulk loads. +</td></tr> </table></div><div class="definition"><h4 id="Fn_Blur_cancelQuery">Function: Blur.cancelQuery</h4> <pre><code>void</code> cancelQuery(<code>string</code> table, <code>string</code> uuid) http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/a0a7d7d7/distribution/src/main/scripts/interface/gen-html/index.html ---------------------------------------------------------------------- diff --git a/distribution/src/main/scripts/interface/gen-html/index.html b/distribution/src/main/scripts/interface/gen-html/index.html index 794f4ef..46eff45 100644 --- a/distribution/src/main/scripts/interface/gen-html/index.html +++ b/distribution/src/main/scripts/interface/gen-html/index.html @@ -8,6 +8,9 @@ <td>Blur</td><td><a href="Blur.html#Svc_Blur">Blur</a><br/> <ul> <li><a href="Blur.html#Fn_Blur_addColumnDefinition">addColumnDefinition</a></li> +<li><a href="Blur.html#Fn_Blur_bulkMutateAdd">bulkMutateAdd</a></li> +<li><a href="Blur.html#Fn_Blur_bulkMutateFinish">bulkMutateFinish</a></li> +<li><a href="Blur.html#Fn_Blur_bulkMutateStart">bulkMutateStart</a></li> <li><a href="Blur.html#Fn_Blur_cancelQuery">cancelQuery</a></li> <li><a href="Blur.html#Fn_Blur_commandCancel">commandCancel</a></li> <li><a href="Blur.html#Fn_Blur_commandStatus">commandStatus</a></li>
