Configura pom.xml para java 1.8 e refatora nome de classe CassandraLo…

…ader
edwardoliveira · Sep 1, 2016 · 9040fd7 · 9040fd7
1 parent 3009ba7
commit 9040fd7
Show file tree

Hide file tree

Showing 4 changed files with 20 additions and 3 deletions.
diff --git a/pom.xml b/pom.xml
@@ -21,5 +21,16 @@
             <version>3.1.0</version>
         </dependency>
     </dependencies>
-
+    <build>
+        <plugins>
+            <plugin>
+                <artifactId>maven-compiler-plugin</artifactId>
+                <configuration>
+                    <source>1.8</source>
+                    <target>1.8</target>
+                    <fork>true</fork>
+                </configuration>
+            </plugin>
+        </plugins>
+    </build>
 </project>
diff --git a/src/main/java/br/unb/cassandra/etl/CassandraBulkLoader.java b/src/main/java/br/unb/cassandra/etl/CassandraBulkLoader.java
@@ -0,0 +1,5 @@
+package br.unb.cassandra.etl;
+
+public class CassandraBulkLoader {
+
+}
diff --git a/...br/unb/cassandra/etl/CassandraLoader.java → .../cassandra/etl/CassandraClientLoader.java b/...br/unb/cassandra/etl/CassandraLoader.java → .../cassandra/etl/CassandraClientLoader.java
@@ -3,7 +3,7 @@
 import com.datastax.driver.core.*;
 import com.datastax.driver.core.utils.UUIDs;
 
-public class CassandraLoader {
+public class CassandraClientLoader {
 
     private Cluster cluster;
     private Session session;
@@ -24,6 +24,7 @@ public void close() {
         if (cluster != null) cluster.close();
     }
 
+    // TODO: use BATCH insert to speedup?
     public void insert(Registro registro) {
 
        PreparedStatement pstmt = session.prepare(insertCmd);

diff --git a/src/main/java/br/unb/cassandra/etl/ETL.java b/src/main/java/br/unb/cassandra/etl/ETL.java
@@ -15,7 +15,7 @@ public ETL() {
 
     private void doLoad(String filename) {
 
-        CassandraLoader cassandraLoader = new CassandraLoader();
+        CassandraClientLoader cassandraLoader = new CassandraClientLoader();
         cassandraLoader.connect();
 
         try (BufferedReader reader = new BufferedReader(new InputStreamReader(new FileInputStream(filename), Charset.forName("ISO-8859-1")))) {