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

Java TBinaryProtocol类代码示例

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

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



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

示例1: deserialize

import org.apache.cassandra.thrift.TBinaryProtocol; //导入依赖的package包/类
public RangeSliceCommand deserialize(DataInputStream dis, int version) throws IOException
{
    String keyspace = dis.readUTF();
    String column_family = dis.readUTF();

    int scLength = dis.readInt();
    ByteBuffer super_column = null;
    if (scLength > 0)
        super_column = ByteBuffer.wrap(readBuf(scLength, dis));

    TDeserializer dser = new TDeserializer(new TBinaryProtocol.Factory());
    SlicePredicate pred = new SlicePredicate();
    FBUtilities.deserialize(dser, pred, dis);

    AbstractBounds range = AbstractBounds.serializer().deserialize(dis);
    int max_keys = dis.readInt();
    return new RangeSliceCommand(keyspace, column_family, super_column, pred, range, max_keys);
}
 
开发者ID:devdattakulkarni,项目名称:Cassandra-KVPM,代码行数:19,代码来源:RangeSliceCommand.java


示例2: dropOldKeyspace

import org.apache.cassandra.thrift.TBinaryProtocol; //导入依赖的package包/类
private void dropOldKeyspace() throws InvalidRequestException, SchemaDisagreementException, TException {
  TTransport tr = new TFramedTransport(new TSocket("localhost", 9160));
  TProtocol proto = new TBinaryProtocol(tr);
  Cassandra.Client client = new Cassandra.Client(proto);
  tr.open();

  client.system_drop_keyspace(JANUSGRAPH);
  LOGGER.info("DROPPED keyspace janusgraph");
  tr.close();
}
 
开发者ID:marcelocf,项目名称:janusgraph_tutorial,代码行数:11,代码来源:Schema.java


示例3: createConnection

import org.apache.cassandra.thrift.TBinaryProtocol; //导入依赖的package包/类
private static Cassandra.Client createConnection(String host, Integer port, boolean framed) throws IOException
{
    TSocket socket = new TSocket(host, port);
    TTransport trans = framed ? new TFramedTransport(socket) : socket;
    try
    {
        trans.open();
    }
    catch (TTransportException e)
    {
        throw new IOException("unable to connect to server", e);
    }
    return new Cassandra.Client(new TBinaryProtocol(trans));
}
 
开发者ID:devdattakulkarni,项目名称:Cassandra-KVPM,代码行数:15,代码来源:ColumnFamilyInputFormat.java


示例4: serialize

import org.apache.cassandra.thrift.TBinaryProtocol; //导入依赖的package包/类
public void serialize(RangeSliceCommand sliceCommand, DataOutputStream dos, int version) throws IOException
{
    dos.writeUTF(sliceCommand.keyspace);
    dos.writeUTF(sliceCommand.column_family);
    ByteBuffer sc = sliceCommand.super_column;
    dos.writeInt(sc == null ? 0 : sc.remaining());
    if (sc != null)
        ByteBufferUtil.write(sc, dos);

    TSerializer ser = new TSerializer(new TBinaryProtocol.Factory());
    FBUtilities.serialize(ser, sliceCommand.predicate, dos);
    AbstractBounds.serializer().serialize(sliceCommand.range, dos);
    dos.writeInt(sliceCommand.max_keys);
}
 
开发者ID:devdattakulkarni,项目名称:Cassandra-KVPM,代码行数:15,代码来源:RangeSliceCommand.java


示例5: serialize

import org.apache.cassandra.thrift.TBinaryProtocol; //导入依赖的package包/类
public void serialize(IndexScanCommand o, DataOutput out) throws IOException
{
    out.writeUTF(o.keyspace);
    out.writeUTF(o.column_family);
    TSerializer ser = new TSerializer(new TBinaryProtocol.Factory());
    FBUtilities.serialize(ser, o.index_clause, out);
    FBUtilities.serialize(ser, o.predicate, out);
    AbstractBounds.serializer().serialize(o.range, out);
}
 
开发者ID:devdattakulkarni,项目名称:Cassandra-KVPM,代码行数:10,代码来源:IndexScanCommand.java


示例6: deserialize

import org.apache.cassandra.thrift.TBinaryProtocol; //导入依赖的package包/类
public IndexScanCommand deserialize(DataInput in) throws IOException
{
    String keyspace = in.readUTF();
    String columnFamily = in.readUTF();

    TDeserializer dser = new TDeserializer(new TBinaryProtocol.Factory());
    IndexClause indexClause = new IndexClause();
    FBUtilities.deserialize(dser, indexClause, in);
    SlicePredicate predicate = new SlicePredicate();
    FBUtilities.deserialize(dser, predicate, in);
    AbstractBounds range = AbstractBounds.serializer().deserialize(in);

    return new IndexScanCommand(keyspace, columnFamily, indexClause, predicate, range);
}
 
开发者ID:devdattakulkarni,项目名称:Cassandra-KVPM,代码行数:15,代码来源:IndexScanCommand.java


示例7: serialize

import org.apache.cassandra.thrift.TBinaryProtocol; //导入依赖的package包/类
public void serialize(RangeSliceCommand sliceCommand, DataOutput dos, int version) throws IOException
{
    dos.writeUTF(sliceCommand.keyspace);
    dos.writeUTF(sliceCommand.column_family);
    ByteBuffer sc = sliceCommand.super_column;
    dos.writeInt(sc == null ? 0 : sc.remaining());
    if (sc != null)
        ByteBufferUtil.write(sc, dos);

    if (version < MessagingService.VERSION_12)
    {
        FBUtilities.serialize(new TSerializer(new TBinaryProtocol.Factory()), asSlicePredicate(sliceCommand.predicate), dos);
    }
    else
    {
        IDiskAtomFilter.Serializer.instance.serialize(sliceCommand.predicate, dos, version);
    }

    if (version >= MessagingService.VERSION_11)
    {
        if (sliceCommand.row_filter == null)
        {
            dos.writeInt(0);
        }
        else
        {
            dos.writeInt(sliceCommand.row_filter.size());
            for (IndexExpression expr : sliceCommand.row_filter)
            {
                if (version < MessagingService.VERSION_12)
                {
                    FBUtilities.serialize(new TSerializer(new TBinaryProtocol.Factory()), expr, dos);
                }
                else
                {
                    ByteBufferUtil.writeWithShortLength(expr.column_name, dos);
                    dos.writeInt(expr.op.getValue());
                    ByteBufferUtil.writeWithShortLength(expr.value, dos);
                }
            }
        }
    }
    AbstractBounds.serializer.serialize(sliceCommand.range, dos, version);
    dos.writeInt(sliceCommand.maxResults);
    if (version >= MessagingService.VERSION_11)
    {
        dos.writeBoolean(sliceCommand.countCQL3Rows);
        dos.writeBoolean(sliceCommand.isPaging);
    }
}
 
开发者ID:dprguiuc,项目名称:Cassandra-Wasef,代码行数:51,代码来源:RangeSliceCommand.java


示例8: initialize

import org.apache.cassandra.thrift.TBinaryProtocol; //导入依赖的package包/类
@Override
public void initialize(InputSplit split, TaskAttemptContext context) throws IOException {
  this.split = (ColumnFamilySplit) split;
  Configuration conf = context.getConfiguration();
  predicate = ConfigHelper.getInputSlicePredicate(conf);
  if (!isSliceRangePredicate(predicate)) {
    throw new AssertionError("WideRowsRequire a slice range");
  }


  totalRowCount = ConfigHelper.getInputSplitSize(conf);
  Log.info("total rows = "+totalRowCount);
  batchRowCount = 1;
  rowPageSize = predicate.getSlice_range().getCount();
  startSlicePredicate = predicate.getSlice_range().start;
  cfName = ConfigHelper.getInputColumnFamily(conf);
  consistencyLevel = ConsistencyLevel.valueOf(ConfigHelper.getReadConsistencyLevel(conf));


  keyspace = ConfigHelper.getInputKeyspace(conf);

  try {
    // only need to connect once
    if (socket != null && socket.isOpen()) {
      return;
    }

    // create connection using thrift
    String location = getLocation();
    socket = new TSocket(location, ConfigHelper.getInputRpcPort(conf));
    TBinaryProtocol binaryProtocol = new TBinaryProtocol(new TFramedTransport(socket));
    client = new Cassandra.Client(binaryProtocol);
    socket.open();

    // log in
    client.set_keyspace(keyspace);
    if (ConfigHelper.getInputKeyspaceUserName(conf) != null) {
      Map<String, String> creds = new HashMap<String, String>();
      creds.put(IAuthenticator.USERNAME_KEY, ConfigHelper.getInputKeyspaceUserName(conf));
      creds.put(IAuthenticator.PASSWORD_KEY, ConfigHelper.getInputKeyspacePassword(conf));
      AuthenticationRequest authRequest = new AuthenticationRequest(creds);
      client.login(authRequest);
    }
  } catch (Exception e) {
    throw new RuntimeException(e);
  }

  iter = new WideRowIterator();
}
 
开发者ID:dvasilen,项目名称:Hive-Cassandra,代码行数:50,代码来源:ColumnFamilyWideRowRecordReader.java



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


鲜花

握手

雷人

路过

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

请发表评论

全部评论

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

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

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

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

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