feathub
feathub copied to clipboard
alibaba
FeatHub - A stream-batch unified feature store for real-time machine learning
Users should also be able to specify whether a build-side entry can be deleted after it is successfully matched with a probe-side event. As an example user side, let's say...
kafka_utils.py: ```python # TODO: Kafka Source throw exception when define a UDF computed column as # row time attribute. We only compute the timestamp here without defining # the row...
BoundedKafkaDynamicSource should be removed after FLINK-24456 resolved.
RedisSinkFunction.java ```java @Override public void close() { // TODO: Remove the registered script from Redis when Redis supports removing a certain // script. client.close(); } ```
Flink protobuf format has problem with map datatype https://issues.apache.org/jira/browse/FLINK-32008
message.proto ```proto message FileSystemTestMessage { // TODO: We have to add a dummy field with type int64 at the beginning, // otherwise exception will be thrown. // https://issues.apache.org/jira/browse/FLINK-31944 ``` ```proto...
In files like `nyc_example.py`, when creating a FeathubClient, apart from listing all the configuration parameters in the format of a dict variable, it should also be supported to read the...