내가 스프링을 사용하고 SpringXDTemplate xdTemplate = new SpringXDTemplate(new URI("http://my.ip:9393"));
List<JobExecutionInfoResource> listJobExecutions = xdTemplate.jobOperations().listJobExecutions();
ecl
ReentrantLock을 SpringXD에서의 작업에 추가하려고 시도하지만 가끔씩 스레드 간 중단이있는 것으로 보입니다. 예를 들어 , 나는이 코드를 가지고 : public class LoadGenerator extends MessageProducerSupport {
private final AtomicBoolean running = new Atomi
jar 파일로 패키지 된 spring xd 모듈이 있습니다. 모듈을 시작할 때 텍스트 파일을 리소스에 저장하고 해당 파일의 데이터를 읽으려고합니다. 내가 지금까지 시도 무엇 는 Thread.currentThread().getClass().getClassLoader().getResource("file")
Thread.currentThread().ge
Spring-XD 내부 데이터베이스에 저장된 내용을 줄이려고합니다. 전체적으로 500,000 개의 항목이 서버의 용량을 오버로드하기 때문에. 매 4 일마다시, 분, 초 따라서, 나는 아래와 같이 절단 할 필요가 예정되어있는 많은 작업 실행의 기록에서 IO 너무 많은 : truncate springxd.batch_step_execution_context;
구현이 가능합니까 (dsl 쿼리 작성)? source은 sink 처리가 완료되지 않은 동안 대기해야합니다. sink - 완료 ->source이 시작됩니다. 예 : 모든 정보는 DB (first stream)에 저장되어있는 경우에만 뭔가를해야 할 몇 가지 정보 (jdbc sink) Second stream을 dB로 작성 First stream. 나는이 순간에
팀, 현재 spring-xd에서 데이터 분석 및 원사 작업의 런타임 컨테이너로 사용하고 있습니다. 내 질문 1) 나는 봄-XD에 사용되는 것과 동일한 환경 설정을 활용할 수 있습니까? 2) 문서에서 마이크로 서비스로 배포 할 수 있으며 스트림 처리에 내장 된 드라이버를 사용하고 있습니까? 임베디드 드라이버를 사용하는 경우 spring-xd와 동일한 인프라
일부 HTTP 리소스를 소비하고 포스트그레스에 쓰고 마지막으로 메시지 버스 (RabbitMQ)에 메시지를 푸는 모듈을 만들고 있습니다. 모듈 내에서 트랜잭션을 처리하는 방법을 알고 싶습니다. 내 포스트그레스 작업을 캡슐화하고 RabbitMQ로 푸시하는 방법 (예 : 메시지를 RabbitMQ로 푸시 할 수없는 경우 내 DB 작업을 롤백해야 함)? 감사합니다.
단일 시스템에서 스프링 XD admin 및 XD 컨테이너를 실행하는 중 이상한 문제가 발생합니다. 환경 변수를 내 보내지 않으면 spring_profiles_active XD admin 및 XD 컨테이너가 예상대로 제대로 작동하지만 xd 컨테이너가 포트 바인드 예외를 throw하는이 환경 변수를 추가 할 때 예외 스택 추적 here을 찾으십시오. xd-co
스프링 클라우드 데이터 플로우 문서가 주요하게 준비 될시기에 대한 모든 업데이트. 완전한 개발자 설명서 없이는 앞으로 중요한 배포를 계획하는 것이 정말 어렵습니다. Spring Cloud Data Flow는 Spring XD를 많이 사용하기 때문에 Spring XD 문서를 사용하여 완성 될 때까지 어떤 방식 으로든 도움이 될 것입니다. 감사합니다.
저는 스프링 XD에 초보자입니다. 특정 디렉토리에서 파일을 구문 분석하고 오라클 테이블에 출력을 푸시하는 요구 사항이 있습니다. 스프링 XD에서이를 달성 할 수 있습니까? 직접적으로 그렇지 않다면, 스프링 부트/통합/배치 어플리케이션을 생성하고 Sprig XD에 같은 것을 배치 할 수 있습니까? 감사합니다, Pratik