Package org.apache.cassandra.config

Examples of org.apache.cassandra.config.CFMetaData.toThrift()

55
56
57
58
59
60
61
62
63
64
65
        {
            CFMetaData oldCfm = ThriftValidation.validateColumnFamily(keyspace(), columnFamily());
            boolean columnExists = false;
            // mutating oldCfm directly would be bad, but mutating a Thrift copy is fine.  This also
            // sets us up to use validateCfDef to check for index name collisions.
            CfDef cf_def = oldCfm.toThrift();
            for (ColumnDef cd : cf_def.column_metadata)
            {
                if (cd.name.equals(columnName.key))
                {
                    if (cd.index_type != null)
View Full Code Here
79
80
81
82
83
84
85
86
87
88
89
    }

    public Migration getMigration() throws InvalidRequestException, ConfigurationException, IOException
    {
        CFMetaData cfmd = getCFMetaData();
        ThriftValidation.validateCfDef(cfmd.toThrift(), null);
        return new AddColumnFamily(cfmd);
    }

    /**
     * Returns a CFMetaData instance based on the parameters parsed from this
View Full Code Here
48
49
50
51
52
53
54
55
56
57
58
    @Test
    public void testColumnNameEqualToKeyAlias()
    {
        CFMetaData metaData = Schema.instance.getCFMetaData("Keyspace1", "Standard1");
        CfDef newMetadata = metaData.toThrift();

        boolean gotException = false;

        // add a key_alias = "id"
        newMetadata.setKey_alias(AsciiType.instance.decompose("id"));
View Full Code Here
100
101
102
103
104
105
106
107
108
109
110
    @Test
    public void testColumnNameEqualToKeyAlias()
    {
        CFMetaData metaData = Schema.instance.getCFMetaData("Keyspace1", "Standard1");
        CfDef newMetadata = metaData.toThrift();

        boolean gotException = false;

        // add a key_alias = "id"
        newMetadata.setKey_alias(AsciiType.instance.decompose("id"));
View Full Code Here
78
79
80
81
82
83
84
85
86
87
88
    }

    public void announceMigration() throws InvalidRequestException, ConfigurationException
    {
        CFMetaData cfmd = getCFMetaData();
        ThriftValidation.validateCfDef(cfmd.toThrift(), null);
        MigrationManager.announceNewColumnFamily(cfmd);
    }

    /**
     * Returns a CFMetaData instance based on the parameters parsed from this
View Full Code Here
50
51
52
53
54
55
56
57
58
59
60
    {
        CFMetaData oldCfm = ThriftValidation.validateColumnFamily(keyspace(), columnFamily());
        boolean columnExists = false;
        // mutating oldCfm directly would be bad, but mutating a Thrift copy is fine.  This also
        // sets us up to use validateCfDef to check for index name collisions.
        CfDef cf_def = oldCfm.toThrift();
        for (ColumnDef cd : cf_def.column_metadata)
        {
            if (cd.name.equals(columnName.key))
            {
                if (cd.index_type != null)
View Full Code Here
100
101
102
103
104
105
106
107
108
109
110
    @Test
    public void testColumnNameEqualToKeyAlias()
    {
        CFMetaData metaData = Schema.instance.getCFMetaData("Keyspace1", "Standard1");
        CfDef newMetadata = metaData.toThrift();

        boolean gotException = false;

        // add a key_alias = "id"
        newMetadata.setKey_alias(AsciiType.instance.decompose("id"));
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.