Flink 실행 계획 UI에 표시 할 연산자, 소스, 싱크 및 패턴 이름 지정

Question

운영자와 소스에 이름을 지정하고 싶습니다. 의는 예를 들어

이 나는 ​​형태 FLINK 대시 보드를 촬영 한 것으로, 실행 계획의 스크린 샷이다 보자. 여기에 나는 DataStreams의 2 소스를 가지고 있고 그들과 합류하고있다. 제 질문은 이러한 소스를 EcgStream 및 Sp02 Stream과 같이 이름을 짓고 Join1 등으로 명명 할 수 있습니까?

이유 나는 시각화가 쉬워지기 때문에이 질문을하고 있습니다. 또한, 나는 페이지의 끝에서, Opsclarity 페이지 불구하고가는대로, 그들은 작업 _ 다음

주를 언급하고 OPERATOR_NAME는 대기 시간이있을 때 우리는 여전히 올바르게 작업 및 운영자를 구별 할 수 압축 한 은 작업 및 운영자에 걸쳐 집계됩니다. 그러나이 압축 된 이름은 이 Flink UI에 표시된 것과 일치하지 않습니다. 그러면 연산자 이름으로 스칼라 코드 조각이 표시됩니다. 이러한 이름이 미터법에서 의미가있는 인 경우,의 Flink 코드에 이름을 제공해야합니다. 이 압축 된 값은 매우 긴 기본 이름 인 경우에만 유효하며 그렇지 않은 경우 합법적 인 메트릭 값은 입니다.

나는 CEP에 대한 패턴을 만들 때 실행 계획 UI가 단지 패턴으로 표시된다는 점도 다른 질문이 있습니다. 그 패턴이 어떤 것인지 보여주는 어떤 방법이 있습니까 A B + C? D. 또한 패턴이 여러 개인 경우 패턴을 사용할 수 있어야합니다. 패턴 {1..n}

Answer 1

, 나는 소스 스트림에 UID를 추가 한이 UID의 또

sout가 3 이하의 결과

System.out.println("id for stream 1 is " + stream1.getId()); 

Answer 2

운영자에게 더 나은 이름을 지정하려면 the documentation을 참조하십시오. 이는 실행 계획을보다 읽기 쉽게 만들뿐만 아니라 애플리케이션이 발전함에 따라 세이브 포인트를보다 강력하게 복원 할 수 있기 때문에 수행해야하는 작업입니다 (docs). @alpinegizmo에 의해 제안

// getting RR interval stream 
DataStream<RRIntervalStreamEvent> rrIntervalStreamEventDataStream = envrionment.addSource(new RR_interval_Gen()).uid("RR interval stream"); 

// getting QRS interval stream 

DataStream<qrsIntervalStreamEvent> qrsIntervalStreamEventDataStream = envrionment.addSource(new Qrs_interval_Gen()).uid("qrs Interval stream"); 

을 다음 그러나 실행 그래프가 보여 그나마으로

Answer 3

이 문제는

// getting RR interval stream 
DataStream<RRIntervalStreamEvent> rrIntervalStreamEventDataStream = envrionment.addSource(new RR_interval_Gen()).name("RR Interval stream"); 


System.out.println("getting transformation for stream 1 = " + rrIntervalStreamEventDataStream.getTransformation()); 
// getting QRS interval stream 

DataStream<qrsIntervalStreamEvent> qrsIntervalStreamEventDataStream = envrionment.addSource(new Qrs_interval_Gen()).name("qrs Interval stream"); 

을 다음과 같이 출력 그래프