小编Cou*_*unt的帖子

我有一个Spark数据帧,其列数非常滞后我想从中删除两列以获得新的数据帧

如果列数较少,我可以使用API​​中的select方法

pcomments = pcomments.select(pcomments.col("post_id"),pcomments.col("comment_id"),pcomments.col("comment_message"),pcomments.col("user_name"),pcomments.col("comment_createdtime"));

但是,从长列表中选择列是一项繁琐的工作,是否有解决方法.

我正在尝试使用以下代码Source通过AdminCommand创建一个kafka主题

 ZkClient zkClient = new ZkClient(kafkaHost, 10000, 10000, ZKStringSerializer$.MODULE$);
    AdminUtils.createTopic(zkClient, "pa_reliancepoc_telecom_usageevent", 10, 2, new Properties());

但得到以下例外

Exception in thread "main" kafka.admin.AdminOperationException: replication factor: 1 larger than available brokers: 0
at kafka.admin.AdminUtils$.assignReplicasToBrokers(AdminUtils.scala:70)
at kafka.admin.AdminUtils$.createTopic(AdminUtils.scala:155)

但是,我可以使用shell命令创建主题.

我正在使用struts2标签,并希望将占位符放在这样的<s:textfield>标记中:

<s:set name="email" value="getText('email')" />
...

<s:form action="Login">
    <s:textfield key="email" theme="simple" placeholder="%{email}" 
         cssClass="span3"/>
    ...
</s:form>

email被定义global.properties为"Correoelectrónico".

我的问题是,当我看到jsp页面时,而不是看到email我看到的值%{email}.

我读到这是版本2.3.1中解决的Struts2的错误:https://issues.apache.org/jira/browse/WW-3644,但我使用的是Struts2 2.3.4并且我一直在使用它问题.

任何人都知道这个问题的解决方案或任何其他方式将占位符放在文本字段中？

作为预处理数据的一部分.我希望能够替换空格后跟一个数字,保持空格后跟一个字符.例如:

Input String: '8.1.7 Sep 2000 Dec 2004 Dec 2006 Indefinite'

Expected output: '8.1.7,Sep 2000,Dec 2004,Dec 2006,Indefinite'

我在python中使用基于正则表达式的替换函数:

re.sub("\s+", ",", release) 

但这并没有取得理想的结果,只是因为这意味着要替换所有空格,不知道如何保持一个字符后跟即[a-z].

或许我需要重新思考方法.

我希望能够根据消息密钥的密钥将Kafkastream中的所有记录发送到另一个主题。例如 Kafka中的流包含名称作为键和记录作为值。我想根据记录的关键将这些记录分散到不同的主题

数据：（jhon-> {jhonsRecord}），（sean-> {seansRecord}），（mary-> {marysRecord}），（jhon-> {jhonsRecord2}），预期

• topic1：名称：jhon->（jhon-> {jhonsRecord}），（jhon-> {jhonsRecord2}）
• topic2：sean->（sean-> {seansRecord}）
• topic3：mary->（mary-> {marysRecord}）

下面是我现在执行此操作的方式，但是由于名称列表比较笨拙，因此速度很慢。另外，即使有一些名字的记录，我也需要遍历整个列表。请提出修复建议

    for( String name : names )
    {
        recordsByName.filterNot(( k, v ) -> k.equalsIgnoreCase(name)).to(name);
    }