public static void createGobblinHelixCluster ( String zkConnectionString , String clusterName , boolean overwrite ) { ClusterSetup clusterSetup = new ClusterSetup ( zkConnectionString ) ; // Create the cluster and overwrite if it already exists clusterSetup . addCluster ( clusterName , overwrite ) ; // Helix 0.6.x requires a configuration property to have the form key=value. String autoJoinConfig = ZKHelixManager . ALLOW_PARTICIPANT_AUTO_JOIN + "=true" ; clusterSetup . setConfig ( HelixConfigScope . ConfigScopeProperty . CLUSTER , clusterName , autoJoinConfig ) ; }
Create a Helix cluster for the Gobblin Cluster application .