Package com.netflix.paas.cassandra.keys

Examples of com.netflix.paas.cassandra.keys.ColumnFamilyKey

156
157
158
159
160
161
162
    }

    @Override
    public ColumnFamilyEntity getColumnFamily(String keyspaceName, String columnFamilyName) throws NotFoundException {
        Dao<ColumnFamilyEntity> dao = daoProvider.getDao(DaoKeys.DAO_COLUMN_FAMILY_ENTITY);
        return dao.read(new ColumnFamilyKey(clusterKey, keyspaceName, columnFamilyName).getCanonicalName());
    }
View Full Code Here
169
170
171
172
173
174
175
            cluster.dropColumnFamily(keyspaceName, columnFamilyName);
        } catch (ConnectionException e) {
            throw new PaasException(String.format("Error creating column family '%s.%s' on cluster '%s'",
                    keyspaceName, columnFamilyName, clusterKey.getClusterName()), e);
        }
        eventBus.post(new ColumnFamilyDeleteEvent(new ColumnFamilyKey(clusterKey, keyspaceName, columnFamilyName)));
    }
View Full Code Here
189
190
191
192
193
194
195
196
197
198
199
        props.setProperty("name",     columnFamily.getName());
        props.setProperty("keyspace", columnFamily.getKeyspaceName());

        try {
            cluster.createColumnFamily(props);
            eventBus.post(new ColumnFamilyUpdateEvent(new ColumnFamilyKey(new KeyspaceKey(clusterKey, keyspaceName), columnFamily.getName())));
        } catch (ConnectionException e) {
            throw new PaasException(String.format("Error creating column family '%s.%s' on cluster '%s'",
                    keyspaceName, columnFamily.getName(), clusterKey.getClusterName()), e);
        }
    }
View Full Code Here
213
214
215
216
217
218
219
220
221
222
223
            }
            props.setProperty("name",     columnFamily.getName());
            props.setProperty("keyspace", columnFamily.getKeyspaceName());

            cluster.createColumnFamily(props);
            eventBus.post(new ColumnFamilyUpdateEvent(new ColumnFamilyKey(new KeyspaceKey(clusterKey, keyspaceName), columnFamily.getName())));
        } catch (ConnectionException e) {
            throw new PaasException(String.format("Error creating column family '%s.%s' on cluster '%s'",
                    keyspaceName, columnFamily.getName(), clusterKey.getClusterName()), e);
        }
    }
View Full Code Here
TOP

Related Classes of com.netflix.paas.cassandra.keys.ColumnFamilyKey

  • com.netflix.paas.cassandra.resources.admin.AstyanaxThriftClusterAdminResource
    • Copyright © 2018 www.massapicom. 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.