def _init_new_loading_node(self, ks_name, create_stmt, use_thrift=False):
    loading_node = Node(name='node2', cluster=self.cluster, auto_bootstrap=False, thrift_interface=(('127.0.0.2', 9160) if use_thrift else None), storage_interface=('127.0.0.2', 7000), jmx_port='7400', remote_debug_port='0', initial_token=None, binary_interface=('127.0.0.2', 9042))
    logger.debug('adding node')
    self.cluster.add(loading_node, is_seed=True, data_center='dc1')
    logger.debug('starting new node')
    loading_node.start(wait_for_binary_proto=120)
    logger.debug('recreating ks and table')
    loading_session = self.patient_exclusive_cql_connection(loading_node)
    create_ks(loading_session, ks_name, rf=1)
    logger.debug('creating new table')
    loading_session.execute(create_stmt)
    logger.debug('stopping new node')
    loading_session.cluster.shutdown()
    loading_node.stop()
    return loading_node
def _init_new_loading_node(self, ks_name, create_stmt, use_thrift=False):
    loading_node = Node(name='node2', cluster=self.cluster, auto_bootstrap=False, thrift_interface=(('127.0.0.2', 9160) if use_thrift else None), storage_interface=('127.0.0.2', 7000), jmx_port='7400', remote_debug_port='0', initial_token=None, binary_interface=('127.0.0.2', 9042))
    logger.debug('adding node')
    self.cluster.add(loading_node, is_seed=True, data_center='dc1')
    logger.debug('starting new node')
    loading_node.start(wait_for_binary_proto=120)
    logger.debug('recreating ks and table')
    loading_session = self.patient_exclusive_cql_connection(loading_node)
    create_ks(loading_session, ks_name, rf=1)
    logger.debug('creating new table')
    loading_session.execute(create_stmt)
    logger.debug('stopping new node')
    loading_session.cluster.shutdown()
    loading_node.stop()
    return loading_node