Permalink
Browse files

Rename packages in preparation for move to Apache

  • Loading branch information...
1 parent 9adaa07 commit 2f93667d98ebbb00de75417ba4e9c289b7fc8e6f Bruce Robbins committed Nov 21, 2011
Showing with 165 additions and 165 deletions.
  1. +1 −1 s4-comm/src/main/java/{io → org/apache}/s4/comm/core/CommEventCallback.java
  2. +1 −1 s4-comm/src/main/java/{io → org/apache}/s4/comm/core/CommLayerState.java
  3. +6 −6 s4-comm/src/main/java/{io → org/apache}/s4/comm/core/CommServiceFactory.java
  4. +1 −1 s4-comm/src/main/java/{io → org/apache}/s4/comm/core/DefaultWatcher.java
  5. +1 −1 s4-comm/src/main/java/{io → org/apache}/s4/comm/core/Deserializer.java
  6. +1 −1 s4-comm/src/main/java/{io → org/apache}/s4/comm/core/GenericListener.java
  7. +1 −1 s4-comm/src/main/java/{io → org/apache}/s4/comm/core/GenericSender.java
  8. +2 −2 s4-comm/src/main/java/{io → org/apache}/s4/comm/core/GenericSerDeser.java
  9. +2 −2 s4-comm/src/main/java/{io → org/apache}/s4/comm/core/ListenerProcess.java
  10. +2 −2 s4-comm/src/main/java/{io → org/apache}/s4/comm/core/MulticastSender.java
  11. +1 −1 s4-comm/src/main/java/{io → org/apache}/s4/comm/core/ProcessMonitor.java
  12. +1 −1 s4-comm/src/main/java/{io → org/apache}/s4/comm/core/SendMode.java
  13. +2 −2 s4-comm/src/main/java/{io → org/apache}/s4/comm/core/SenderProcess.java
  14. +1 −1 s4-comm/src/main/java/{io → org/apache}/s4/comm/core/Serializer.java
  15. +1 −1 s4-comm/src/main/java/{io → org/apache}/s4/comm/core/TaskManager.java
  16. +4 −4 s4-comm/src/main/java/{io → org/apache}/s4/comm/file/StaticProcessMonitor.java
  17. +7 −7 s4-comm/src/main/java/{io → org/apache}/s4/comm/file/StaticTaskManager.java
  18. +5 −5 s4-comm/src/main/java/{io → org/apache}/s4/comm/test/ProcessMonitorTest.java
  19. +6 −6 s4-comm/src/main/java/{io → org/apache}/s4/comm/test/TaskManagerTest.java
  20. +6 −6 s4-comm/src/main/java/{io → org/apache}/s4/comm/test/TestTaskSetupApp.java
  21. +2 −2 s4-comm/src/main/java/{io → org/apache}/s4/comm/test/ZkQueueTest.java
  22. +6 −6 s4-comm/src/main/java/{io → org/apache}/s4/comm/tools/TaskSetupApp.java
  23. +1 −1 s4-comm/src/main/java/{io → org/apache}/s4/comm/util/CommUtil.java
  24. +2 −2 s4-comm/src/main/java/{io → org/apache}/s4/comm/util/ConfigParser.java
  25. +4 −4 s4-comm/src/main/java/{io → org/apache}/s4/comm/util/ConfigUtils.java
  26. +1 −1 s4-comm/src/main/java/{io → org/apache}/s4/comm/util/IOUtil.java
  27. +1 −1 s4-comm/src/main/java/{io → org/apache}/s4/comm/util/JSONUtil.java
  28. +1 −1 s4-comm/src/main/java/{io → org/apache}/s4/comm/util/SystemUtils.java
  29. +1 −1 s4-comm/src/main/java/{io → org/apache}/s4/comm/zk/ThreadTest.java
  30. +6 −6 s4-comm/src/main/java/{io → org/apache}/s4/comm/zk/ZkProcessMonitor.java
  31. +3 −3 s4-comm/src/main/java/{io → org/apache}/s4/comm/zk/ZkQueue.java
  32. +6 −6 s4-comm/src/main/java/{io → org/apache}/s4/comm/zk/ZkTaskManager.java
  33. +6 −6 s4-comm/src/main/java/{io → org/apache}/s4/comm/zk/ZkTaskSetup.java
  34. +2 −2 s4-comm/src/main/java/{io → org/apache}/s4/comm/zk/ZkUtil.java
  35. +1 −1 s4-core/src/main/java/org/apache/s4/MainApp.java
  36. +2 −2 s4-core/src/main/java/org/apache/s4/client/util/ObjectBuilder.java
  37. +2 −2 s4-core/src/main/java/org/apache/s4/dispatcher/partitioner/DefaultPartitioner.java
  38. +1 −1 s4-core/src/main/java/org/apache/s4/processor/PEContainer.java
  39. +2 −2 s4-core/src/test/java/{io → org/apache}/s4/ft/CheckpointingTest.java
  40. +10 −10 s4-core/src/test/java/{io → org/apache}/s4/ft/EventGenerator.java
  41. +1 −1 s4-core/src/test/java/{io → org/apache}/s4/ft/KeyValue.java
  42. +1 −1 s4-core/src/test/java/{io → org/apache}/s4/ft/RecoveryTest.java
  43. +6 −6 s4-core/src/test/java/{io → org/apache}/s4/ft/S4App.java
  44. +2 −2 s4-core/src/test/java/{io → org/apache}/s4/ft/S4TestCase.java
  45. +6 −6 s4-core/src/test/java/{io → org/apache}/s4/ft/SimpleEventProducer.java
  46. +2 −2 s4-core/src/test/java/{io → org/apache}/s4/ft/StatefulTestPE.java
  47. +2 −2 s4-core/src/test/java/{io → org/apache}/s4/ft/TestRedisStateStorage.java
  48. +1 −1 s4-core/src/test/java/{io → org/apache}/s4/ft/TestUtils.java
  49. 0 s4-core/src/test/java/{io → org/apache}/s4/ft/adapter.properties
  50. 0 s4-core/src/test/java/{io → org/apache}/s4/ft/adapter_conf.xml
  51. 0 s4-core/src/test/java/{io → org/apache}/s4/ft/app_adapter_conf.out.xml
  52. 0 s4-core/src/test/java/{io → org/apache}/s4/ft/app_adapter_conf.xml
  53. 0 s4-core/src/test/java/{io → org/apache}/s4/ft/app_conf.xml
  54. 0 s4-core/src/test/java/{io → org/apache}/s4/ft/s4_core_conf_bk_backend.xml
  55. 0 s4-core/src/test/java/{io → org/apache}/s4/ft/s4_core_conf_fs_backend.xml
  56. 0 s4-core/src/test/java/{io → org/apache}/s4/ft/wall_clock.xml
  57. +8 −8 s4-core/src/test/java/{io → org/apache}/s4/ft/wordcount/FTWordCountTest.java
  58. 0 s4-core/src/test/java/{io → org/apache}/s4/ft/wordcount/app_conf.xml
  59. 0 s4-core/src/test/java/{io → org/apache}/s4/ft/wordcount/s4_core_conf_fs_backend.xml
  60. 0 s4-core/src/test/java/{io → org/apache}/s4/ft/wordcount/s4_core_conf_redis_backend.xml
  61. 0 s4-core/src/test/java/{io → org/apache}/s4/ft/wordcount/wall_clock.xml
  62. +1 −1 s4-core/src/test/java/{io → org/apache}/s4/processor/MockPE.java
  63. +2 −2 s4-core/src/test/java/{io → org/apache}/s4/processor/TestPrototypeWrapper.java
  64. +1 −1 s4-core/src/test/java/{io → org/apache}/s4/wordcount/Word.java
  65. +5 −5 s4-core/src/test/java/{io → org/apache}/s4/wordcount/WordClassifier.java
  66. +1 −1 s4-core/src/test/java/{io → org/apache}/s4/wordcount/WordCount.java
  67. +6 −6 s4-core/src/test/java/{io → org/apache}/s4/wordcount/WordCountTest.java
  68. +4 −4 s4-core/src/test/java/{io → org/apache}/s4/wordcount/WordCounter.java
  69. +4 −4 s4-core/src/test/java/{io → org/apache}/s4/wordcount/WordSplitter.java
  70. 0 s4-core/src/test/java/{io → org/apache}/s4/wordcount/app_conf.xml
  71. 0 s4-core/src/test/java/{io → org/apache}/s4/wordcount/s4_core_conf.xml
  72. 0 s4-core/src/test/java/{io → org/apache}/s4/wordcount/wall_clock.xml
@@ -13,7 +13,7 @@
* language governing permissions and limitations under the
* License. See accompanying LICENSE file.
*/
-package io.s4.comm.core;
+package org.apache.s4.comm.core;
import java.util.Map;
@@ -1,4 +1,4 @@
-package io.s4.comm.core;
+package org.apache.s4.comm.core;
public enum CommLayerState {
INITIALIZED, BROKEN
@@ -13,13 +13,13 @@
* language governing permissions and limitations under the
* License. See accompanying LICENSE file.
*/
-package io.s4.comm.core;
+package org.apache.s4.comm.core;
-import io.s4.comm.file.StaticProcessMonitor;
-import io.s4.comm.file.StaticTaskManager;
-import io.s4.comm.util.ConfigParser.Cluster.ClusterType;
-import io.s4.comm.zk.ZkProcessMonitor;
-import io.s4.comm.zk.ZkTaskManager;
+import org.apache.s4.comm.file.StaticProcessMonitor;
+import org.apache.s4.comm.file.StaticTaskManager;
+import org.apache.s4.comm.util.ConfigParser.Cluster.ClusterType;
+import org.apache.s4.comm.zk.ZkProcessMonitor;
+import org.apache.s4.comm.zk.ZkTaskManager;
import org.apache.log4j.Logger;
@@ -13,7 +13,7 @@
* language governing permissions and limitations under the
* License. See accompanying LICENSE file.
*/
-package io.s4.comm.core;
+package org.apache.s4.comm.core;
import java.util.ArrayList;
import java.util.HashMap;
@@ -13,7 +13,7 @@
* language governing permissions and limitations under the
* License. See accompanying LICENSE file.
*/
-package io.s4.comm.core;
+package org.apache.s4.comm.core;
public interface Deserializer {
@@ -13,7 +13,7 @@
* language governing permissions and limitations under the
* License. See accompanying LICENSE file.
*/
-package io.s4.comm.core;
+package org.apache.s4.comm.core;
import java.io.IOException;
import java.net.DatagramPacket;
@@ -13,7 +13,7 @@
* language governing permissions and limitations under the
* License. See accompanying LICENSE file.
*/
-package io.s4.comm.core;
+package org.apache.s4.comm.core;
import java.io.IOException;
import java.net.DatagramPacket;
@@ -13,9 +13,9 @@
* language governing permissions and limitations under the
* License. See accompanying LICENSE file.
*/
-package io.s4.comm.core;
+package org.apache.s4.comm.core;
-import io.s4.comm.util.IOUtil;
+import org.apache.s4.comm.util.IOUtil;
public class GenericSerDeser implements Serializer, Deserializer {
@@ -13,9 +13,9 @@
* language governing permissions and limitations under the
* License. See accompanying LICENSE file.
*/
-package io.s4.comm.core;
+package org.apache.s4.comm.core;
-import io.s4.comm.util.ConfigParser.Cluster.ClusterType;
+import org.apache.s4.comm.util.ConfigParser.Cluster.ClusterType;
import java.util.HashMap;
import java.util.Map;
@@ -13,9 +13,9 @@
* language governing permissions and limitations under the
* License. See accompanying LICENSE file.
*/
-package io.s4.comm.core;
+package org.apache.s4.comm.core;
-import io.s4.comm.util.IOUtil;
+import org.apache.s4.comm.util.IOUtil;
import java.io.IOException;
import java.net.DatagramPacket;
@@ -13,7 +13,7 @@
* language governing permissions and limitations under the
* License. See accompanying LICENSE file.
*/
-package io.s4.comm.core;
+package org.apache.s4.comm.core;
import java.util.List;
import java.util.Map;
@@ -13,7 +13,7 @@
* language governing permissions and limitations under the
* License. See accompanying LICENSE file.
*/
-package io.s4.comm.core;
+package org.apache.s4.comm.core;
public enum SendMode {
@@ -13,9 +13,9 @@
* language governing permissions and limitations under the
* License. See accompanying LICENSE file.
*/
-package io.s4.comm.core;
+package org.apache.s4.comm.core;
-import io.s4.comm.util.ConfigParser.Cluster.ClusterType;
+import org.apache.s4.comm.util.ConfigParser.Cluster.ClusterType;
import java.util.Map;
@@ -13,7 +13,7 @@
* language governing permissions and limitations under the
* License. See accompanying LICENSE file.
*/
-package io.s4.comm.core;
+package org.apache.s4.comm.core;
public interface Serializer {
@@ -13,7 +13,7 @@
* language governing permissions and limitations under the
* License. See accompanying LICENSE file.
*/
-package io.s4.comm.core;
+package org.apache.s4.comm.core;
import java.util.Map;
@@ -13,11 +13,11 @@
* language governing permissions and limitations under the
* License. See accompanying LICENSE file.
*/
-package io.s4.comm.file;
+package org.apache.s4.comm.file;
-import io.s4.comm.core.ProcessMonitor;
-import io.s4.comm.util.ConfigUtils;
-import io.s4.comm.util.ConfigParser.Cluster.ClusterType;
+import org.apache.s4.comm.core.ProcessMonitor;
+import org.apache.s4.comm.util.ConfigUtils;
+import org.apache.s4.comm.util.ConfigParser.Cluster.ClusterType;
import java.util.ArrayList;
import java.util.HashMap;
@@ -13,14 +13,14 @@
* language governing permissions and limitations under the
* License. See accompanying LICENSE file.
*/
-package io.s4.comm.file;
+package org.apache.s4.comm.file;
-import io.s4.comm.core.CommEventCallback;
-import io.s4.comm.core.CommLayerState;
-import io.s4.comm.core.TaskManager;
-import io.s4.comm.util.ConfigUtils;
-import io.s4.comm.util.SystemUtils;
-import io.s4.comm.util.ConfigParser.Cluster.ClusterType;
+import org.apache.s4.comm.core.CommEventCallback;
+import org.apache.s4.comm.core.CommLayerState;
+import org.apache.s4.comm.core.TaskManager;
+import org.apache.s4.comm.util.ConfigUtils;
+import org.apache.s4.comm.util.SystemUtils;
+import org.apache.s4.comm.util.ConfigParser.Cluster.ClusterType;
import java.io.File;
import java.io.FileOutputStream;
@@ -13,12 +13,12 @@
* language governing permissions and limitations under the
* License. See accompanying LICENSE file.
*/
-package io.s4.comm.test;
+package org.apache.s4.comm.test;
-import io.s4.comm.file.StaticProcessMonitor;
-import io.s4.comm.util.ConfigParser.Cluster.ClusterType;
-import io.s4.comm.zk.ZkTaskSetup;
-import io.s4.comm.zk.ZkTaskManager;
+import org.apache.s4.comm.file.StaticProcessMonitor;
+import org.apache.s4.comm.util.ConfigParser.Cluster.ClusterType;
+import org.apache.s4.comm.zk.ZkTaskSetup;
+import org.apache.s4.comm.zk.ZkTaskManager;
import java.io.File;
import java.util.HashMap;
@@ -13,13 +13,13 @@
* language governing permissions and limitations under the
* License. See accompanying LICENSE file.
*/
-package io.s4.comm.test;
+package org.apache.s4.comm.test;
-import io.s4.comm.core.TaskManager;
-import io.s4.comm.file.StaticTaskManager;
-import io.s4.comm.util.ConfigParser.Cluster.ClusterType;
-import io.s4.comm.zk.ZkTaskSetup;
-import io.s4.comm.zk.ZkTaskManager;
+import org.apache.s4.comm.core.TaskManager;
+import org.apache.s4.comm.file.StaticTaskManager;
+import org.apache.s4.comm.util.ConfigParser.Cluster.ClusterType;
+import org.apache.s4.comm.zk.ZkTaskSetup;
+import org.apache.s4.comm.zk.ZkTaskManager;
import java.io.File;
import java.util.HashMap;
@@ -13,13 +13,13 @@
* language governing permissions and limitations under the
* License. See accompanying LICENSE file.
*/
-package io.s4.comm.test;
+package org.apache.s4.comm.test;
-import io.s4.comm.util.CommUtil;
-import io.s4.comm.util.JSONUtil;
-import io.s4.comm.util.ConfigParser.Cluster.ClusterType;
-import io.s4.comm.zk.ZkTaskSetup;
-import io.s4.comm.zk.ZkTaskManager;
+import org.apache.s4.comm.util.CommUtil;
+import org.apache.s4.comm.util.JSONUtil;
+import org.apache.s4.comm.util.ConfigParser.Cluster.ClusterType;
+import org.apache.s4.comm.zk.ZkTaskSetup;
+import org.apache.s4.comm.zk.ZkTaskManager;
import java.util.Arrays;
import java.util.HashMap;
@@ -13,9 +13,9 @@
* language governing permissions and limitations under the
* License. See accompanying LICENSE file.
*/
-package io.s4.comm.test;
+package org.apache.s4.comm.test;
-import io.s4.comm.zk.ZkQueue;
+import org.apache.s4.comm.zk.ZkQueue;
import org.apache.zookeeper.KeeperException;
@@ -13,13 +13,13 @@
* language governing permissions and limitations under the
* License. See accompanying LICENSE file.
*/
-package io.s4.comm.tools;
+package org.apache.s4.comm.tools;
-import io.s4.comm.util.ConfigUtils;
-import io.s4.comm.util.ConfigParser;
-import io.s4.comm.util.ConfigParser.Cluster;
-import io.s4.comm.util.ConfigParser.Config;
-import io.s4.comm.zk.ZkTaskSetup;
+import org.apache.s4.comm.util.ConfigUtils;
+import org.apache.s4.comm.util.ConfigParser;
+import org.apache.s4.comm.util.ConfigParser.Cluster;
+import org.apache.s4.comm.util.ConfigParser.Config;
+import org.apache.s4.comm.zk.ZkTaskSetup;
import java.io.File;
import java.util.List;
@@ -13,7 +13,7 @@
* language governing permissions and limitations under the
* License. See accompanying LICENSE file.
*/
-package io.s4.comm.util;
+package org.apache.s4.comm.util;
import java.util.Map;
@@ -1,6 +1,6 @@
-package io.s4.comm.util;
+package org.apache.s4.comm.util;
-import io.s4.comm.util.ConfigParser.Cluster.ClusterType;
+import org.apache.s4.comm.util.ConfigParser.Cluster.ClusterType;
import java.io.File;
import java.io.FileInputStream;
@@ -1,13 +1,13 @@
-package io.s4.comm.util;
+package org.apache.s4.comm.util;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
-import io.s4.comm.util.ConfigParser.Cluster;
-import io.s4.comm.util.ConfigParser.Cluster.ClusterType;
-import io.s4.comm.util.ConfigParser.ClusterNode;
+import org.apache.s4.comm.util.ConfigParser.Cluster;
+import org.apache.s4.comm.util.ConfigParser.Cluster.ClusterType;
+import org.apache.s4.comm.util.ConfigParser.ClusterNode;
public class ConfigUtils {
public static List<Map<String, String>> readConfig(String configFilename,
@@ -13,7 +13,7 @@
* language governing permissions and limitations under the
* License. See accompanying LICENSE file.
*/
-package io.s4.comm.util;
+package org.apache.s4.comm.util;
import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
@@ -13,7 +13,7 @@
* language governing permissions and limitations under the
* License. See accompanying LICENSE file.
*/
-package io.s4.comm.util;
+package org.apache.s4.comm.util;
import java.lang.reflect.Array;
import java.lang.reflect.Field;
@@ -13,7 +13,7 @@
* language governing permissions and limitations under the
* License. See accompanying LICENSE file.
*/
-package io.s4.comm.util;
+package org.apache.s4.comm.util;
public class SystemUtils {
@@ -13,7 +13,7 @@
* language governing permissions and limitations under the
* License. See accompanying LICENSE file.
*/
-package io.s4.comm.zk;
+package org.apache.s4.comm.zk;
public class ThreadTest {
static Object lock = new Object();
@@ -13,13 +13,13 @@
* language governing permissions and limitations under the
* License. See accompanying LICENSE file.
*/
-package io.s4.comm.zk;
+package org.apache.s4.comm.zk;
-import io.s4.comm.core.CommEventCallback;
-import io.s4.comm.core.DefaultWatcher;
-import io.s4.comm.core.ProcessMonitor;
-import io.s4.comm.util.JSONUtil;
-import io.s4.comm.util.ConfigParser.Cluster.ClusterType;
+import org.apache.s4.comm.core.CommEventCallback;
+import org.apache.s4.comm.core.DefaultWatcher;
+import org.apache.s4.comm.core.ProcessMonitor;
+import org.apache.s4.comm.util.JSONUtil;
+import org.apache.s4.comm.util.ConfigParser.Cluster.ClusterType;
import java.util.ArrayList;
import java.util.HashMap;
@@ -13,10 +13,10 @@
* language governing permissions and limitations under the
* License. See accompanying LICENSE file.
*/
-package io.s4.comm.zk;
+package org.apache.s4.comm.zk;
-import io.s4.comm.core.DefaultWatcher;
-import io.s4.comm.util.IOUtil;
+import org.apache.s4.comm.core.DefaultWatcher;
+import org.apache.s4.comm.util.IOUtil;
import java.nio.ByteBuffer;
import java.util.Collection;
Oops, something went wrong.

0 comments on commit 2f93667

Please sign in to comment.