问题标签 [sink]
For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.
r - RStudio / R:sink()在哪里保存我的文件
我在 RStudio 中运行分析并使用 sink 将输出存储在文件中,因为行数太大而无法从控制台手动复制它。代码是:
现在,我在哪里可以找到我机器上的 filename.txt 文件?
谢谢
sql-server - Serilog 可配置 SQL Server 接收器
我正在尝试使用可在web.config
.
有没有办法以例如滚动文件接收器的方式做到这一点?
例子:
我已经下载了MSSQL
serilog 的扩展,它可以在 (C#) 之类的代码中运行:
但不喜欢:
当然有可能解决这个问题,但我仍然想知道这是否可能,出于好奇心和更好看的代码。
有没有人让它工作?
感谢回复
r - 将每次运行 for 循环的控制台输出保存在单独的文件中
我想将每次运行 for 循环的控制台输出保存在单独的文本文件中。我正在做以下事情。
但是一段时间后我收到了一个错误
最有效的方法是什么?
r - r cat 命令生成输出,其中 /t 解释为 /t 而不是制表符
我想使用以下命令生成类似“我想测试\ttab”的输出,但输出是“我想测试选项卡”。我希望 \t 在那里而不是被解释为制表符分隔符。有没有办法做到这一点?任何人都可以帮忙吗?非常感谢您!
谢谢,R
hdfs - 水槽事件被截断
这里我遇到一个问题,我从Kafka源接收消息,并编写一个拦截器从kafka消息(json格式)中提取两个字段(dataSoure和businessType)。这里我使用 gson.fromJson()。但问题是我得到了以下错误。
这里我想知道Flume是否会在超过限制时截断Flume事件?如果是,如何将其设置为更大的值。因为我的 kafka 消息总是很长,大约 60K 字节。
期待回复。提前致谢!
2015-12-09 11:48:05,665 (PollableSourceRunner-KafkaSource-apply) [错误 - org.apache.flume.source.kafka.KafkaSource.process(KafkaSource.java:153)] KafkaSource 异常,{} com.google。 gson.JsonSyntaxException: com.google.gson.stream.MalformedJsonException: com.google.gson.Gson.fromJson(Gson.java:809) com.google.gson.Gson.fromJson(Gson) 的第 1 行第 4096 列未终止的字符串.java:761) 在 com.xxx.flume.interceptor.JsonLogTypeInterceptor.intercept(JsonLogTypeInterceptor.java:43) 在 com.xxx.flume.interceptor 的 com.google.gson.Gson.fromJson(Gson.java:710)。 JsonLogTypeInterceptor.intercept(JsonLogTypeInterceptor.java:61) 在 org.apache.flume.interceptor.InterceptorChain.intercept(InterceptorChain.java:62) 在 org.apache.flume.channel.ChannelProcessor。org.apache.flume.source.kafka.KafkaSource.process(KafkaSource.java:130) 上的 processEventBatch(ChannelProcessor.java:146)
r - 运行 R 脚本时创建警告日志文件
我想为 R 脚本创建警告/错误日志。
请看下面的例子:
我期待它会列出所有警告:
警告消息:
1:在日志中(i - 50):产生了 NaN
2:在日志中(i - 50):产生了 NaN
3:在日志中(i - 50):产生了 NaN
但是对于 1:30 中的循环 i,all.rout 文件中只有一行:
有 30 个警告(使用 warnings() 来查看它们)
知道如何解决吗?
我创建了基于另一个主题的代码:
r - 保存 r 脚本的输出,包括其命令
我想将我的 r 脚本输出的一部分(包括命令)保存到文本文件中。我知道 sink()
,但它不包含命令,或者我找不到执行此操作的特定选项。
是否有可能在r 会话中捕获命令及其输出。简单地编写一个 Rmd 或在控制台中捕获输出不是目前的解决方案。
character - Flume:Kafka Sink 和控制角色
我正在尝试使用 Flume 1.6 读取我的源文件(管道分隔的文本文件)并将它们提供给 kafka。
所有管道似乎都工作正常,所有记录都成功进入卡夫卡。但是,Flume 似乎在每个数据行的开头添加了 NUL 和 STX 控制字符。
这对我来说有点问题,因为最终我将所有数据从 Kafka 流式传输到 Amazon S3,最后进入 Amazon Redshift。由于这些控制字符,我将数据加载到 Redshift(COPY 命令)失败。
我花了相当多的时间在互联网上研究这个问题,但到目前为止还没有运气。我可以以某种方式指示 Flume 不要在我的源数据中添加这些字符吗?
我的 Flume 配置如下。我已经尝试过“exec”和“spoolDir”来源,但没有任何改变。
任何帮助表示赞赏。
谢谢普拉维什
r - 为什么使用接收器函数保存到文件返回空文件
我尝试使用 sink() 函数将屏幕文本保存到文件中。该文件已创建但其中没有任何数据。我做错了什么?这是我的玩具代码:
c++ - 将 g++ 编译错误消息从 TMB 库导出到文本文件
我正在尝试在 R 中使用 gcc (c++) 编译模型(使用 TMB 包)。错误如此之多,以至于在 Rstudio 中,我什至无法向上滚动查看它们的开头。因此,我想将控制台中的所有内容(消息、错误和警告)打印到文本文件中。这样我还可以比较不同的模型输出(或者特别是它们的失败)。
我尝试了以下事情:
=> 给我一个空文件(我或多或少预期)
=> 只打印最终错误
我忽略了什么?