Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- //Create cluster
- Cluster cluster = Cluster.builder().addContactPoint(hostNameOrIp)
- //Get session
- Session session = cluster.connect();
- //create keyspace using session
- session.execute(String.format("CREATE KEYSPACE IF NOT EXISTS %s WITH REPLICATION = {'class' : 'SimpleStrategy', 'replication_factor': %d}",
- QueryBuilder.quote("MY_KS"),
- 1)
- );
- String tableQuery = "CREATE TABLE timeline2 (
- key varchar,
- open float,
- high float,
- low float,
- close float,
- volume int,
- adjusted float,
- dtime timestamp,
- PRIMARY KEY (key, dtime)
- )";
- //create columnFamily using session
- ResultSet result = session.execute(tableQuery);
- Map<String, String> accessMap = new HashMap<String, String>();
- accessMap.put("username", username);
- accessMap.put("password", password);
- Cluster cluster = HFactory.getOrCreateCluster("TEST_CLUSTER", new CassandraHostConfigurator(cassandraUrl), accessMap);
- ColumnFamilyDefinition cfDef = HFactory.createColumnFamilyDefinition("MY_KS", ComparatorType.BYTESTYPE);
- KeyspaceDefinition newKeyspaceDef = HFactory.createKeyspaceDefinition("MY_KS", ThriftKsDef.DEF_STRATEGY_CLASS, 1, Arrays.asList(cfDef));
- //Add the schema to the cluster.
- //"true" as the second param means that Hector will block until all nodes see the change.
- cassandraCluster.addKeyspace(newKeyspaceDef, true);
- Keyspace ksp = HFactory.createKeyspace("MY_KS", cassandraCluster);
- //This will give a connection to the cluster
- Cluster cassandraCluster = connectApacheCassandra();
- ColumnFamilyDefinition cfDef = HFactory.createColumnFamilyDefinition("TEST_KS", "TEST_CF",
- ComparatorType.BYTESTYPE);
- KeyspaceDefinition newKeyspaceDef = HFactory.createKeyspaceDefinition("TEST_KS", ThriftKsDef.DEF_STRATEGY_CLASS, 1, Arrays.asList(cfDef));
- cassandraCluster.addKeyspace(newKeyspaceDef, true);
- Keyspace ksp = HFactory.createKeyspace("TEST_KS", cassandraCluster);
- BasicColumnFamilyDefinition columnFamilyDefinition = new BasicColumnFamilyDefinition(cfDef);
- cassandraCluster.addKeyspace(newKeyspaceDef, true);
- Keyspace ksp = HFactory.createKeyspace("TEST_KS", cassandraCluster);
- BasicColumnFamilyDefinition columnFamilyDefinition = new BasicColumnFamilyDefinition(cfDef);
- BasicColumnDefinition columnDefinition = new BasicColumnDefinition();
- columnDefinition.setName(StringSerializer.get().toByteBuffer("aKey"));
- columnDefinition.setIndexName("key_idx1");
- columnDefinition.setIndexType(ColumnIndexType.KEYS);
- columnDefinition.setValidationClass(ComparatorType.LONGTYPE.getClassName());
- columnFamilyDefinition.addColumnDefinition(columnDefinition);
- columnDefinition = new BasicColumnDefinition();
- columnDefinition.setName(StringSerializer.get().toByteBuffer("aTestColumn"));
- columnDefinition.setValidationClass(ComparatorType.LONGTYPE.getClassName());
- columnFamilyDefinition.addColumnDefinition(columnDefinition);
- cassandraCluster.updateColumnFamily(new ThriftCfDef(columnFamilyDefinition));
- CREATE TABLE "TEST_CF" (
- key blob,
- column1 blob,
- "614b6579" bigint,
- "6154657374436f6c756d6e" bigint,
- value blob,
- PRIMARY KEY (key, column1)
- ) WITH COMPACT STORAGE AND
- bloom_filter_fp_chance=0.010000 AND
- caching='KEYS_ONLY' AND
- comment='' AND
- dclocal_read_repair_chance=0.000000 AND
- gc_grace_seconds=864000 AND
- index_interval=128 AND
- read_repair_chance=1.000000 AND
- replicate_on_write='true' AND
- populate_io_cache_on_flush='false' AND
- default_time_to_live=0 AND
- speculative_retry='NONE' AND
- memtable_flush_period_in_ms=0 AND
- compaction={'class': 'SizeTieredCompactionStrategy'} AND
- compression={'sstable_compression': 'LZ4Compressor'};
- CREATE TABLE TEST_CF (
- aKey varchar,
- aColumn varchar
- PRIMARY KEY (aKey )
- )";
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement