incubator-blur-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From amccu...@apache.org
Subject [2/5] git commit: Generated code changes.
Date Mon, 15 Dec 2014 15:38:43 GMT
http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/25ad5d45/distribution/src/main/scripts/interface/gen-perl/Blur/Blur.pm
----------------------------------------------------------------------
diff --git a/distribution/src/main/scripts/interface/gen-perl/Blur/Blur.pm b/distribution/src/main/scripts/interface/gen-perl/Blur/Blur.pm
index 3bd192e..eec4783 100644
--- a/distribution/src/main/scripts/interface/gen-perl/Blur/Blur.pm
+++ b/distribution/src/main/scripts/interface/gen-perl/Blur/Blur.pm
@@ -3916,6 +3916,150 @@ sub write {
   return $xfer;
 }
 
+package Blur::Blur_loadData_args;
+use base qw(Class::Accessor);
+Blur::Blur_loadData_args->mk_accessors( qw( table location ) );
+
+sub new {
+  my $classname = shift;
+  my $self      = {};
+  my $vals      = shift || {};
+  $self->{table} = undef;
+  $self->{location} = undef;
+  if (UNIVERSAL::isa($vals,'HASH')) {
+    if (defined $vals->{table}) {
+      $self->{table} = $vals->{table};
+    }
+    if (defined $vals->{location}) {
+      $self->{location} = $vals->{location};
+    }
+  }
+  return bless ($self, $classname);
+}
+
+sub getName {
+  return 'Blur_loadData_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; };
+      /^2$/ && do{      if ($ftype == TType::STRING) {
+        $xfer += $input->readString(\$self->{location});
+      } 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_loadData_args');
+  if (defined $self->{table}) {
+    $xfer += $output->writeFieldBegin('table', TType::STRING, 1);
+    $xfer += $output->writeString($self->{table});
+    $xfer += $output->writeFieldEnd();
+  }
+  if (defined $self->{location}) {
+    $xfer += $output->writeFieldBegin('location', TType::STRING, 2);
+    $xfer += $output->writeString($self->{location});
+    $xfer += $output->writeFieldEnd();
+  }
+  $xfer += $output->writeFieldStop();
+  $xfer += $output->writeStructEnd();
+  return $xfer;
+}
+
+package Blur::Blur_loadData_result;
+use base qw(Class::Accessor);
+Blur::Blur_loadData_result->mk_accessors( qw( ) );
+
+sub new {
+  my $classname = shift;
+  my $self      = {};
+  my $vals      = shift || {};
+  $self->{ex} = undef;
+  if (UNIVERSAL::isa($vals,'HASH')) {
+    if (defined $vals->{ex}) {
+      $self->{ex} = $vals->{ex};
+    }
+  }
+  return bless ($self, $classname);
+}
+
+sub getName {
+  return 'Blur_loadData_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)
+    {
+      /^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_loadData_result');
+  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_mutate_args;
 use base qw(Class::Accessor);
 Blur::Blur_mutate_args->mk_accessors( qw( mutation ) );
@@ -7937,6 +8081,14 @@ sub fetchRowBatch{
   die 'implement interface';
 }
 
+sub loadData{
+  my $self = shift;
+  my $table = shift;
+  my $location = shift;
+
+  die 'implement interface';
+}
+
 sub mutate{
   my $self = shift;
   my $mutation = shift;
@@ -8321,6 +8473,14 @@ sub fetchRowBatch{
   return $self->{impl}->fetchRowBatch($table, $selectors);
 }
 
+sub loadData{
+  my ($self, $request) = @_;
+
+  my $table = ($request->{'table'}) ? $request->{'table'} : undef;
+  my $location = ($request->{'location'}) ? $request->{'location'} : undef;
+  return $self->{impl}->loadData($table, $location);
+}
+
 sub mutate{
   my ($self, $request) = @_;
 
@@ -9664,6 +9824,52 @@ sub recv_fetchRowBatch{
   }
   die "fetchRowBatch failed: unknown result";
 }
+sub loadData{
+  my $self = shift;
+  my $table = shift;
+  my $location = shift;
+
+    $self->send_loadData($table, $location);
+  $self->recv_loadData();
+}
+
+sub send_loadData{
+  my $self = shift;
+  my $table = shift;
+  my $location = shift;
+
+  $self->{output}->writeMessageBegin('loadData', TMessageType::CALL, $self->{seqid});
+  my $args = new Blur::Blur_loadData_args();
+  $args->{table} = $table;
+  $args->{location} = $location;
+  $args->write($self->{output});
+  $self->{output}->writeMessageEnd();
+  $self->{output}->getTransport()->flush();
+}
+
+sub recv_loadData{
+  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_loadData_result();
+  $result->read($self->{input});
+  $self->{input}->readMessageEnd();
+
+  if (defined $result->{ex}) {
+    die $result->{ex};
+  }
+  return;
+}
 sub mutate{
   my $self = shift;
   my $mutation = shift;
@@ -11236,6 +11442,23 @@ sub process_fetchRowBatch {
     $output->getTransport()->flush();
 }
 
+sub process_loadData {
+    my ($self, $seqid, $input, $output) = @_;
+    my $args = new Blur::Blur_loadData_args();
+    $args->read($input);
+    $input->readMessageEnd();
+    my $result = new Blur::Blur_loadData_result();
+    eval {
+      $self->{handler}->loadData($args->table, $args->location);
+    }; if( UNIVERSAL::isa($@,'Blur::BlurException') ){ 
+      $result->{ex} = $@;
+    }
+    $output->writeMessageBegin('loadData', TMessageType::REPLY, $seqid);
+    $result->write($output);
+    $output->writeMessageEnd();
+    $output->getTransport()->flush();
+}
+
 sub process_mutate {
     my ($self, $seqid, $input, $output) = @_;
     my $args = new Blur::Blur_mutate_args();

http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/25ad5d45/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 706ff09..124d1d5 100644
--- a/distribution/src/main/scripts/interface/gen-rb/blur.rb
+++ b/distribution/src/main/scripts/interface/gen-rb/blur.rb
@@ -404,6 +404,21 @@ module Blur
         raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT,
'fetchRowBatch failed: unknown result')
       end
 
+      def loadData(table, location)
+        send_loadData(table, location)
+        recv_loadData()
+      end
+
+      def send_loadData(table, location)
+        send_message('loadData', LoadData_args, :table => table, :location => location)
+      end
+
+      def recv_loadData()
+        result = receive_message(LoadData_result)
+        raise result.ex unless result.ex.nil?
+        return
+      end
+
       def mutate(mutation)
         send_mutate(mutation)
         recv_mutate()
@@ -1070,6 +1085,17 @@ module Blur
         write_result(result, oprot, 'fetchRowBatch', seqid)
       end
 
+      def process_loadData(seqid, iprot, oprot)
+        args = read_args(iprot, LoadData_args)
+        result = LoadData_result.new()
+        begin
+          @handler.loadData(args.table, args.location)
+        rescue ::Blur::BlurException => ex
+          result.ex = ex
+        end
+        write_result(result, oprot, 'loadData', seqid)
+      end
+
       def process_mutate(seqid, iprot, oprot)
         args = read_args(iprot, Mutate_args)
         result = Mutate_result.new()
@@ -2252,6 +2278,42 @@ module Blur
       ::Thrift::Struct.generate_accessors self
     end
 
+    class LoadData_args
+      include ::Thrift::Struct, ::Thrift::Struct_Union
+      TABLE = 1
+      LOCATION = 2
+
+      FIELDS = {
+        # The table name.
+        TABLE => {:type => ::Thrift::Types::STRING, :name => 'table'},
+        # Location of bulk data load.
+        LOCATION => {:type => ::Thrift::Types::STRING, :name => 'location'}
+      }
+
+      def struct_fields; FIELDS; end
+
+      def validate
+      end
+
+      ::Thrift::Struct.generate_accessors self
+    end
+
+    class LoadData_result
+      include ::Thrift::Struct, ::Thrift::Struct_Union
+      EX = 1
+
+      FIELDS = {
+        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 Mutate_args
       include ::Thrift::Struct, ::Thrift::Struct_Union
       MUTATION = 1


Mime
View raw message