Skip to content

Instantly share code, notes, and snippets.

@alexradzin

alexradzin/CQLTest

Last active August 29, 2015 14:11
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save alexradzin/9223fc16e95318e017ec to your computer and use it in GitHub Desktop.
Save alexradzin/9223fc16e95318e017ec to your computer and use it in GitHub Desktop.
Download ZIP
CQLTest that reproduces FSWriteError in Cassandra: https://issues.apache.org/jira/browse/CASSANDRA-8390
Raw
CQLTest
import com.datastax.driver.core.Cluster;
import com.datastax.driver.core.ResultSetFuture;
import com.datastax.driver.core.Session;
import com.google.common.util.concurrent.Futures;
import org.junit.Test;
import java.util.ArrayList;
import java.util.Collection;
public class CQLTest {
@Test //throws NoHostAvailableException at client side and FSWriteError at server side
public void cqlSync() {
Cluster cluster = Cluster.builder().addContactPoint("localhost").build();
Session session = cluster.connect();
String year = "2013";
for (int i = 1; i <= 12; i++) {
String yearMonth = year + i;
for (String template : cql.split("\\n")) {
String query = String.format(template, yearMonth);
System.out.println(query);
//session.executeAsync(query).getUninterruptibly();
session.execute(query);
}
}
}
@Test //works for me
public void cqlAsync() throws ExecutionException, InterruptedException {
Collection<ResultSetFuture> futures = new ArrayList<>();
Cluster cluster = Cluster.builder().addContactPoint("localhost").build();
Session session = cluster.connect();
String year = "2014";
for (int i = 1; i <= 1200; i++) {
String yearMonth = year + i;
for (String template : cql.split("\\n")) {
String query = String.format(template, yearMonth);
System.out.println(query);
ResultSetFuture future = session.executeAsync(query);
futures.add(future);
}
}
Futures.successfulAsList(futures).get();
}
private static final String cql =
"CREATE KEYSPACE measure_%s WITH DURABLE_WRITES = false AND REPLICATION = {'class': 'SimpleStrategy', 'replication_factor': 1};\n" +
"CREATE TABLE measure_%s.measurements (partition ascii, time timeuuid, data blob, PRIMARY KEY (partition, time)) WITH compaction = { 'class' : 'SizeTieredCompactionStrategy', 'min_threshold' : 40, 'max_threshold' : 45 } AND gc_grace_seconds = 0 AND memtable_flush_period_in_ms = 300000;\n" +
"CREATE TABLE measure_%s.index_page (partition ascii, value varchar, time timeuuid, bloom blob, PRIMARY KEY (partition, value, time)) WITH compaction = { 'class' : 'SizeTieredCompactionStrategy', 'min_threshold' : 40, 'max_threshold' : 45 } AND gc_grace_seconds = 0 AND memtable_flush_period_in_ms = 300000;\n" +
"CREATE TABLE measure_%s.index_urlpattern (partition ascii, value varchar, time timeuuid, bloom blob, PRIMARY KEY (partition, value, time)) WITH compaction = { 'class' : 'SizeTieredCompactionStrategy', 'min_threshold' : 40, 'max_threshold' : 45 } AND gc_grace_seconds = 0 AND memtable_flush_period_in_ms = 300000;\n" +
"CREATE TABLE measure_%s.index_country (partition ascii, value varchar, time timeuuid, bloom blob, PRIMARY KEY (partition, value, time)) WITH compaction = { 'class' : 'SizeTieredCompactionStrategy', 'min_threshold' : 40, 'max_threshold' : 45 } AND gc_grace_seconds = 0 AND memtable_flush_period_in_ms = 300000;\n" +
"CREATE TABLE measure_%s.index_region (partition ascii, value varchar, time timeuuid, bloom blob, PRIMARY KEY (partition, value, time)) WITH compaction = { 'class' : 'SizeTieredCompactionStrategy', 'min_threshold' : 40, 'max_threshold' : 45 } AND gc_grace_seconds = 0 AND memtable_flush_period_in_ms = 300000;\n" +
"CREATE TABLE measure_%s.index_city (partition ascii, value varchar, time timeuuid, bloom blob, PRIMARY KEY (partition, value, time)) WITH compaction = { 'class' : 'SizeTieredCompactionStrategy', 'min_threshold' : 40, 'max_threshold' : 45 } AND gc_grace_seconds = 0 AND memtable_flush_period_in_ms = 300000;\n" +
"CREATE TABLE measure_%s.index_isp (partition ascii, value varchar, time timeuuid, bloom blob, PRIMARY KEY (partition, value, time)) WITH compaction = { 'class' : 'SizeTieredCompactionStrategy', 'min_threshold' : 40, 'max_threshold' : 45 } AND gc_grace_seconds = 0 AND memtable_flush_period_in_ms = 300000;\n" +
"CREATE TABLE measure_%s.index_server (partition ascii, value varchar, time timeuuid, bloom blob, PRIMARY KEY (partition, value, time)) WITH compaction = { 'class' : 'SizeTieredCompactionStrategy', 'min_threshold' : 40, 'max_threshold' : 45 } AND gc_grace_seconds = 0 AND memtable_flush_period_in_ms = 300000;\n" +
"CREATE TABLE measure_%s.index_application (partition ascii, value int, time timeuuid, bloom blob, PRIMARY KEY (partition, value, time)) WITH compaction = { 'class' : 'SizeTieredCompactionStrategy', 'min_threshold' : 40, 'max_threshold' : 45 } AND gc_grace_seconds = 0 AND memtable_flush_period_in_ms = 300000;\n" +
"CREATE TABLE measure_%s.index_operatingsystem (partition ascii, value varchar, time timeuuid, bloom blob, PRIMARY KEY (partition, value, time)) WITH compaction = { 'class' : 'SizeTieredCompactionStrategy', 'min_threshold' : 40, 'max_threshold' : 45 } AND gc_grace_seconds = 0 AND memtable_flush_period_in_ms = 300000;\n" +
"CREATE TABLE measure_%s.index_browsergroup (partition ascii, value varchar, time timeuuid, bloom blob, PRIMARY KEY (partition, value, time)) WITH compaction = { 'class' : 'SizeTieredCompactionStrategy', 'min_threshold' : 40, 'max_threshold' : 45 } AND gc_grace_seconds = 0 AND memtable_flush_period_in_ms = 300000;\n" +
"CREATE TABLE measure_%s.index_browser (partition ascii, value varchar, time timeuuid, bloom blob, PRIMARY KEY (partition, value, time)) WITH compaction = { 'class' : 'SizeTieredCompactionStrategy', 'min_threshold' : 40, 'max_threshold' : 45 } AND gc_grace_seconds = 0 AND memtable_flush_period_in_ms = 300000;\n" +
"CREATE TABLE measure_%s.index_devicetype (partition ascii, value varchar, time timeuuid, bloom blob, PRIMARY KEY (partition, value, time)) WITH compaction = { 'class' : 'SizeTieredCompactionStrategy', 'min_threshold' : 40, 'max_threshold' : 45 } AND gc_grace_seconds = 0 AND memtable_flush_period_in_ms = 300000;\n" +
"CREATE TABLE measure_%s.applications (partition ascii, time timeuuid, data blob, PRIMARY KEY (partition, time)) WITH compaction = { 'class' : 'SizeTieredCompactionStrategy', 'min_threshold' : 40, 'max_threshold' : 45 } AND gc_grace_seconds = 0 AND memtable_flush_period_in_ms = 300000;\n" +
"CREATE TABLE measure_%s.view_page (partition ascii, time timeuuid, data blob, PRIMARY KEY (partition, time)) WITH compaction = { 'class' : 'SizeTieredCompactionStrategy', 'min_threshold' : 40, 'max_threshold' : 45 } AND gc_grace_seconds = 0 AND memtable_flush_period_in_ms = 300000;\n" +
"CREATE TABLE measure_%s.view_location (partition ascii, time timeuuid, data blob, PRIMARY KEY (partition, time)) WITH compaction = { 'class' : 'SizeTieredCompactionStrategy', 'min_threshold' : 40, 'max_threshold' : 45 } AND gc_grace_seconds = 0 AND memtable_flush_period_in_ms = 300000;\n" +
"CREATE TABLE measure_%s.view_isp (partition ascii, time timeuuid, data blob, PRIMARY KEY (partition, time)) WITH compaction = { 'class' : 'SizeTieredCompactionStrategy', 'min_threshold' : 40, 'max_threshold' : 45 } AND gc_grace_seconds = 0 AND memtable_flush_period_in_ms = 300000;\n" +
"CREATE TABLE measure_%s.view_server (partition ascii, time timeuuid, data blob, PRIMARY KEY (partition, time)) WITH compaction = { 'class' : 'SizeTieredCompactionStrategy', 'min_threshold' : 40, 'max_threshold' : 45 } AND gc_grace_seconds = 0 AND memtable_flush_period_in_ms = 300000;\n" +
"CREATE TABLE measure_%s.sessions (partition ascii, time timeuuid, data blob, PRIMARY KEY (partition, time)) WITH compaction = { 'class' : 'SizeTieredCompactionStrategy', 'min_threshold' : 40, 'max_threshold' : 45 } AND gc_grace_seconds = 0 AND memtable_flush_period_in_ms = 300000;\n" +
"CREATE TABLE measure_%s.index_session_attributes (partition ascii, attr ascii, value varchar, time timeuuid, PRIMARY KEY (partition, attr, value, time)) WITH compaction = { 'class' : 'SizeTieredCompactionStrategy', 'min_threshold' : 40, 'max_threshold' : 45 } AND gc_grace_seconds = 0 AND memtable_flush_period_in_ms = 300000;\n" +
"CREATE TABLE measure_%s.data_problematic_hits (partition ascii, time timeuuid, data blob, PRIMARY KEY (partition, time)) WITH compaction = { 'class' : 'SizeTieredCompactionStrategy', 'min_threshold' : 40, 'max_threshold' : 45 } AND gc_grace_seconds = 0 AND memtable_flush_period_in_ms = 300000;\n" +
"CREATE TABLE measure_%s.index_problematic_hits (partition ascii, attr ascii, value varchar, time timeuuid, bloom blob, PRIMARY KEY (partition, attr, value, time)) WITH compaction = { 'class' : 'SizeTieredCompactionStrategy', 'min_threshold' : 40, 'max_threshold' : 45 } AND gc_grace_seconds = 0 AND memtable_flush_period_in_ms = 300000;\n" +
"CREATE TABLE measure_%s.bcon_page_load_aggregation (partition ascii, time timeuuid, data blob, PRIMARY KEY (partition, time)) WITH compaction = { 'class' : 'SizeTieredCompactionStrategy', 'min_threshold' : 40, 'max_threshold' : 45 } AND gc_grace_seconds = 0 AND memtable_flush_period_in_ms = 300000;\n" +
"CREATE TABLE measure_%s.index_bcon_page_load_aggregation (partition ascii, attr ascii, value varchar, time timeuuid, bloom blob, PRIMARY KEY (partition, attr, value, time)) WITH compaction = { 'class' : 'SizeTieredCompactionStrategy', 'min_threshold' : 40, 'max_threshold' : 45 } AND gc_grace_seconds = 0 AND memtable_flush_period_in_ms = 300000;\n" +
"CREATE TABLE measure_%s.bcon_page_event_aggregation (partition ascii, time timeuuid, data blob, PRIMARY KEY (partition, time)) WITH compaction = { 'class' : 'SizeTieredCompactionStrategy', 'min_threshold' : 40, 'max_threshold' : 45 } AND gc_grace_seconds = 0 AND memtable_flush_period_in_ms = 300000;\n" +
"CREATE TABLE measure_%s.index_bcon_page_event_aggregation (partition ascii, attr ascii, value varchar, time timeuuid, bloom blob, PRIMARY KEY (partition, attr, value, time)) WITH compaction = { 'class' : 'SizeTieredCompactionStrategy', 'min_threshold' : 40, 'max_threshold' : 45 } AND gc_grace_seconds = 0 AND memtable_flush_period_in_ms = 300000;\n" +
"CREATE TABLE measure_%s.bf_aggregation (partition ascii, time timeuuid, data blob, PRIMARY KEY (partition, time)) WITH compaction = { 'class' : 'SizeTieredCompactionStrategy', 'min_threshold' : 40, 'max_threshold' : 45 } AND gc_grace_seconds = 0 AND memtable_flush_period_in_ms = 300000;\n" +
"CREATE TABLE measure_%s.index_bf_aggregation (partition ascii, attr ascii, value varchar, time timeuuid, bloom blob, PRIMARY KEY (partition, attr, value, time)) WITH compaction = { 'class' : 'SizeTieredCompactionStrategy', 'min_threshold' : 40, 'max_threshold' : 45 } AND gc_grace_seconds = 0 AND memtable_flush_period_in_ms = 300000;\n" +
"CREATE TABLE measure_%s.bf_steps_aggregation (partition ascii, time timeuuid, data blob, PRIMARY KEY (partition, time)) WITH compaction = { 'class' : 'SizeTieredCompactionStrategy', 'min_threshold' : 40, 'max_threshold' : 45 } AND gc_grace_seconds = 0 AND memtable_flush_period_in_ms = 300000;\n" +
"CREATE TABLE measure_%s.index_bf_steps_aggregation (partition ascii, attr ascii, value varchar, time timeuuid, bloom blob, PRIMARY KEY (partition, attr, value, time)) WITH compaction = { 'class' : 'SizeTieredCompactionStrategy', 'min_threshold' : 40, 'max_threshold' : 45 } AND gc_grace_seconds = 0 AND memtable_flush_period_in_ms = 300000;\n" +
"CREATE TABLE measure_%s.bf_completed (partition ascii, time timeuuid, data blob, PRIMARY KEY (partition, time)) WITH compaction = { 'class' : 'SizeTieredCompactionStrategy', 'min_threshold' : 40, 'max_threshold' : 45 } AND gc_grace_seconds = 0 AND memtable_flush_period_in_ms = 300000;\n" +
"CREATE TABLE measure_%s.index_bf_completed (partition ascii, attr ascii, value varchar, time timeuuid, bloom blob, PRIMARY KEY (partition, attr, value, time)) WITH compaction = { 'class' : 'SizeTieredCompactionStrategy', 'min_threshold' : 40, 'max_threshold' : 45 } AND gc_grace_seconds = 0 AND memtable_flush_period_in_ms = 300000;\n" +
"CREATE TABLE measure_%s.bf_aborted (partition ascii, time timeuuid, data blob, PRIMARY KEY (partition, time)) WITH compaction = { 'class' : 'SizeTieredCompactionStrategy', 'min_threshold' : 40, 'max_threshold' : 45 } AND gc_grace_seconds = 0 AND memtable_flush_period_in_ms = 300000;\n" +
"CREATE TABLE measure_%s.index_bf_aborted (partition ascii, attr ascii, value varchar, time timeuuid, bloom blob, PRIMARY KEY (partition, attr, value, time)) WITH compaction = { 'class' : 'SizeTieredCompactionStrategy', 'min_threshold' : 40, 'max_threshold' : 45 } AND gc_grace_seconds = 0 AND memtable_flush_period_in_ms = 300000;\n" +
"CREATE TABLE measure_%s.bcon_bf_aggregation (partition ascii, time timeuuid, data blob, PRIMARY KEY (partition, time)) WITH compaction = { 'class' : 'SizeTieredCompactionStrategy', 'min_threshold' : 40, 'max_threshold' : 45 } AND gc_grace_seconds = 0 AND memtable_flush_period_in_ms = 300000;\n" +
"CREATE TABLE measure_%s.index_bcon_bf_aggregation (partition ascii, attr ascii, value varchar, time timeuuid, bloom blob, PRIMARY KEY (partition, attr, value, time)) WITH compaction = { 'class' : 'SizeTieredCompactionStrategy', 'min_threshold' : 40, 'max_threshold' : 45 } AND gc_grace_seconds = 0 AND memtable_flush_period_in_ms = 300000;\n" +
"CREATE TABLE measure_%s.bcon_bf_steps_aggregation (partition ascii, time timeuuid, data blob, PRIMARY KEY (partition, time)) WITH compaction = { 'class' : 'SizeTieredCompactionStrategy', 'min_threshold' : 40, 'max_threshold' : 45 } AND gc_grace_seconds = 0 AND memtable_flush_period_in_ms = 300000;\n" +
"CREATE TABLE measure_%s.index_bcon_bf_steps_aggregation (partition ascii, attr ascii, value varchar, time timeuuid, bloom blob, PRIMARY KEY (partition, attr, value, time)) WITH compaction = { 'class' : 'SizeTieredCompactionStrategy', 'min_threshold' : 40, 'max_threshold' : 45 } AND gc_grace_seconds = 0 AND memtable_flush_period_in_ms = 300000;\n" +
"CREATE TABLE measure_%s.bcon_bf_completed (partition ascii, time timeuuid, data blob, PRIMARY KEY (partition, time)) WITH compaction = { 'class' : 'SizeTieredCompactionStrategy', 'min_threshold' : 40, 'max_threshold' : 45 } AND gc_grace_seconds = 0 AND memtable_flush_period_in_ms = 300000;\n" +
"CREATE TABLE measure_%s.index_bcon_bf_completed (partition ascii, attr ascii, value varchar, time timeuuid, bloom blob, PRIMARY KEY (partition, attr, value, time)) WITH compaction = { 'class' : 'SizeTieredCompactionStrategy', 'min_threshold' : 40, 'max_threshold' : 45 } AND gc_grace_seconds = 0 AND memtable_flush_period_in_ms = 300000;\n" +
"CREATE TABLE measure_%s.bcon_bf_aborted (partition ascii, time timeuuid, data blob, PRIMARY KEY (partition, time)) WITH compaction = { 'class' : 'SizeTieredCompactionStrategy', 'min_threshold' : 40, 'max_threshold' : 45 } AND gc_grace_seconds = 0 AND memtable_flush_period_in_ms = 300000;\n" +
"CREATE TABLE measure_%s.index_bcon_bf_aborted (partition ascii, attr ascii, value varchar, time timeuuid, bloom blob, PRIMARY KEY (partition, attr, value, time)) WITH compaction = { 'class' : 'SizeTieredCompactionStrategy', 'min_threshold' : 40, 'max_threshold' : 45 } AND gc_grace_seconds = 0 AND memtable_flush_period_in_ms = 300000;\n" +
"CREATE TABLE measure_%s.client_reports (partition ascii, time timeuuid, data blob, PRIMARY KEY (partition, time)) WITH compaction = { 'class' : 'SizeTieredCompactionStrategy', 'min_threshold' : 40, 'max_threshold' : 45 } AND gc_grace_seconds = 0 AND memtable_flush_period_in_ms = 300000;\n" +
"CREATE TABLE measure_%s.index_client_reports (partition ascii, attr ascii, value varchar, time timeuuid, bloom blob, PRIMARY KEY (partition, attr, value, time)) WITH compaction = { 'class' : 'SizeTieredCompactionStrategy', 'min_threshold' : 40, 'max_threshold' : 45 } AND gc_grace_seconds = 0 AND memtable_flush_period_in_ms = 300000;\n" +
"CREATE TABLE measure_%s.alerts (partition ascii, time timeuuid, data blob, PRIMARY KEY (partition, time)) WITH compaction = { 'class' : 'SizeTieredCompactionStrategy', 'min_threshold' : 40, 'max_threshold' : 45 } AND gc_grace_seconds = 0 AND memtable_flush_period_in_ms = 300000;\n" +
"CREATE TABLE measure_%s.top_pages_counters_daily (partition ascii, slot int, dimension_value blob, c0 counter, c3 counter, PRIMARY KEY (partition, slot, dimension_value)) WITH compaction = { 'class' : 'SizeTieredCompactionStrategy', 'min_threshold' : 40, 'max_threshold' : 45 } AND gc_grace_seconds = 0 AND memtable_flush_period_in_ms = 300000;\n" +
"CREATE TABLE measure_%s.top_pages_counters_hourly (partition ascii, slot int, dimension_value blob, c0 counter, c3 counter, PRIMARY KEY (partition, slot, dimension_value)) WITH compaction = { 'class' : 'SizeTieredCompactionStrategy', 'min_threshold' : 40, 'max_threshold' : 45 } AND gc_grace_seconds = 0 AND memtable_flush_period_in_ms = 300000;\n" +
"CREATE TABLE measure_%s.top_pages_counters_minutely (partition ascii, slot int, dimension_value blob, c0 counter, c3 counter, PRIMARY KEY (partition, slot, dimension_value)) WITH compaction = { 'class' : 'SizeTieredCompactionStrategy', 'min_threshold' : 40, 'max_threshold' : 45 } AND gc_grace_seconds = 0 AND memtable_flush_period_in_ms = 300000;\n" +
"CREATE TABLE measure_%s.top_browser_counters_daily (partition ascii, slot int, dimension_value blob, c0 counter, PRIMARY KEY (partition, slot, dimension_value)) WITH compaction = { 'class' : 'SizeTieredCompactionStrategy', 'min_threshold' : 40, 'max_threshold' : 45 } AND gc_grace_seconds = 0 AND memtable_flush_period_in_ms = 300000;\n" +
"CREATE TABLE measure_%s.top_browser_counters_hourly (partition ascii, slot int, dimension_value blob, c0 counter, PRIMARY KEY (partition, slot, dimension_value)) WITH compaction = { 'class' : 'SizeTieredCompactionStrategy', 'min_threshold' : 40, 'max_threshold' : 45 } AND gc_grace_seconds = 0 AND memtable_flush_period_in_ms = 300000;\n" +
"CREATE TABLE measure_%s.top_browser_counters_minutely (partition ascii, slot int, dimension_value blob, c0 counter, PRIMARY KEY (partition, slot, dimension_value)) WITH compaction = { 'class' : 'SizeTieredCompactionStrategy', 'min_threshold' : 40, 'max_threshold' : 45 } AND gc_grace_seconds = 0 AND memtable_flush_period_in_ms = 300000;\n" +
"CREATE TABLE measure_%s.top_referrer_counters_daily (partition ascii, slot int, dimension_value blob, c0 counter, PRIMARY KEY (partition, slot, dimension_value)) WITH compaction = { 'class' : 'SizeTieredCompactionStrategy', 'min_threshold' : 40, 'max_threshold' : 45 } AND gc_grace_seconds = 0 AND memtable_flush_period_in_ms = 300000;\n" +
"CREATE TABLE measure_%s.top_referrer_counters_hourly (partition ascii, slot int, dimension_value blob, c0 counter, PRIMARY KEY (partition, slot, dimension_value)) WITH compaction = { 'class' : 'SizeTieredCompactionStrategy', 'min_threshold' : 40, 'max_threshold' : 45 } AND gc_grace_seconds = 0 AND memtable_flush_period_in_ms = 300000;\n" +
"CREATE TABLE measure_%s.top_referrer_counters_minutely (partition ascii, slot int, dimension_value blob, c0 counter, PRIMARY KEY (partition, slot, dimension_value)) WITH compaction = { 'class' : 'SizeTieredCompactionStrategy', 'min_threshold' : 40, 'max_threshold' : 45 } AND gc_grace_seconds = 0 AND memtable_flush_period_in_ms = 300000;\n" +
"CREATE TABLE measure_%s.page_counter_materialized_view_daily (partition ascii, slot int, dimension_value blob, c0 counter, c1 counter, c2 counter, c3 counter, c4 counter, c5 counter, c6 counter, c7 counter, c8 counter, c9 counter, c10 counter, c11 counter, c12 counter, c13 counter, c14 counter, c15 counter, c16 counter, c17 counter, c20 counter, PRIMARY KEY (partition, slot, dimension_value)) WITH compaction = { 'class' : 'SizeTieredCompactionStrategy', 'min_threshold' : 40, 'max_threshold' : 45 } AND gc_grace_seconds = 0 AND memtable_flush_period_in_ms = 300000;\n" +
"CREATE TABLE measure_%s.page_counter_materialized_view_hourly (partition ascii, slot int, dimension_value blob, c0 counter, c1 counter, c2 counter, c3 counter, c4 counter, c5 counter, c6 counter, c7 counter, c8 counter, c9 counter, c10 counter, c11 counter, c12 counter, c13 counter, c14 counter, c15 counter, c16 counter, c17 counter, c20 counter, PRIMARY KEY (partition, slot, dimension_value)) WITH compaction = { 'class' : 'SizeTieredCompactionStrategy', 'min_threshold' : 40, 'max_threshold' : 45 } AND gc_grace_seconds = 0 AND memtable_flush_period_in_ms = 300000;\n" +
"CREATE TABLE measure_%s.page_counter_materialized_view_minutely (partition ascii, slot int, dimension_value blob, c0 counter, c1 counter, c2 counter, c3 counter, c4 counter, c5 counter, c6 counter, c7 counter, c8 counter, c9 counter, c10 counter, c11 counter, c12 counter, c13 counter, c14 counter, c15 counter, c16 counter, c17 counter, c20 counter, PRIMARY KEY (partition, slot, dimension_value)) WITH compaction = { 'class' : 'SizeTieredCompactionStrategy', 'min_threshold' : 40, 'max_threshold' : 45 } AND gc_grace_seconds = 0 AND memtable_flush_period_in_ms = 300000;\n" +
"CREATE TABLE measure_%s.page_counter_materialized_view_sets_daily (partition ascii, slot int, dimension_value blob, measurement int, set_element blob, v blob, PRIMARY KEY (partition, slot, dimension_value, measurement, set_element)) WITH compaction = { 'class' : 'SizeTieredCompactionStrategy', 'min_threshold' : 40, 'max_threshold' : 45 } AND gc_grace_seconds = 0 AND memtable_flush_period_in_ms = 300000;\n" +
"CREATE TABLE measure_%s.page_counter_materialized_view_sets_hourly (partition ascii, slot int, dimension_value blob, measurement int, set_element blob, v blob, PRIMARY KEY (partition, slot, dimension_value, measurement, set_element)) WITH compaction = { 'class' : 'SizeTieredCompactionStrategy', 'min_threshold' : 40, 'max_threshold' : 45 } AND gc_grace_seconds = 0 AND memtable_flush_period_in_ms = 300000;\n" +
"CREATE TABLE measure_%s.page_counter_materialized_view_sets_minutely (partition ascii, slot int, dimension_value blob, measurement int, set_element blob, v blob, PRIMARY KEY (partition, slot, dimension_value, measurement, set_element)) WITH compaction = { 'class' : 'SizeTieredCompactionStrategy', 'min_threshold' : 40, 'max_threshold' : 45 } AND gc_grace_seconds = 0 AND memtable_flush_period_in_ms = 300000;\n";
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment