31
31
from grackle.server.cassandra import workaround_1779
34
def create_schema(host, keyspace, clobber=False, create_keyspace=False):
35
35
mgr = SystemManager(host)
38
41
for cf in mgr.get_keyspace_column_families(keyspace):
39
42
mgr.drop_column_family(keyspace, cf)