sink

1열

1답변

다른 변수의 결과를 출력하기 위해 R로 텍스트 파일을 만드는 방법은 무엇입니까?

R 스크립트에서 텍스트 파일을 내보내려면 어떻게해야합니까? 결과에 관계없이 인쇄 할 텍스트를 미리 설정하고 싶지만 텍스트 파일에서 변경할 수있는 변수를 추가하고 싶습니다. 이 작업을 수행하는 방법을 알고있는 유일한 방법은 sink 및 cat을 사용하는 것입니다. 문제는 각 독립 줄마다 cat을 만들어야한다는 것입니다. 각 줄마다 cat을 사용하지 않고 큰

0열

1답변

R foreach 스레드를 동일한 로그 파일에 쓰는 방법

각 스레드가 다른 스레드와 독립적으로 작동하도록 foreach-dopar와 병렬 처리 할 긴 작업이 여러 개 있습니다. sink을 사용하여 로그 파일에 기록하여 각 스레드의 상태를 추적하려고합니다 (일부는 다른 스레드가 성공할 경우 실패 할 수 있습니다). 다음은 분명히 작동하지 않습니다. 로그 파일에는 하나의 항목 만 있습니다. 잘못된 무엇 ....sav

5열

1답변

싱크대를 사용하고 R에서 메시지를 인쇄하려면 어떻게해야합니까?

나는 다음과 같은 코드로, 승압 사용 sink 함수의 로그를 저장하려고 : require(xgboost) require(R.utils) data(iris) train.model <- model.matrix(Sepal.Length~., iris) dtrain <- xgb.DMatrix(data=train.model, label=iris$Sepal.

1열

1답변

동일한 CSV 파일 (R)에서 다른 크기의 데이터 프레임을 추가하십시오.

해결 방법을 찾을 수 없습니다. 나는 많은 데이터 프레임 (더 큰 데이터 프레임의 서브 세트)을 가지고있다. a b c 3,4 good HJJR 및 cod x c utc country jhh34s 5 HJJR +1 Poland jhh22d 0 JJHE +1 Poland 그리고 난 그저과 같이 하나의 CSV 파일을 싱크 싶습니다 a b

0열

1답변

두 데이터베이스의 스프링 클라우드 스트림 작성하기

나는 하나의 소스, 하나의 변환기가있는 스프링 클라우드 스트림 상황이 있으며 두 데이터베이스에 똑같은 것을 써야합니다. 나는 2 개의 싱크가있는 선택권이 있는지 검사하고 있었다 그러나 나는 그것을하는 방법을 찾아 낼 수 없다. 제 사례에 대한 모범 사례가 있으면 큰 도움이 될 것입니다.

2열

2답변

spark 2.2 struct 스트리밍 foreach 작성자 jdbc 싱크 지연

나는 spark 2.2 struct streaming을 사용하여 kafka msg를 oracle 데이터베이스로 읽는 프로젝트에 있습니다. kafka 로의 메시지 흐름은 초당 약 4000-6000 개의 메시지입니다. hdfs 파일 시스템을 싱크 대상으로 사용하는 경우에는 정상적으로 작동합니다. foreach jdbc writer를 사용할 때 시간이 지남에 따

1열

1답변

kafka couchbase sink 커넥터가 일부 레코드를 덤프 한 후 연결이 끊어졌습니다.

confluent_3.3.0을 설치하고 zookeper, schema-registry 및 kafka broker를 시작했습니다. 아래 링크 https://github.com/couchbase/kafka-connect-couchbase 에서 그리고 다운로드 카우치베이스 주식회사 커넥터가 커넥터를 실행 한 후 명령 ./bin/connect-standalone

0열

2답변

커스텀 StatsD를 사용하여 실행 프로그램을 구성하는 방법 Spark 메트릭 싱크

Executor 용으로 StatsD sink에 Spark Streaming 메트릭을 싱크하려면 어떻게해야합니까? 다른보고 된 문제 (sink class not found, sink class in executor)와 유사 , 나는 드라이버 통계를 얻을 수 있지만, 집행 내 설치를 ClassNotFoundException을 던져 : StatsD sink 클래

0열

1답변

flush 에이전트 (syslogs 소스 및 hbase 싱크 포함)

나는 flume을 syslogs 소스 및 hbase 싱크와 함께 사용하려고합니다. 내가 flume agent를 실행할 때 나는이 오류를 얻는다 : Failed to start agent because dependencies were not found in classpath. Error follows. java.lang.NoClassDefFoundError:

1열

1답변

C# Serilog는 오류 후 전자 메일 만받습니다.

Serilog 싱크를 사용하고 있습니다. Serilog.Sinks.Email. 나는 이메일을 받는다. 불행히도 "정보"도 있습니다. 경고 오류이거나 치명적인 경우 먼저 이메일을 수신하고 싶습니다. 설정 방법이 있습니까? "정보"는 더 이상 전자 메일로 전송되지 않아야합니다. BUT .txt 파일에 정보를 다시 써야합니다. 경고, 오류 또는 치명적인 경우 전