flink-streaming

0열

1답변

Apache Flink : InvalidProgramException : 테이블 프로그램을 컴파일 할 수 없습니다.

단일 문자열 필드를 추출하려는 Avro 객체의 DataStream이있는 간단한 프로그램이 있습니다. DataStream을 Table으로 변환하고 간단한 투영법으로 쿼리를 실행합니다. (accepted_cohort_id, ADMIN_ID, after_submission : - : 2017년 11월 29일 16시 7분 36초 출처 :>에서 사용자 정의 소스 나

0열

1답변

apache flink 대시 보드에서 작업 이름을 사용자 정의하는 방법은 무엇입니까?

apache flink 대시 보드에서 작업 이름을 사용자 정의하고 싶습니다. 예를 들어 대시 보드에 작업 맵이있는 경우 이름은 MAP입니다. 특정 이름을 추가하려면 어떻게 변경합니까? 고마워요. 다음 예와 같이

0열

1답변

Flink 및 Event-Time 기반 스트림으로 평균값 계산

Flickink에서 역사적 이벤트를 기반으로 한 스트림으로 창 기반 평균 (또는 나로 정의 된 다른 모든 함수)을 계산하려면 스트림이 Event-Times 내가 섭취에 타임 스탬프를 추가하는 방법을 발견했다 val env: StreamExecutionEnvironment = StreamExecutionEnvironment.getExecutionEnviron

0열

1답변

한 번에 하나의 FLINK CEP 패턴 존재

한 번에 하나의 키에 대해 단일 패턴을 사용할 수 있습니까? 예 : 나는 1 분 안에 어떤 조건을 만족시키는 5 가지 이벤트를 얻었는지 확인하고 최소 10 분의 이벤트를 얻으면 2 개의 경고를 얻어야하지만 6 개의 경고를 얻고 싶습니다. 모든 이벤트가 새로운 패턴을 유발하기 때문입니다. 한 번에 하나의 패턴 인스턴스를 키로 사용할 수 있습니까?

0열

2답변

플립 크에서 델타 트리거를 사용하는 방법?

나는 아파치 FLINK (FLINK 1.3)에서 deltatrigger을 사용하고 싶지만이 코드 몇 가지 문제가 있습니다 .trigger(DeltaTrigger.of(100, new DeltaFunction[uniqStruct] { override def getDelta(oldFp: uniqStruct, newFp: uniqStruct): Doub

0열

1답변

이벤트 시간 기반 슬라이딩 창에 대한 최신 창만 확인하십시오.

슬라이딩 창을 사용하여 EvenTime에서 이벤트를 처리하고 싶습니다. 슬라이딩 간격은 24 시간이고 증가분은 30 분입니다. 문제는 아래 코드가 각 이벤트에 대해 48 개의 계산을 생성하고 있다는 것입니다. 우리의 경우 이벤트가 순서대로오고 있으므로 최신 윈도우 만 평가하면됩니다. 감사합니다, 데얀 public static void processEvent

2열

1답변

플립크 싱크가 바이오 만 지원합니까?

invoke 싱크대 방법은 비동기식 io를 만드는 방법이 아닙니다. 예 : Future을 반환합니까? 는 예를 들어, 레디 스 커넥터 동기 레디 스 명령을 실행하는 LIB jedis 사용 https://github.com/apache/bahir-flink/blob/master/flink-connector-redis/src/main/java/org/apach

0열

1답변

재사용이 스트림의 카피 예를 들어하지

이다, 키잉 스트림이 :이 FLINK 동일 스트림의 재사용 생각 val keyedStream: KeyedStream[event, Key] = env .addSource(...) .keyBy(...) // several transformations on the same stream keyedStream.map(....) keyedSt

0열

1답변

Apache Flink : Table API로 관계형 데이터베이스를 쿼리하는 방법은 무엇입니까?

다음 코드는이 blog post에서 가져온 것입니다 : val sensorTable = ??? // can be a CSV file, Kafka topic, database, or ... // register the table source tEnv.registerTableSource("sensors", sensorTable) 내가 관계형 데이터베이

1열

1답변

Apache Flink : 로컬 사전 집계를 사용하여 창을 계산하려면 어떻게해야합니까?

나는 DataStream을 가지고 있으며 그것에 창 집계를 계산해야합니다. 일반 창 집계를 수행 할 때 네트워크 IO가 매우 높습니다. 그래서 네트워크 IO를 줄이기 위해 로컬 사전 집계를 수행하고 싶습니다. 작업 관리자에서 로컬로 사전 집계 (즉, 레코드를 셔플 링하기 전에) 한 다음 전체 집계를 수행 할 수 있는지 궁금합니다. Flink의 DataStr