fluo-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ktur...@apache.org
Subject [08/10] incubator-fluo-recipes git commit: Made SharedBatchWriter package private
Date Fri, 15 Jul 2016 22:07:56 GMT
Made SharedBatchWriter package private


Project: http://git-wip-us.apache.org/repos/asf/incubator-fluo-recipes/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-fluo-recipes/commit/594997ab
Tree: http://git-wip-us.apache.org/repos/asf/incubator-fluo-recipes/tree/594997ab
Diff: http://git-wip-us.apache.org/repos/asf/incubator-fluo-recipes/diff/594997ab

Branch: refs/heads/master
Commit: 594997ab7afe4f5a0b57854e64f245b96816aaeb
Parents: beea3f9
Author: Mike Walch <mwalch@gmail.com>
Authored: Fri Jul 15 11:50:40 2016 -0400
Committer: Mike Walch <mwalch@gmail.com>
Committed: Fri Jul 15 11:50:40 2016 -0400

----------------------------------------------------------------------
 .../recipes/accumulo/export/SharedBatchWriter.java    | 14 +++++++-------
 1 file changed, 7 insertions(+), 7 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-fluo-recipes/blob/594997ab/modules/accumulo/src/main/java/org/apache/fluo/recipes/accumulo/export/SharedBatchWriter.java
----------------------------------------------------------------------
diff --git a/modules/accumulo/src/main/java/org/apache/fluo/recipes/accumulo/export/SharedBatchWriter.java
b/modules/accumulo/src/main/java/org/apache/fluo/recipes/accumulo/export/SharedBatchWriter.java
index ddc7830..9d189e6 100644
--- a/modules/accumulo/src/main/java/org/apache/fluo/recipes/accumulo/export/SharedBatchWriter.java
+++ b/modules/accumulo/src/main/java/org/apache/fluo/recipes/accumulo/export/SharedBatchWriter.java
@@ -36,14 +36,14 @@ import org.apache.accumulo.core.client.ZooKeeperInstance;
 import org.apache.accumulo.core.client.security.tokens.PasswordToken;
 import org.apache.accumulo.core.data.Mutation;
 
-public class SharedBatchWriter {
+class SharedBatchWriter {
 
   private static class Mutations {
 
     List<Mutation> mutations;
     CountDownLatch cdl = new CountDownLatch(1);
 
-    public Mutations(Collection<Mutation> mutations) {
+    Mutations(Collection<Mutation> mutations) {
       this.mutations = new ArrayList<>(mutations);
     }
   }
@@ -52,8 +52,8 @@ public class SharedBatchWriter {
 
     private BatchWriter bw;
 
-    public ExportTask(String instanceName, String zookeepers, String user, String password,
-        String table) throws TableNotFoundException, AccumuloException, AccumuloSecurityException
{
+    ExportTask(String instanceName, String zookeepers, String user, String password, String
table)
+        throws TableNotFoundException, AccumuloException, AccumuloSecurityException {
       ZooKeeperInstance zki =
           new ZooKeeperInstance(new ClientConfiguration().withInstance(instanceName).withZkHosts(
               zookeepers));
@@ -107,7 +107,7 @@ public class SharedBatchWriter {
 
   private static LinkedBlockingQueue<Mutations> exportQueue = null;
 
-  public SharedBatchWriter(String instanceName, String zookeepers, String user, String password,
+  private SharedBatchWriter(String instanceName, String zookeepers, String user, String password,
       String table) throws Exception {
 
     // TODO: fix this write to static and remove findbugs max rank override in pom.xml
@@ -121,7 +121,7 @@ public class SharedBatchWriter {
 
   private static Map<String, SharedBatchWriter> exporters = new HashMap<>();
 
-  public static synchronized SharedBatchWriter getInstance(String instanceName, String zookeepers,
+  static synchronized SharedBatchWriter getInstance(String instanceName, String zookeepers,
       String user, String password, String table) throws Exception {
 
     String key =
@@ -137,7 +137,7 @@ public class SharedBatchWriter {
     return ret;
   }
 
-  public void write(Collection<Mutation> mutations) {
+  void write(Collection<Mutation> mutations) {
     Mutations work = new Mutations(mutations);
     exportQueue.add(work);
     try {


Mime
View raw message