Examples of addTriggerDefinition()

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

66
67
68
69
70
71
72
73
74
75
76
    }

    public void announceMigration() throws ConfigurationException
    {
        CFMetaData cfm = Schema.instance.getCFMetaData(keyspace(), columnFamily()).copy();
        cfm.addTriggerDefinition(TriggerDefinition.create(triggerName, triggerClass));
        logger.info("Adding trigger with name {} and class {}", triggerName, triggerClass);
        MigrationManager.announceColumnFamilyUpdate(cfm, false);
    }

    public ResultMessage.SchemaChange.Change changeType()
View Full Code Here

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

66
67
68
69
70
71
72
73
74
75
76
    }

    public void announceMigration() throws ConfigurationException
    {
        CFMetaData cfm = Schema.instance.getCFMetaData(keyspace(), columnFamily()).clone();
        cfm.addTriggerDefinition(TriggerDefinition.create(triggerName, triggerClass));
        logger.info("Adding trigger with name {} and class {}", triggerName, triggerClass);
        MigrationManager.announceColumnFamilyUpdate(cfm, false);
    }

    public ResultMessage.SchemaChange.Change changeType()
View Full Code Here

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

51
52
53
54
55
56
57
58
59
60
61
    @Test
    public void newKsContainsCfWithTrigger() throws Exception
    {
        TriggerDefinition td = TriggerDefinition.create(triggerName, triggerClass);
        CFMetaData cfm1 = CFMetaData.compile(String.format("CREATE TABLE %s (k int PRIMARY KEY, v int)", cfName), ksName);
        cfm1.addTriggerDefinition(td);
        KSMetaData ksm = KSMetaData.newKeyspace(ksName,
                                                SimpleStrategy.class,
                                                Collections.singletonMap("replication_factor", "1"),
                                                true,
                                                Collections.singletonList(cfm1));
View Full Code Here

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

77
78
79
80
81
82
83
84
85
86
87
                                                Collections.EMPTY_LIST);
        MigrationManager.announceNewKeyspace(ksm);

        CFMetaData cfm1 = CFMetaData.compile(String.format("CREATE TABLE %s (k int PRIMARY KEY, v int)", cfName), ksName);
        TriggerDefinition td = TriggerDefinition.create(triggerName, triggerClass);
        cfm1.addTriggerDefinition(td);

        MigrationManager.announceNewColumnFamily(cfm1);

        CFMetaData cfm2 = Schema.instance.getCFMetaData(ksName, cfName);
        assertFalse(cfm2.getTriggers().isEmpty());
View Full Code Here

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

100
101
102
103
104
105
106
107
108
109
110
                                                Collections.singletonList(cfm1));
        MigrationManager.announceNewKeyspace(ksm);

        CFMetaData cfm2 = Schema.instance.getCFMetaData(ksName, cfName).copy();
        TriggerDefinition td = TriggerDefinition.create(triggerName, triggerClass);
        cfm2.addTriggerDefinition(td);
        MigrationManager.announceColumnFamilyUpdate(cfm2, false);

        CFMetaData cfm3 = Schema.instance.getCFMetaData(ksName, cfName);
        assertFalse(cfm3.getTriggers().isEmpty());
        assertEquals(1, cfm3.getTriggers().size());
View Full Code Here

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

114
115
116
117
118
119
120
121
122
123
124
    @Test
    public void removeTriggerFromCf() throws Exception
    {
        TriggerDefinition td = TriggerDefinition.create(triggerName, triggerClass);
        CFMetaData cfm1 = CFMetaData.compile(String.format("CREATE TABLE %s (k int PRIMARY KEY, v int)", cfName), ksName);
        cfm1.addTriggerDefinition(td);
        KSMetaData ksm = KSMetaData.newKeyspace(ksName,
                                                SimpleStrategy.class,
                                                Collections.singletonMap("replication_factor", "1"),
                                                true,
                                                Collections.singletonList(cfm1));
View Full Code Here

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

74
75
76
77
78
79
80
81
82
83
84
        TriggerDefinition triggerDefinition = TriggerDefinition.create(triggerName, triggerClass);

        if (!ifNotExists || !cfm.containsTriggerDefinition(triggerDefinition))
        {
            cfm.addTriggerDefinition(triggerDefinition);
            logger.info("Adding trigger with name {} and class {}", triggerName, triggerClass);
            MigrationManager.announceColumnFamilyUpdate(cfm, false, isLocalOnly);
            return true;
        }
        return false;
View Full Code Here

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

226
227
228
229
230
231
232
233
234
235
236
                                                                          UTF8Type.instance,
                                                                          0));
        try
        {
            if (trigger != null)
                metadata.addTriggerDefinition(trigger);
        }
        catch (InvalidRequestException e)
        {
            throw new AssertionError(e);
        }
View Full Code Here

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

66
67
68
69
70
71
72
73
74
75
76
    }

    public boolean announceMigration() throws ConfigurationException
    {
        CFMetaData cfm = Schema.instance.getCFMetaData(keyspace(), columnFamily()).clone();
        cfm.addTriggerDefinition(TriggerDefinition.create(triggerName, triggerClass));
        logger.info("Adding trigger with name {} and class {}", triggerName, triggerClass);
        MigrationManager.announceColumnFamilyUpdate(cfm, false);
        return true;
    }
View Full Code Here

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

43
44
45
46
47
48
49
50
51
52
53
    @Test
    public void newKsContainsCfWithTrigger() throws Exception
    {
        TriggerDefinition td = TriggerDefinition.create(triggerName, triggerClass);
        CFMetaData cfm1 = CFMetaData.compile(String.format("CREATE TABLE %s (k int PRIMARY KEY, v int)", cfName), ksName);
        cfm1.addTriggerDefinition(td);
        KSMetaData ksm = KSMetaData.newKeyspace(ksName,
                                                SimpleStrategy.class,
                                                Collections.singletonMap("replication_factor", "1"),
                                                true,
                                                Collections.singletonList(cfm1));
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.