Modified: helix/site-content/0.9.9-docs/privacy-policy.html URL: http://svn.apache.org/viewvc/helix/site-content/0.9.9-docs/privacy-policy.html?rev=1900255&r1=1900254&r2=1900255&view=diff ============================================================================== --- helix/site-content/0.9.9-docs/privacy-policy.html (original) +++ helix/site-content/0.9.9-docs/privacy-policy.html Mon Apr 25 08:18:23 2022 @@ -1,7 +1,13 @@ <!DOCTYPE html> + + + + + + <!-- - Generated by Apache Maven Doxia at 2022-04-23 Rendered using Reflow Maven Skin 2.0.0-SNAPSHOT (https://andriusvelykis.github.io/reflow-maven-skin) + Generated by Apache Maven Doxia at 2022-04-25 Rendered using Reflow Maven Skin 2.0.0 (https://olamy.github.io/reflow-maven-skin) --> <html xml:lang="en" lang="en"> @@ -30,24 +36,31 @@ <![endif]--> - <script type="text/javascript"> - - var _gaq = _gaq || []; - _gaq.push(['_setAccount', 'UA-3211522-12']); - _gaq.push(['_trackPageview']); - (function() { - var ga = document.createElement('script'); ga.type = 'text/javascript'; ga.async = true; - ga.src = ('https:' == document.location.protocol ? 'https://ssl' : 'http://www') + '.google-analytics.com/ga.js'; - var s = document.getElementsByTagName('script')[0]; s.parentNode.insertBefore(ga, s); - })(); - </script> - </head> + +<!-- Matomo --> +<script> + var _paq = window._paq = window._paq || []; + _paq.push(['disableCookies']); + _paq.push(['trackPageView']); + _paq.push(['enableLinkTracking']); + + (function() { + var u="https://analytics.apache.org";; + _paq.push(['setTrackerUrl', u+'/matomo.php']); + _paq.push(['setSiteId', '15']); + var d=document, g=d.createElement('script'), s=d.getElementsByTagName('script')[0]; + g.async=true; g.src=u+'/matomo.js'; s.parentNode.insertBefore(g,s); + })(); +</script> +<!-- End Matomo Code --> + </head> <body class="page-privacy-policy project-099-docs" data-spy="scroll" data-offset="60" data-target="#toc-scroll-target"> + <div class="navbar navbar-fixed-top"> <div class="navbar-inner"> <div class="container"> @@ -120,7 +133,7 @@ <li><a href="./" title="Release 0.9.9">Release 0.9.9</a></li> <li class="divider">/</li> <li>Privacy Policy</li> - <li class="publishDate version-date pull-right">Last Published: 2022-04-23</li> + <li class="publishDate version-date pull-right">Last Published: 2022-04-25</li> </ul> </div> </header> @@ -214,7 +227,7 @@ <div class="span12"> <p class="pull-right"><a href="#">Back to top</a></p> <p class="copyright">Copyright ©2022 <a href="https://www.apache.org/";>The Apache Software Foundation</a>. All Rights Reserved.</p> - <p><a href="https://github.com/olamy/reflow-maven-skin"; title="Reflow Maven skin">Reflow Maven skin</a> by <a href="https://andrius.velykis.lt"; target="_blank" title="Andrius Velykis">Andrius Velykis</a>.</p> + <p><a href="https://github.com/olamy/reflow-maven-skin"; title="Reflow Maven skin">Reflow Maven skin</a> maintained by <a href="https://twitter.com/olamy"; target="_blank" title="Olivier Lamy">Olivier Lamy</a>.</p> <div class="row span16"><div>Apache Helix, Apache, the Apache feather logo, and the Apache Helix project logos are trademarks of The Apache Software Foundation. All other marks mentioned may be trademarks or registered trademarks of their respective owners.</div> <a href="https://helix.apache.org/0.9.9-docs/privacy-policy.html";>Privacy Policy</a>
Modified: helix/site-content/0.9.9-docs/quota_scheduling.html URL: http://svn.apache.org/viewvc/helix/site-content/0.9.9-docs/quota_scheduling.html?rev=1900255&r1=1900254&r2=1900255&view=diff ============================================================================== --- helix/site-content/0.9.9-docs/quota_scheduling.html (original) +++ helix/site-content/0.9.9-docs/quota_scheduling.html Mon Apr 25 08:18:23 2022 @@ -1,7 +1,13 @@ <!DOCTYPE html> + + + + + + <!-- - Generated by Apache Maven Doxia at 2022-04-23 Rendered using Reflow Maven Skin 2.0.0-SNAPSHOT (https://andriusvelykis.github.io/reflow-maven-skin) + Generated by Apache Maven Doxia at 2022-04-25 Rendered using Reflow Maven Skin 2.0.0 (https://olamy.github.io/reflow-maven-skin) --> <html xml:lang="en" lang="en"> @@ -29,24 +35,31 @@ <![endif]--> - <script type="text/javascript"> - - var _gaq = _gaq || []; - _gaq.push(['_setAccount', 'UA-3211522-12']); - _gaq.push(['_trackPageview']); - (function() { - var ga = document.createElement('script'); ga.type = 'text/javascript'; ga.async = true; - ga.src = ('https:' == document.location.protocol ? 'https://ssl' : 'http://www') + '.google-analytics.com/ga.js'; - var s = document.getElementsByTagName('script')[0]; s.parentNode.insertBefore(ga, s); - })(); - </script> - </head> + +<!-- Matomo --> +<script> + var _paq = window._paq = window._paq || []; + _paq.push(['disableCookies']); + _paq.push(['trackPageView']); + _paq.push(['enableLinkTracking']); + + (function() { + var u="https://analytics.apache.org";; + _paq.push(['setTrackerUrl', u+'/matomo.php']); + _paq.push(['setSiteId', '15']); + var d=document, g=d.createElement('script'), s=d.getElementsByTagName('script')[0]; + g.async=true; g.src=u+'/matomo.js'; s.parentNode.insertBefore(g,s); + })(); +</script> +<!-- End Matomo Code --> + </head> <body class="page-quota_scheduling project-099-docs" data-spy="scroll" data-offset="60" data-target="#toc-scroll-target"> + <div class="navbar navbar-fixed-top"> <div class="navbar-inner"> <div class="container"> @@ -119,7 +132,7 @@ <li><a href="./" title="Release 0.9.9">Release 0.9.9</a></li> <li class="divider">/</li> <li>Quota-based Task Scheduling</li> - <li class="publishDate version-date pull-right">Last Published: 2022-04-23</li> + <li class="publishDate version-date pull-right">Last Published: 2022-04-25</li> </ul> </div> </header> @@ -151,7 +164,7 @@ under the License. </div> <section> <h2 id="Introduction">Introduction</h2> - <p><img src="./images/quota_intro.png" alt="Intro" /></p> + <p><img src="./images/quota_intro.png" alt="Intro"></p> <p>Quota-based task scheduling is a feature addition to Helix Task Framework that enables users of Task Framework to apply the notion of categories in distributed task management.</p> </section> <section> @@ -200,7 +213,7 @@ under the License. <section> <h3 id="RuntimeJobDag_.28JobDagIterator.29">RuntimeJobDag (JobDagIterator)</h3> <p>This new component serves as an iterator for JobDAGs for the Controller. Previously, task assignment required the Controller to iterate through all jobs and their underlying tasks to determine whether there were any tasks that needed to be assigned and scheduled. This proved to be inefficient and did not scale with the increasing load we were putting on Task Framework. Each RuntimeJobDag records states, that is, it knows what task needs to be offered up to the Controller for scheduling. This saves the redundant computation for the Controller every time it goes through the TaskSchedulingStage of the Task pipeline.</p> - <p><img src="./images/quota_InstanceCapacityManager.jpeg" alt="Architecture" /></p> + <p><img src="./images/quota_InstanceCapacityManager.jpeg" alt="Architecture"></p> </section> </section> <section> @@ -209,10 +222,10 @@ under the License. <h3 id="How_it_works">How it works</h3> <p>Quota-based task scheduling works as follows. If a quota type is set, Task Framework will calculate a ratio against the sum of all quota config numbers for each quota type. Then it will apply that ratio to find the actual resource amount allotted to each quota type. Here is an example to illustrate this: Suppose the quota config is as follows:</p> <div class="source"> - <pre><code class="language-json">"QUOTA_TYPES":{ - "A":"2" - ,"B":"1" - ,"DEFAULT":"1" + <pre><code class="language-json">"QUOTA_TYPES":{ + "A":"2" + ,"B":"1" + ,"DEFAULT":"1" } </code></pre> </div> @@ -259,9 +272,9 @@ under the License. <div class="source"> <pre><code class="language-java">ClusterConfig clusterConfig = _manager.getConfigAccessor().getClusterConfig(CLUSTER_NAME); // Retrieve ClusterConfig clusterConfig.resetTaskQuotaRatioMap(); // Optional: you may want to reset the quota config before creating a new quota config -clusterConfig.setTaskQuotaRatio(DEFAULT_QUOTA_TYPE, 10); // Define the default quota (DEFAULT_QUOTA_TYPE = "DEFAULT") -clusterConfig.setTaskQuotaRatio("A", 20); // Define quota type A -clusterConfig.setTaskQuotaRatio("B", 10); // Define quota type B +clusterConfig.setTaskQuotaRatio(DEFAULT_QUOTA_TYPE, 10); // Define the default quota (DEFAULT_QUOTA_TYPE = "DEFAULT") +clusterConfig.setTaskQuotaRatio("A", 20); // Define quota type A +clusterConfig.setTaskQuotaRatio("B", 10); // Define quota type B _manager.getConfigAccessor().setClusterConfig(CLUSTER_NAME, clusterConfig); // Set the new ClusterConfig </code></pre> </div> @@ -269,17 +282,17 @@ _manager.getConfigAccessor().setClusterC <p>Upon setting the quota config in ClusterConfig, you will see the updated field in your ZooKeeper cluster config ZNode in the JSON format. See an example below:</p> <div class="source"> <pre><code class="language-json">{ - "id":"Example_Cluster" - ,"simpleFields":{ - "allowParticipantAutoJoin":"true" + "id":"Example_Cluster" + ,"simpleFields":{ + "allowParticipantAutoJoin":"true" } - ,"listFields":{ + ,"listFields":{ } - ,"mapFields":{ - "QUOTA_TYPES":{ - "A":"20" - ,"B":"10" - ,"DEFAULT":"10" + ,"mapFields":{ + "QUOTA_TYPES":{ + "A":"20" + ,"B":"10" + ,"DEFAULT":"10" } } } @@ -291,8 +304,8 @@ _manager.getConfigAccessor().setClusterC <div class="source"> <pre><code class="language-java">JobConfig.Builder jobBuilderA = new JobConfig.Builder().setCommand(JOB_COMMAND).setJobCommandConfigMap(_jobCommandMap) - .addTaskConfigs(taskConfigsA).setNumConcurrentTasksPerInstance(50).setJobType("A"); // Setting the job quota type as "A" -workflowBuilder.addJob("JOB_A", jobBuilderA); + .addTaskConfigs(taskConfigsA).setNumConcurrentTasksPerInstance(50).setJobType("A"); // Setting the job quota type as "A" +workflowBuilder.addJob("JOB_A", jobBuilderA); </code></pre> </div> </section> @@ -407,7 +420,7 @@ workflowBuilder.addJob("JOB_A" <div class="span12"> <p class="pull-right"><a href="#">Back to top</a></p> <p class="copyright">Copyright ©2022 <a href="https://www.apache.org/";>The Apache Software Foundation</a>. All Rights Reserved.</p> - <p><a href="https://github.com/olamy/reflow-maven-skin"; title="Reflow Maven skin">Reflow Maven skin</a> by <a href="https://andrius.velykis.lt"; target="_blank" title="Andrius Velykis">Andrius Velykis</a>.</p> + <p><a href="https://github.com/olamy/reflow-maven-skin"; title="Reflow Maven skin">Reflow Maven skin</a> maintained by <a href="https://twitter.com/olamy"; target="_blank" title="Olivier Lamy">Olivier Lamy</a>.</p> <div class="row span16"><div>Apache Helix, Apache, the Apache feather logo, and the Apache Helix project logos are trademarks of The Apache Software Foundation. All other marks mentioned may be trademarks or registered trademarks of their respective owners.</div> <a href="https://helix.apache.org/0.9.9-docs/privacy-policy.html";>Privacy Policy</a> Modified: helix/site-content/0.9.9-docs/recipes/lock_manager.html URL: http://svn.apache.org/viewvc/helix/site-content/0.9.9-docs/recipes/lock_manager.html?rev=1900255&r1=1900254&r2=1900255&view=diff ============================================================================== --- helix/site-content/0.9.9-docs/recipes/lock_manager.html (original) +++ helix/site-content/0.9.9-docs/recipes/lock_manager.html Mon Apr 25 08:18:23 2022 @@ -1,7 +1,13 @@ <!DOCTYPE html> + + + + + + <!-- - Generated by Apache Maven Doxia at 2022-04-23 Rendered using Reflow Maven Skin 2.0.0-SNAPSHOT (https://andriusvelykis.github.io/reflow-maven-skin) + Generated by Apache Maven Doxia at 2022-04-25 Rendered using Reflow Maven Skin 2.0.0 (https://olamy.github.io/reflow-maven-skin) --> <html xml:lang="en" lang="en"> @@ -29,24 +35,31 @@ <![endif]--> - <script type="text/javascript"> - - var _gaq = _gaq || []; - _gaq.push(['_setAccount', 'UA-3211522-12']); - _gaq.push(['_trackPageview']); - (function() { - var ga = document.createElement('script'); ga.type = 'text/javascript'; ga.async = true; - ga.src = ('https:' == document.location.protocol ? 'https://ssl' : 'http://www') + '.google-analytics.com/ga.js'; - var s = document.getElementsByTagName('script')[0]; s.parentNode.insertBefore(ga, s); - })(); - </script> - </head> + +<!-- Matomo --> +<script> + var _paq = window._paq = window._paq || []; + _paq.push(['disableCookies']); + _paq.push(['trackPageView']); + _paq.push(['enableLinkTracking']); + + (function() { + var u="https://analytics.apache.org";; + _paq.push(['setTrackerUrl', u+'/matomo.php']); + _paq.push(['setSiteId', '15']); + var d=document, g=d.createElement('script'), s=d.getElementsByTagName('script')[0]; + g.async=true; g.src=u+'/matomo.js'; s.parentNode.insertBefore(g,s); + })(); +</script> +<!-- End Matomo Code --> + </head> <body class="page-recipes-lock_manager project-099-docs" data-spy="scroll" data-offset="60" data-target="#toc-scroll-target"> + <div class="navbar navbar-fixed-top"> <div class="navbar-inner"> <div class="container"> @@ -119,7 +132,7 @@ <li><a href="../" title="Release 0.9.9">Release 0.9.9</a></li> <li class="divider">/</li> <li>Distributed Lock Manager</li> - <li class="publishDate version-date pull-right">Last Published: 2022-04-23</li> + <li class="publishDate version-date pull-right">Last Published: 2022-04-25</li> </ul> </div> </header> @@ -171,7 +184,7 @@ under the License. </ul> <p>Helix provides a simple and elegant solution to this problem. Simply specify the number of locks and Helix will ensure that above constraints are satisfied.</p> <p>To quickly see this working run the <code>lock-manager-demo</code> script where 12 locks are evenly distributed among three nodes, and when a node fails, the locks get re-distributed among remaining two nodes. Note that Helix does not re-shuffle the locks completely, instead it simply distributes the locks relinquished by dead node among 2 remaining nodes evenly.</p> - <hr /> + <hr> <section> <h3 id="Short_Version">Short Version</h3> <p>This version starts multiple threads within the same process to simulate a multi node deployment. Try the long version to get a better idea of how it works.</p> @@ -244,7 +257,7 @@ lock-group_9 localhost_12001 </code></pre> </div> - <hr /> + <hr> </section> </section> <section> @@ -284,11 +297,11 @@ lock-group_9 localhost_12001 } public void lock(Message m, NotificationContext context) { - System.out.println(" acquired lock:"+ lockName ); + System.out.println(" acquired lock:"+ lockName ); } public void release(Message m, NotificationContext context) { - System.out.println(" releasing lock:"+ lockName ); + System.out.println(" releasing lock:"+ lockName ); } } @@ -308,15 +321,15 @@ lock-group_9 localhost_12001 <div class="source"> <pre><code>public class LockProcess { public static void main(String args) { - String zkAddress= "localhost:2199"; - String clusterName = "lock-manager-demo"; + String zkAddress= "localhost:2199"; + String clusterName = "lock-manager-demo"; //Give a unique id to each process, most commonly used format hostname_port - String instanceName ="localhost_12000"; + String instanceName ="localhost_12000"; ZKHelixAdmin helixAdmin = new ZKHelixAdmin(zkAddress); //configure the instance and provide some metadata InstanceConfig config = new InstanceConfig(instanceName); - config.setHostName("localhost"); - config.setPort("12000"); + config.setHostName("localhost"); + config.setPort("12000"); admin.addInstance(clusterName, config); //join the cluster HelixManager manager; @@ -324,7 +337,7 @@ lock-group_9 localhost_12001 instanceName, InstanceType.PARTICIPANT, zkAddress); - manager.getStateMachineEngine().registerStateModelFactory("OnlineOffline", modelFactory); + manager.getStateMachineEngine().registerStateModelFactory("OnlineOffline", modelFactory); manager.connect(); Thread.currentThread.join(); } @@ -349,15 +362,15 @@ lock-group_9 localhost_12001 <div class="source"> <pre><code>public class LockProcess { public static void main(String args) { - String zkAddress= "localhost:2199"; - String clusterName = "lock-manager-demo"; + String zkAddress= "localhost:2199"; + String clusterName = "lock-manager-demo"; // . // . manager.connect(); HelixManager controller; controller = HelixControllerMain.startHelixController(zkAddress, clusterName, - "controller", + "controller", HelixControllerMain.STANDALONE); Thread.currentThread.join(); } @@ -437,7 +450,7 @@ lock-group_9 localhost_12001 <div class="span12"> <p class="pull-right"><a href="#">Back to top</a></p> <p class="copyright">Copyright ©2022 <a href="https://www.apache.org/";>The Apache Software Foundation</a>. All Rights Reserved.</p> - <p><a href="https://github.com/olamy/reflow-maven-skin"; title="Reflow Maven skin">Reflow Maven skin</a> by <a href="https://andrius.velykis.lt"; target="_blank" title="Andrius Velykis">Andrius Velykis</a>.</p> + <p><a href="https://github.com/olamy/reflow-maven-skin"; title="Reflow Maven skin">Reflow Maven skin</a> maintained by <a href="https://twitter.com/olamy"; target="_blank" title="Olivier Lamy">Olivier Lamy</a>.</p> <div class="row span16"><div>Apache Helix, Apache, the Apache feather logo, and the Apache Helix project logos are trademarks of The Apache Software Foundation. All other marks mentioned may be trademarks or registered trademarks of their respective owners.</div> <a href="https://helix.apache.org/0.9.9-docs/privacy-policy.html";>Privacy Policy</a> Modified: helix/site-content/0.9.9-docs/recipes/rabbitmq_consumer_group.html URL: http://svn.apache.org/viewvc/helix/site-content/0.9.9-docs/recipes/rabbitmq_consumer_group.html?rev=1900255&r1=1900254&r2=1900255&view=diff ============================================================================== --- helix/site-content/0.9.9-docs/recipes/rabbitmq_consumer_group.html (original) +++ helix/site-content/0.9.9-docs/recipes/rabbitmq_consumer_group.html Mon Apr 25 08:18:23 2022 @@ -1,7 +1,13 @@ <!DOCTYPE html> + + + + + + <!-- - Generated by Apache Maven Doxia at 2022-04-23 Rendered using Reflow Maven Skin 2.0.0-SNAPSHOT (https://andriusvelykis.github.io/reflow-maven-skin) + Generated by Apache Maven Doxia at 2022-04-25 Rendered using Reflow Maven Skin 2.0.0 (https://olamy.github.io/reflow-maven-skin) --> <html xml:lang="en" lang="en"> @@ -29,24 +35,31 @@ <![endif]--> - <script type="text/javascript"> - - var _gaq = _gaq || []; - _gaq.push(['_setAccount', 'UA-3211522-12']); - _gaq.push(['_trackPageview']); - (function() { - var ga = document.createElement('script'); ga.type = 'text/javascript'; ga.async = true; - ga.src = ('https:' == document.location.protocol ? 'https://ssl' : 'http://www') + '.google-analytics.com/ga.js'; - var s = document.getElementsByTagName('script')[0]; s.parentNode.insertBefore(ga, s); - })(); - </script> - </head> + +<!-- Matomo --> +<script> + var _paq = window._paq = window._paq || []; + _paq.push(['disableCookies']); + _paq.push(['trackPageView']); + _paq.push(['enableLinkTracking']); + + (function() { + var u="https://analytics.apache.org";; + _paq.push(['setTrackerUrl', u+'/matomo.php']); + _paq.push(['setSiteId', '15']); + var d=document, g=d.createElement('script'), s=d.getElementsByTagName('script')[0]; + g.async=true; g.src=u+'/matomo.js'; s.parentNode.insertBefore(g,s); + })(); +</script> +<!-- End Matomo Code --> + </head> <body class="page-recipes-rabbitmq_consumer_group project-099-docs" data-spy="scroll" data-offset="60" data-target="#toc-scroll-target"> + <div class="navbar navbar-fixed-top"> <div class="navbar-inner"> <div class="container"> @@ -119,7 +132,7 @@ <li><a href="../" title="Release 0.9.9">Release 0.9.9</a></li> <li class="divider">/</li> <li>RabbitMQ Consumer Group</li> - <li class="publishDate version-date pull-right">Last Published: 2022-04-23</li> + <li class="publishDate version-date pull-right">Last Published: 2022-04-25</li> </ul> </div> </header> @@ -266,12 +279,12 @@ admin.addCluster(clusterName, true); // add state model definition StateModelConfigGenerator generator = new StateModelConfigGenerator(); -admin.addStateModelDef(clusterName, "OnlineOffline", +admin.addStateModelDef(clusterName, "OnlineOffline", new StateModelDefinition(generator.generateConfigForOnlineOffline())); -// add resource "topic" which has 6 partitions -String resourceName = "rabbitmq-consumer-group"; -admin.addResource(clusterName, resourceName, 6, "OnlineOffline", "AUTO_REBALANCE"); +// add resource "topic" which has 6 partitions +String resourceName = "rabbitmq-consumer-group"; +admin.addResource(clusterName, resourceName, 6, "OnlineOffline", "AUTO_REBALANCE"); </code></pre> </div> </section> @@ -288,35 +301,35 @@ admin.addResource(clusterName, resourceN StateMachineEngine stateMach = _manager.getStateMachineEngine(); ConsumerStateModelFactory modelFactory = new ConsumerStateModelFactory(_consumerId, _mqServer); -stateMach.registerStateModelFactory("OnlineOffline", modelFactory); +stateMach.registerStateModelFactory("OnlineOffline", modelFactory); _manager.connect(); </code></pre> </div> <p>Once the consumer has registered the state model and the controller is started, the consumer starts getting callbacks (onBecomeOnlineFromOffline) for the partition it needs to host. All it needs to do as part of the callback is to start consuming messages from the appropriate queue. Similarly, when the controller deallocates a partitions from a consumer, it fires onBecomeOfflineFromOnline for the same partition. As a part of this transition, the consumer will stop consuming from a that queue.</p> <div class="source"> - <pre><code>@Transition(to = "ONLINE", from = "OFFLINE") + <pre><code>@Transition(to = "ONLINE", from = "OFFLINE") public void onBecomeOnlineFromOffline(Message message, NotificationContext context) { - LOG.debug(_consumerId + " becomes ONLINE from OFFLINE for " + _partition); + LOG.debug(_consumerId + " becomes ONLINE from OFFLINE for " + _partition); if (_thread == null) { - LOG.debug("Starting ConsumerThread for " + _partition + "..."); + LOG.debug("Starting ConsumerThread for " + _partition + "..."); _thread = new ConsumerThread(_partition, _mqServer, _consumerId); _thread.start(); - LOG.debug("Starting ConsumerThread for " + _partition + " done"); + LOG.debug("Starting ConsumerThread for " + _partition + " done"); } } -@Transition(to = "OFFLINE", from = "ONLINE") +@Transition(to = "OFFLINE", from = "ONLINE") public void onBecomeOfflineFromOnline(Message message, NotificationContext context) throws InterruptedException { - LOG.debug(_consumerId + " becomes OFFLINE from ONLINE for " + _partition); + LOG.debug(_consumerId + " becomes OFFLINE from ONLINE for " + _partition); if (_thread != null) { - LOG.debug("Stopping " + _consumerId + " for " + _partition + "..."); + LOG.debug("Stopping " + _consumerId + " for " + _partition + "..."); _thread.interrupt(); _thread.join(2000); _thread = null; - LOG.debug("Stopping " + _consumerId + " for " + _partition + " done"); + LOG.debug("Stopping " + _consumerId + " for " + _partition + " done"); } } </code></pre> @@ -392,7 +405,7 @@ public void onBecomeOfflineFromOnline(Me <div class="span12"> <p class="pull-right"><a href="#">Back to top</a></p> <p class="copyright">Copyright ©2022 <a href="https://www.apache.org/";>The Apache Software Foundation</a>. All Rights Reserved.</p> - <p><a href="https://github.com/olamy/reflow-maven-skin"; title="Reflow Maven skin">Reflow Maven skin</a> by <a href="https://andrius.velykis.lt"; target="_blank" title="Andrius Velykis">Andrius Velykis</a>.</p> + <p><a href="https://github.com/olamy/reflow-maven-skin"; title="Reflow Maven skin">Reflow Maven skin</a> maintained by <a href="https://twitter.com/olamy"; target="_blank" title="Olivier Lamy">Olivier Lamy</a>.</p> <div class="row span16"><div>Apache Helix, Apache, the Apache feather logo, and the Apache Helix project logos are trademarks of The Apache Software Foundation. All other marks mentioned may be trademarks or registered trademarks of their respective owners.</div> <a href="https://helix.apache.org/0.9.9-docs/privacy-policy.html";>Privacy Policy</a> Modified: helix/site-content/0.9.9-docs/recipes/rsync_replicated_file_store.html URL: http://svn.apache.org/viewvc/helix/site-content/0.9.9-docs/recipes/rsync_replicated_file_store.html?rev=1900255&r1=1900254&r2=1900255&view=diff ============================================================================== --- helix/site-content/0.9.9-docs/recipes/rsync_replicated_file_store.html (original) +++ helix/site-content/0.9.9-docs/recipes/rsync_replicated_file_store.html Mon Apr 25 08:18:23 2022 @@ -1,7 +1,13 @@ <!DOCTYPE html> + + + + + + <!-- - Generated by Apache Maven Doxia at 2022-04-23 Rendered using Reflow Maven Skin 2.0.0-SNAPSHOT (https://andriusvelykis.github.io/reflow-maven-skin) + Generated by Apache Maven Doxia at 2022-04-25 Rendered using Reflow Maven Skin 2.0.0 (https://olamy.github.io/reflow-maven-skin) --> <html xml:lang="en" lang="en"> @@ -29,24 +35,31 @@ <![endif]--> - <script type="text/javascript"> - - var _gaq = _gaq || []; - _gaq.push(['_setAccount', 'UA-3211522-12']); - _gaq.push(['_trackPageview']); - (function() { - var ga = document.createElement('script'); ga.type = 'text/javascript'; ga.async = true; - ga.src = ('https:' == document.location.protocol ? 'https://ssl' : 'http://www') + '.google-analytics.com/ga.js'; - var s = document.getElementsByTagName('script')[0]; s.parentNode.insertBefore(ga, s); - })(); - </script> - </head> + +<!-- Matomo --> +<script> + var _paq = window._paq = window._paq || []; + _paq.push(['disableCookies']); + _paq.push(['trackPageView']); + _paq.push(['enableLinkTracking']); + + (function() { + var u="https://analytics.apache.org";; + _paq.push(['setTrackerUrl', u+'/matomo.php']); + _paq.push(['setSiteId', '15']); + var d=document, g=d.createElement('script'), s=d.getElementsByTagName('script')[0]; + g.async=true; g.src=u+'/matomo.js'; s.parentNode.insertBefore(g,s); + })(); +</script> +<!-- End Matomo Code --> + </head> <body class="page-recipes-rsync_replicated_file_store project-099-docs" data-spy="scroll" data-offset="60" data-target="#toc-scroll-target"> + <div class="navbar navbar-fixed-top"> <div class="navbar-inner"> <div class="container"> @@ -119,7 +132,7 @@ <li><a href="../" title="Release 0.9.9">Release 0.9.9</a></li> <li class="divider">/</li> <li>Near-Realtime Rsync Replicated File System</li> - <li class="publishDate version-date pull-right">Last Published: 2022-04-23</li> + <li class="publishDate version-date pull-right">Last Published: 2022-04-25</li> </ul> </div> </header> @@ -222,12 +235,12 @@ chmod +x * <section> <h4 id="Failover">Failover</h4> <p>When a master fails, a new slave will be promoted to master. If the previous master node is reachable, then the new master will flush all the changes from previous the master before taking up mastership. The new master will record the end transaction ID of the current generation and then start a new generation with sequence starting from 1. After this the master will begin accepting writes.</p> - <p><img src="../images/PFS-Generic.png" alt="Partitioned File Store" /></p> + <p><img src="../images/PFS-Generic.png" alt="Partitioned File Store"></p> </section> </section> <section> <h3 id="Rsync-based_Solution">Rsync-based Solution</h3> - <p><img src="../images/RSYNC_BASED_PFS.png" alt="Rsync based File Store" /></p> + <p><img src="../images/RSYNC_BASED_PFS.png" alt="Rsync based File Store"></p> <p>This application demonstrates a file store that uses rsync as the replication mechanism. One can envision a similar system where instead of using rsync, one can implement a custom solution to notify the slave of the changes and also provide an api to pull the change files.</p> <section> <h4 id="Concepts">Concepts</h4> @@ -334,7 +347,7 @@ chmod +x * <div class="span12"> <p class="pull-right"><a href="#">Back to top</a></p> <p class="copyright">Copyright ©2022 <a href="https://www.apache.org/";>The Apache Software Foundation</a>. All Rights Reserved.</p> - <p><a href="https://github.com/olamy/reflow-maven-skin"; title="Reflow Maven skin">Reflow Maven skin</a> by <a href="https://andrius.velykis.lt"; target="_blank" title="Andrius Velykis">Andrius Velykis</a>.</p> + <p><a href="https://github.com/olamy/reflow-maven-skin"; title="Reflow Maven skin">Reflow Maven skin</a> maintained by <a href="https://twitter.com/olamy"; target="_blank" title="Olivier Lamy">Olivier Lamy</a>.</p> <div class="row span16"><div>Apache Helix, Apache, the Apache feather logo, and the Apache Helix project logos are trademarks of The Apache Software Foundation. All other marks mentioned may be trademarks or registered trademarks of their respective owners.</div> <a href="https://helix.apache.org/0.9.9-docs/privacy-policy.html";>Privacy Policy</a> Modified: helix/site-content/0.9.9-docs/recipes/service_discovery.html URL: http://svn.apache.org/viewvc/helix/site-content/0.9.9-docs/recipes/service_discovery.html?rev=1900255&r1=1900254&r2=1900255&view=diff ============================================================================== --- helix/site-content/0.9.9-docs/recipes/service_discovery.html (original) +++ helix/site-content/0.9.9-docs/recipes/service_discovery.html Mon Apr 25 08:18:23 2022 @@ -1,7 +1,13 @@ <!DOCTYPE html> + + + + + + <!-- - Generated by Apache Maven Doxia at 2022-04-23 Rendered using Reflow Maven Skin 2.0.0-SNAPSHOT (https://andriusvelykis.github.io/reflow-maven-skin) + Generated by Apache Maven Doxia at 2022-04-25 Rendered using Reflow Maven Skin 2.0.0 (https://olamy.github.io/reflow-maven-skin) --> <html xml:lang="en" lang="en"> @@ -29,24 +35,31 @@ <![endif]--> - <script type="text/javascript"> - - var _gaq = _gaq || []; - _gaq.push(['_setAccount', 'UA-3211522-12']); - _gaq.push(['_trackPageview']); - (function() { - var ga = document.createElement('script'); ga.type = 'text/javascript'; ga.async = true; - ga.src = ('https:' == document.location.protocol ? 'https://ssl' : 'http://www') + '.google-analytics.com/ga.js'; - var s = document.getElementsByTagName('script')[0]; s.parentNode.insertBefore(ga, s); - })(); - </script> - </head> + +<!-- Matomo --> +<script> + var _paq = window._paq = window._paq || []; + _paq.push(['disableCookies']); + _paq.push(['trackPageView']); + _paq.push(['enableLinkTracking']); + + (function() { + var u="https://analytics.apache.org";; + _paq.push(['setTrackerUrl', u+'/matomo.php']); + _paq.push(['setSiteId', '15']); + var d=document, g=d.createElement('script'), s=d.getElementsByTagName('script')[0]; + g.async=true; g.src=u+'/matomo.js'; s.parentNode.insertBefore(g,s); + })(); +</script> +<!-- End Matomo Code --> + </head> <body class="page-recipes-service_discovery project-099-docs" data-spy="scroll" data-offset="60" data-target="#toc-scroll-target"> + <div class="navbar navbar-fixed-top"> <div class="navbar-inner"> <div class="container"> @@ -119,7 +132,7 @@ <li><a href="../" title="Release 0.9.9">Release 0.9.9</a></li> <li class="divider">/</li> <li>Service Discovery</li> - <li class="publishDate version-date pull-right">Last Published: 2022-04-23</li> + <li class="publishDate version-date pull-right">Last Published: 2022-04-25</li> </ul> </div> </header> @@ -379,7 +392,7 @@ END:Service discovery demo mode:NONE <div class="span12"> <p class="pull-right"><a href="#">Back to top</a></p> <p class="copyright">Copyright ©2022 <a href="https://www.apache.org/";>The Apache Software Foundation</a>. All Rights Reserved.</p> - <p><a href="https://github.com/olamy/reflow-maven-skin"; title="Reflow Maven skin">Reflow Maven skin</a> by <a href="https://andrius.velykis.lt"; target="_blank" title="Andrius Velykis">Andrius Velykis</a>.</p> + <p><a href="https://github.com/olamy/reflow-maven-skin"; title="Reflow Maven skin">Reflow Maven skin</a> maintained by <a href="https://twitter.com/olamy"; target="_blank" title="Olivier Lamy">Olivier Lamy</a>.</p> <div class="row span16"><div>Apache Helix, Apache, the Apache feather logo, and the Apache Helix project logos are trademarks of The Apache Software Foundation. All other marks mentioned may be trademarks or registered trademarks of their respective owners.</div> <a href="https://helix.apache.org/0.9.9-docs/privacy-policy.html";>Privacy Policy</a> Modified: helix/site-content/0.9.9-docs/recipes/task_dag_execution.html URL: http://svn.apache.org/viewvc/helix/site-content/0.9.9-docs/recipes/task_dag_execution.html?rev=1900255&r1=1900254&r2=1900255&view=diff ============================================================================== --- helix/site-content/0.9.9-docs/recipes/task_dag_execution.html (original) +++ helix/site-content/0.9.9-docs/recipes/task_dag_execution.html Mon Apr 25 08:18:23 2022 @@ -1,7 +1,13 @@ <!DOCTYPE html> + + + + + + <!-- - Generated by Apache Maven Doxia at 2022-04-23 Rendered using Reflow Maven Skin 2.0.0-SNAPSHOT (https://andriusvelykis.github.io/reflow-maven-skin) + Generated by Apache Maven Doxia at 2022-04-25 Rendered using Reflow Maven Skin 2.0.0 (https://olamy.github.io/reflow-maven-skin) --> <html xml:lang="en" lang="en"> @@ -29,24 +35,31 @@ <![endif]--> - <script type="text/javascript"> - - var _gaq = _gaq || []; - _gaq.push(['_setAccount', 'UA-3211522-12']); - _gaq.push(['_trackPageview']); - (function() { - var ga = document.createElement('script'); ga.type = 'text/javascript'; ga.async = true; - ga.src = ('https:' == document.location.protocol ? 'https://ssl' : 'http://www') + '.google-analytics.com/ga.js'; - var s = document.getElementsByTagName('script')[0]; s.parentNode.insertBefore(ga, s); - })(); - </script> - </head> + +<!-- Matomo --> +<script> + var _paq = window._paq = window._paq || []; + _paq.push(['disableCookies']); + _paq.push(['trackPageView']); + _paq.push(['enableLinkTracking']); + + (function() { + var u="https://analytics.apache.org";; + _paq.push(['setTrackerUrl', u+'/matomo.php']); + _paq.push(['setSiteId', '15']); + var d=document, g=d.createElement('script'), s=d.getElementsByTagName('script')[0]; + g.async=true; g.src=u+'/matomo.js'; s.parentNode.insertBefore(g,s); + })(); +</script> +<!-- End Matomo Code --> + </head> <body class="page-recipes-task_dag_execution project-099-docs" data-spy="scroll" data-offset="60" data-target="#toc-scroll-target"> + <div class="navbar navbar-fixed-top"> <div class="navbar-inner"> <div class="container"> @@ -119,7 +132,7 @@ <li><a href="../" title="Release 0.9.9">Release 0.9.9</a></li> <li class="divider">/</li> <li>Distributed Task Execution</li> - <li class="publishDate version-date pull-right">Last Published: 2022-04-23</li> + <li class="publishDate version-date pull-right">Last Published: 2022-04-25</li> </ul> </div> </header> @@ -181,14 +194,14 @@ under the License. <p>Each stage is represented as a Node along with the upstream dependency and desired parallelism. Each stage is modeled as a resource in Helix using OnlineOffline state model. As part of an Offline to Online transition, we watch the external view of upstream resources and wait for them to transition to the online state. See Task.java for additional info.</p> <div class="source"> <pre><code>Dag dag = new Dag(); -dag.addNode(new Node("filterImps", 10, "")); -dag.addNode(new Node("filterClicks", 5, "")); -dag.addNode(new Node("impClickJoin", 10, "filterImps,filterClicks")); -dag.addNode(new Node("impCountsByGender", 10, "filterImps")); -dag.addNode(new Node("impCountsByCountry", 10, "filterImps")); -dag.addNode(new Node("clickCountsByGender", 5, "impClickJoin")); -dag.addNode(new Node("clickCountsByCountry", 5, "impClickJoin")); -dag.addNode(new Node("report",1,"impCountsByGender,impCountsByCountry,clickCountsByGender,clickCountsByCountry")); +dag.addNode(new Node("filterImps", 10, "")); +dag.addNode(new Node("filterClicks", 5, "")); +dag.addNode(new Node("impClickJoin", 10, "filterImps,filterClicks")); +dag.addNode(new Node("impCountsByGender", 10, "filterImps")); +dag.addNode(new Node("impCountsByCountry", 10, "filterImps")); +dag.addNode(new Node("clickCountsByGender", 5, "impClickJoin")); +dag.addNode(new Node("clickCountsByCountry", 5, "impClickJoin")); +dag.addNode(new Node("report",1,"impCountsByGender,impCountsByCountry,clickCountsByGender,clickCountsByCountry")); </code></pre> </div> </section> @@ -389,7 +402,7 @@ Click counts per gender <div class="span12"> <p class="pull-right"><a href="#">Back to top</a></p> <p class="copyright">Copyright ©2022 <a href="https://www.apache.org/";>The Apache Software Foundation</a>. All Rights Reserved.</p> - <p><a href="https://github.com/olamy/reflow-maven-skin"; title="Reflow Maven skin">Reflow Maven skin</a> by <a href="https://andrius.velykis.lt"; target="_blank" title="Andrius Velykis">Andrius Velykis</a>.</p> + <p><a href="https://github.com/olamy/reflow-maven-skin"; title="Reflow Maven skin">Reflow Maven skin</a> maintained by <a href="https://twitter.com/olamy"; target="_blank" title="Olivier Lamy">Olivier Lamy</a>.</p> <div class="row span16"><div>Apache Helix, Apache, the Apache feather logo, and the Apache Helix project logos are trademarks of The Apache Software Foundation. All other marks mentioned may be trademarks or registered trademarks of their respective owners.</div> <a href="https://helix.apache.org/0.9.9-docs/privacy-policy.html";>Privacy Policy</a> Modified: helix/site-content/0.9.9-docs/releasenotes/release-0.9.9.html URL: http://svn.apache.org/viewvc/helix/site-content/0.9.9-docs/releasenotes/release-0.9.9.html?rev=1900255&r1=1900254&r2=1900255&view=diff ============================================================================== --- helix/site-content/0.9.9-docs/releasenotes/release-0.9.9.html (original) +++ helix/site-content/0.9.9-docs/releasenotes/release-0.9.9.html Mon Apr 25 08:18:23 2022 @@ -1,7 +1,13 @@ <!DOCTYPE html> + + + + + + <!-- - Generated by Apache Maven Doxia at 2022-04-23 Rendered using Reflow Maven Skin 2.0.0-SNAPSHOT (https://andriusvelykis.github.io/reflow-maven-skin) + Generated by Apache Maven Doxia at 2022-04-25 Rendered using Reflow Maven Skin 2.0.0 (https://olamy.github.io/reflow-maven-skin) --> <html xml:lang="en" lang="en"> @@ -29,24 +35,31 @@ <![endif]--> - <script type="text/javascript"> - - var _gaq = _gaq || []; - _gaq.push(['_setAccount', 'UA-3211522-12']); - _gaq.push(['_trackPageview']); - (function() { - var ga = document.createElement('script'); ga.type = 'text/javascript'; ga.async = true; - ga.src = ('https:' == document.location.protocol ? 'https://ssl' : 'http://www') + '.google-analytics.com/ga.js'; - var s = document.getElementsByTagName('script')[0]; s.parentNode.insertBefore(ga, s); - })(); - </script> - </head> + +<!-- Matomo --> +<script> + var _paq = window._paq = window._paq || []; + _paq.push(['disableCookies']); + _paq.push(['trackPageView']); + _paq.push(['enableLinkTracking']); + + (function() { + var u="https://analytics.apache.org";; + _paq.push(['setTrackerUrl', u+'/matomo.php']); + _paq.push(['setSiteId', '15']); + var d=document, g=d.createElement('script'), s=d.getElementsByTagName('script')[0]; + g.async=true; g.src=u+'/matomo.js'; s.parentNode.insertBefore(g,s); + })(); +</script> +<!-- End Matomo Code --> + </head> <body class="page-releasenotes-release-099 project-099-docs" data-spy="scroll" data-offset="60" data-target="#toc-scroll-target"> + <div class="navbar navbar-fixed-top"> <div class="navbar-inner"> <div class="container"> @@ -119,7 +132,7 @@ <li><a href="../" title="Release 0.9.9">Release 0.9.9</a></li> <li class="divider">/</li> <li>Release Notes for Apache Helix 0.9.9</li> - <li class="publishDate version-date pull-right">Last Published: 2022-04-23</li> + <li class="publishDate version-date pull-right">Last Published: 2022-04-25</li> </ul> </div> </header> @@ -227,7 +240,7 @@ <div class="span12"> <p class="pull-right"><a href="#">Back to top</a></p> <p class="copyright">Copyright ©2022 <a href="https://www.apache.org/";>The Apache Software Foundation</a>. All Rights Reserved.</p> - <p><a href="https://github.com/olamy/reflow-maven-skin"; title="Reflow Maven skin">Reflow Maven skin</a> by <a href="https://andrius.velykis.lt"; target="_blank" title="Andrius Velykis">Andrius Velykis</a>.</p> + <p><a href="https://github.com/olamy/reflow-maven-skin"; title="Reflow Maven skin">Reflow Maven skin</a> maintained by <a href="https://twitter.com/olamy"; target="_blank" title="Olivier Lamy">Olivier Lamy</a>.</p> <div class="row span16"><div>Apache Helix, Apache, the Apache feather logo, and the Apache Helix project logos are trademarks of The Apache Software Foundation. All other marks mentioned may be trademarks or registered trademarks of their respective owners.</div> <a href="https://helix.apache.org/0.9.9-docs/privacy-policy.html";>Privacy Policy</a> Modified: helix/site-content/0.9.9-docs/tutorial_admin.html URL: http://svn.apache.org/viewvc/helix/site-content/0.9.9-docs/tutorial_admin.html?rev=1900255&r1=1900254&r2=1900255&view=diff ============================================================================== --- helix/site-content/0.9.9-docs/tutorial_admin.html (original) +++ helix/site-content/0.9.9-docs/tutorial_admin.html Mon Apr 25 08:18:23 2022 @@ -1,7 +1,13 @@ <!DOCTYPE html> + + + + + + <!-- - Generated by Apache Maven Doxia at 2022-04-23 Rendered using Reflow Maven Skin 2.0.0-SNAPSHOT (https://andriusvelykis.github.io/reflow-maven-skin) + Generated by Apache Maven Doxia at 2022-04-25 Rendered using Reflow Maven Skin 2.0.0 (https://olamy.github.io/reflow-maven-skin) --> <html xml:lang="en" lang="en"> @@ -29,24 +35,31 @@ <![endif]--> - <script type="text/javascript"> - - var _gaq = _gaq || []; - _gaq.push(['_setAccount', 'UA-3211522-12']); - _gaq.push(['_trackPageview']); - (function() { - var ga = document.createElement('script'); ga.type = 'text/javascript'; ga.async = true; - ga.src = ('https:' == document.location.protocol ? 'https://ssl' : 'http://www') + '.google-analytics.com/ga.js'; - var s = document.getElementsByTagName('script')[0]; s.parentNode.insertBefore(ga, s); - })(); - </script> - </head> + +<!-- Matomo --> +<script> + var _paq = window._paq = window._paq || []; + _paq.push(['disableCookies']); + _paq.push(['trackPageView']); + _paq.push(['enableLinkTracking']); + + (function() { + var u="https://analytics.apache.org";; + _paq.push(['setTrackerUrl', u+'/matomo.php']); + _paq.push(['setSiteId', '15']); + var d=document, g=d.createElement('script'), s=d.getElementsByTagName('script')[0]; + g.async=true; g.src=u+'/matomo.js'; s.parentNode.insertBefore(g,s); + })(); +</script> +<!-- End Matomo Code --> + </head> <body class="page-tutorial_admin project-099-docs" data-spy="scroll" data-offset="60" data-target="#toc-scroll-target"> + <div class="navbar navbar-fixed-top"> <div class="navbar-inner"> <div class="container"> @@ -119,7 +132,7 @@ <li><a href="./" title="Release 0.9.9">Release 0.9.9</a></li> <li class="divider">/</li> <li>Tutorial - Admin Operations</li> - <li class="publishDate version-date pull-right">Last Published: 2022-04-23</li> + <li class="publishDate version-date pull-right">Last Published: 2022-04-25</li> </ul> </div> </header> @@ -385,7 +398,7 @@ chmod +x *.sh <li>Add a cluster</li> </ul> <div class="source"> - <pre><code>curl -d 'jsonParameters={"command":"addCluster","clusterName":"MyCluster"}' -H "Content-Type: application/json" http://localhost:8100/clusters + <pre><code>curl -d 'jsonParameters={"command":"addCluster","clusterName":"MyCluster"}' -H "Content-Type: application/json" http://localhost:8100/clusters </code></pre> </div> </li> <li> <p><i>/clusters/{clusterName}</i></p> @@ -400,7 +413,7 @@ chmod +x *.sh <li>Enable/disable a cluster in distributed controller mode</li> </ul> <div class="source"> - <pre><code>curl -d 'jsonParameters={"command":"activateCluster","grandCluster":"MyControllerCluster","enabled":"true"}' -H "Content-Type: application/json" http://localhost:8100/clusters/MyCluster + <pre><code>curl -d 'jsonParameters={"command":"activateCluster","grandCluster":"MyControllerCluster","enabled":"true"}' -H "Content-Type: application/json" http://localhost:8100/clusters/MyCluster </code></pre> </div> <ul> @@ -422,7 +435,7 @@ chmod +x *.sh <li>Add a resource to cluster</li> </ul> <div class="source"> - <pre><code>curl -d 'jsonParameters={"command":"addResource","resourceGroupName":"MyDB","partitions":"8","stateModelDefRef":"MasterSlave" }' -H "Content-Type: application/json" http://localhost:8100/clusters/MyCluster/resourceGroups + <pre><code>curl -d 'jsonParameters={"command":"addResource","resourceGroupName":"MyDB","partitions":"8","stateModelDefRef":"MasterSlave" }' -H "Content-Type: application/json" http://localhost:8100/clusters/MyCluster/resourceGroups </code></pre> </div> </li> <li> <p><i>/clusters/{clusterName}/resourceGroups/{resourceName}</i></p> @@ -444,7 +457,7 @@ chmod +x *.sh <li>Reset all erroneous partitions of a resource</li> </ul> <div class="source"> - <pre><code>curl -d 'jsonParameters={"command":"resetResource"}' -H "Content-Type: application/json" http://localhost:8100/clusters/MyCluster/resourceGroups/MyDB + <pre><code>curl -d 'jsonParameters={"command":"resetResource"}' -H "Content-Type: application/json" http://localhost:8100/clusters/MyCluster/resourceGroups/MyDB </code></pre> </div> </li> <li> <p><i>/clusters/{clusterName}/resourceGroups/{resourceName}/idealState</i></p> @@ -452,7 +465,7 @@ chmod +x *.sh <li>Rebalance a resource</li> </ul> <div class="source"> - <pre><code>curl -d 'jsonParameters={"command":"rebalance","replicas":"3"}' -H "Content-Type: application/json" http://localhost:8100/clusters/MyCluster/resourceGroups/MyDB/idealState + <pre><code>curl -d 'jsonParameters={"command":"rebalance","replicas":"3"}' -H "Content-Type: application/json" http://localhost:8100/clusters/MyCluster/resourceGroups/MyDB/idealState </code></pre> </div> <ul> @@ -460,23 +473,23 @@ chmod +x *.sh </ul> <div class="source"> <pre><code>echo jsonParameters={ -"command":"addIdealState" +"command":"addIdealState" }&newIdealState={ - "id" : "MyDB", - "simpleFields" : { - "IDEAL_STATE_MODE" : "AUTO", - "NUM_PARTITIONS" : "8", - "REBALANCE_MODE" : "SEMI_AUTO", - "REPLICAS" : "0", - "STATE_MODEL_DEF_REF" : "MasterSlave", - "STATE_MODEL_FACTORY_NAME" : "DEFAULT" + "id" : "MyDB", + "simpleFields" : { + "IDEAL_STATE_MODE" : "AUTO", + "NUM_PARTITIONS" : "8", + "REBALANCE_MODE" : "SEMI_AUTO", + "REPLICAS" : "0", + "STATE_MODEL_DEF_REF" : "MasterSlave", + "STATE_MODEL_FACTORY_NAME" : "DEFAULT" }, - "listFields" : { + "listFields" : { }, - "mapFields" : { - "MyDB_0" : { - "localhost_1001" : "MASTER", - "localhost_1002" : "SLAVE" + "mapFields" : { + "MyDB_0" : { + "localhost_1001" : "MASTER", + "localhost_1002" : "SLAVE" } } } @@ -488,7 +501,7 @@ curl -d @'./newIdealState.json' -H 'Cont <li>Add resource property</li> </ul> <div class="source"> - <pre><code>curl -d 'jsonParameters={"command":"addResourceProperty","REBALANCE_TIMER_PERIOD":"500"}' -H "Content-Type: application/json" http://localhost:8100/clusters/MyCluster/resourceGroups/MyDB/idealState + <pre><code>curl -d 'jsonParameters={"command":"addResourceProperty","REBALANCE_TIMER_PERIOD":"500"}' -H "Content-Type: application/json" http://localhost:8100/clusters/MyCluster/resourceGroups/MyDB/idealState </code></pre> </div> </li> <li> <p><i>/clusters/{clusterName}/resourceGroups/{resourceName}/externalView</i></p> @@ -511,14 +524,14 @@ curl -d @'./newIdealState.json' -H 'Cont <li>Add an instance</li> </ul> <div class="source"> - <pre><code>curl -d 'jsonParameters={"command":"addInstance","instanceNames":"localhost_1001"}' -H "Content-Type: application/json" http://localhost:8100/clusters/MyCluster/instances + <pre><code>curl -d 'jsonParameters={"command":"addInstance","instanceNames":"localhost_1001"}' -H "Content-Type: application/json" http://localhost:8100/clusters/MyCluster/instances </code></pre> </div> <ul> <li>Swap an instance</li> </ul> <div class="source"> - <pre><code>curl -d 'jsonParameters={"command":"swapInstance","oldInstance":"localhost_1001", "newInstance":"localhost_1002"}' -H "Content-Type: application/json" http://localhost:8100/clusters/MyCluster/instances + <pre><code>curl -d 'jsonParameters={"command":"swapInstance","oldInstance":"localhost_1001", "newInstance":"localhost_1002"}' -H "Content-Type: application/json" http://localhost:8100/clusters/MyCluster/instances </code></pre> </div> </li> <li> <p><i>/clusters/{clusterName}/instances/{instanceName}</i></p> @@ -533,7 +546,7 @@ curl -d @'./newIdealState.json' -H 'Cont <li>Enable/disable an instance</li> </ul> <div class="source"> - <pre><code>curl -d 'jsonParameters={"command":"enableInstance","enabled":"false"}' -H "Content-Type: application/json" http://localhost:8100/clusters/MyCluster/instances/localhost_1001 + <pre><code>curl -d 'jsonParameters={"command":"enableInstance","enabled":"false"}' -H "Content-Type: application/json" http://localhost:8100/clusters/MyCluster/instances/localhost_1001 </code></pre> </div> <ul> @@ -547,21 +560,21 @@ curl -d @'./newIdealState.json' -H 'Cont <li>Disable/enable partitions on an instance</li> </ul> <div class="source"> - <pre><code>curl -d 'jsonParameters={"command":"enablePartition","resource": "MyDB","partition":"MyDB_0", "enabled" : "false"}' -H "Content-Type: application/json" http://localhost:8100/clusters/MyCluster/instances/localhost_1001 + <pre><code>curl -d 'jsonParameters={"command":"enablePartition","resource": "MyDB","partition":"MyDB_0", "enabled" : "false"}' -H "Content-Type: application/json" http://localhost:8100/clusters/MyCluster/instances/localhost_1001 </code></pre> </div> <ul> <li>Reset an erroneous partition on an instance</li> </ul> <div class="source"> - <pre><code>curl -d 'jsonParameters={"command":"resetPartition","resource": "MyDB","partition":"MyDB_0"}' -H "Content-Type: application/json" http://localhost:8100/clusters/MyCluster/instances/localhost_1001 + <pre><code>curl -d 'jsonParameters={"command":"resetPartition","resource": "MyDB","partition":"MyDB_0"}' -H "Content-Type: application/json" http://localhost:8100/clusters/MyCluster/instances/localhost_1001 </code></pre> </div> <ul> <li>Reset all erroneous partitions on an instance</li> </ul> <div class="source"> - <pre><code>curl -d 'jsonParameters={"command":"resetInstance"}' -H "Content-Type: application/json" http://localhost:8100/clusters/MyCluster/instances/localhost_1001 + <pre><code>curl -d 'jsonParameters={"command":"resetInstance"}' -H "Content-Type: application/json" http://localhost:8100/clusters/MyCluster/instances/localhost_1001 </code></pre> </div> </li> <li> <p><i>/clusters/{clusterName}/configs</i></p> @@ -576,28 +589,28 @@ curl -d @'./newIdealState.json' -H 'Cont <li>Set user cluster level config</li> </ul> <div class="source"> - <pre><code>curl -d 'jsonParameters={"command":"setConfig","configs":"key1=value1,key2=value2"}' -H "Content-Type: application/json" http://localhost:8100/clusters/MyCluster/configs/cluster + <pre><code>curl -d 'jsonParameters={"command":"setConfig","configs":"key1=value1,key2=value2"}' -H "Content-Type: application/json" http://localhost:8100/clusters/MyCluster/configs/cluster </code></pre> </div> <ul> <li>Remove user cluster level config</li> </ul> <div class="source"> - <pre><code>curl -d 'jsonParameters={"command":"removeConfig","configs":"key1,key2"}' -H "Content-Type: application/json" http://localhost:8100/clusters/MyCluster/configs/cluster + <pre><code>curl -d 'jsonParameters={"command":"removeConfig","configs":"key1,key2"}' -H "Content-Type: application/json" http://localhost:8100/clusters/MyCluster/configs/cluster </code></pre> </div> <ul> <li>Get/set/remove user participant level config</li> </ul> <div class="source"> - <pre><code>curl -d 'jsonParameters={"command":"setConfig","configs":"key1=value1,key2=value2"}' -H "Content-Type: application/json" http://localhost:8100/clusters/MyCluster/configs/participant/localhost_1001 + <pre><code>curl -d 'jsonParameters={"command":"setConfig","configs":"key1=value1,key2=value2"}' -H "Content-Type: application/json" http://localhost:8100/clusters/MyCluster/configs/participant/localhost_1001 </code></pre> </div> <ul> <li>Get/set/remove resource level config</li> </ul> <div class="source"> - <pre><code>curl -d 'jsonParameters={"command":"setConfig","configs":"key1=value1,key2=value2"}' -H "Content-Type: application/json" http://localhost:8100/clusters/MyCluster/configs/resource/MyDB + <pre><code>curl -d 'jsonParameters={"command":"setConfig","configs":"key1=value1,key2=value2"}' -H "Content-Type: application/json" http://localhost:8100/clusters/MyCluster/configs/resource/MyDB </code></pre> </div> </li> <li> <p><i>/clusters/{clusterName}/controller</i></p> @@ -612,7 +625,7 @@ curl -d @'./newIdealState.json' -H 'Cont <li>Enable/disable cluster</li> </ul> <div class="source"> - <pre><code>curl -d 'jsonParameters={"command":"enableCluster","enabled":"false"}' -H "Content-Type: application/json" http://localhost:8100/clusters/MyCluster/Controller + <pre><code>curl -d 'jsonParameters={"command":"enableCluster","enabled":"false"}' -H "Content-Type: application/json" http://localhost:8100/clusters/MyCluster/Controller </code></pre> </div> </li> <li> <p><i>/zkPath/{path}</i></p> @@ -636,33 +649,33 @@ curl -d @'./newIdealState.json' -H 'Cont </ul> <div class="source"> <pre><code>echo jsonParameters={ - "command":"addStateModelDef" + "command":"addStateModelDef" }&newStateModelDef={ - "id" : "OnlineOffline", - "simpleFields" : { - "INITIAL_STATE" : "OFFLINE" + "id" : "OnlineOffline", + "simpleFields" : { + "INITIAL_STATE" : "OFFLINE" }, - "listFields" : { - "STATE_PRIORITY_LIST" : [ "ONLINE", "OFFLINE", "DROPPED" ], - "STATE_TRANSITION_PRIORITYLIST" : [ "OFFLINE-ONLINE", "ONLINE-OFFLINE", "OFFLINE-DROPPED" ] + "listFields" : { + "STATE_PRIORITY_LIST" : [ "ONLINE", "OFFLINE", "DROPPED" ], + "STATE_TRANSITION_PRIORITYLIST" : [ "OFFLINE-ONLINE", "ONLINE-OFFLINE", "OFFLINE-DROPPED" ] }, - "mapFields" : { - "DROPPED.meta" : { - "count" : "-1" + "mapFields" : { + "DROPPED.meta" : { + "count" : "-1" }, - "OFFLINE.meta" : { - "count" : "-1" + "OFFLINE.meta" : { + "count" : "-1" }, - "OFFLINE.next" : { - "DROPPED" : "DROPPED", - "ONLINE" : "ONLINE" + "OFFLINE.next" : { + "DROPPED" : "DROPPED", + "ONLINE" : "ONLINE" }, - "ONLINE.meta" : { - "count" : "R" + "ONLINE.meta" : { + "count" : "R" }, - "ONLINE.next" : { - "DROPPED" : "OFFLINE", - "OFFLINE" : "OFFLINE" + "ONLINE.next" : { + "DROPPED" : "OFFLINE", + "OFFLINE" : "OFFLINE" } } } @@ -690,7 +703,7 @@ curl -d @'./untitled.txt' -H 'Content-Ty <li>Set a contraint</li> </ul> <div class="source"> - <pre><code>curl -d 'jsonParameters={"constraintAttributes":"RESOURCE=MyDB,CONSTRAINT_VALUE=1"}' -H "Content-Type: application/json" http://localhost:8100/clusters/MyCluster/constraints/MESSAGE_CONSTRAINT/MyConstraint + <pre><code>curl -d 'jsonParameters={"constraintAttributes":"RESOURCE=MyDB,CONSTRAINT_VALUE=1"}' -H "Content-Type: application/json" http://localhost:8100/clusters/MyCluster/constraints/MESSAGE_CONSTRAINT/MyConstraint </code></pre> </div> <ul> @@ -773,7 +786,7 @@ curl -d @'./untitled.txt' -H 'Content-Ty <div class="span12"> <p class="pull-right"><a href="#">Back to top</a></p> <p class="copyright">Copyright ©2022 <a href="https://www.apache.org/";>The Apache Software Foundation</a>. All Rights Reserved.</p> - <p><a href="https://github.com/olamy/reflow-maven-skin"; title="Reflow Maven skin">Reflow Maven skin</a> by <a href="https://andrius.velykis.lt"; target="_blank" title="Andrius Velykis">Andrius Velykis</a>.</p> + <p><a href="https://github.com/olamy/reflow-maven-skin"; title="Reflow Maven skin">Reflow Maven skin</a> maintained by <a href="https://twitter.com/olamy"; target="_blank" title="Olivier Lamy">Olivier Lamy</a>.</p> <div class="row span16"><div>Apache Helix, Apache, the Apache feather logo, and the Apache Helix project logos are trademarks of The Apache Software Foundation. All other marks mentioned may be trademarks or registered trademarks of their respective owners.</div> <a href="https://helix.apache.org/0.9.9-docs/privacy-policy.html";>Privacy Policy</a> Modified: helix/site-content/0.9.9-docs/tutorial_agent.html URL: http://svn.apache.org/viewvc/helix/site-content/0.9.9-docs/tutorial_agent.html?rev=1900255&r1=1900254&r2=1900255&view=diff ============================================================================== --- helix/site-content/0.9.9-docs/tutorial_agent.html (original) +++ helix/site-content/0.9.9-docs/tutorial_agent.html Mon Apr 25 08:18:23 2022 @@ -1,7 +1,13 @@ <!DOCTYPE html> + + + + + + <!-- - Generated by Apache Maven Doxia at 2022-04-23 Rendered using Reflow Maven Skin 2.0.0-SNAPSHOT (https://andriusvelykis.github.io/reflow-maven-skin) + Generated by Apache Maven Doxia at 2022-04-25 Rendered using Reflow Maven Skin 2.0.0 (https://olamy.github.io/reflow-maven-skin) --> <html xml:lang="en" lang="en"> @@ -29,24 +35,31 @@ <![endif]--> - <script type="text/javascript"> - - var _gaq = _gaq || []; - _gaq.push(['_setAccount', 'UA-3211522-12']); - _gaq.push(['_trackPageview']); - (function() { - var ga = document.createElement('script'); ga.type = 'text/javascript'; ga.async = true; - ga.src = ('https:' == document.location.protocol ? 'https://ssl' : 'http://www') + '.google-analytics.com/ga.js'; - var s = document.getElementsByTagName('script')[0]; s.parentNode.insertBefore(ga, s); - })(); - </script> - </head> + +<!-- Matomo --> +<script> + var _paq = window._paq = window._paq || []; + _paq.push(['disableCookies']); + _paq.push(['trackPageView']); + _paq.push(['enableLinkTracking']); + + (function() { + var u="https://analytics.apache.org";; + _paq.push(['setTrackerUrl', u+'/matomo.php']); + _paq.push(['setSiteId', '15']); + var d=document, g=d.createElement('script'), s=d.getElementsByTagName('script')[0]; + g.async=true; g.src=u+'/matomo.js'; s.parentNode.insertBefore(g,s); + })(); +</script> +<!-- End Matomo Code --> + </head> <body class="page-tutorial_agent project-099-docs" data-spy="scroll" data-offset="60" data-target="#toc-scroll-target"> + <div class="navbar navbar-fixed-top"> <div class="navbar-inner"> <div class="container"> @@ -119,7 +132,7 @@ <li><a href="./" title="Release 0.9.9">Release 0.9.9</a></li> <li class="divider">/</li> <li>Tutorial - Helix Agent</li> - <li class="publishDate version-date pull-right">Last Published: 2022-04-23</li> + <li class="publishDate version-date pull-right">Last Published: 2022-04-25</li> </ul> </div> </header> @@ -180,9 +193,9 @@ ConfigAccessor configAccessor = new Conf // Specify the script for OFFLINE --> ONLINE CommandConfig.Builder builder = new CommandConfig.Builder(); CommandConfig cmdConfig = - builder.setTransition("OFFLINE", "ONLINE").setCommand("simpleHttpClient.py OFFLINE-ONLINE") + builder.setTransition("OFFLINE", "ONLINE").setCommand("simpleHttpClient.py OFFLINE-ONLINE") .setCommandWorkingDir(workingDir) - .setCommandTimeout("5000L") // optional: ms to wait before failing + .setCommandTimeout("5000L") // optional: ms to wait before failing .setPidFile(pidFile) // optional: for daemon-like systems that will write the process id to a file .build(); configAccessor.set(scope, cmdConfig.toKeyValueMap()); @@ -190,7 +203,7 @@ configAccessor.set(scope, cmdConfig.toKe // Specify the script for ONLINE --> OFFLINE builder = new CommandConfig.Builder(); cmdConfig = - builder.setTransition("ONLINE", "OFFLINE").setCommand("simpleHttpClient.py ONLINE-OFFLINE") + builder.setTransition("ONLINE", "OFFLINE").setCommand("simpleHttpClient.py ONLINE-OFFLINE") .setCommandWorkingDir(workingDir) .build(); configAccessor.set(scope, cmdConfig.toKeyValueMap()); @@ -198,7 +211,7 @@ configAccessor.set(scope, cmdConfig.toKe // Specify NOP for OFFLINE --> DROPPED builder = new CommandConfig.Builder(); cmdConfig = - builder.setTransition("OFFLINE", "DROPPED") + builder.setTransition("OFFLINE", "DROPPED") .setCommand(CommandAttribute.NOP.getName()) .build(); configAccessor.set(scope, cmdConfig.toKeyValueMap()); @@ -212,19 +225,19 @@ configAccessor.set(scope, cmdConfig.toKe <p>It is also possible to configure everything directly from the command line. Here's how that would look for cluster-wide configuration:</p> <div class="source"> <pre><code># Specify the script for OFFLINE --> ONLINE -/helix-admin.sh --zkSvr localhost:2181 --setConfig CLUSTER clusterName OFFLINE-ONLINE.command="simpleHttpClient.py OFFLINE-ONLINE",OFFLINE-ONLINE.workingDir="/path/to/script", OFFLINE-ONLINE.command.pidfile="/path/to/pidfile" +/helix-admin.sh --zkSvr localhost:2181 --setConfig CLUSTER clusterName OFFLINE-ONLINE.command="simpleHttpClient.py OFFLINE-ONLINE",OFFLINE-ONLINE.workingDir="/path/to/script", OFFLINE-ONLINE.command.pidfile="/path/to/pidfile" # Specify the script for ONLINE --> OFFLINE -/helix-admin.sh --zkSvr localhost:2181 --setConfig CLUSTER clusterName ONLINE-OFFLINE.command="simpleHttpClient.py ONLINE-OFFLINE",ONLINE-OFFLINE.workingDir="/path/to/script", OFFLINE-ONLINE.command.pidfile="/path/to/pidfile" +/helix-admin.sh --zkSvr localhost:2181 --setConfig CLUSTER clusterName ONLINE-OFFLINE.command="simpleHttpClient.py ONLINE-OFFLINE",ONLINE-OFFLINE.workingDir="/path/to/script", OFFLINE-ONLINE.command.pidfile="/path/to/pidfile" # Specify NOP for OFFLINE --> DROPPED -/helix-admin.sh --zkSvr localhost:2181 --setConfig CLUSTER clusterName ONLINE-OFFLINE.command="nop" +/helix-admin.sh --zkSvr localhost:2181 --setConfig CLUSTER clusterName ONLINE-OFFLINE.command="nop" </code></pre> </div> <p>Like in the Java configuration, it is also possible to specify a resource scope instead of a cluster scope:</p> <div class="source"> <pre><code># Specify the script for OFFLINE --> ONLINE -/helix-admin.sh --zkSvr localhost:2181 --setConfig RESOURCE clusterName,resourceName OFFLINE-ONLINE.command="simpleHttpClient.py OFFLINE-ONLINE",OFFLINE-ONLINE.workingDir="/path/to/script", OFFLINE-ONLINE.command.pidfile="/path/to/pidfile" +/helix-admin.sh --zkSvr localhost:2181 --setConfig RESOURCE clusterName,resourceName OFFLINE-ONLINE.command="simpleHttpClient.py OFFLINE-ONLINE",OFFLINE-ONLINE.workingDir="/path/to/script", OFFLINE-ONLINE.command.pidfile="/path/to/pidfile" </code></pre> </div> </section> @@ -237,7 +250,7 @@ configAccessor.set(scope, cmdConfig.toKe <h4 id="Java">Java</h4> <div class="source"> <pre><code>// Start your application process -ExternalCommand serverCmd = ExternalCommand.start(workingDir + "/simpleHttpServer.py"); +ExternalCommand serverCmd = ExternalCommand.start(workingDir + "/simpleHttpServer.py"); // Start the agent Thread agentThread = new Thread() { @@ -246,14 +259,14 @@ Thread agentThread = new Thread() { while(!isInterrupted()) { try { HelixAgentMain.main(new String[] { - "--zkSvr", zkAddr, "--cluster", clusterName, "--instanceName", instanceName, - "--stateModel", "OnlineOffline" + "--zkSvr", zkAddr, "--cluster", clusterName, "--instanceName", instanceName, + "--stateModel", "OnlineOffline" }); } catch (InterruptedException e) { - LOG.info("Agent thread interrupted", e); + LOG.info("Agent thread interrupted", e); interrupt(); } catch (Exception e) { - LOG.error("Exception start helix-agent", e); + LOG.error("Exception start helix-agent", e); } } } @@ -360,7 +373,7 @@ helix-agent/target/helix-agent-pkg/bin/s <div class="span12"> <p class="pull-right"><a href="#">Back to top</a></p> <p class="copyright">Copyright ©2022 <a href="https://www.apache.org/";>The Apache Software Foundation</a>. All Rights Reserved.</p> - <p><a href="https://github.com/olamy/reflow-maven-skin"; title="Reflow Maven skin">Reflow Maven skin</a> by <a href="https://andrius.velykis.lt"; target="_blank" title="Andrius Velykis">Andrius Velykis</a>.</p> + <p><a href="https://github.com/olamy/reflow-maven-skin"; title="Reflow Maven skin">Reflow Maven skin</a> maintained by <a href="https://twitter.com/olamy"; target="_blank" title="Olivier Lamy">Olivier Lamy</a>.</p> <div class="row span16"><div>Apache Helix, Apache, the Apache feather logo, and the Apache Helix project logos are trademarks of The Apache Software Foundation. All other marks mentioned may be trademarks or registered trademarks of their respective owners.</div> <a href="https://helix.apache.org/0.9.9-docs/privacy-policy.html";>Privacy Policy</a> Modified: helix/site-content/0.9.9-docs/tutorial_controller.html URL: http://svn.apache.org/viewvc/helix/site-content/0.9.9-docs/tutorial_controller.html?rev=1900255&r1=1900254&r2=1900255&view=diff ============================================================================== --- helix/site-content/0.9.9-docs/tutorial_controller.html (original) +++ helix/site-content/0.9.9-docs/tutorial_controller.html Mon Apr 25 08:18:23 2022 @@ -1,7 +1,13 @@ <!DOCTYPE html> + + + + + + <!-- - Generated by Apache Maven Doxia at 2022-04-23 Rendered using Reflow Maven Skin 2.0.0-SNAPSHOT (https://andriusvelykis.github.io/reflow-maven-skin) + Generated by Apache Maven Doxia at 2022-04-25 Rendered using Reflow Maven Skin 2.0.0 (https://olamy.github.io/reflow-maven-skin) --> <html xml:lang="en" lang="en"> @@ -29,24 +35,31 @@ <![endif]--> - <script type="text/javascript"> - - var _gaq = _gaq || []; - _gaq.push(['_setAccount', 'UA-3211522-12']); - _gaq.push(['_trackPageview']); - (function() { - var ga = document.createElement('script'); ga.type = 'text/javascript'; ga.async = true; - ga.src = ('https:' == document.location.protocol ? 'https://ssl' : 'http://www') + '.google-analytics.com/ga.js'; - var s = document.getElementsByTagName('script')[0]; s.parentNode.insertBefore(ga, s); - })(); - </script> - </head> + +<!-- Matomo --> +<script> + var _paq = window._paq = window._paq || []; + _paq.push(['disableCookies']); + _paq.push(['trackPageView']); + _paq.push(['enableLinkTracking']); + + (function() { + var u="https://analytics.apache.org";; + _paq.push(['setTrackerUrl', u+'/matomo.php']); + _paq.push(['setSiteId', '15']); + var d=document, g=d.createElement('script'), s=d.getElementsByTagName('script')[0]; + g.async=true; g.src=u+'/matomo.js'; s.parentNode.insertBefore(g,s); + })(); +</script> +<!-- End Matomo Code --> + </head> <body class="page-tutorial_controller project-099-docs" data-spy="scroll" data-offset="60" data-target="#toc-scroll-target"> + <div class="navbar navbar-fixed-top"> <div class="navbar-inner"> <div class="container"> @@ -119,7 +132,7 @@ <li><a href="./" title="Release 0.9.9">Release 0.9.9</a></li> <li class="divider">/</li> <li>Tutorial - Controller</li> - <li class="publishDate version-date pull-right">Last Published: 2022-04-23</li> + <li class="publishDate version-date pull-right">Last Published: 2022-04-25</li> </ul> </div> </header> @@ -347,7 +360,7 @@ manager.connect(); <div class="span12"> <p class="pull-right"><a href="#">Back to top</a></p> <p class="copyright">Copyright ©2022 <a href="https://www.apache.org/";>The Apache Software Foundation</a>. All Rights Reserved.</p> - <p><a href="https://github.com/olamy/reflow-maven-skin"; title="Reflow Maven skin">Reflow Maven skin</a> by <a href="https://andrius.velykis.lt"; target="_blank" title="Andrius Velykis">Andrius Velykis</a>.</p> + <p><a href="https://github.com/olamy/reflow-maven-skin"; title="Reflow Maven skin">Reflow Maven skin</a> maintained by <a href="https://twitter.com/olamy"; target="_blank" title="Olivier Lamy">Olivier Lamy</a>.</p> <div class="row span16"><div>Apache Helix, Apache, the Apache feather logo, and the Apache Helix project logos are trademarks of The Apache Software Foundation. All other marks mentioned may be trademarks or registered trademarks of their respective owners.</div> <a href="https://helix.apache.org/0.9.9-docs/privacy-policy.html";>Privacy Policy</a> Modified: helix/site-content/0.9.9-docs/tutorial_health.html URL: http://svn.apache.org/viewvc/helix/site-content/0.9.9-docs/tutorial_health.html?rev=1900255&r1=1900254&r2=1900255&view=diff ============================================================================== --- helix/site-content/0.9.9-docs/tutorial_health.html (original) +++ helix/site-content/0.9.9-docs/tutorial_health.html Mon Apr 25 08:18:23 2022 @@ -1,7 +1,13 @@ <!DOCTYPE html> + + + + + + <!-- - Generated by Apache Maven Doxia at 2022-04-23 Rendered using Reflow Maven Skin 2.0.0-SNAPSHOT (https://andriusvelykis.github.io/reflow-maven-skin) + Generated by Apache Maven Doxia at 2022-04-25 Rendered using Reflow Maven Skin 2.0.0 (https://olamy.github.io/reflow-maven-skin) --> <html xml:lang="en" lang="en"> @@ -29,24 +35,31 @@ <![endif]--> - <script type="text/javascript"> - - var _gaq = _gaq || []; - _gaq.push(['_setAccount', 'UA-3211522-12']); - _gaq.push(['_trackPageview']); - (function() { - var ga = document.createElement('script'); ga.type = 'text/javascript'; ga.async = true; - ga.src = ('https:' == document.location.protocol ? 'https://ssl' : 'http://www') + '.google-analytics.com/ga.js'; - var s = document.getElementsByTagName('script')[0]; s.parentNode.insertBefore(ga, s); - })(); - </script> - </head> + +<!-- Matomo --> +<script> + var _paq = window._paq = window._paq || []; + _paq.push(['disableCookies']); + _paq.push(['trackPageView']); + _paq.push(['enableLinkTracking']); + + (function() { + var u="https://analytics.apache.org";; + _paq.push(['setTrackerUrl', u+'/matomo.php']); + _paq.push(['setSiteId', '15']); + var d=document, g=d.createElement('script'), s=d.getElementsByTagName('script')[0]; + g.async=true; g.src=u+'/matomo.js'; s.parentNode.insertBefore(g,s); + })(); +</script> +<!-- End Matomo Code --> + </head> <body class="page-tutorial_health project-099-docs" data-spy="scroll" data-offset="60" data-target="#toc-scroll-target"> + <div class="navbar navbar-fixed-top"> <div class="navbar-inner"> <div class="container"> @@ -119,7 +132,7 @@ <li><a href="./" title="Release 0.9.9">Release 0.9.9</a></li> <li class="divider">/</li> <li>Tutorial - Customizing Heath Checks</li> - <li class="publishDate version-date pull-right">Last Published: 2022-04-23</li> + <li class="publishDate version-date pull-right">Last Published: 2022-04-25</li> </ul> </div> </header> @@ -235,7 +248,7 @@ under the License. <div class="span12"> <p class="pull-right"><a href="#">Back to top</a></p> <p class="copyright">Copyright ©2022 <a href="https://www.apache.org/";>The Apache Software Foundation</a>. All Rights Reserved.</p> - <p><a href="https://github.com/olamy/reflow-maven-skin"; title="Reflow Maven skin">Reflow Maven skin</a> by <a href="https://andrius.velykis.lt"; target="_blank" title="Andrius Velykis">Andrius Velykis</a>.</p> + <p><a href="https://github.com/olamy/reflow-maven-skin"; title="Reflow Maven skin">Reflow Maven skin</a> maintained by <a href="https://twitter.com/olamy"; target="_blank" title="Olivier Lamy">Olivier Lamy</a>.</p> <div class="row span16"><div>Apache Helix, Apache, the Apache feather logo, and the Apache Helix project logos are trademarks of The Apache Software Foundation. All other marks mentioned may be trademarks or registered trademarks of their respective owners.</div> <a href="https://helix.apache.org/0.9.9-docs/privacy-policy.html";>Privacy Policy</a> Modified: helix/site-content/0.9.9-docs/tutorial_messaging.html URL: http://svn.apache.org/viewvc/helix/site-content/0.9.9-docs/tutorial_messaging.html?rev=1900255&r1=1900254&r2=1900255&view=diff ============================================================================== --- helix/site-content/0.9.9-docs/tutorial_messaging.html (original) +++ helix/site-content/0.9.9-docs/tutorial_messaging.html Mon Apr 25 08:18:23 2022 @@ -1,7 +1,13 @@ <!DOCTYPE html> + + + + + + <!-- - Generated by Apache Maven Doxia at 2022-04-23 Rendered using Reflow Maven Skin 2.0.0-SNAPSHOT (https://andriusvelykis.github.io/reflow-maven-skin) + Generated by Apache Maven Doxia at 2022-04-25 Rendered using Reflow Maven Skin 2.0.0 (https://olamy.github.io/reflow-maven-skin) --> <html xml:lang="en" lang="en"> @@ -29,24 +35,31 @@ <![endif]--> - <script type="text/javascript"> - - var _gaq = _gaq || []; - _gaq.push(['_setAccount', 'UA-3211522-12']); - _gaq.push(['_trackPageview']); - (function() { - var ga = document.createElement('script'); ga.type = 'text/javascript'; ga.async = true; - ga.src = ('https:' == document.location.protocol ? 'https://ssl' : 'http://www') + '.google-analytics.com/ga.js'; - var s = document.getElementsByTagName('script')[0]; s.parentNode.insertBefore(ga, s); - })(); - </script> - </head> + +<!-- Matomo --> +<script> + var _paq = window._paq = window._paq || []; + _paq.push(['disableCookies']); + _paq.push(['trackPageView']); + _paq.push(['enableLinkTracking']); + + (function() { + var u="https://analytics.apache.org";; + _paq.push(['setTrackerUrl', u+'/matomo.php']); + _paq.push(['setSiteId', '15']); + var d=document, g=d.createElement('script'), s=d.getElementsByTagName('script')[0]; + g.async=true; g.src=u+'/matomo.js'; s.parentNode.insertBefore(g,s); + })(); +</script> +<!-- End Matomo Code --> + </head> <body class="page-tutorial_messaging project-099-docs" data-spy="scroll" data-offset="60" data-target="#toc-scroll-target"> + <div class="navbar navbar-fixed-top"> <div class="navbar-inner"> <div class="container"> @@ -119,7 +132,7 @@ <li><a href="./" title="Release 0.9.9">Release 0.9.9</a></li> <li class="divider">/</li> <li>Tutorial - Messaging</li> - <li class="publishDate version-date pull-right">Last Published: 2022-04-23</li> + <li class="publishDate version-date pull-right">Last Published: 2022-04-25</li> </ul> </div> </header> @@ -168,10 +181,10 @@ requestBackupUriRequest.setMsgState(Mess // Set the Recipient criteria: all nodes that satisfy the criteria will receive the message Criteria recipientCriteria = new Criteria(); -recipientCriteria.setInstanceName("%"); +recipientCriteria.setInstanceName("%"); recipientCriteria.setRecipientInstanceType(InstanceType.PARTICIPANT); -recipientCriteria.setResource("MyDB"); -recipientCriteria.setPartition(""); +recipientCriteria.setResource("MyDB"); +recipientCriteria.setPartition(""); // Should be processed only by process(es) that are active at the time of sending the message // This means if the recipient is restarted after message is sent, it will not be processe. @@ -260,7 +273,7 @@ int sentMessageCount = messagingService. <div class="span12"> <p class="pull-right"><a href="#">Back to top</a></p> <p class="copyright">Copyright ©2022 <a href="https://www.apache.org/";>The Apache Software Foundation</a>. All Rights Reserved.</p> - <p><a href="https://github.com/olamy/reflow-maven-skin"; title="Reflow Maven skin">Reflow Maven skin</a> by <a href="https://andrius.velykis.lt"; target="_blank" title="Andrius Velykis">Andrius Velykis</a>.</p> + <p><a href="https://github.com/olamy/reflow-maven-skin"; title="Reflow Maven skin">Reflow Maven skin</a> maintained by <a href="https://twitter.com/olamy"; target="_blank" title="Olivier Lamy">Olivier Lamy</a>.</p> <div class="row span16"><div>Apache Helix, Apache, the Apache feather logo, and the Apache Helix project logos are trademarks of The Apache Software Foundation. All other marks mentioned may be trademarks or registered trademarks of their respective owners.</div> <a href="https://helix.apache.org/0.9.9-docs/privacy-policy.html";>Privacy Policy</a>
