flink-cep

1열

1답변

우수 클럽 개발 라이브러리 X가 val pattern = Pattern.begin("start").where(_.value == "X") .next("end).where(_.value == "Y") Y. 뒤에 경우는 간단합니다 말할 수있는 설명하는 프로그램을 작성 할 수 있습니다 문제가되지 않는 FLINK CEP 프로그램을 작성하는 방법 그러나 내가 어떻게

0열

1답변

Flink CEP에서 "every"패턴 연산자를 사용하는 방법

Esper CEP 엔진 이벤트 패턴에는 Every 연산자가 있습니다.이 연산자는 every 키워드로 정규화 된 하위 표현식이 true 또는 false로 평가 될 때 패턴 하위 표현식이 다시 시작되어야 함을 나타냅니다. According to this document, 우리는 같은 다른 방법으로 every 연산자를 사용할 수 있습니다 : A -> B

0열

2답변

어떻게 subtype()을 flink cep에서 튜플 링합니까?

Pattern< Tuple3< String, String, String >, ? > pattern = Pattern.<Tuple3< String, String, String > > begin("start") .next("3").where(new FilterFunction< Tuple3< String, String, String > >()

1열

1답변

TaskManager가 실패 할 때 예상되는 HA 동작

1 개의 JobManager와 2 개의 TaskManagers로 구성된 HA Flink v1.2 클러스터를 자체 VM (YARN 또는 hdfs를 사용하지 않음)에 각각 만들었습니다. JobManager 노드에서 작업을 시작하면 하나의 TaskManager 인스턴스가 종료됩니다. 즉시 웹 대시 보드에서 작업 취소 및 실패를 볼 수 있습니다. 나는 로그를 확인

0열

1답변

TaskManager 용 Flink 상태 백엔드

저는 1 개의 JobManager와 2 개의 TaskManagers를 가진 Flink v1.2 설정을 가지고 있습니다. 각 TaskManagers는 자체 VM입니다. 상태 백엔드를 파일 시스템으로 구성하고 위의 각 호스트 (state.backend.fs.checkpointdir : file : /// home/ubuntu/Prototype/flink/fli

1열

1답변

플립 크 및 동적 템플릿 인식

일부 동적 템플릿에 따라 많은 양의 이벤트를 처리하기 위해 Flink CEP를 사용할 계획입니다. 시스템은 이벤트 체인을 인식해야합니다 (조건 및 그룹화가있는 복잡한 체인). 템플릿은 사용자가 만듭니다. 즉, 코드를 건드리지 않고 복잡한 템플릿을 만들어야합니다. 이 문제를 해결하기 위해 Apache Flink를 사용할 수 있습니까? Filnk는 동적 템플릿

2열

1답변

execute()를 호출 한 후 FLINK CEP에 새로운 패턴을 추가 할 수 있습니까?

내 코드는 다음과 같다 : StreamExecutionEnvironment env= StreamExecutionEnvironment.getExecutionEnvironment(); DataStream<MyObject> input = env.addSource(new MyCustomSource()); Pattern<MyObject, ?> pattern

0열

1답변

쌍으로 이전에 일치하는 이벤트를 찾을 때 Flink 이벤트를 내 보냅니다.

두 개의 이벤트 스트림이 있습니다. 하나는 항목의 수명 시작을 알리는 이벤트를 내보내는 이벤트이고, 다른 하나는 항목의 수명이 끝났음을 알리는 이벤트를 보내는 스트림입니다. . 해당 시작 가 어떻게 각 itemId1만 이벤트에 "수명의 끝"을 가지고위한 FLINK에 새로운 이벤트를 방출 할 수있다 (스트림의이. itemId에 가입 할 수있다), 그리고? (

0열

1답변

세 번째 이벤트를 기반으로 Flink에서 두 이벤트 연결

두 이벤트가 Flink로 스트리밍되는 경우, 다음 이벤트 (DataStream API 또는 CEP 사용)의 정보를 사용하여 논리적으로 조인 될 수 있습니까? 예 : 아래 예제의 세 번째 이벤트는 right_id 및 left_id를 기반으로 처음 두 이벤트를 연결하는 데 사용할 수 있습니까? ID: AAAA ID: BBBB ID: ZZZZ, right_i

1열

1답변

Flink-CEP에서 hashCode와 같음 사용

패턴 정의에 속성 수준 비교 만있는 경우 비교를 위해 Flink-CEP에서 hashCode()과 equals()을 사용합니까? hashCode()의 정확성을 보장 할 수 없으므로 문의하는 중입니다.