小编Ank*_*ita的帖子

我在一个关于回归建模的教程中看到了以下命令:

myFormula <- Species ~ Sepal.Length + Sepal.Width + Petal.Length + Petal.Width

这个命令究竟做了什么,~(tilde)在命令中的作用是什么？

我正在使用Kafka 0.8.0并试图实现下面提到的场景.

JCA API(充当生产者并发送数据)----->消费者------> HBase

一旦我使用JCA客户端获取数据,我就会将每条消息发送给消费者.例如,一旦生产者发送消息no.1,我想从消费者那里获取相同的内容并在HBase中"put".但是我的消费者在一些随机的n消息之后开始获取消息.我想让生产者和消费者同步,以便他们两个开始一起工作.

我用过:

1经纪人

1个单一主题

1个单一生产者和高级消费者

任何人都可以建议我需要做些什么来达到同样的目的？

编辑:

添加一些相关的代码段.

Consumer.java

public class Consumer extends Thread {
    private final ConsumerConnector consumer;
    private final String topic;
    PrintWriter pw = null;
    int t = 0;
    StringDecoder kd = new StringDecoder(null);
    Map<String, Integer> topicCountMap = new HashMap<String, Integer>();
    Map<String, List<KafkaStream<String, Signal>>> consumerMap;
    KafkaStream<String, Signal> stream;
    ConsumerIterator<String, Signal> it;

    public Consumer(String topic) {
        consumer = kafka.consumer.Consumer.createJavaConsumerConnector(createConsumerConfig());

        this.topic = topic;
        topicCountMap.put(topic, new Integer(1));
        consumerMap = consumer.createMessageStreams(topicCountMap, kd, new Serializer(
                new VerifiableProperties()));
        stream …

我目前正在处理Google Protocol Buffers并需要生成动态消息.我已经定义了如下所示的.proto文件.

message TSInbound
{
  string id = 1;
  map<string,string> state = 2;
  map<string,string> reading =3;
}

AFAIK,我可以使用文件描述符集来创建动态消息.但是,这将涉及使用编译器生成desc文件.我想生成描述符而不编译.proto文件.有没有办法使用自定义.proto文件动态创建消息而不使用protoc？

我正在尝试更新基表中的列,该列是物化视图中的分区键,并尝试了解其在生产环境中的性能影响.

基表:

CREATE TABLE if not exists data.test
 ( ?foreignid    uuid,
? id           uuid,?        
 kind         text,
? version      text,?           
 createdon    timestamp,?        
**certid**    text,
? PRIMARY KEY(foreignid,createdon,id)?    );

物化视图:

CREATE MATERIALIZED VIEW if not exists data.test_by_certid 
AS? SELECT *?FROM data.test? WHERE id IS NOT NULL AND foreignid 
IS NOT NULL AND createdon IS NOT NULL AND certid IS NOT NULL 
PRIMARY KEY (**certid**, foreignid, createdon, id);

因此,certid是物化视图中的新分区键

发生了什么:

1. When we first insert into the test table , usually the certids …