回答情况：
提问时间：
问题标签：
在我的Delphi应用程序中，我想使用(NLM)：来了解网络更改var pCpc: IConnectionPointContainer; pSink: IUnknown;const
IID_IConnectionPointContainer: TGUID = '{B196B28
浏览 5修改于2014-07-08得票数 2
回答已采纳
我有一个方法可以将其输出发送到给定的Sink<Node>中。
我想把它导入stdout，这是一个Sink<List<int>>。假设我有一个函数convert将Node转换为List<int>，我如何将stdout转换为Sink<Node>，以便将my Tree打印到控制台？
浏览 2提问于2019-11-29得票数 0
回答已采纳
我正在尝试使用sink()函数将输出写入一个新文件。如果我从源代码运行以下代码：cat("hello world")RStudio将创建一个新文件，其中包含以下文本：hello world我想这应该只是输出有没有人能
浏览 0修改于2018-04-20得票数 0
但是下面的.sink()闭包从未被调用。看来，未来的实例在被调用之后就被释放了。) + 1) { } .receive(on: DispatchQueue.main) }, receiveValue: { })
因此，我将.subscribe(Subscribers.Sink())替换为.sink()闭包，如下所示。什
浏览 0提问于2020-04-14得票数 6
回答已采纳
2019-07-15 14:24:17,669 WARN org.apache.flume.sink.hdfs.BucketWriter: Caught IOException writing to HDFSWriter(AvroEventSerializer.java:187) at org.apache.flume.sink.hdfs.BucketWrit
浏览 0提问于2019-07-15得票数 0
回答已采纳
我用卡桑德拉水槽写了一个Flink应用程序。一切都运行得很好，但是没有生成各种指标(比如延迟、NumRecordsInPerSecond等)。我确实需要Flink提供的延迟度量，但它确实显示了任何数据。谢谢。
浏览 1提问于2017-10-29得票数 1
回答已采纳
我读到过Kafka连接源可以从数据库接收多个主题(一个主题代表一个表)。我有很多表的PostgreSQL数据库，一个卡夫卡源码已经足够满足这个时间了。但是，如果我只声明一个JDBC Kafka接收器来使用基于主题的目标表中的所有主题，例如，将PostgreSQL中的所有表都消费到单个MS SQL Server数据库中，那么它是否可用？这是时间成本，例如，如果我有来自一个数据库的200个表，并且必须为每个表建立200个接收器连接，尽管我只需要声明一次源。
浏览 13修改于2020-03-15得票数 0
回答已采纳
我正在尝试使用云shell中的接收器将日志导出到bigquery中。我做了以下步骤: bq mk数据集我为接收器创建了一个服务帐户，并将他绑定到bigQuery.dataEditor和logging.logWriter
问题是，如果我不去控制台->编辑接收器->更新
浏览 12提问于2020-05-21得票数 0
我正在尝试理解Flink中的并行性是如何工作的。这个文档似乎表明接收器的并行度等于1。在我的例子中，我在接收器中写入HBase -这是否意味着只有一个任务(线程？)哪个将写入HBase？它是否没有获得为应用程序设置的全局并行度？
浏览 2修改于2019-10-04得票数 1
我使用的是elasticsearch版本1.4.1和flume版本1.5.2，它们都在我的机器上本地运行agent.sinks.elasticSearchSink.type= org.apache.flume.sink.elasticsearch.ElasticSearchSinkagent.sinks.
浏览 4提问于2015-03-15得票数 0
回答已采纳
result: @escaping ((Result<Self.Output, Self.Failure>) -> Void)) -> AnyCancellable {
return sink
浏览 20修改于2022-09-20得票数 0
回答已采纳
寻找一个Spring Cloud Stream SFTP解决方案(Sink)来从DB中SFTP字节流，这将是cron调度在CF上。
浏览 19提问于2020-10-21得票数 0
回答已采纳
我在Datafactory中有一个复制活动，它动态地映射表A和表B中的文件之间的列。表A有8列，这8列使用映射json变量映射到表B中12列中的8列。此json是创建要在复制活动中使用的映射变量的活动的输出。但是，当我运行管道时，所有映射都可以正常工作，但是最初位于接收器(4)中的非映射列消失了。是否有一种方法可以将这些列保留在活动中并保持其不变？
浏览 2提问于2022-05-13得票数 0
1回答
我知道Google只作为I/O支持、BigQuery、Avro文件或Pub/Sub中的一个文件。现在，我必须将数据迁移到BigQuery，或者编写完整的管道I/O实现，然后才能知道Google是否是解决当前问题的可行方案。
浏览 1修改于2016-05-23得票数 1
回答已采纳
我正在尝试使用在web.config中可配置的Server来设置一个Serilog记录器。示例：我下载了serilog的MSSQL扩展，它以类似(C#)的代码工作：
public ILogger Log = new LoggerConfiguration().WriteTo.MSSqlServer(@"Serv
浏览 1修改于2015-11-04得票数 3
回答已采纳
1回答
在医生里，我读到：
val sink = Sink.foreach(println)val transformed_source= source.map(n => n * 10).alsoTo(sink</e
浏览 2修改于2019-03-04得票数 0
newtype Sink p = Sink {unSink :: MVar (E.Iteratee (Message p) IO ())}
?deriving instance Eq (Sink p)
附言:我读过这篇文章，但它超出了我理解的能力范围
浏览 2提问于2012-11-13得票数 0
回答已采纳
1回答
我是新的组合和Sink，然而，我在其中放置的打印似乎没有日志，但行动的结果完成，因为用户是在AWS放大器内创建。value: email)] let sinkAmplify.Auth.signUp(username: email, password: password, options: options)
.resultPublisher.sink)"
浏览 9修改于2021-01-13得票数 2
回答已采纳
我正在试着建库。alljoyn音频接收器，但在构建此文件时有错误。[armeabi] Compile++ arm : AllJoynSink <= AndroidJNIBridge.ccmake.exe: *** [obj/local/armeabi/objs/AllJoynAudioSink/AndroidJNIBridge.o] Error 1
浏览 2提问于2014-07-01得票数 0
回答已采纳
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号