小编Nis*_*yal的帖子

我的正则表达式是

(pnr|(P|p)[ _.:,!"'-/$](N|n)[ _.:,!"'-/$](R|r))+[ _.:,!"'-/$]+[0-9]{3}[ _.:,!"'-/$]+[0-9]{7}

它正在从列中提取 pnr 编号。

示例文本 ：

94eb2c0cb17ef354bb052c57f40c\r\nContent-Type: text/plain; charset=UTF-8\r\nContent-Transfer-Encoding pnr:986-097832

94eb2c0cb17ef354bb052c57f40c\r\nContent-Type: pnr:986-097832 text/plain; charset=UTF-8\r\nContent-Transfer-Encoding 

pnr:986-097832 94eb2c0cb17ef354bb052c57f40c\r\nContent-Type: text/plain; charset=UTF-8\r\nContent-Transfer-Encoding

我必须创建一个 mysql 查询，它只会提取 pnr 号码

我想在Jquery中设置一个全局变量,这样当我单击列表项时,单击的列表项的id将成为变量的值.我有下面的代码也在这个小提琴.

但是我拥有它的方式:当你单击列表项时,正确地将值放入console.log.However然后当我点击demo div时,变量被重置并且未定义.

当我点击demo时,如何获取id的值,当我点击列表项时,它是id的值？

例如:

当我点击aaa时,点击演示框时的值应为id-1

当我点击bbb时,单击演示框时的值应为id-2

    <div id="demo"></div>
    <ul>
        <li id="id-1">aaa</li>
        <li id="id-2">bbb</li>
    </ul>

    <script>
    var id;
    jQuery(document).on("click", "li", function (event) {
            var id =jQuery(this).attr('id') || '';
            console.log(id);
        $( "#demo" ).show();
        });

    $(function() {
    $("#demo").click(function(e) {
    console.log(id);
    });
    });

    </script>

    <style>
    #demo {
        border: 1px solid; 
        display:none;
        height: 100px; 
        width: 100px;
    }
    </style>

我正在尝试使用Azure HDInsight的Hadoop。我通过ssh登录到集群并运行以下命令

hadoop jar jar_name class_name wasb://container@storagename.core.windows.net/inputdir wasb://container@storagename.core.windows.net/outputdir 

但是我得到以下异常：

线程“主”中的异常org.apache.hadoop.fs.azure.AzureException：org.apache.hadoop.fs.azure.AzureException：无法使用匿名凭据访问帐户yyy.core.windows.net中的容器xxx在配置中为他们找到的凭据。

我正在使用azure cli，并且在运行上述hadoop作业之前运行了“ azure登录”。

请让我知道如何解决此错误。

Ubuntu 12.04在这些计算机上运行。

PS：也在Azure论坛上发布了此内容，但在此处重新发布以吸引更多的受众。

我是apache flink的新手.我的输入中有一个未绑定的数据流(通过kakfa送入flink 0.10).

我想获得每个主键的第一次出现(主键是contract_num和event_dt).
这些"重复"几乎在彼此之后立即发生.源系统不能为我过滤这个,所以flink必须这样做.

这是我的输入数据:
contract_num,event_dt,attr
A1,2016-02-24 10:25: 08,X
A1,2016-02-24
10:25: 08,Y A1,2016-02-24 10:25: 09,Z
A2,2016-02-24 10:25:10,C

这是我想要的输出数据:
A1,2016-02-24 10 :25: 08,X A1,2016-02-24 10 :25:
09,Z A2,2016-02-24 10 :25:10
,C

请注意第2行已被删除,因为A001和'2016-02-24 10:25:08'的组合键已在第1行中出现.

我怎么能用flink 0.10做到这一点？

我正在考虑使用keyBy(0,1),
但之后我不知道该怎么做!

(我使用joda-time和org.flinkspector来设置这些测试).

contract_num, event_dt, attr 
A1, 2016-02-24 10:25:08, X
A1, 2016-02-24 10:25:08, Y
A1, 2016-02-24 10:25:09, Z
A2, 2016-02-24 10:25:10, C

我对卡夫卡非常陌生。我已经在我的 mac 上使用自制软件安装了 kafka 和 zookeeper，我正在玩快速入门指南。

我已经能够使用以下命令和 STDIN 将消息推送到 Kafka

kafka-console-producer --broker-list localhost:9092 --topic test

我可以使用

kafka-console-consumer --bootstrap-server localhost:9092 --topic test --from-beginning

我不清楚的是我如何使用偏移量。我的理解是，添加到主题的每条消息都会有一个数字增量偏移值。但是，如果我尝试做这样的事情

kafka-console-consumer --bootstrap-server localhost:9092 --topic test --offset 1

我得到一个非零状态代码并且没有显示任何消息（除了通常的帮助/使用信息）

我也无法使用最新或最早的关键字

kafka-console-consumer --bootstrap-server localhost:9092 --topic test --offset earliest
kafka-console-consumer --bootstrap-server localhost:9092 --topic test --offset latest

以上两者也返回非零状态代码。

我从根本上误解了偏移量吗？如果没有，有没有办法列出所有带有偏移量的消息？最后 - 最简单的--offset标志示例是kafka-console-consumer什么？

像这样的 SQL

SELECT empno, deptno, 
COUNT(*) OVER (PARTITION BY deptno) DEPT_COUNT FROM emp WHERE deptno IN (20, 30);

非常有用。

我只是想知道在H2中，我们如何实现类似的功能？也许创建一个 java 程序会起作用。但是这个功能会在 H2 数据库的路线图中吗？

在JAVA类中有20-25个实例变量和它们的getter/setter是不是很好的OO设计？
所有变量都是完全独立的.
因为我在HBase中使用了一个类,它代表一个列族,所以列族可以为每一行提供不同数量的列.所以我必须在这个类中加入这么多变量.我很好奇,JAVA类应该有多少实例变量和方法？

我有一个文本文件,我想加载到我的猪引擎,文本文件中的名称在单独的行中,数据,但有错误...特殊字符....像这样的东西:

Ja@@$s000on   
J@@a%^ke
T!!ina
Mel@ani

我想使用REGEX从所有名称中删除特殊字符....我发现在猪中完成工作的一种方式,最后输出为......

Jason
Jake
Tina
Melani

有人可以告诉我将在Pig工作的正则表达式.同时编写将执行此操作的命令,因为我无法使用REGEX_EXTRACT和REGEX_EXTRACT_ALL函数.
还有人可以解释在定义正则表达式之后我们传递给此函数作为参数的数字1的意义是什么.

任何帮助将受到高度赞赏.

当使用 Integer 作为键时，这不是问题，kafka 应该能够将 Strings 作为键处理。

ProducerFactory<String, String> pf =
                new DefaultKafkaProducerFactory<String, String>(senderProps);
KafkaTemplate<String, String> template = new KafkaTemplate<>(pf);
ProducerRecord<String,String> pr = new ProducerRecord<>("my-topic", "key1","test");
        template.send(pr);`

它抛出以下异常：

Org.apache.kafka.common.errors.SerializationException：无法将类 java.lang.String 的键转换为 key.serializer 中指定的类 org.apache.kafka.common.serialization.IntegerSerializer

引起原因：java.lang.ClassCastException：java.lang.String无法在org.apache.kafka.common.serialization.IntegerSerializer.serialize(IntegerSerializer.java:21)在org.apache.kafka处转换为java.lang.Integer .common.serialization.ExtendedSerializer$Wrapper.serialize(ExtendedSerializer.java:65) 在 org.apache.kafka.common.serialization.ExtendedSerializer$Wrapper.serialize(ExtendedSerializer.java:55) 在 org.apache.kafka.clients. Producer .KafkaProducer.doSend(KafkaProducer.java:799) 在 org.apache.kafka.clients. Producer.KafkaProducer.send(KafkaProducer.java:784) 在 org.springframework.kafka.core.DefaultKafkaProducerFactory$CloseSafeProducer.send(DefaultKafkaProducerFactory.java ：285）在org.springframework.kafka.core.KafkaTemplate.doSend（KafkaTemplate.java：357）在org.springframework.kafka.core.KafkaTemplate.send（KafkaTemplate.java：206）

我有一个从GenericRecord类型的主题中提取json字符串的处理器。现在我将流分成2个分支。我进入第一个分支，然后将（键，值）映射到2个字符串中，该字符串包含json的特定字段和该字段的值，并且按键分组。到目前为止，一切都很好。现在，我必须使用新的Type用户定义来聚合流，并且会收到异常。

这里的代码：

新类型：

private class Tuple {

    public int occ;
    public int sum;


    public Tuple (int occ, int sum) {
        this.occ = occ;
        this.sum = sum;
    }

    public void sum (int toAdd) {
        this.sum += toAdd;
        this.occ ++;
    }

    public int getAverage () {
        return this.sum / this.occ;
    }

    public String toString() {
        return occ + "-> " + sum + ": " + getAverage();
    }

好流：

  StreamsBuilder builder = new StreamsBuilder();
    KStream<GenericRecord, GenericRecord> source =
          builder.stream(topic);

    KStream<GenericRecord, GenericRecord>[] branches …