한 번에 하나의 키에 대해 단일 패턴을 사용할 수 있습니까? 예 : 나는 1 분 안에 어떤 조건을 만족시키는 5 가지 이벤트를 얻었는지 확인하고 최소 10 분의 이벤트를 얻으면 2 개의 경고를 얻어야하지만 6 개의 경고를 얻고 싶습니다. 모든 이벤트가 새로운 패턴을 유발하기 때문입니다. 한 번에 하나의 패턴 인스턴스를 키로 사용할 수 있습니까?
나는 아파치 FLINK (FLINK 1.3)에서 deltatrigger을 사용하고 싶지만이 코드 몇 가지 문제가 있습니다 .trigger(DeltaTrigger.of(100, new DeltaFunction[uniqStruct] {
override def getDelta(oldFp: uniqStruct, newFp: uniqStruct): Doub
나는 kafka 메시지를 읽고 AWS s3의 ORC 파일로 메시지를 덤핑하는 Flink 스트리밍 프로그램을 만들고 있습니다. Flink의 BucketingSink와 ORC 파일 작성자의 통합에 대한 문서는 발견되지 않았습니다. BucketingSink에서 사용할 수있는 그러한 ORC 파일 작성기 구현은 없습니다. 여기에 붙어있는 아이디어가 있습니까?
안녕하세요, 저는 다음과 같이 수신 데이터를 처리해야하는 Flink 작업을 실행하려고합니다. keyBy() 바로 뒤에있는 처리 연산자에서 데이터의 일부 속성에 따라 너무 많은 시간이 걸리는 경우가 있습니다. 들어오는 데이터에 다른 ID (스트림에 사용됨)가 있더라도 처리 함수의 긴 처리 코드는 다른 들어오는 데이터를 차단합니다. 전체 흐름을 의미합니다. R
지도 함수 (SCALA) 내에서 kafka 토픽에 쓰기? 나는 목록을 반복하고있는지도 기능 내 -지도 기능 문제 설명 내에서 데이터를 처리하는 FLINK 응용 프로그램 의 카프카 항목에서 읽기 . 목록의 각 요소에 대해 카프카 (kafka) 주제에 게시하고 싶습니다. 나는지도의 출력을 얻을 작동,하지만 난지도 방법 내에서 주제에 밀어 넣기를 시도하는 경우는
DataSet API를 사용하여 flink-connectors (flink-hbase_2.11)의 hbase TableInputFormat에서 Flink 1.3.2를 사용하고 있습니다. 는 I는 다음과 같이 rowkeys가 stuctured된다 HBase를 표 가지고 가 | RowKey | data |
| 0-someuniqid | data |
| 0
슬라이딩 창을 사용하여 EvenTime에서 이벤트를 처리하고 싶습니다. 슬라이딩 간격은 24 시간이고 증가분은 30 분입니다. 문제는 아래 코드가 각 이벤트에 대해 48 개의 계산을 생성하고 있다는 것입니다. 우리의 경우 이벤트가 순서대로오고 있으므로 최신 윈도우 만 평가하면됩니다. 감사합니다, 데얀 public static void processEvent
invoke 싱크대 방법은 비동기식 io를 만드는 방법이 아닙니다. 예 : Future을 반환합니까? 는 예를 들어, 레디 스 커넥터 동기 레디 스 명령을 실행하는 LIB jedis 사용 https://github.com/apache/bahir-flink/blob/master/flink-connector-redis/src/main/java/org/apach