spring-xd

0열

1답변

스프링 XD : 애그리 게이터 작성 중. 비동기 적으로 출력하는 방법, 적어도 1 : 1로 출력하지 않는 방법?

제목별로 수집기 변환기 모듈을 작성하는 모범 사례, 예제 등이 있습니까? 우리는 집계가 데이터의 타임 스탬프를 기반으로하며 데이터가 순서가 뒤늦거나 늦을 수도 있고 너무 늦게 고려 될 수도 있습니다. "너무 늦은"경우에는 filter을 사용하여 트랜스포머를보기 전에 제거 할 계획입니다. 그러나 이것은 기본적인 질문으로 이어집니다. - 어 그리 게이터의 출력

0열

2답변

봄-XD는 HDFS

내 마지막 논문에서 일하고 있어요 을 트위터에서 스트림을 기록하지 않습니다와 나는 봄-XD에 문제가 : 내 XD - 쉘에서 실행 : 을 --deploy | "로그인 --track = twitterstream ', 마일리 사이러스를 마일리 사이러스'"그리고 그것은 작동 스트림은 --name cyrustweets --definition을 만들 수 있습니다. 내

0열

2답변

봄 XD DIST 작업은 지점에서 만들 때 실패

gradlew DIST -xtest -xjavadoc -xsetupui 마스터에서 DIST는 빌드가 성공. 브랜치에서 실행 중일 때, 실패합니다. 브랜치를 리모컨으로 푸시했는데, 왜 gradle 태스크가 원격 브랜치에 대해 알아야하는지 잘 모르겠습니다. -xpullDocs를 사용하여 성공적으로 실행할 수 있습니다. "wikiBranch"속성과 관련이 있습니

0열

1답변

봄 xd에 단일 메시지에서 여러 메시지를 생성하는 방법은 무엇입니까?

봄 xd와 함께 이것을 달성하는 방법? 입력 메시지 : { "키": "온도", "키 1": "ABC"} 출력 메시지 (내 요구 사항) : { "키": "온도", "키 1" "a"} { "key": "temp", "key1": "b"} { "key": "temp", "key1": "c"} [참고 : 스플리터는 전체 페이로드를 입력으로 사용합니다.]

1열

1답변

스프링 XD - 모듈 "source : trigger"가 예상대로 작동하지 않습니다.

"source : trigger"모듈이 Spring XD에서 작동하는 방법에 대해 약간 혼란 스럽습니다. 설명서를 기반으로 시작 날짜와 고정 지연을 제공 할 수 있으며 이론적으로 트리거를 정의하는 스트림은 해당 시간에만 시작하고 고정 지연에 따라 반복되어야합니다. 예를 들어 : 배포하면,이 스트림이 날짜 형식을 사용합니다 (12/08/14에 23시 35분

1열

1답변

Spring XD Json에서 Java로 변환하기위한 사용자 정의 ObjectMapper 사용

사용자 정의 ObjectMapper (Jackson)를 사용하여 JSON 페이로드를 Java 객체로 변환하는 쉬운 방법이 있습니까? 아니면 사용자 정의 유형 변환기를 제공해야합니까? 프로세서를 사용할 수는 있지만 스트림 정의의 입력 및 출력 유형을 사용하는 것이 좋을 것입니다. 두 번째 경우 : Java 용 application/json에 대한 사용자 정의

0열

1답변

spring-xd에 정의 된 스트림에서 여러 인스턴스가있는 모듈에서 다른 옵션 값을 지정하는 방법은 무엇입니까?

예를 들어, Spring-XD에서 스트림을 'source1 | sink1 ' 이고'source1 '모듈에는'option1 '옵션이 있습니다. 'source1'을 여러 인스턴스로 구성하는 것 (이것은 Spring-XD에서 수행 가능함)과 동시에 'source1'의 각 인스턴스가 서로 다른 값을 갖도록하고 싶습니다. '옵션 1'. 현재 사용 가능한 DSL 디자

1열

1답변

spring xd jms 소스의 Activemq 와일드 카드 지원?

I ', 스프링 xd 1.1과 함께 activemq 5.9 사용. 나는 activemq 주제를 구독하고 싶다. 그래서 jms 소스를 사용하고 있습니다. Activemq는 *,>와 같은 와일드 카드를 지원합니다. >은이 이름에서 시작하는 대상을 재귀 적으로 일치시키는 데 사용됩니다. 다음과 같이 jms 소스를 구독하는 동안이 와일드 카드를 사용하려고합니다.

0열

1답변

봄-XD -

내가이 스프링 XD 코드에 의해 파일에 트윗을 기록 스트림 생성 "Twittersearch"로 데이터를 스트리밍하려고 오류 : 불행하게도 stream create --name javatweets --definition "twittersearch --query=java --consumerKey=<my_key> --consumerSecret=<my_secre

0열

2답변

스프링 XD의 1.1.0.M2 난 그냥 spring-xd-1.1.0.M2.zip 다운로드하고 설치하려면 아래 링크에 대한 지침을 따라

시작하는 데 실패 그게 유일한 전제 조건입니다). 내가 스프링 XD를 시작하려고하면 , 그것은 아래의 예외와 함께 실패합니다 C : \ 소프트웨어 \ 봄-XD-1.1.0.M2 \ XD \ bin에> XD-singlenode Started : SingleNodeApplication Documentation: https://github.com/spring-p