Class BootStrapper

    • Method Detail

      • bootstrap

        public com.google.common.util.concurrent.ListenableFuture<StreamState> bootstrap​(StreamStateStore stateStore,
                                                                                         boolean useStrictConsistency)
      • getBootstrapTokens

        public static java.util.Collection<Token> getBootstrapTokens​(TokenMetadata metadata,
                                                                     InetAddressAndPort address,
                                                                     long schemaWaitDelay)
                                                              throws ConfigurationException
        if initialtoken was specified, use that (split on comma). otherwise, if allocationKeyspace is specified use the token allocation algorithm to generate suitable tokens else choose num_tokens tokens at random
        Throws:
        ConfigurationException
      • getRandomTokens

        public static java.util.Collection<Token> getRandomTokens​(TokenMetadata metadata,
                                                                  int numTokens)