小编Soh*_*ohi的帖子

在 flink ui 上监视流作业时，我在 JVM 之外遇到了。

它到底是什么，什么是计数列？

我有带有 pom.xml 的 java 应用程序。我正在制作带有前缀标签的 rpm 包。

当我查询 rpm 的前缀标签时：

sudo rpm -qp --queryformat "%{prefixes}\n" java-hbase-processor-1.0-SNAPSHOT20160330060627.noarch.rpm 

我得到了 ==> /var

如果我运行以下命令：

rpm -qi java-hbase-processor | grep Relocations

我得到：重定位：/opt /tmp 重定位：/var /tmp

以上都表明 rpm 是可重定位的。但是如果运行安装命令

sudo rpm -i --prefix=/home/sohanvir/ java-hbase-processor-1.0-SNAPSHOT20160330060627.noarch.rpm

它会给出错误消息：

错误：包 java-hbase-processor 不可重定位

提前致谢 。

我正在通过这里提到的示例:https: //github.com/confluentinc/examples/blob/3.2.x/kafka-streams/src/main/java/io/confluent/examples/streams/PageViewRegionLambdaExample.java

我以json字符串的形式生成输入数据.

对于主题 - PageViews

{"industry":"eng","user":"bob","page":"index.html"}

对于主题 - UserProfiles

{"experience":"some","region":"europe"}

我的班级看起来像:

import com.google.gson.Gson;
import com.sohi.examples.dto.PageViews;
import com.sohi.examples.dto.UserProfiles;
import com.sohi.examples.dto.ViewsByRegion;
import org.apache.kafka.clients.consumer.ConsumerConfig;
import org.apache.kafka.common.serialization.Serde;
import org.apache.kafka.common.serialization.Serdes;
import org.apache.kafka.streams.KafkaStreams;
import org.apache.kafka.streams.KeyValue;
import org.apache.kafka.streams.StreamsConfig;
import org.apache.kafka.streams.kstream.*;

import java.io.IOException;
import java.util.Properties;


public class PageViewRegionLambdaExample {

    public static void main(String[] args) throws IOException {

        final String bootstrapServers = args.length > 0 ? args[0] : "localhost:9092";
        final Properties streamsConfiguration = new Properties();

        streamsConfiguration.put(StreamsConfig.APPLICATION_ID_CONFIG, "pageview-region-lambda-example");
        streamsConfiguration.put(StreamsConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapServers);
        streamsConfiguration.put(StreamsConfig.KEY_SERDE_CLASS_CONFIG, Serdes.String().getClass().getName());//NOSONAR
        streamsConfiguration.put(StreamsConfig.VALUE_SERDE_CLASS_CONFIG, Serdes.String().getClass().getName());//NOSONAR
        streamsConfiguration.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, "earliest");
        streamsConfiguration.put(StreamsConfig.COMMIT_INTERVAL_MS_CONFIG, …

我正在使用 Cloudera Quick Start VM 并在其上运行 hbase。以下是我的疑问：

hbase(main):009:0> create 'test', 'cf'
0 row(s) in 0.4500 seconds

=> Hbase::Table - test
hbase(main):010:0> put 'test', 'row3', 'cf:c', 'value3'
0 row(s) in 0.1950 seconds

hbase(main):011:0> put 'test', 'row3', 'cf:c', 'value4'
0 row(s) in 0.0580 seconds

hbase(main):012:0> scan 'test' 
ROW                                      COLUMN+CELL                                                                                                         
 row3                                    column=cf:c, timestamp=1414148485533, value=value4                                                                  
1 row(s) in 0.0420 seconds

hbase(main):013:0> scan 'test', {VERSIONS => 3}
ROW                                      COLUMN+CELL                                                                                                         
 row3                                    column=cf:c, timestamp=1414148485533, value=value4                                                                  
1 row(s) in 0.0370 seconds

hbase(main):014:0> get 'test', 'row3', {COLUMN => 'cf:c', …