• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    公众号

Java IndexType类代码示例

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

本文整理汇总了Java中org.apache.cassandra.thrift.IndexType的典型用法代码示例。如果您正苦于以下问题:Java IndexType类的具体用法?Java IndexType怎么用?Java IndexType使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。



IndexType类属于org.apache.cassandra.thrift包,在下文中一共展示了IndexType类的17个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: testSerializeDeserialize

import org.apache.cassandra.thrift.IndexType; //导入依赖的package包/类
@Test
public void testSerializeDeserialize() throws Exception
{
    ColumnDefinition cd0 = new ColumnDefinition(ByteBufferUtil.bytes("TestColumnDefinitionName0"),
                                                BytesType.instance,
                                                IndexType.KEYS,
                                                null,
                                                "random index name 0",
                                                null);

    ColumnDefinition cd1 = new ColumnDefinition(ByteBufferUtil.bytes("TestColumnDefinition1"),
                                                LongType.instance,
                                                null,
                                                null,
                                                null,
                                                null);

    testSerializeDeserialize(cd0);
    testSerializeDeserialize(cd1);
}
 
开发者ID:dprguiuc,项目名称:Cassandra-Wasef,代码行数:21,代码来源:ColumnDefinitionTest.java


示例2: perRowIndexedCFMD

import org.apache.cassandra.thrift.IndexType; //导入依赖的package包/类
private static CFMetaData perRowIndexedCFMD(String ksName, String cfName, boolean withOldCfIds)
{
    final Map<String, String> indexOptions = Collections.singletonMap(
                                                  SecondaryIndex.CUSTOM_INDEX_OPTION_NAME,
                                                  PerRowSecondaryIndexTest.TestIndex.class.getName());
    return standardCFMD(ksName, cfName, withOldCfIds)
            .keyValidator(AsciiType.instance)
            .columnMetadata(new HashMap<ByteBuffer, ColumnDefinition>()
            {{
                    ByteBuffer cName = ByteBuffer.wrap("indexed".getBytes(Charsets.UTF_8));
                    put(cName, new ColumnDefinition(cName,
                            AsciiType.instance,
                            IndexType.CUSTOM,
                            indexOptions,
                            ByteBufferUtil.bytesToHex(cName),
                            null));
            }});
}
 
开发者ID:dprguiuc,项目名称:Cassandra-Wasef,代码行数:19,代码来源:SchemaLoader.java


示例3: compositeIndexCFMD

import org.apache.cassandra.thrift.IndexType; //导入依赖的package包/类
private static CFMetaData compositeIndexCFMD(String ksName, String cfName, final Boolean withIdxType, boolean withOldCfIds) throws ConfigurationException
{
    final Map<String, String> idxOpts = Collections.singletonMap(CompositesIndex.PREFIX_SIZE_OPTION, "1");
    final CompositeType composite = CompositeType.getInstance(Arrays.asList(new AbstractType<?>[]{UTF8Type.instance, UTF8Type.instance})); 
    return new CFMetaData(ksName,
            cfName,
            ColumnFamilyType.Standard,
            composite,
            null)
           .columnMetadata(new HashMap<ByteBuffer, ColumnDefinition>()
            {{
               ByteBuffer cName = ByteBuffer.wrap("col1".getBytes(Charsets.UTF_8));
               IndexType idxType = withIdxType ? IndexType.COMPOSITES : null;
               put(cName, new ColumnDefinition(cName, UTF8Type.instance, idxType, idxOpts, withIdxType ? "col1_idx" : null, 1));
            }});
}
 
开发者ID:dprguiuc,项目名称:Cassandra-Wasef,代码行数:17,代码来源:SchemaLoader.java


示例4: testSerializeDeserialize

import org.apache.cassandra.thrift.IndexType; //导入依赖的package包/类
@Test
public void testSerializeDeserialize() throws Exception
{
    ColumnDefinition cd0 = new ColumnDefinition(ByteBufferUtil.bytes("TestColumnDefinitionName0"),
                                                BytesType.instance,
                                                IndexType.KEYS,
                                                "random index name 0");

    ColumnDefinition cd1 = new ColumnDefinition(ByteBufferUtil.bytes("TestColumnDefinition1"),
                                                LongType.instance,
                                                null,
                                                null);

    testSerializeDeserialize(cd0);
    testSerializeDeserialize(cd1);
}
 
开发者ID:devdattakulkarni,项目名称:Cassandra-KVPM,代码行数:17,代码来源:ColumnDefinitionTest.java


示例5: getIndexMetadata

import org.apache.cassandra.thrift.IndexType; //导入依赖的package包/类
public static List<ColumnDefinition> getIndexMetadata( String indexes ) {
    if ( indexes == null ) {
        return null;
    }
    String[] index_entries = split( indexes, ',' );
    List<ColumnDef> columns = new ArrayList<ColumnDef>();
    for ( String index_entry : index_entries ) {
        String column_name = stringOrSubstringBeforeFirst( index_entry, ':' ).trim();
        String comparer = substringAfterLast( index_entry, ":" ).trim();
        if ( StringUtils.isBlank( comparer ) ) {
            comparer = "UUIDType";
        }
        if ( StringUtils.isNotBlank( column_name ) ) {
            ColumnDef cd = new ColumnDef( bytebuffer( column_name ), comparer );
            cd.setIndex_name( column_name );
            cd.setIndex_type( IndexType.KEYS );
            columns.add( cd );
        }
    }
    return ThriftColumnDef.fromThriftList( columns );
}
 
开发者ID:apache,项目名称:usergrid,代码行数:22,代码来源:CassandraPersistenceUtils.java


示例6: testThriftConversion

import org.apache.cassandra.thrift.IndexType; //导入依赖的package包/类
@Test
public void testThriftConversion() throws Exception
{
    CfDef cfDef = new CfDef().setDefault_validation_class(AsciiType.class.getCanonicalName())
                             .setComment("Test comment")
                             .setColumn_metadata(columnDefs)
                             .setKeyspace(KEYSPACE)
                             .setName(COLUMN_FAMILY);

    // convert Thrift to CFMetaData
    CFMetaData cfMetaData = CFMetaData.fromThrift(cfDef);

    CfDef thriftCfDef = new CfDef();
    thriftCfDef.keyspace = KEYSPACE;
    thriftCfDef.name = COLUMN_FAMILY;
    thriftCfDef.default_validation_class = cfDef.default_validation_class;
    thriftCfDef.comment = cfDef.comment;
    thriftCfDef.column_metadata = new ArrayList<ColumnDef>();
    for (ColumnDef columnDef : columnDefs)
    {
        ColumnDef c = new ColumnDef();
        c.name = ByteBufferUtil.clone(columnDef.name);
        c.validation_class = columnDef.getValidation_class();
        c.index_name = columnDef.getIndex_name();
        c.index_type = IndexType.KEYS;
        thriftCfDef.column_metadata.add(c);
    }

    CfDef converted = cfMetaData.toThrift();

    assertEquals(thriftCfDef.keyspace, converted.keyspace);
    assertEquals(thriftCfDef.name, converted.name);
    assertEquals(thriftCfDef.default_validation_class, converted.default_validation_class);
    assertEquals(thriftCfDef.comment, converted.comment);
    assertEquals(new HashSet<>(thriftCfDef.column_metadata), new HashSet<>(converted.column_metadata));
}
 
开发者ID:vcostet,项目名称:cassandra-kmean,代码行数:37,代码来源:CFMetaDataTest.java


示例7: testThriftConversion

import org.apache.cassandra.thrift.IndexType; //导入依赖的package包/类
@Test
public void testThriftConversion() throws Exception
{
    CfDef cfDef = new CfDef().setDefault_validation_class(AsciiType.class.getCanonicalName())
                             .setComment("Test comment")
                             .setColumn_metadata(columnDefs)
                             .setKeyspace(KEYSPACE)
                             .setName(COLUMN_FAMILY);

    // convert Thrift to CFMetaData
    CFMetaData cfMetaData = CFMetaData.fromThrift(cfDef);

    CfDef thriftCfDef = new CfDef();
    thriftCfDef.keyspace = KEYSPACE;
    thriftCfDef.name = COLUMN_FAMILY;
    thriftCfDef.default_validation_class = cfDef.default_validation_class;
    thriftCfDef.comment = cfDef.comment;
    thriftCfDef.column_metadata = new ArrayList<ColumnDef>();
    for (ColumnDef columnDef : columnDefs)
    {
        ColumnDef c = new ColumnDef();
        c.name = ByteBufferUtil.clone(columnDef.name);
        c.validation_class = columnDef.getValidation_class();
        c.index_name = columnDef.getIndex_name();
        c.index_type = IndexType.KEYS;
        thriftCfDef.column_metadata.add(c);
    }

    CfDef converted = cfMetaData.toThrift();

    assertEquals(thriftCfDef.keyspace, converted.keyspace);
    assertEquals(thriftCfDef.name, converted.name);
    assertEquals(thriftCfDef.default_validation_class, converted.default_validation_class);
    assertEquals(thriftCfDef.comment, converted.comment);
    assertEquals(thriftCfDef.column_metadata, converted.column_metadata);
}
 
开发者ID:pgaref,项目名称:ACaZoo,代码行数:37,代码来源:CFMetaDataTest.java


示例8: testThriftConversion

import org.apache.cassandra.thrift.IndexType; //导入依赖的package包/类
@Test
public void testThriftConversion() throws Exception
{
    CfDef cfDef = new CfDef().setDefault_validation_class(AsciiType.class.getCanonicalName())
                             .setComment("Test comment")
                             .setColumn_metadata(columnDefs)
                             .setKeyspace(KEYSPACE1)
                             .setName(CF_STANDARD1);

    // convert Thrift to CFMetaData
    CFMetaData cfMetaData = ThriftConversion.fromThrift(cfDef);

    CfDef thriftCfDef = new CfDef();
    thriftCfDef.keyspace = KEYSPACE1;
    thriftCfDef.name = CF_STANDARD1;
    thriftCfDef.default_validation_class = cfDef.default_validation_class;
    thriftCfDef.comment = cfDef.comment;
    thriftCfDef.column_metadata = new ArrayList<>();
    for (ColumnDef columnDef : columnDefs)
    {
        ColumnDef c = new ColumnDef();
        c.name = ByteBufferUtil.clone(columnDef.name);
        c.validation_class = columnDef.getValidation_class();
        c.index_name = columnDef.getIndex_name();
        c.index_type = IndexType.KEYS;
        thriftCfDef.column_metadata.add(c);
    }

    CfDef converted = ThriftConversion.toThrift(cfMetaData);

    assertEquals(thriftCfDef.keyspace, converted.keyspace);
    assertEquals(thriftCfDef.name, converted.name);
    assertEquals(thriftCfDef.default_validation_class, converted.default_validation_class);
    assertEquals(thriftCfDef.comment, converted.comment);
    assertEquals(new HashSet<>(thriftCfDef.column_metadata), new HashSet<>(converted.column_metadata));
}
 
开发者ID:scylladb,项目名称:scylla-tools-java,代码行数:37,代码来源:SchemaKeyspaceTest.java


示例9: testThriftConversion

import org.apache.cassandra.thrift.IndexType; //导入依赖的package包/类
@Test
public void testThriftConversion() throws Exception
{
    CfDef cfDef = new CfDef().setDefault_validation_class(AsciiType.class.getCanonicalName())
                             .setComment("Test comment")
                             .setColumn_metadata(columnDefs)
                             .setKeyspace(KEYSPACE1)
                             .setName(CF_STANDARD1);

    // convert Thrift to CFMetaData
    CFMetaData cfMetaData = CFMetaData.fromThrift(cfDef);

    CfDef thriftCfDef = new CfDef();
    thriftCfDef.keyspace = KEYSPACE1;
    thriftCfDef.name = CF_STANDARD1;
    thriftCfDef.default_validation_class = cfDef.default_validation_class;
    thriftCfDef.comment = cfDef.comment;
    thriftCfDef.column_metadata = new ArrayList<ColumnDef>();
    for (ColumnDef columnDef : columnDefs)
    {
        ColumnDef c = new ColumnDef();
        c.name = ByteBufferUtil.clone(columnDef.name);
        c.validation_class = columnDef.getValidation_class();
        c.index_name = columnDef.getIndex_name();
        c.index_type = IndexType.KEYS;
        thriftCfDef.column_metadata.add(c);
    }

    CfDef converted = cfMetaData.toThrift();

    assertEquals(thriftCfDef.keyspace, converted.keyspace);
    assertEquals(thriftCfDef.name, converted.name);
    assertEquals(thriftCfDef.default_validation_class, converted.default_validation_class);
    assertEquals(thriftCfDef.comment, converted.comment);
    assertEquals(new HashSet<>(thriftCfDef.column_metadata), new HashSet<>(converted.column_metadata));
}
 
开发者ID:daidong,项目名称:GraphTrek,代码行数:37,代码来源:CFMetaDataTest.java


示例10: announceMigration

import org.apache.cassandra.thrift.IndexType; //导入依赖的package包/类
public void announceMigration() throws InvalidRequestException, ConfigurationException
{
    logger.debug("Updating column {} definition for index {}", columnName, indexName);
    CFMetaData cfm = Schema.instance.getCFMetaData(keyspace(), columnFamily()).clone();
    CFDefinition cfDef = cfm.getCfDef();
    ColumnDefinition cd = cfm.getColumnDefinition(columnName.key);

    if (isCustom)
    {
        cd.setIndexType(IndexType.CUSTOM, Collections.singletonMap(SecondaryIndex.CUSTOM_INDEX_OPTION_NAME, indexClass));
    }
    else if (cfDef.isComposite)
    {
        CompositeType composite = (CompositeType)cfm.comparator;
        Map<String, String> opts = new HashMap<String, String>();
        opts.put(CompositesIndex.PREFIX_SIZE_OPTION, String.valueOf(composite.types.size() - (cfDef.hasCollections ? 2 : 1)));
        cd.setIndexType(IndexType.COMPOSITES, opts);
    }
    else
    {
        cd.setIndexType(IndexType.KEYS, Collections.<String, String>emptyMap());
    }

    cd.setIndexName(indexName);
    cfm.addDefaultIndexNames();
    MigrationManager.announceColumnFamilyUpdate(cfm);
}
 
开发者ID:dprguiuc,项目名称:Cassandra-Wasef,代码行数:28,代码来源:CreateIndexStatement.java


示例11: ColumnDefinition

import org.apache.cassandra.thrift.IndexType; //导入依赖的package包/类
public ColumnDefinition(ByteBuffer name, AbstractType<?> validator, IndexType index_type, Map<String, String> index_options, String index_name, Integer componentIndex)
{
    assert name != null && validator != null;
    this.name = name;
    this.index_name = index_name;
    this.validator = validator;
    this.componentIndex = componentIndex;
    this.setIndexType(index_type, index_options);
}
 
开发者ID:dprguiuc,项目名称:Cassandra-Wasef,代码行数:10,代码来源:ColumnDefinition.java


示例12: toThrift

import org.apache.cassandra.thrift.IndexType; //导入依赖的package包/类
public ColumnDef toThrift()
{
    ColumnDef cd = new ColumnDef();

    cd.setName(ByteBufferUtil.clone(name));
    cd.setValidation_class(validator.toString());

    cd.setIndex_type(index_type == null
                        ? null
                        : IndexType.valueOf(index_type.name()));
    cd.setIndex_name(index_name == null ? null : index_name);
    cd.setIndex_options(index_options == null ? null : Maps.newHashMap(index_options));

    return cd;
}
 
开发者ID:dprguiuc,项目名称:Cassandra-Wasef,代码行数:16,代码来源:ColumnDefinition.java


示例13: fromSchema

import org.apache.cassandra.thrift.IndexType; //导入依赖的package包/类
/**
 * Deserialize columns from low-level representation
 *
 * @return Thrift-based deserialized representation of the column
 * @param row
 */
public static List<ColumnDefinition> fromSchema(Row row, CFMetaData cfm)
{
    if (row.cf == null)
        return Collections.emptyList();

    List<ColumnDefinition> cds = new ArrayList<ColumnDefinition>();
    for (UntypedResultSet.Row result : QueryProcessor.resultify("SELECT * FROM system.schema_columns", row))
    {
        try
        {
            IndexType index_type = null;
            Map<String,String> index_options = null;
            String index_name = null;
            Integer componentIndex = null;

            if (result.has("index_type"))
                index_type = IndexType.valueOf(result.getString("index_type"));
            if (result.has("index_options"))
                index_options = FBUtilities.fromJsonMap(result.getString("index_options"));
            if (result.has("index_name"))
                index_name = result.getString("index_name");
            if (result.has("component_index"))
                componentIndex = result.getInt("component_index");

            cds.add(new ColumnDefinition(cfm.getColumnDefinitionComparator(componentIndex).fromString(result.getString("column_name")),
                                         TypeParser.parse(result.getString("validator")),
                                         index_type,
                                         index_options,
                                         index_name,
                                         componentIndex));
        }
        catch (RequestValidationException e)
        {
            throw new RuntimeException(e);
        }
    }

    return cds;
}
 
开发者ID:dprguiuc,项目名称:Cassandra-Wasef,代码行数:46,代码来源:ColumnDefinition.java


示例14: columnFromAvro

import org.apache.cassandra.thrift.IndexType; //导入依赖的package包/类
@Deprecated
public static ColumnDefinition columnFromAvro(org.apache.cassandra.db.migration.avro.ColumnDef cd)
{
    IndexType index_type = cd.index_type == null ? null : Enum.valueOf(IndexType.class, cd.index_type.name());
    String index_name = cd.index_name == null ? null : cd.index_name.toString();
    try
    {
        AbstractType<?> validatorType = TypeParser.parse(cd.validation_class);
        return new ColumnDefinition(ByteBufferUtil.clone(cd.name), validatorType, index_type, ColumnDefinition.getStringMap(cd.index_options), index_name, null);
    }
    catch (RequestValidationException e)
    {
        throw new RuntimeException(e);
    }
}
 
开发者ID:dprguiuc,项目名称:Cassandra-Wasef,代码行数:16,代码来源:Avro.java


示例15: testThriftToAvroConversion

import org.apache.cassandra.thrift.IndexType; //导入依赖的package包/类
@Test
public void testThriftToAvroConversion() throws Exception
{
    CfDef cfDef = new CfDef().setDefault_validation_class(AsciiType.class.getCanonicalName())
                             .setComment("Test comment")
                             .setColumn_metadata(columnDefs)
                             .setKeyspace(KEYSPACE)
                             .setName(COLUMN_FAMILY);

    // convert Thrift to CFMetaData
    CFMetaData cfMetaData = CFMetaData.fromThrift(cfDef);

    // make a correct Avro object
    CfDef thriftCfDef = new CfDef();
    thriftCfDef.keyspace = KEYSPACE;
    thriftCfDef.name = COLUMN_FAMILY;
    thriftCfDef.default_validation_class = cfDef.default_validation_class;
    thriftCfDef.comment = cfDef.comment;
    thriftCfDef.column_metadata = new ArrayList<ColumnDef>();
    for (ColumnDef columnDef : columnDefs)
    {
        ColumnDef c = new ColumnDef();
        c.name = ByteBufferUtil.clone(columnDef.name);
        c.validation_class = columnDef.getValidation_class();
        c.index_name = columnDef.getIndex_name();
        c.index_type = IndexType.KEYS;
        thriftCfDef.column_metadata.add(c);
    }

    CfDef converted = cfMetaData.toThrift();

    assertEquals(thriftCfDef.keyspace, converted.keyspace);
    assertEquals(thriftCfDef.name, converted.name);
    assertEquals(thriftCfDef.default_validation_class, converted.default_validation_class);
    assertEquals(thriftCfDef.comment, converted.comment);
    assertEquals(thriftCfDef.column_metadata, converted.column_metadata);
}
 
开发者ID:dprguiuc,项目名称:Cassandra-Wasef,代码行数:38,代码来源:CFMetaDataTest.java


示例16: indexCFMD

import org.apache.cassandra.thrift.IndexType; //导入依赖的package包/类
private static CFMetaData indexCFMD(String ksName, String cfName, final Boolean withIdxType, boolean withOldCfIds) throws ConfigurationException
{
    return standardCFMD(ksName, cfName, withOldCfIds)
           .keyValidator(AsciiType.instance)
           .columnMetadata(new HashMap<ByteBuffer, ColumnDefinition>()
               {{
                    ByteBuffer cName = ByteBuffer.wrap("birthdate".getBytes(Charsets.UTF_8));
                    IndexType keys = withIdxType ? IndexType.KEYS : null;
                    put(cName, new ColumnDefinition(cName, LongType.instance, keys, null, withIdxType ? ByteBufferUtil.bytesToHex(cName) : null, null));
                }});
}
 
开发者ID:dprguiuc,项目名称:Cassandra-Wasef,代码行数:12,代码来源:SchemaLoader.java


示例17: ColumnDefinition

import org.apache.cassandra.thrift.IndexType; //导入依赖的package包/类
public ColumnDefinition(ByteBuffer name, AbstractType validator, IndexType index_type, String index_name)
{
    this.name = name;
    this.index_type = index_type;
    this.index_name = index_name;
    this.validator = validator;
}
 
开发者ID:devdattakulkarni,项目名称:Cassandra-KVPM,代码行数:8,代码来源:ColumnDefinition.java



注:本文中的org.apache.cassandra.thrift.IndexType类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
Java DefaultKafkaConsumerFactory类代码示例发布时间:2022-05-21
下一篇:
Java InterruptibleChannel类代码示例发布时间:2022-05-21
热门推荐
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap