小编Him*_*dav的帖子

如何为下面给出的Java代码设置应用程序？

Hashtable<String, String> properties = new Hashtable<String, String>();
            properties.put(Context.INITIAL_CONTEXT_FACTORY, "com.test.factory");
            properties.put("com.domain", "DevelopmentDomain");
//            properties.put(Context.PROVIDER_URL, "tcp://test:0506");
            properties.put(Context.PROVIDER_URL, "tcp://10.00.0.00:0506");


            properties.put(Context.SECURITY_PRINCIPAL, "aaa");
            properties.put(Context.SECURITY_CREDENTIALS, "aaa");

            javax.naming.Context context = new javax.naming.InitialContext(properties);
            ConnectionFactory factory = (ConnectionFactory) context.lookup("ImpactPocQueueConnectionFactory");

            Connection connection = factory.createConnection();

            connection.start();

            Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);

            Destination queue = session.createQueue("test.producer");

我在这里和那里看到了许多例子,但没有一个给出完整的图片.

有没有办法从桶中读取所有文件？它是一个活跃的存储桶,我也想访问新创建的文档.
很少有人建议使用查看来查询存储桶.
如何创建将使用新文档或更新文档更新的视图？
新创建的视图的地图功能:

function (doc, meta) {
  emit(doc);
}

减少功能是空的.当我查询这样的视图时,bucket.query(ViewQuery.from("test1", "all")).totalRows()它返回0结果.

如何部署到依赖于外部库的python函数？
例如，我正在尝试部署到数据分析python函数。当我尝试从lambda控制台测试python函数时，我得到：
Unable to import module 'lambda_function': No module named pandas

我对Aws Lambda完全陌生

是否有运行Lambda函数的Linux机器，我可以在其中安装这些库？

我有一个 Spark Structured Streaming 作业，它从 Kafka 主题读取偏移量并将其写入 aerospike 数据库。目前，我正在准备这项工作生产并实施SparkListener.

在阅读文档时，我偶然发现了这个例子：

StreamingQuery query = wordCounts.writeStream()
    .outputMode("complete")
    .format("console")
    .start();
query.awaitTermination();

Run Code Online (Sandbox Code Playgroud)

执行此代码后，流式计算将
在后台启动。查询对象是该活动
流查询的句柄，我们决定
使用 awaitTermination()等待查询终止，以防止进程
在查询处于活动状态时退出。

我知道它在终止进程之前等待查询完成。

它到底是什么意思？它有助于避免查询写入的数据丢失。

当查询每天写入数百万条记录时，它有何帮助？

我的代码看起来很简单：

dataset.writeStream()
  .option("startingOffsets", "earliest")
  .outputMode(OutputMode.Append())
  .format("console")
  .foreach(sink)
  .trigger(Trigger.ProcessingTime(triggerInterval))
  .option("checkpointLocation", checkpointLocation)
  .start();

如何以所需格式返回Restlet响应？我使用的方法:

@Get ("json")
public Address sendResponse(){
    Address add = getAddress();
    return add;
}

现在我必须显式地将java对象转换为json字符串作为对浏览器的响应.Restlet框架本身不能照顾它吗？

Spring MVC的Restful实现可以做到.我也在Restlet中寻找类似的实现.

拥有多个 MBean 是否会带来性能问题？

尝试跟踪应用程序中运行的多个事务。我可能会停止创建 30 多个 MBean。
我真的很担心它是否会与 JVM 太吵闹。

模板:

<template name="header">
    <div class="blog-masthead">
        <div class="container">
            <nav class="blog-nav">
              <a class="blog-nav-item {{active}}" href="{{pathFor 'homePage'}}">Home</a>
              {{#if currentUser}}
                <a class="blog-nav-item {{active}}" href="#">{{Meteor.userId}}</a>
              {{else}}
                <a class="blog-nav-item {{active}}" href="{{pathFor 'loginPage'}}">Login</a>
                <a class="blog-nav-item {{active}}" href="{{pathFor 'signUpPage'}}">Sign Up</a>
              {{/if}}
              <a class="blog-nav-item {{active}}" href="#">About</a>
            </nav>
        </div>
    </div>
</template>

header.js

Template.header.events({
    'click a': function(e) {
        e.preventDefault();
        this.active?"active":"";
    }
});

我只是想设置点击链接的类active.点击链接类应该是这样的class="blog-nav-item active".

有没有办法在不运行和构建war文件的情况下发布Thymeleaf模板？
这就是我的gradle文件的样子:

apply plugin: 'war'

war {
    baseName = 'bootBlog'
    version =  '0.1.0'
}


repositories {
    mavenLocal()
    mavenCentral()
    maven { url "https://repo.spring.io/libs-release" }
}

configurations {
    providedRuntime
}

dependencies {
    compile("org.springframework.boot:spring-boot-starter-thymeleaf")
    compile("org.springframework.boot:spring-boot-starter-data-mongodb")
    compile("org.springframework.boot:spring-boot-starter-actuator")
    testCompile("junit:junit")
    providedRuntime("org.springframework.boot:spring-boot-starter-tomcat")

我是Angular2的新手并尝试运行本教程.它使用a fakeBackendProvide来模拟后端调用MockBackend.

fackBackend的逻辑是这样的: export let fakeBackendProvider = {}

index.tsclass有助于导出fackBackendProvider一行: export * from './fake-backend';

app.module.ts 看起来像这样:

providers: [
    AuthGuard,
    AuthenticationService,
    UserService,

    //fake backend providers
    fakeBackendProvider,
    MockBackend,
    BaseRequestOptions
  ],

我收到此错误消息: ERROR in Error encountered resolving symbol values statically. Function calls are not supported. Consider replacing the function or lambda with a reference to an exported function (position 7:15 in the original .ts file), resolving symbol fakeBackendProvider in /Users/hyadav/Documents/hp-app/src/app/helpers/fake-backend.ts, resolving symbol fakeBackendProvider in /Users/hyadav/Documents/hp-app/src/app/helpers/index.ts, resolving …

Spark 流作业正在读取繁忙的 kafka 主题中的事件。为了了解每个触发间隔有多少数据进入，我只想输出从主题读取的行数。我尝试了多种方法，但无法弄清楚。

Dataset<Row> stream = sparkSession.readStream()
          .format("kafka")
          .option("kafka.bootstrap.servers", kafkaBootstrapServersString)
          .option("subscribe", topic)
          .option("startingOffsets", "latest")
          .option("enable.auto.commit", false)
//          .option("failOnDataLoss", false)
//          .option("maxOffsetsPerTrigger", 10000)
          .load();
      stream.selectExpr("topic").agg(count("topic")).as("count");
      //stream.selectExpr("topic").groupBy("topic").agg(count(col("topic")).as("count"));
      stream.writeStream()
            .format("console")
            .option("truncate", false)
            .trigger(Trigger.ProcessingTime("10 seconds"))
            .start();