example added

2013Commons · Apr 11, 2014 · e129ba4 · e129ba4
1 parent 3e12545
commit e129ba4
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 27 deletions.
diff --git a/pom.xml b/pom.xml
@@ -5,7 +5,6 @@
     <version>0.0.1</version>
 
     <repositories>
-
         <repository>
             <id>cloudera-repos</id>
             <name>cloudera-repos</name>
@@ -57,28 +56,6 @@
             <plugin>
                 <groupId>org.apache.maven.plugins</groupId>
                 <artifactId>maven-assembly-plugin</artifactId>
-                <configuration>
-                    <!--
-                            <descriptorRefs>
-                                    <descriptorRef>jar-with-dependencies</descriptorRef>
-                            </descriptorRefs>
-                    -->
-
-                    <!--descriptors>
-                      <descriptor>src/assemble/filter.xml</descriptor>
-                    </descriptors-->
-                </configuration>
-                <executions>
-                    <!--
-                    <execution>
-                            <id>make-jar-with-dependencies</id>
-                            <phase>package</phase>
-                            <goals>
-                                    <goal>single</goal>
-                            </goals>
-                    </execution>
-                    -->
-                </executions>
             </plugin>
         </plugins>
     </build>
@@ -125,8 +102,7 @@
             <version>0.11.0</version>
             <type>jar</type>
             <scope>compile</scope>
-        </dependency>
-
+        </dependency>		
         <dependency>
             <groupId>org.apache.cassandra</groupId>
             <artifactId>cassandra-all</artifactId>
@@ -143,8 +119,7 @@
             <groupId>io.netty</groupId>
             <artifactId>netty</artifactId>
             <version>3.9.0.Final</version>
-        </dependency>
-
+        </dependency>       
         <dependency>
             <groupId>org.apache.hadoop</groupId>
             <artifactId>hadoop-core</artifactId>

diff --git a/src/main/java/org/apache/hadoop/hive/cassandra/input/cql/CqlHiveRecordReader.java b/src/main/java/org/apache/hadoop/hive/cassandra/input/cql/CqlHiveRecordReader.java
@@ -91,6 +91,14 @@ public void initialize(InputSplit split, TaskAttemptContext context) throws IOEx
         cfrr.initialize(split, context);
     }
 
+
+    /**
+     * Where we treat the buffer from cassandra, be careful with that, and make sure if
+     * you want to support the null column.
+     * 
+     * @param val
+     * @return 
+     */
     private BytesWritable convertByteBuffer(ByteBuffer val) {
         if (val == null) {
             return new BytesWritable(new byte[]{});