Review Board 1.7.22


FLUME-1183:Hbase sink

Review Request #5073 - Created May 9, 2012 and submitted

Hari Shreedharan
trunk
FLUME-1183
Reviewers
Flume
flume-git
Hbase sink.
Unit tests added
pom.xml
Revision 8c11a2d New Change
[20] 621 lines
[+20]
622
        <groupId>joda-time</groupId>
622
        <groupId>joda-time</groupId>
623
        <artifactId>joda-time</artifactId>
623
        <artifactId>joda-time</artifactId>
624
        <version>2.1</version>
624
        <version>2.1</version>
625
      </dependency>
625
      </dependency>
626

    
   
626

   

    
   
627
      <dependency>

    
   
628
        <groupId>org.apache.hbase</groupId>

    
   
629
        <artifactId>hbase</artifactId>

    
   
630
        <version>0.92.1</version>

    
   
631
      </dependency>

    
   
632

   

    
   
633
      <dependency>

    
   
634
        <groupId>org.apache.hbase</groupId>

    
   
635
        <artifactId>hbase</artifactId>

    
   
636
        <version>0.92.1</version>

    
   
637
        <classifier>tests</classifier>

    
   
638
        <scope>test</scope>

    
   
639
      </dependency>

    
   
640

   

    
   
641
      <dependency>

    
   
642
        <groupId>org.apache.hadoop</groupId>

    
   
643
        <artifactId>hadoop</artifactId>

    
   
644
        <version>${hadoop.version}</version>

    
   
645
      </dependency>

    
   
646

   

    
   
647
      <dependency>

    
   
648
        <groupId>org.apache.hadoop</groupId>

    
   
649
        <artifactId>hadoop-test</artifactId>

    
   
650
        <version>${hadoop.version}</version>

    
   
651
        <scope>test</scope>

    
   
652
      </dependency>
627

    
   
653

   
628
      <!-- internal module dependencies -->
654
      <!-- internal module dependencies -->
629

    
   
655

   
630
      <dependency>
656
      <dependency>
631
        <groupId>org.apache.flume</groupId>
657
        <groupId>org.apache.flume</groupId>
[+20] [20] 41 lines
[+20]
673
        <artifactId>flume-irc-sink</artifactId>
699
        <artifactId>flume-irc-sink</artifactId>
674
        <version>1.2.0-incubating-SNAPSHOT</version>
700
        <version>1.2.0-incubating-SNAPSHOT</version>
675
      </dependency>
701
      </dependency>
676

    
   
702

   
677
      <dependency>
703
      <dependency>

    
   
704
        <groupId>org.apache.flume.flume-ng-sinks</groupId>

    
   
705
        <artifactId>flume-ng-hbase-sink</artifactId>

    
   
706
        <version>1.2.0-incubating-SNAPSHOT</version>

    
   
707
      </dependency>

    
   
708

   

    
   
709
      <dependency>
678
        <groupId>org.apache.flume.flume-ng-legacy-sources</groupId>
710
        <groupId>org.apache.flume.flume-ng-legacy-sources</groupId>
679
        <artifactId>flume-thrift-source</artifactId>
711
        <artifactId>flume-thrift-source</artifactId>
680
        <version>1.2.0-incubating-SNAPSHOT</version>
712
        <version>1.2.0-incubating-SNAPSHOT</version>
681
      </dependency>
713
      </dependency>
682

    
   
714

   
[+20] [20] 48 lines
bin/flume-ng
Revision 0108997 New Change
 
flume-ng-dist/pom.xml
Revision 5bdcfe7 New Change
 
flume-ng-sinks/pom.xml
Revision acb3087 New Change
 
flume-ng-sinks/flume-ng-hbase-sink/pom.xml
New File
 
flume-ng-sinks/flume-ng-hbase-sink/src/main/java/org/apache/flume/sink/hbase/HBaseSink.java
New File
 
flume-ng-sinks/flume-ng-hbase-sink/src/main/java/org/apache/flume/sink/hbase/HbaseEventSerializer.java
New File
 
flume-ng-sinks/flume-ng-hbase-sink/src/main/java/org/apache/flume/sink/hbase/SimpleHbaseEventSerializer.java
New File
 
flume-ng-sinks/flume-ng-hbase-sink/src/main/java/org/apache/flume/sink/hbase/SimpleRowKeyGenerator.java
New File
 
flume-ng-sinks/flume-ng-hbase-sink/src/test/java/org/apache/flume/sink/hbase/TestHBaseSink.java
New File
 
  1. pom.xml: Loading...
  2. bin/flume-ng: Loading...
  3. flume-ng-dist/pom.xml: Loading...
  4. flume-ng-sinks/pom.xml: Loading...
  5. flume-ng-sinks/flume-ng-hbase-sink/pom.xml: Loading...
  6. flume-ng-sinks/flume-ng-hbase-sink/src/main/java/org/apache/flume/sink/hbase/HBaseSink.java: Loading...
  7. flume-ng-sinks/flume-ng-hbase-sink/src/main/java/org/apache/flume/sink/hbase/HbaseEventSerializer.java: Loading...
  8. flume-ng-sinks/flume-ng-hbase-sink/src/main/java/org/apache/flume/sink/hbase/SimpleHbaseEventSerializer.java: Loading...
  9. flume-ng-sinks/flume-ng-hbase-sink/src/main/java/org/apache/flume/sink/hbase/SimpleRowKeyGenerator.java: Loading...
  10. flume-ng-sinks/flume-ng-hbase-sink/src/test/java/org/apache/flume/sink/hbase/TestHBaseSink.java: Loading...