http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/0238b4a9/distribution/src/main/scripts/interface/gen-rb/blur.rb ---------------------------------------------------------------------- diff --git a/distribution/src/main/scripts/interface/gen-rb/blur.rb b/distribution/src/main/scripts/interface/gen-rb/blur.rb index 126cb59..706ff09 100644 --- a/distribution/src/main/scripts/interface/gen-rb/blur.rb +++ b/distribution/src/main/scripts/interface/gen-rb/blur.rb @@ -45,13 +45,13 @@ module Blur raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'execute failed: unknown result') end - def reconnect(executionId) - send_reconnect(executionId) + def reconnect(instanceExecutionId) + send_reconnect(instanceExecutionId) return recv_reconnect() end - def send_reconnect(executionId) - send_message('reconnect', Reconnect_args, :executionId => executionId) + def send_reconnect(instanceExecutionId) + send_message('reconnect', Reconnect_args, :instanceExecutionId => instanceExecutionId) end def recv_reconnect() @@ -78,13 +78,13 @@ module Blur raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'commandStatusList failed: unknown result') end - def commandStatus(executionId) - send_commandStatus(executionId) + def commandStatus(commandExecutionId) + send_commandStatus(commandExecutionId) return recv_commandStatus() end - def send_commandStatus(executionId) - send_message('commandStatus', CommandStatus_args, :executionId => executionId) + def send_commandStatus(commandExecutionId) + send_message('commandStatus', CommandStatus_args, :commandExecutionId => commandExecutionId) end def recv_commandStatus() @@ -94,13 +94,13 @@ module Blur raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'commandStatus failed: unknown result') end - def commandCancel(executionId) - send_commandCancel(executionId) + def commandCancel(commandExecutionId) + send_commandCancel(commandExecutionId) recv_commandCancel() end - def send_commandCancel(executionId) - send_message('commandCancel', CommandCancel_args, :executionId => executionId) + def send_commandCancel(commandExecutionId) + send_message('commandCancel', CommandCancel_args, :commandExecutionId => commandExecutionId) end def recv_commandCancel() @@ -818,7 +818,7 @@ module Blur args = read_args(iprot, Reconnect_args) result = Reconnect_result.new() begin - result.success = @handler.reconnect(args.executionId) + result.success = @handler.reconnect(args.instanceExecutionId) rescue ::Blur::BlurException => bex result.bex = bex rescue ::Blur::TimeoutException => tex @@ -842,7 +842,7 @@ module Blur args = read_args(iprot, CommandStatus_args) result = CommandStatus_result.new() begin - result.success = @handler.commandStatus(args.executionId) + result.success = @handler.commandStatus(args.commandExecutionId) rescue ::Blur::BlurException => ex result.ex = ex end @@ -853,7 +853,7 @@ module Blur args = read_args(iprot, CommandCancel_args) result = CommandCancel_result.new() begin - @handler.commandCancel(args.executionId) + @handler.commandCancel(args.commandExecutionId) rescue ::Blur::BlurException => ex result.ex = ex end @@ -1413,10 +1413,10 @@ module Blur class Reconnect_args include ::Thrift::Struct, ::Thrift::Struct_Union - EXECUTIONID = 1 + INSTANCEEXECUTIONID = 1 FIELDS = { - EXECUTIONID => {:type => ::Thrift::Types::STRING, :name => 'executionId'} + INSTANCEEXECUTIONID => {:type => ::Thrift::Types::I64, :name => 'instanceExecutionId'} } def struct_fields; FIELDS; end @@ -1490,10 +1490,10 @@ module Blur class CommandStatus_args include ::Thrift::Struct, ::Thrift::Struct_Union - EXECUTIONID = 1 + COMMANDEXECUTIONID = 1 FIELDS = { - EXECUTIONID => {:type => ::Thrift::Types::STRING, :name => 'executionId'} + COMMANDEXECUTIONID => {:type => ::Thrift::Types::STRING, :name => 'commandExecutionId'} } def struct_fields; FIELDS; end @@ -1524,10 +1524,10 @@ module Blur class CommandCancel_args include ::Thrift::Struct, ::Thrift::Struct_Union - EXECUTIONID = 1 + COMMANDEXECUTIONID = 1 FIELDS = { - EXECUTIONID => {:type => ::Thrift::Types::STRING, :name => 'executionId'} + COMMANDEXECUTIONID => {:type => ::Thrift::Types::STRING, :name => 'commandExecutionId'} } def struct_fields; FIELDS; end
http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/0238b4a9/distribution/src/main/scripts/interface/gen-rb/blur_types.rb ---------------------------------------------------------------------- diff --git a/distribution/src/main/scripts/interface/gen-rb/blur_types.rb b/distribution/src/main/scripts/interface/gen-rb/blur_types.rb index dedac6c..1a824fc 100644 --- a/distribution/src/main/scripts/interface/gen-rb/blur_types.rb +++ b/distribution/src/main/scripts/interface/gen-rb/blur_types.rb @@ -132,17 +132,10 @@ module Blur # happens so that the client can reconnect. class TimeoutException < ::Thrift::Exception include ::Thrift::Struct, ::Thrift::Struct_Union - def initialize(message=nil) - super() - self.executionId = message - end - - def message; executionId end - - EXECUTIONID = 1 + INSTANCEEXECUTIONID = 1 FIELDS = { - EXECUTIONID => {:type => ::Thrift::Types::STRING, :name => 'executionId'} + INSTANCEEXECUTIONID => {:type => ::Thrift::Types::I64, :name => 'instanceExecutionId'} } def struct_fields; FIELDS; end http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/0238b4a9/docs/Blur.html ---------------------------------------------------------------------- diff --git a/docs/Blur.html b/docs/Blur.html index 121e460..ab7b47d 100644 --- a/docs/Blur.html +++ b/docs/Blur.html @@ -309,7 +309,7 @@ Logging level enum used to change the logging levels at runtime. trace (if any). <br/></p></section><section><div class="page-header"><h3 id="Struct_TimeoutException">Exception: TimeoutException</h3></div><p class="lead"> <table class="table-bordered table-striped table-condensed"><thead><th>Key</th><th>Field</th><th>Type</th><th>Description</th><th>Requiredness</th><th>Default value</th></thead> -<tr><td>1</td><td>executionId</td><td><code>string</code></td><td></td><td>default</td><td></td></tr> +<tr><td>1</td><td>instanceExecutionId</td><td><code>i64</code></td><td></td><td>default</td><td></td></tr> </table><br/>TimeoutException occurs before the network connection timeout happens so that the client can reconnect. <br/></p></section><section><div class="page-header"><h3 id="Struct_User">Struct: User</h3></div><p class="lead"> @@ -742,7 +742,7 @@ throws <code><a href="Blur.html#Struct_BlurException">BlurException</a></code> throws <code><a href="Blur.html#Struct_BlurException">BlurException</a></code>, <code><a href="Blur.html#Struct_TimeoutException">TimeoutException</a></code> </pre>Executes the given command by name on the table with the provided arguments. <br/></p></section><section><div class="page-header"><h4 id="Fn_Blur_reconnect">Function: Blur.reconnect</h4></div><p class="lead"> -<pre><code><a href="Blur.html#Struct_Response">Response</a></code> reconnect(<code>string</code> executionId) +<pre><code><a href="Blur.html#Struct_Response">Response</a></code> reconnect(<code>i64</code> instanceExecutionId) throws <code><a href="Blur.html#Struct_BlurException">BlurException</a></code>, <code><a href="Blur.html#Struct_TimeoutException">TimeoutException</a></code> </pre>If the execute command times out due to command taking longer than the configured network tcp timeout this method allows the client to reconnect to the already @@ -754,13 +754,13 @@ executing command. throws <code><a href="Blur.html#Struct_BlurException">BlurException</a></code> </pre>Fetches the command status ids in the order they were submitted. <br/></p></section><section><div class="page-header"><h4 id="Fn_Blur_commandStatus">Function: Blur.commandStatus</h4></div><p class="lead"> -<pre><code><a href="Blur.html#Struct_CommandStatus">CommandStatus</a></code> commandStatus(<code>string</code> executionId) +<pre><code><a href="Blur.html#Struct_CommandStatus">CommandStatus</a></code> commandStatus(<code>string</code> commandExecutionId) throws <code><a href="Blur.html#Struct_BlurException">BlurException</a></code> -</pre>Retrieves the command status by the given execution id. +</pre>Retrieves the command status by the given command execution id. <br/></p></section><section><div class="page-header"><h4 id="Fn_Blur_commandCancel">Function: Blur.commandCancel</h4></div><p class="lead"> -<pre><code>void</code> commandCancel(<code>string</code> executionId) +<pre><code>void</code> commandCancel(<code>string</code> commandExecutionId) throws <code><a href="Blur.html#Struct_BlurException">BlurException</a></code> -</pre>Cancels the command with the given execution id. +</pre>Cancels the command with the given command execution id. <br/></p></section><section><div class="page-header"><h4 id="Fn_Blur_refresh">Function: Blur.refresh</h4></div><p class="lead"> <pre><code>void</code> refresh() </pre>Releases and refreshes the read snapshots of the indexes in the session for the
