Examples of makeColumnFamilyDefinition()

Examples of com.netflix.astyanax.Cluster.makeColumnFamilyDefinition()

95
96
97
98
99
100
101
102
103
104
105
            }
        }
       
        LOG.warn("Adding column family: '{}'", cf);
        try {
        cluster.addColumnFamily(cluster.makeColumnFamilyDefinition().setKeyspace(ks).setName(cf).setComparatorType(comparator)
                .setKeyValidationClass(keyValidator).setDefaultValidationClass(defValidator));
        } catch (BadRequestException bre){
          LOG.warn("Could not create column family [" + bre.getMessage() + "]");
        }
    }
View Full Code Here

Examples of com.netflix.astyanax.Cluster.makeColumnFamilyDefinition()

116
117
118
119
120
121
122
123
124
125
126
        stratOptions.put("replication_factor", "1");
        ksDef.setName(ks)
                .setStrategyClass("SimpleStrategy")
                .setStrategyOptions(stratOptions)
                .addColumnFamily(
                        cluster.makeColumnFamilyDefinition().setName(cf).setComparatorType("UTF8Type")
                                .setKeyValidationClass("UTF8Type").setDefaultValidationClass("CounterColumnType"));

        cluster.addKeyspace(ksDef);
    }
View Full Code Here

Examples of com.netflix.astyanax.Cluster.makeColumnFamilyDefinition()

81
82
83
84
85
86
87
88
89
90
91
                ksDef.setName(TEST_KEYSPACE_NAME)
                        .setStrategyOptions(stratOptions)
                        .setStrategyClass("SimpleStrategy")
                        .addColumnFamily(
                                cluster.makeColumnFamilyDefinition()
                                        .setName(CF_DATA.getName())
                                        .setComparatorType("UTF8Type"));
                cluster.addKeyspace(ksDef);
                Thread.sleep(1000);
            } catch (ConnectionException e) {
View Full Code Here

Examples of com.netflix.astyanax.Cluster.makeColumnFamilyDefinition()

111
112
113
114
115
116
117
118
119
120
121
                ksDef.setName(TEST_KEYSPACE_NAME)
                        .setStrategyOptions(stratOptions)
                        .setStrategyClass("SimpleStrategy")
                        .addColumnFamily(
                                cluster.makeColumnFamilyDefinition()
                                        .setName(CF_DATA.getName())
                                        .setComparatorType("UTF8Type")
                        // .setKeyValidationClass("LongType")
                        // .setDefaultValidationClass("BytesType")
                        )
View Full Code Here

Examples of com.netflix.astyanax.Cluster.makeColumnFamilyDefinition()

118
119
120
121
122
123
124
125
126
127
128
                                        .setComparatorType("UTF8Type")
                        // .setKeyValidationClass("LongType")
                        // .setDefaultValidationClass("BytesType")
                        )
                        .addColumnFamily(
                                cluster.makeColumnFamilyDefinition()
                                        .setName(CF_INDEX.getName())
                                        .setComparatorType(
                                                "CompositeType(LongType, LongType)")
                                        .setDefaultValidationClass("BytesType"));
                cluster.addKeyspace(ksDef);
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.