incubator-blur-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From amccu...@apache.org
Subject [1/4] This fixes BLUR-74.
Date Mon, 22 Apr 2013 02:16:31 GMT
Updated Branches:
  refs/heads/0.1.5 830def562 -> 7dd0ea550


http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/7dd0ea55/src/distribution/src/main/scripts/interface/gen-perl/Blur/Blur.pm
----------------------------------------------------------------------
diff --git a/src/distribution/src/main/scripts/interface/gen-perl/Blur/Blur.pm b/src/distribution/src/main/scripts/interface/gen-perl/Blur/Blur.pm
index 068063b..e001421 100644
--- a/src/distribution/src/main/scripts/interface/gen-perl/Blur/Blur.pm
+++ b/src/distribution/src/main/scripts/interface/gen-perl/Blur/Blur.pm
@@ -640,6 +640,200 @@ sub write {
   return $xfer;
 }
 
+package Blur::Blur_shardServerLayoutState_args;
+use base qw(Class::Accessor);
+Blur::Blur_shardServerLayoutState_args->mk_accessors( qw( table ) );
+
+sub new {
+  my $classname = shift;
+  my $self      = {};
+  my $vals      = shift || {};
+  $self->{table} = undef;
+  if (UNIVERSAL::isa($vals,'HASH')) {
+    if (defined $vals->{table}) {
+      $self->{table} = $vals->{table};
+    }
+  }
+  return bless ($self, $classname);
+}
+
+sub getName {
+  return 'Blur_shardServerLayoutState_args';
+}
+
+sub read {
+  my ($self, $input) = @_;
+  my $xfer  = 0;
+  my $fname;
+  my $ftype = 0;
+  my $fid   = 0;
+  $xfer += $input->readStructBegin(\$fname);
+  while (1) 
+  {
+    $xfer += $input->readFieldBegin(\$fname, \$ftype, \$fid);
+    if ($ftype == TType::STOP) {
+      last;
+    }
+    SWITCH: for($fid)
+    {
+      /^1$/ && do{      if ($ftype == TType::STRING) {
+        $xfer += $input->readString(\$self->{table});
+      } else {
+        $xfer += $input->skip($ftype);
+      }
+      last; };
+        $xfer += $input->skip($ftype);
+    }
+    $xfer += $input->readFieldEnd();
+  }
+  $xfer += $input->readStructEnd();
+  return $xfer;
+}
+
+sub write {
+  my ($self, $output) = @_;
+  my $xfer   = 0;
+  $xfer += $output->writeStructBegin('Blur_shardServerLayoutState_args');
+  if (defined $self->{table}) {
+    $xfer += $output->writeFieldBegin('table', TType::STRING, 1);
+    $xfer += $output->writeString($self->{table});
+    $xfer += $output->writeFieldEnd();
+  }
+  $xfer += $output->writeFieldStop();
+  $xfer += $output->writeStructEnd();
+  return $xfer;
+}
+
+package Blur::Blur_shardServerLayoutState_result;
+use base qw(Class::Accessor);
+Blur::Blur_shardServerLayoutState_result->mk_accessors( qw( success ) );
+
+sub new {
+  my $classname = shift;
+  my $self      = {};
+  my $vals      = shift || {};
+  $self->{success} = undef;
+  $self->{ex} = undef;
+  if (UNIVERSAL::isa($vals,'HASH')) {
+    if (defined $vals->{success}) {
+      $self->{success} = $vals->{success};
+    }
+    if (defined $vals->{ex}) {
+      $self->{ex} = $vals->{ex};
+    }
+  }
+  return bless ($self, $classname);
+}
+
+sub getName {
+  return 'Blur_shardServerLayoutState_result';
+}
+
+sub read {
+  my ($self, $input) = @_;
+  my $xfer  = 0;
+  my $fname;
+  my $ftype = 0;
+  my $fid   = 0;
+  $xfer += $input->readStructBegin(\$fname);
+  while (1) 
+  {
+    $xfer += $input->readFieldBegin(\$fname, \$ftype, \$fid);
+    if ($ftype == TType::STOP) {
+      last;
+    }
+    SWITCH: for($fid)
+    {
+      /^0$/ && do{      if ($ftype == TType::MAP) {
+        {
+          my $_size186 = 0;
+          $self->{success} = {};
+          my $_ktype187 = 0;
+          my $_vtype188 = 0;
+          $xfer += $input->readMapBegin(\$_ktype187, \$_vtype188, \$_size186);
+          for (my $_i190 = 0; $_i190 < $_size186; ++$_i190)
+          {
+            my $key191 = '';
+            my $val192 = [];
+            $xfer += $input->readString(\$key191);
+            {
+              my $_size193 = 0;
+              $val192 = {};
+              my $_ktype194 = 0;
+              my $_vtype195 = 0;
+              $xfer += $input->readMapBegin(\$_ktype194, \$_vtype195, \$_size193);
+              for (my $_i197 = 0; $_i197 < $_size193; ++$_i197)
+              {
+                my $key198 = '';
+                my $val199 = 0;
+                $xfer += $input->readString(\$key198);
+                $xfer += $input->readI32(\$val199);
+                $val192->{$key198} = $val199;
+              }
+              $xfer += $input->readMapEnd();
+            }
+            $self->{success}->{$key191} = $val192;
+          }
+          $xfer += $input->readMapEnd();
+        }
+      } else {
+        $xfer += $input->skip($ftype);
+      }
+      last; };
+      /^1$/ && do{      if ($ftype == TType::STRUCT) {
+        $self->{ex} = new Blur::BlurException();
+        $xfer += $self->{ex}->read($input);
+      } else {
+        $xfer += $input->skip($ftype);
+      }
+      last; };
+        $xfer += $input->skip($ftype);
+    }
+    $xfer += $input->readFieldEnd();
+  }
+  $xfer += $input->readStructEnd();
+  return $xfer;
+}
+
+sub write {
+  my ($self, $output) = @_;
+  my $xfer   = 0;
+  $xfer += $output->writeStructBegin('Blur_shardServerLayoutState_result');
+  if (defined $self->{success}) {
+    $xfer += $output->writeFieldBegin('success', TType::MAP, 0);
+    {
+      $xfer += $output->writeMapBegin(TType::STRING, TType::MAP, scalar(keys %{$self->{success}}));
+      {
+        while( my ($kiter200,$viter201) = each %{$self->{success}}) 
+        {
+          $xfer += $output->writeString($kiter200);
+          {
+            $xfer += $output->writeMapBegin(TType::STRING, TType::I32, scalar(keys %{${viter201}}));
+            {
+              while( my ($kiter202,$viter203) = each %{${viter201}}) 
+              {
+                $xfer += $output->writeString($kiter202);
+                $xfer += $output->writeI32($viter203);
+              }
+            }
+            $xfer += $output->writeMapEnd();
+          }
+        }
+      }
+      $xfer += $output->writeMapEnd();
+    }
+    $xfer += $output->writeFieldEnd();
+  }
+  if (defined $self->{ex}) {
+    $xfer += $output->writeFieldBegin('ex', TType::STRUCT, 1);
+    $xfer += $self->{ex}->write($output);
+    $xfer += $output->writeFieldEnd();
+  }
+  $xfer += $output->writeFieldStop();
+  $xfer += $output->writeStructEnd();
+  return $xfer;
+}
+
 package Blur::Blur_tableList_args;
 use base qw(Class::Accessor);
 
@@ -728,15 +922,15 @@ sub read {
     {
       /^0$/ && do{      if ($ftype == TType::LIST) {
         {
-          my $_size186 = 0;
+          my $_size204 = 0;
           $self->{success} = [];
-          my $_etype189 = 0;
-          $xfer += $input->readListBegin(\$_etype189, \$_size186);
-          for (my $_i190 = 0; $_i190 < $_size186; ++$_i190)
+          my $_etype207 = 0;
+          $xfer += $input->readListBegin(\$_etype207, \$_size204);
+          for (my $_i208 = 0; $_i208 < $_size204; ++$_i208)
           {
-            my $elem191 = undef;
-            $xfer += $input->readString(\$elem191);
-            push(@{$self->{success}},$elem191);
+            my $elem209 = undef;
+            $xfer += $input->readString(\$elem209);
+            push(@{$self->{success}},$elem209);
           }
           $xfer += $input->readListEnd();
         }
@@ -768,9 +962,9 @@ sub write {
     {
       $xfer += $output->writeListBegin(TType::STRING, scalar(@{$self->{success}}));
       {
-        foreach my $iter192 (@{$self->{success}}) 
+        foreach my $iter210 (@{$self->{success}}) 
         {
-          $xfer += $output->writeString($iter192);
+          $xfer += $output->writeString($iter210);
         }
       }
       $xfer += $output->writeListEnd();
@@ -893,15 +1087,15 @@ sub read {
     {
       /^0$/ && do{      if ($ftype == TType::LIST) {
         {
-          my $_size193 = 0;
+          my $_size211 = 0;
           $self->{success} = [];
-          my $_etype196 = 0;
-          $xfer += $input->readListBegin(\$_etype196, \$_size193);
-          for (my $_i197 = 0; $_i197 < $_size193; ++$_i197)
+          my $_etype214 = 0;
+          $xfer += $input->readListBegin(\$_etype214, \$_size211);
+          for (my $_i215 = 0; $_i215 < $_size211; ++$_i215)
           {
-            my $elem198 = undef;
-            $xfer += $input->readString(\$elem198);
-            push(@{$self->{success}},$elem198);
+            my $elem216 = undef;
+            $xfer += $input->readString(\$elem216);
+            push(@{$self->{success}},$elem216);
           }
           $xfer += $input->readListEnd();
         }
@@ -933,9 +1127,9 @@ sub write {
     {
       $xfer += $output->writeListBegin(TType::STRING, scalar(@{$self->{success}}));
       {
-        foreach my $iter199 (@{$self->{success}}) 
+        foreach my $iter217 (@{$self->{success}}) 
         {
-          $xfer += $output->writeString($iter199);
+          $xfer += $output->writeString($iter217);
         }
       }
       $xfer += $output->writeListEnd();
@@ -1508,16 +1702,16 @@ sub read {
     {
       /^0$/ && do{      if ($ftype == TType::LIST) {
         {
-          my $_size200 = 0;
+          my $_size218 = 0;
           $self->{success} = [];
-          my $_etype203 = 0;
-          $xfer += $input->readListBegin(\$_etype203, \$_size200);
-          for (my $_i204 = 0; $_i204 < $_size200; ++$_i204)
+          my $_etype221 = 0;
+          $xfer += $input->readListBegin(\$_etype221, \$_size218);
+          for (my $_i222 = 0; $_i222 < $_size218; ++$_i222)
           {
-            my $elem205 = undef;
-            $elem205 = new Blur::BlurQueryStatus();
-            $xfer += $elem205->read($input);
-            push(@{$self->{success}},$elem205);
+            my $elem223 = undef;
+            $elem223 = new Blur::BlurQueryStatus();
+            $xfer += $elem223->read($input);
+            push(@{$self->{success}},$elem223);
           }
           $xfer += $input->readListEnd();
         }
@@ -1549,9 +1743,9 @@ sub write {
     {
       $xfer += $output->writeListBegin(TType::STRUCT, scalar(@{$self->{success}}));
       {
-        foreach my $iter206 (@{$self->{success}}) 
+        foreach my $iter224 (@{$self->{success}}) 
         {
-          $xfer += ${iter206}->write($output);
+          $xfer += ${iter224}->write($output);
         }
       }
       $xfer += $output->writeListEnd();
@@ -1674,15 +1868,15 @@ sub read {
     {
       /^0$/ && do{      if ($ftype == TType::LIST) {
         {
-          my $_size207 = 0;
+          my $_size225 = 0;
           $self->{success} = [];
-          my $_etype210 = 0;
-          $xfer += $input->readListBegin(\$_etype210, \$_size207);
-          for (my $_i211 = 0; $_i211 < $_size207; ++$_i211)
+          my $_etype228 = 0;
+          $xfer += $input->readListBegin(\$_etype228, \$_size225);
+          for (my $_i229 = 0; $_i229 < $_size225; ++$_i229)
           {
-            my $elem212 = undef;
-            $xfer += $input->readI64(\$elem212);
-            push(@{$self->{success}},$elem212);
+            my $elem230 = undef;
+            $xfer += $input->readI64(\$elem230);
+            push(@{$self->{success}},$elem230);
           }
           $xfer += $input->readListEnd();
         }
@@ -1714,9 +1908,9 @@ sub write {
     {
       $xfer += $output->writeListBegin(TType::I64, scalar(@{$self->{success}}));
       {
-        foreach my $iter213 (@{$self->{success}}) 
+        foreach my $iter231 (@{$self->{success}}) 
         {
-          $xfer += $output->writeI64($iter213);
+          $xfer += $output->writeI64($iter231);
         }
       }
       $xfer += $output->writeListEnd();
@@ -2494,15 +2688,15 @@ sub read {
     {
       /^0$/ && do{      if ($ftype == TType::LIST) {
         {
-          my $_size214 = 0;
+          my $_size232 = 0;
           $self->{success} = [];
-          my $_etype217 = 0;
-          $xfer += $input->readListBegin(\$_etype217, \$_size214);
-          for (my $_i218 = 0; $_i218 < $_size214; ++$_i218)
+          my $_etype235 = 0;
+          $xfer += $input->readListBegin(\$_etype235, \$_size232);
+          for (my $_i236 = 0; $_i236 < $_size232; ++$_i236)
           {
-            my $elem219 = undef;
-            $xfer += $input->readString(\$elem219);
-            push(@{$self->{success}},$elem219);
+            my $elem237 = undef;
+            $xfer += $input->readString(\$elem237);
+            push(@{$self->{success}},$elem237);
           }
           $xfer += $input->readListEnd();
         }
@@ -2534,9 +2728,9 @@ sub write {
     {
       $xfer += $output->writeListBegin(TType::STRING, scalar(@{$self->{success}}));
       {
-        foreach my $iter220 (@{$self->{success}}) 
+        foreach my $iter238 (@{$self->{success}}) 
         {
-          $xfer += $output->writeString($iter220);
+          $xfer += $output->writeString($iter238);
         }
       }
       $xfer += $output->writeListEnd();
@@ -3071,16 +3265,16 @@ sub read {
     {
       /^1$/ && do{      if ($ftype == TType::LIST) {
         {
-          my $_size221 = 0;
+          my $_size239 = 0;
           $self->{mutations} = [];
-          my $_etype224 = 0;
-          $xfer += $input->readListBegin(\$_etype224, \$_size221);
-          for (my $_i225 = 0; $_i225 < $_size221; ++$_i225)
+          my $_etype242 = 0;
+          $xfer += $input->readListBegin(\$_etype242, \$_size239);
+          for (my $_i243 = 0; $_i243 < $_size239; ++$_i243)
           {
-            my $elem226 = undef;
-            $elem226 = new Blur::RowMutation();
-            $xfer += $elem226->read($input);
-            push(@{$self->{mutations}},$elem226);
+            my $elem244 = undef;
+            $elem244 = new Blur::RowMutation();
+            $xfer += $elem244->read($input);
+            push(@{$self->{mutations}},$elem244);
           }
           $xfer += $input->readListEnd();
         }
@@ -3105,9 +3299,9 @@ sub write {
     {
       $xfer += $output->writeListBegin(TType::STRUCT, scalar(@{$self->{mutations}}));
       {
-        foreach my $iter227 (@{$self->{mutations}}) 
+        foreach my $iter245 (@{$self->{mutations}}) 
         {
-          $xfer += ${iter227}->write($output);
+          $xfer += ${iter245}->write($output);
         }
       }
       $xfer += $output->writeListEnd();
@@ -4092,18 +4286,18 @@ sub read {
     {
       /^0$/ && do{      if ($ftype == TType::MAP) {
         {
-          my $_size228 = 0;
+          my $_size246 = 0;
           $self->{success} = {};
-          my $_ktype229 = 0;
-          my $_vtype230 = 0;
-          $xfer += $input->readMapBegin(\$_ktype229, \$_vtype230, \$_size228);
-          for (my $_i232 = 0; $_i232 < $_size228; ++$_i232)
+          my $_ktype247 = 0;
+          my $_vtype248 = 0;
+          $xfer += $input->readMapBegin(\$_ktype247, \$_vtype248, \$_size246);
+          for (my $_i250 = 0; $_i250 < $_size246; ++$_i250)
           {
-            my $key233 = '';
-            my $val234 = '';
-            $xfer += $input->readString(\$key233);
-            $xfer += $input->readString(\$val234);
-            $self->{success}->{$key233} = $val234;
+            my $key251 = '';
+            my $val252 = '';
+            $xfer += $input->readString(\$key251);
+            $xfer += $input->readString(\$val252);
+            $self->{success}->{$key251} = $val252;
           }
           $xfer += $input->readMapEnd();
         }
@@ -4135,10 +4329,10 @@ sub write {
     {
       $xfer += $output->writeMapBegin(TType::STRING, TType::STRING, scalar(keys %{$self->{success}}));
       {
-        while( my ($kiter235,$viter236) = each %{$self->{success}}) 
+        while( my ($kiter253,$viter254) = each %{$self->{success}}) 
         {
-          $xfer += $output->writeString($kiter235);
-          $xfer += $output->writeString($viter236);
+          $xfer += $output->writeString($kiter253);
+          $xfer += $output->writeString($viter254);
         }
       }
       $xfer += $output->writeMapEnd();
@@ -4186,6 +4380,13 @@ sub shardServerLayout{
   die 'implement interface';
 }
 
+sub shardServerLayoutState{
+  my $self = shift;
+  my $table = shift;
+
+  die 'implement interface';
+}
+
 sub tableList{
   my $self = shift;
 
@@ -4396,6 +4597,13 @@ sub shardServerLayout{
   return $self->{impl}->shardServerLayout($table);
 }
 
+sub shardServerLayoutState{
+  my ($self, $request) = @_;
+
+  my $table = ($request->{'table'}) ? $request->{'table'} : undef;
+  return $self->{impl}->shardServerLayoutState($table);
+}
+
 sub tableList{
   my ($self, $request) = @_;
 
@@ -4759,6 +4967,52 @@ sub recv_shardServerLayout{
   }
   die "shardServerLayout failed: unknown result";
 }
+sub shardServerLayoutState{
+  my $self = shift;
+  my $table = shift;
+
+    $self->send_shardServerLayoutState($table);
+  return $self->recv_shardServerLayoutState();
+}
+
+sub send_shardServerLayoutState{
+  my $self = shift;
+  my $table = shift;
+
+  $self->{output}->writeMessageBegin('shardServerLayoutState', TMessageType::CALL,
$self->{seqid});
+  my $args = new Blur::Blur_shardServerLayoutState_args();
+  $args->{table} = $table;
+  $args->write($self->{output});
+  $self->{output}->writeMessageEnd();
+  $self->{output}->getTransport()->flush();
+}
+
+sub recv_shardServerLayoutState{
+  my $self = shift;
+
+  my $rseqid = 0;
+  my $fname;
+  my $mtype = 0;
+
+  $self->{input}->readMessageBegin(\$fname, \$mtype, \$rseqid);
+  if ($mtype == TMessageType::EXCEPTION) {
+    my $x = new TApplicationException();
+    $x->read($self->{input});
+    $self->{input}->readMessageEnd();
+    die $x;
+  }
+  my $result = new Blur::Blur_shardServerLayoutState_result();
+  $result->read($self->{input});
+  $self->{input}->readMessageEnd();
+
+  if (defined $result->{success} ) {
+    return $result->{success};
+  }
+  if (defined $result->{ex}) {
+    die $result->{ex};
+  }
+  die "shardServerLayoutState failed: unknown result";
+}
 sub tableList{
   my $self = shift;
 
@@ -5928,6 +6182,23 @@ sub process_shardServerLayout {
     $output->getTransport()->flush();
 }
 
+sub process_shardServerLayoutState {
+    my ($self, $seqid, $input, $output) = @_;
+    my $args = new Blur::Blur_shardServerLayoutState_args();
+    $args->read($input);
+    $input->readMessageEnd();
+    my $result = new Blur::Blur_shardServerLayoutState_result();
+    eval {
+      $result->{success} = $self->{handler}->shardServerLayoutState($args->table);
+    }; if( UNIVERSAL::isa($@,'Blur::BlurException') ){ 
+      $result->{ex} = $@;
+    }
+    $output->writeMessageBegin('shardServerLayoutState', TMessageType::REPLY, $seqid);
+    $result->write($output);
+    $output->writeMessageEnd();
+    $output->getTransport()->flush();
+}
+
 sub process_tableList {
     my ($self, $seqid, $input, $output) = @_;
     my $args = new Blur::Blur_tableList_args();

http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/7dd0ea55/src/distribution/src/main/scripts/interface/gen-perl/Blur/Types.pm
----------------------------------------------------------------------
diff --git a/src/distribution/src/main/scripts/interface/gen-perl/Blur/Types.pm b/src/distribution/src/main/scripts/interface/gen-perl/Blur/Types.pm
index ffaed44..61f627d 100644
--- a/src/distribution/src/main/scripts/interface/gen-perl/Blur/Types.pm
+++ b/src/distribution/src/main/scripts/interface/gen-perl/Blur/Types.pm
@@ -26,6 +26,13 @@ use constant DELETE_ENTIRE_RECORD => 0;
 use constant REPLACE_ENTIRE_RECORD => 1;
 use constant REPLACE_COLUMNS => 2;
 use constant APPEND_COLUMN_VALUES => 3;
+package Blur::ShardState;
+use constant OPENING => 0;
+use constant OPEN => 1;
+use constant OPENING_ERROR => 2;
+use constant CLOSING => 3;
+use constant CLOSED => 4;
+use constant CLOSING_ERROR => 5;
 package Blur::BlurException;
 use base qw(Thrift::TException);
 use base qw(Class::Accessor);

http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/7dd0ea55/src/distribution/src/main/scripts/interface/gen-rb/blur.rb
----------------------------------------------------------------------
diff --git a/src/distribution/src/main/scripts/interface/gen-rb/blur.rb b/src/distribution/src/main/scripts/interface/gen-rb/blur.rb
index aa17c7a..27043c9 100644
--- a/src/distribution/src/main/scripts/interface/gen-rb/blur.rb
+++ b/src/distribution/src/main/scripts/interface/gen-rb/blur.rb
@@ -76,6 +76,22 @@ module Blur
         raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT,
'shardServerLayout failed: unknown result')
       end
 
+      def shardServerLayoutState(table)
+        send_shardServerLayoutState(table)
+        return recv_shardServerLayoutState()
+      end
+
+      def send_shardServerLayoutState(table)
+        send_message('shardServerLayoutState', ShardServerLayoutState_args, :table =>
table)
+      end
+
+      def recv_shardServerLayoutState()
+        result = receive_message(ShardServerLayoutState_result)
+        return result.success unless result.success.nil?
+        raise result.ex unless result.ex.nil?
+        raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT,
'shardServerLayoutState failed: unknown result')
+      end
+
       def tableList()
         send_tableList()
         return recv_tableList()
@@ -485,6 +501,17 @@ module Blur
         write_result(result, oprot, 'shardServerLayout', seqid)
       end
 
+      def process_shardServerLayoutState(seqid, iprot, oprot)
+        args = read_args(iprot, ShardServerLayoutState_args)
+        result = ShardServerLayoutState_result.new()
+        begin
+          result.success = @handler.shardServerLayoutState(args.table)
+        rescue ::Blur::BlurException => ex
+          result.ex = ex
+        end
+        write_result(result, oprot, 'shardServerLayoutState', seqid)
+      end
+
       def process_tableList(seqid, iprot, oprot)
         args = read_args(iprot, TableList_args)
         result = TableList_result.new()
@@ -876,6 +903,40 @@ module Blur
       ::Thrift::Struct.generate_accessors self
     end
 
+    class ShardServerLayoutState_args
+      include ::Thrift::Struct, ::Thrift::Struct_Union
+      TABLE = 1
+
+      FIELDS = {
+        TABLE => {:type => ::Thrift::Types::STRING, :name => 'table'}
+      }
+
+      def struct_fields; FIELDS; end
+
+      def validate
+      end
+
+      ::Thrift::Struct.generate_accessors self
+    end
+
+    class ShardServerLayoutState_result
+      include ::Thrift::Struct, ::Thrift::Struct_Union
+      SUCCESS = 0
+      EX = 1
+
+      FIELDS = {
+        SUCCESS => {:type => ::Thrift::Types::MAP, :name => 'success', :key =>
{:type => ::Thrift::Types::STRING}, :value => {:type => ::Thrift::Types::MAP, :key
=> {:type => ::Thrift::Types::STRING}, :value => {:type => ::Thrift::Types::I32,
:enum_class => ::Blur::ShardState}}},
+        EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => ::Blur::BlurException}
+      }
+
+      def struct_fields; FIELDS; end
+
+      def validate
+      end
+
+      ::Thrift::Struct.generate_accessors self
+    end
+
     class TableList_args
       include ::Thrift::Struct, ::Thrift::Struct_Union
 

http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/7dd0ea55/src/distribution/src/main/scripts/interface/gen-rb/blur_types.rb
----------------------------------------------------------------------
diff --git a/src/distribution/src/main/scripts/interface/gen-rb/blur_types.rb b/src/distribution/src/main/scripts/interface/gen-rb/blur_types.rb
index 8b40b6c..a8e451c 100644
--- a/src/distribution/src/main/scripts/interface/gen-rb/blur_types.rb
+++ b/src/distribution/src/main/scripts/interface/gen-rb/blur_types.rb
@@ -41,6 +41,17 @@ module Blur
     VALID_VALUES = Set.new([DELETE_ENTIRE_RECORD, REPLACE_ENTIRE_RECORD, REPLACE_COLUMNS,
APPEND_COLUMN_VALUES]).freeze
   end
 
+  module ShardState
+    OPENING = 0
+    OPEN = 1
+    OPENING_ERROR = 2
+    CLOSING = 3
+    CLOSED = 4
+    CLOSING_ERROR = 5
+    VALUE_MAP = {0 => "OPENING", 1 => "OPEN", 2 => "OPENING_ERROR", 3 => "CLOSING",
4 => "CLOSED", 5 => "CLOSING_ERROR"}
+    VALID_VALUES = Set.new([OPENING, OPEN, OPENING_ERROR, CLOSING, CLOSED, CLOSING_ERROR]).freeze
+  end
+
   # BlurException that carries a message plus the original stack
 # trace (if any).
   class BlurException < ::Thrift::Exception


Mime
View raw message