1. 首頁
  2. 問答
  3. apache是​​否啓動在啓動時創建cassandra表或者我們需要運行任何命令？

apache是​​否啓動在啓動時創建cassandra表或者我們需要運行任何命令？

2017-03-16 74 views
1

我已將cassandra配置爲持久性存儲，cassandra keyspeaces和表是如何以及何時通過點燃創建的？apache是​​否啓動在啓動時創建cassandra表或者我們需要運行任何命令？

我開始點燃，但沒有創建鍵空間和表。我是否需要運行任何命令或什麼？或者它應該在啓動時創建密鑰空間和表？

我跟着從https://apacheignite-mix.readme.io/docs/examples

public class CassandraDataSource implements Factory<DataSource> { 

    @Override 
    public DataSource create() { 
     String[] contactPoints = {"localhost"}; 
     DataSource dataSource = new DataSource(); 
     dataSource.setContactPoints(contactPoints); 
     return dataSource; 
    } 
} 



public class RatioCacheConfig { 

    /** Cache name. */ 
    public static final String CACHE_NAME = "RatioCache"; 

    /** 
    * Creates cache configurations. 
    * @param <K> 
    * @param <V> 
    * 
    * @return {@link CacheConfiguration}. 
    */ 
    public static <K, V> CacheConfiguration <K, V> cache(CassandraCacheStoreFactory<K, V> storeFactory) { 

     CacheConfiguration cacheCfg = new CacheConfiguration(); 

     cacheCfg.setCacheStoreFactory(storeFactory); 
     cacheCfg.setReadThrough(true); 

     cacheCfg.setIndexedTypes(String.class, Ratio.class); 
     cacheCfg.setName(CACHE_NAME); 

     return cacheCfg; 
    } 

} 



String ratioPersistenceSettingConfig = "<persistence keyspace=\"ignite_view\" table=\"ratio\"><keyPersistence class=\"java.lang.String\" strategy=\"PRIMITIVE\"/><valuePersistence class=\"com.my.ignite.ratio.Ratio\" strategy=\"POJO\"/></persistence>"; 

KeyValuePersistenceSettings ratioPersistenceSetting = new KeyValuePersistenceSettings(ratioPersistenceSettingConfig); 

CassandraCacheStoreFactory<String, Ratio> ratioStoreFactory = new CassandraCacheStoreFactory<>(); 
ratioStoreFactory.setDataSource(new CassandraDataSource().create()); 
ratioStoreFactory.setPersistenceSettings(ratioPersistenceSetting); 

try (IgniteCache<String, Ratio> ratioCache = ignite.getOrCreateCache(RatioCacheConfig.cache(ratioStoreFactory))) { 

}

日誌的文件和例如：

>>> Starting timeseries cache loader... 
Mar 16, 2017 8:13:59 PM java.util.logging.LogManager$RootLogger log 
SEVERE: Failed to resolve default logging config file: config/java.util.logging.properties 
[20:13:59] __________ ________________ 
[20:13:59] /_/ ___/ |//_/_ __/ __/ 
[20:13:59] _/ // (7 7 ////// _/ 
[20:13:59] /___/\___/_/|_/___/ /_/ /___/ 
[20:13:59] 
[20:13:59] ver. 1.9.0#20170302-sha1:a8169d0a 
[20:13:59] 2017 Copyright(C) Apache Software Foundation 
[20:13:59] 
[20:13:59] Ignite documentation: http://ignite.apache.org 
[20:13:59] 
[20:13:59] Quiet mode. 
[20:13:59] ^-- To see **FULL** console log here add -DIGNITE_QUIET=false or "-v" to ignite.{sh|bat} 
[20:13:59] 
[20:13:59] OS: Linux 4.4.0-66-generic amd64 
[20:13:59] VM information: Java(TM) SE Runtime Environment 1.8.0_91-b14 Oracle Corporation Java HotSpot(TM) 64-Bit Server VM 25.91-b14 
[20:13:59] Initial heap size is 250MB (should be no less than 512MB, use -Xms512m -Xmx512m). 
[20:13:59] Configured plugins: 
[20:13:59] ^-- None 
[20:13:59] 
[20:13:59] Message queue limit is set to 0 which may lead to potential OOMEs when running cache operations in FULL_ASYNC or PRIMARY_SYNC modes due to message queues growth on sender and receiver sides. 
[20:13:59] Security status [authentication=off, tls/ssl=off] 
[20:14:01] Performance suggestions for grid (fix if possible) 
[20:14:01] To disable, set -DIGNITE_PERFORMANCE_SUGGESTIONS_DISABLED=true 
[20:14:01] ^-- Enable G1 Garbage Collector (add '-XX:+UseG1GC' to JVM options) 
[20:14:01] ^-- Specify JVM heap max size (add '-Xmx<size>[g|G|m|M|k|K]' to JVM options) 
[20:14:01] ^-- Set max direct memory size if getting 'OOME: Direct buffer memory' (add '-XX:MaxDirectMemorySize=<size>[g|G|m|M|k|K]' to JVM options) 
[20:14:01] ^-- Disable processing of calls to System.gc() (add '-XX:+DisableExplicitGC' to JVM options) 
[20:14:01] Refer to this page for more performance suggestions: https://apacheignite.readme.io/docs/jvm-and-system-tuning 
[20:14:01] 
[20:14:01] To start Console Management & Monitoring run ignitevisorcmd.{sh|bat} 
[20:14:01] 
[20:14:01] Ignite node started OK (id=baf95d6d) 
[20:14:01] Topology snapshot [ver=1, servers=1, clients=0, CPUs=4, heap=3.5GB] 
2017-03-16 20:14:01 DEBUG BooleanConverter:336 - Setting default value: false 
2017-03-16 20:14:01 DEBUG BooleanConverter:127 - Converting 'Boolean' value 'false' to type 'Boolean' 
2017-03-16 20:14:01 DEBUG BooleanConverter:149 -  No conversion required, value is already a Boolean 
2017-03-16 20:14:01 DEBUG ByteConverter:336 - Setting default value: 0 
2017-03-16 20:14:01 DEBUG ByteConverter:127 - Converting 'Integer' value '0' to type 'Byte' 
2017-03-16 20:14:01 DEBUG ByteConverter:158 -  Converted to Byte value '0' 
2017-03-16 20:14:01 DEBUG CharacterConverter:336 - Setting default value: 
2017-03-16 20:14:01 DEBUG CharacterConverter:127 - Converting 'Character' value ' ' to type 'Character' 
2017-03-16 20:14:01 DEBUG CharacterConverter:149 -  No conversion required, value is already a Character 
2017-03-16 20:14:01 DEBUG DoubleConverter:336 - Setting default value: 0 
2017-03-16 20:14:01 DEBUG DoubleConverter:127 - Converting 'Integer' value '0' to type 'Double' 
2017-03-16 20:14:01 DEBUG DoubleConverter:158 -  Converted to Double value '0.0' 
2017-03-16 20:14:01 DEBUG FloatConverter:336 - Setting default value: 0 
2017-03-16 20:14:01 DEBUG FloatConverter:127 - Converting 'Integer' value '0' to type 'Float' 
2017-03-16 20:14:01 DEBUG FloatConverter:158 -  Converted to Float value '0.0' 
2017-03-16 20:14:01 DEBUG IntegerConverter:336 - Setting default value: 0 
2017-03-16 20:14:01 DEBUG IntegerConverter:127 - Converting 'Integer' value '0' to type 'Integer' 
2017-03-16 20:14:01 DEBUG IntegerConverter:149 -  No conversion required, value is already a Integer 
2017-03-16 20:14:01 DEBUG LongConverter:336 - Setting default value: 0 
2017-03-16 20:14:01 DEBUG LongConverter:127 - Converting 'Integer' value '0' to type 'Long' 
2017-03-16 20:14:01 DEBUG LongConverter:158 -  Converted to Long value '0' 
2017-03-16 20:14:01 DEBUG ShortConverter:336 - Setting default value: 0 
2017-03-16 20:14:01 DEBUG ShortConverter:127 - Converting 'Integer' value '0' to type 'Short' 
2017-03-16 20:14:01 DEBUG ShortConverter:158 -  Converted to Short value '0' 
2017-03-16 20:14:01 DEBUG BigDecimalConverter:336 - Setting default value: 0.0 
2017-03-16 20:14:01 DEBUG BigDecimalConverter:127 - Converting 'BigDecimal' value '0.0' to type 'BigDecimal' 
2017-03-16 20:14:01 DEBUG BigDecimalConverter:149 -  No conversion required, value is already a BigDecimal 
2017-03-16 20:14:01 DEBUG BigIntegerConverter:336 - Setting default value: 0 
2017-03-16 20:14:01 DEBUG BigIntegerConverter:127 - Converting 'BigInteger' value '0' to type 'BigInteger' 
2017-03-16 20:14:01 DEBUG BigIntegerConverter:149 -  No conversion required, value is already a BigInteger 
2017-03-16 20:14:01 DEBUG BooleanConverter:336 - Setting default value: false 
2017-03-16 20:14:01 DEBUG BooleanConverter:127 - Converting 'Boolean' value 'false' to type 'Boolean' 
2017-03-16 20:14:01 DEBUG BooleanConverter:149 -  No conversion required, value is already a Boolean 
2017-03-16 20:14:01 DEBUG ByteConverter:336 - Setting default value: 0 
2017-03-16 20:14:01 DEBUG ByteConverter:127 - Converting 'Integer' value '0' to type 'Byte' 
2017-03-16 20:14:01 DEBUG ByteConverter:158 -  Converted to Byte value '0' 
2017-03-16 20:14:01 DEBUG CharacterConverter:336 - Setting default value: 
2017-03-16 20:14:01 DEBUG CharacterConverter:127 - Converting 'Character' value ' ' to type 'Character' 
2017-03-16 20:14:01 DEBUG CharacterConverter:149 -  No conversion required, value is already a Character 
2017-03-16 20:14:01 DEBUG DoubleConverter:336 - Setting default value: 0 
2017-03-16 20:14:01 DEBUG DoubleConverter:127 - Converting 'Integer' value '0' to type 'Double' 
2017-03-16 20:14:01 DEBUG DoubleConverter:158 -  Converted to Double value '0.0' 
2017-03-16 20:14:01 DEBUG FloatConverter:336 - Setting default value: 0 
2017-03-16 20:14:01 DEBUG FloatConverter:127 - Converting 'Integer' value '0' to type 'Float' 
2017-03-16 20:14:01 DEBUG FloatConverter:158 -  Converted to Float value '0.0' 
2017-03-16 20:14:01 DEBUG IntegerConverter:336 - Setting default value: 0 
2017-03-16 20:14:01 DEBUG IntegerConverter:127 - Converting 'Integer' value '0' to type 'Integer' 
2017-03-16 20:14:01 DEBUG IntegerConverter:149 -  No conversion required, value is already a Integer 
2017-03-16 20:14:01 DEBUG LongConverter:336 - Setting default value: 0 
2017-03-16 20:14:01 DEBUG LongConverter:127 - Converting 'Integer' value '0' to type 'Long' 
2017-03-16 20:14:01 DEBUG LongConverter:158 -  Converted to Long value '0' 
2017-03-16 20:14:01 DEBUG ShortConverter:336 - Setting default value: 0 
2017-03-16 20:14:01 DEBUG ShortConverter:127 - Converting 'Integer' value '0' to type 'Short' 
2017-03-16 20:14:01 DEBUG ShortConverter:158 -  Converted to Short value '0' 
2017-03-16 20:14:01 DEBUG StringConverter:336 - Setting default value: 
2017-03-16 20:14:01 DEBUG StringConverter:127 - Converting 'String' value '' to type 'String' 
2017-03-16 20:14:01 DEBUG ArrayConverter:336 - Setting default value: [[email protected] 
2017-03-16 20:14:01 DEBUG ArrayConverter:127 - Converting 'boolean[]' value '[[email protected]' to type 'boolean[]' 
2017-03-16 20:14:01 DEBUG ArrayConverter:149 -  No conversion required, value is already a boolean[] 
2017-03-16 20:14:01 DEBUG ArrayConverter:336 - Setting default value: [[email protected] 
2017-03-16 20:14:01 DEBUG ArrayConverter:127 - Converting 'byte[]' value '[[email protected]' to type 'byte[]' 
2017-03-16 20:14:01 DEBUG ArrayConverter:149 -  No conversion required, value is already a byte[] 
2017-03-16 20:14:01 DEBUG ArrayConverter:336 - Setting default value: [[email protected] 
2017-03-16 20:14:01 DEBUG ArrayConverter:127 - Converting 'char[]' value '[[email protected]' to type 'char[]' 
2017-03-16 20:14:01 DEBUG ArrayConverter:149 -  No conversion required, value is already a char[] 
2017-03-16 20:14:01 DEBUG ArrayConverter:336 - Setting default value: [[email protected] 
2017-03-16 20:14:01 DEBUG ArrayConverter:127 - Converting 'double[]' value '[[email protected]' to type 'double[]' 
2017-03-16 20:14:01 DEBUG ArrayConverter:149 -  No conversion required, value is already a double[] 
2017-03-16 20:14:01 DEBUG ArrayConverter:336 - Setting default value: [[email protected] 
2017-03-16 20:14:01 DEBUG ArrayConverter:127 - Converting 'float[]' value '[[email protected]' to type 'float[]' 
2017-03-16 20:14:01 DEBUG ArrayConverter:149 -  No conversion required, value is already a float[] 
2017-03-16 20:14:01 DEBUG ArrayConverter:336 - Setting default value: [[email protected] 
2017-03-16 20:14:01 DEBUG ArrayConverter:127 - Converting 'int[]' value '[[email protected]' to type 'int[]' 
2017-03-16 20:14:01 DEBUG ArrayConverter:149 -  No conversion required, value is already a int[] 
2017-03-16 20:14:01 DEBUG ArrayConverter:336 - Setting default value: [[email protected] 
2017-03-16 20:14:01 DEBUG ArrayConverter:127 - Converting 'long[]' value '[[email protected]' to type 'long[]' 
2017-03-16 20:14:01 DEBUG ArrayConverter:149 -  No conversion required, value is already a long[] 
2017-03-16 20:14:01 DEBUG ArrayConverter:336 - Setting default value: [[email protected] 
2017-03-16 20:14:01 DEBUG ArrayConverter:127 - Converting 'short[]' value '[[email protected]' to type 'short[]' 
2017-03-16 20:14:01 DEBUG ArrayConverter:149 -  No conversion required, value is already a short[] 
2017-03-16 20:14:01 DEBUG ArrayConverter:336 - Setting default value: [Ljava.math.BigDecimal;@3f23a3a0 
2017-03-16 20:14:01 DEBUG ArrayConverter:127 - Converting 'BigDecimal[]' value '[Ljava.math.BigDecimal;@3f23a3a0' to type 'BigDecimal[]' 
2017-03-16 20:14:01 DEBUG ArrayConverter:149 -  No conversion required, value is already a BigDecimal[] 
2017-03-16 20:14:01 DEBUG ArrayConverter:336 - Setting default value: [Ljava.math.BigInteger;@5ab14cb9 
2017-03-16 20:14:01 DEBUG ArrayConverter:127 - Converting 'BigInteger[]' value '[Ljava.math.BigInteger;@5ab14cb9' to type 'BigInteger[]' 
2017-03-16 20:14:01 DEBUG ArrayConverter:149 -  No conversion required, value is already a BigInteger[] 
2017-03-16 20:14:01 DEBUG ArrayConverter:336 - Setting default value: [Ljava.lang.Boolean;@439a8f59 
2017-03-16 20:14:01 DEBUG ArrayConverter:127 - Converting 'Boolean[]' value '[Ljava.lang.Boolean;@439a8f59' to type 'Boolean[]' 
2017-03-16 20:14:01 DEBUG ArrayConverter:149 -  No conversion required, value is already a Boolean[] 
2017-03-16 20:14:01 DEBUG ArrayConverter:336 - Setting default value: [Ljava.lang.Byte;@31024624 
2017-03-16 20:14:01 DEBUG ArrayConverter:127 - Converting 'Byte[]' value '[Ljava.lang.Byte;@31024624' to type 'Byte[]' 
2017-03-16 20:14:01 DEBUG ArrayConverter:149 -  No conversion required, value is already a Byte[] 
2017-03-16 20:14:01 DEBUG ArrayConverter:336 - Setting default value: [Ljava.lang.Character;@32cb636e 
2017-03-16 20:14:01 DEBUG ArrayConverter:127 - Converting 'Character[]' value '[Ljava.lang.Character;@32cb636e' to type 'Character[]' 
2017-03-16 20:14:01 DEBUG ArrayConverter:149 -  No conversion required, value is already a Character[] 
2017-03-16 20:14:01 DEBUG ArrayConverter:336 - Setting default value: [Ljava.lang.Double;@40dd3977 
2017-03-16 20:14:01 DEBUG ArrayConverter:127 - Converting 'Double[]' value '[Ljava.lang.Double;@40dd3977' to type 'Double[]' 
2017-03-16 20:14:01 DEBUG ArrayConverter:149 -  No conversion required, value is already a Double[] 
2017-03-16 20:14:01 DEBUG ArrayConverter:336 - Setting default value: [Ljava.lang.Float;@6a1d204a 
2017-03-16 20:14:01 DEBUG ArrayConverter:127 - Converting 'Float[]' value '[Ljava.lang.Float;@6a1d204a' to type 'Float[]' 
2017-03-16 20:14:01 DEBUG ArrayConverter:149 -  No conversion required, value is already a Float[] 
2017-03-16 20:14:01 DEBUG ArrayConverter:336 - Setting default value: [Ljava.lang.Integer;@4b6579e8 
2017-03-16 20:14:01 DEBUG ArrayConverter:127 - Converting 'Integer[]' value '[Ljava.lang.Integer;@4b6579e8' to type 'Integer[]' 
2017-03-16 20:14:01 DEBUG ArrayConverter:149 -  No conversion required, value is already a Integer[] 
2017-03-16 20:14:01 DEBUG ArrayConverter:336 - Setting default value: [Ljava.lang.Long;@6c6357f9 
2017-03-16 20:14:01 DEBUG ArrayConverter:127 - Converting 'Long[]' value '[Ljava.lang.Long;@6c6357f9' to type 'Long[]' 
2017-03-16 20:14:01 DEBUG ArrayConverter:149 -  No conversion required, value is already a Long[] 
2017-03-16 20:14:01 DEBUG ArrayConverter:336 - Setting default value: [Ljava.lang.Short;@3954d008 
2017-03-16 20:14:01 DEBUG ArrayConverter:127 - Converting 'Short[]' value '[Ljava.lang.Short;@3954d008' to type 'Short[]' 
2017-03-16 20:14:01 DEBUG ArrayConverter:149 -  No conversion required, value is already a Short[] 
2017-03-16 20:14:01 DEBUG ArrayConverter:336 - Setting default value: [Ljava.lang.String;@593e824f 
2017-03-16 20:14:01 DEBUG ArrayConverter:127 - Converting 'String[]' value '[Ljava.lang.String;@593e824f' to type 'String[]' 
2017-03-16 20:14:01 DEBUG ArrayConverter:149 -  No conversion required, value is already a String[] 
2017-03-16 20:14:01 DEBUG ArrayConverter:336 - Setting default value: [Ljava.lang.Class;@72ccd81a 
2017-03-16 20:14:01 DEBUG ArrayConverter:127 - Converting 'Class[]' value '[Ljava.lang.Class;@72ccd81a' to type 'Class[]' 
2017-03-16 20:14:01 DEBUG ArrayConverter:149 -  No conversion required, value is already a Class[] 
2017-03-16 20:14:01 DEBUG ArrayConverter:336 - Setting default value: [Ljava.util.Date;@6d8792db 
2017-03-16 20:14:01 DEBUG ArrayConverter:127 - Converting 'Date[]' value '[Ljava.util.Date;@6d8792db' to type 'Date[]' 
2017-03-16 20:14:01 DEBUG ArrayConverter:149 -  No conversion required, value is already a Date[] 
2017-03-16 20:14:01 DEBUG ArrayConverter:336 - Setting default value: [Ljava.util.Calendar;@64bc21ac 
2017-03-16 20:14:01 DEBUG ArrayConverter:127 - Converting 'Calendar[]' value '[Ljava.util.Calendar;@64bc21ac' to type 'Calendar[]' 
2017-03-16 20:14:01 DEBUG ArrayConverter:149 -  No conversion required, value is already a Calendar[] 
2017-03-16 20:14:01 DEBUG ArrayConverter:336 - Setting default value: [Ljava.io.File;@5d25e6bb 
2017-03-16 20:14:01 DEBUG ArrayConverter:127 - Converting 'java.io.File[]' value '[Ljava.io.File;@5d25e6bb' to type 'java.io.File[]' 
2017-03-16 20:14:01 DEBUG ArrayConverter:149 -  No conversion required, value is already a java.io.File[] 
2017-03-16 20:14:01 DEBUG ArrayConverter:336 - Setting default value: [Ljava.sql.Date;@9d157ff 
2017-03-16 20:14:01 DEBUG ArrayConverter:127 - Converting 'java.sql.Date[]' value '[Ljava.sql.Date;@9d157ff' to type 'java.sql.Date[]' 
2017-03-16 20:14:01 DEBUG ArrayConverter:149 -  No conversion required, value is already a java.sql.Date[] 
2017-03-16 20:14:01 DEBUG ArrayConverter:336 - Setting default value: [Ljava.sql.Time;@5df417a7 
2017-03-16 20:14:01 DEBUG ArrayConverter:127 - Converting 'java.sql.Time[]' value '[Ljava.sql.Time;@5df417a7' to type 'java.sql.Time[]' 
2017-03-16 20:14:01 DEBUG ArrayConverter:149 -  No conversion required, value is already a java.sql.Time[] 
2017-03-16 20:14:01 DEBUG ArrayConverter:336 - Setting default value: [Ljava.sql.Timestamp;@7f69d591 
2017-03-16 20:14:01 DEBUG ArrayConverter:127 - Converting 'java.sql.Timestamp[]' value '[Ljava.sql.Timestamp;@7f69d591' to type 'java.sql.Timestamp[]' 
2017-03-16 20:14:01 DEBUG ArrayConverter:149 -  No conversion required, value is already a java.sql.Timestamp[] 
2017-03-16 20:14:01 DEBUG ArrayConverter:336 - Setting default value: [Ljava.net.URL;@61078690 
2017-03-16 20:14:01 DEBUG ArrayConverter:127 - Converting 'java.net.URL[]' value '[Ljava.net.URL;@61078690' to type 'java.net.URL[]' 
2017-03-16 20:14:01 DEBUG ArrayConverter:149 -  No conversion required, value is already a java.net.URL[]

來源

2017-03-16 vishal

回答

0

Keyspaces和表按需創建。基本上，當與商店進行第一次交互時，會發出'找不到表'異常，Ignite捕獲它並創建所有必需的表。因此，當你剛啓動一個節點時，它們還沒有被創建。

另外，您應確保Ignite連接的用戶具有足夠的權限來創建表。如果這是不可能的，你也可以使用DDL生成器根據你的持久性配置手動創建模式：https://apacheignite-mix.readme.io/docs/ddl-generator

來源

2017-03-27 23:22:33

+0

我沒有寫信給cassandra從點燃，我已經配置只讀通過。我將使用一些外部命令從csv將數據加載到cassandra中。我試圖在啓動時加載cassandra的緩存。 – vishal

+0

此外，對於ddl生成器，我將項目嵌入點燃，我沒有將它作爲獨立服務器使用。所以cassandra模塊被嵌入爲依賴。不知道如何在這種情況下運行ddl生成器命令。 – vishal

+0

我很困惑。如果你是從Cassandra加載的，那麼你必須已經把所有的表都填充了這個數據，對吧？你能澄清這一點嗎？如果你從CSV加載到Cassandra，那麼Ignite就會涉及到，所以你將不得不手動創建表格。 –

相關問題

 相關問題