小编flo*_*ins的帖子

我正在使用Oracle 11g,我想使用REGEXP_SUBSTR来匹配给定模式的所有事件.例如

 SELECT
  REGEXP_SUBSTR('Txa233141b Ta233141 Ta233142 Ta233147 Ta233148',
  '(^|\s)[A-Za-z]{2}[0-9]{5,}(\s|$)') "REGEXP_SUBSTR"
  FROM DUAL;

只返回第一个匹配Ta233141,但我想返回与正则表达式匹配的其他匹配项,即Ta233142 Ta233147 Ta233148.

我想问你是否有一个涉及Amazon Elastic Container Service(ECS)和应用程序负载均衡器(ALB)的微服务架构(基于Spring Boot),服务发现是由平台自动执行的,还是需要一个特殊的机制(如尤里卡或领事)？

从文档(ECS和ALB)不清楚您是否提供此功能.

我正在使用AllegroGraph来存储这样的语句:

<newsid1  hasAnnotation  Gamma>
<newsid1  hasAnnotation Beta>

我想在这个staments上定义一条规则:如果主题 newsid1 hasAnnotation 是 Gamma 或者 Beta,那么 在triplestore中添加一个说明主题的新语句hasAnnotation Theta,即语句

<newsid1  hasAnnotation Theta>

我的问题如下:

1. 我如何为Allegro定义这样的规则？
2. 我如何在声明中应用这些规则？

Spark MLLib中的相关结果是org.apache.spark.mllib.linalg.Matrix类型的。（请参阅http://spark.apache.org/docs/1.2.1/mllib-statistics.html#correlations）

val data: RDD[Vector] = ... 

val correlMatrix: Matrix = Statistics.corr(data, "pearson")

我想将结果保存到文件中。我怎样才能做到这一点？

我正在使用Kafka 0.9.1新的消费者API。使用者被手动分配给分区。对于这个消费者，我希望看到它的进展（意味着滞后）。由于我将组ID消费者教程添加为属性，因此我假设可以使用以下命令

bin/kafka-consumer-groups.sh --new-consumer --describe --group consumer-tutorial --bootstrap-server localhost:9092

（如此处http://www.confluent.io/blog/tutorial-getting-started-with-the-new-apache-kafka-0.9-consumer-client所述）

不幸的是，使用上述命令未显示我的消费者组详细信息。因此，我无法监视我的消费者的进度（这是滞后的）。在上述场景（手动分配的分区）中，如何监控延迟？

代码是：

Properties props = new Properties();
props.put("bootstrap.servers", "localhost:9092");
props.put("group.id", "consumer-tutorial");
props.put("key.deserializer", StringDeserializer.class.getName());
props.put("value.deserializer", StringDeserializer.class.getName());
KafkaConsumer<String, String> consumer = new KafkaConsumer<>(props);


        String topic = "my-topic";
        TopicPartition topicPartition = new TopicPartition(topic, 0);
        consumer.assign(Arrays.asList(topicPartition));
        consumer.seekToBeginning(topicPartition);
try {
  while (true) {
    ConsumerRecords<String, String> records = consumer.poll(1000);
    for (ConsumerRecord<String, String> record : records)
     System.out.println(record.offset() + ": " + record.value());
  consumer.commitSynch();
  }
} finally {
  consumer.close();
}