Ecosyste.ms: Issues

An open API service for providing issue and pull request metadata for open source projects.

GitHub / alibaba/feathub issues and pull requests

#157 - Support keep_timestamp_field in Sinks

Pull Request - State: closed - Opened by yunfengzhou-hub over 1 year ago - 2 comments

#156 - Optimize RedisSource map lookup behavior

Pull Request - State: closed - Opened by yunfengzhou-hub over 1 year ago - 1 comment

#155 - Support partially updating hash/map in RedisSink

Pull Request - State: closed - Opened by yunfengzhou-hub over 1 year ago - 2 comments

#154 - Set HiveSource to streaming mode

Pull Request - State: closed - Opened by yunfengzhou-hub over 1 year ago - 3 comments

#153 - Support timestamp comparison when writing data to Redis

Issue - State: open - Opened by yunfengzhou-hub over 1 year ago
Labels: type:feature

#152 - Support Redis key expr without feature name

Pull Request - State: closed - Opened by yunfengzhou-hub over 1 year ago

#151 - Run nightly with different python versions

Pull Request - State: closed - Opened by Sxnan over 1 year ago - 3 comments

#150 - Support TOP_N aggregation function

Issue - State: open - Opened by lindong28 over 1 year ago
Labels: type:feature

#149 - Support grouping multiple materialize_features() into one job

Pull Request - State: closed - Opened by Sxnan over 1 year ago - 5 comments

#147 - Support Redis lookup join in FlinkProcessor

Pull Request - State: closed - Opened by yunfengzhou-hub over 1 year ago - 4 comments

#146 - Add IT test joining SlidingFeatureView with FileSystemSource

Pull Request - State: closed - Opened by Sxnan over 1 year ago - 1 comment

#144 - Improve error message when the timestamp field contains corrupted data

Issue - State: open - Opened by Sxnan over 1 year ago
Labels: type:improvement

#143 - Improve doc for aggregation functions

Pull Request - State: closed - Opened by lindong28 over 1 year ago - 2 comments

#142 - Support custom key in Redis connector

Pull Request - State: closed - Opened by yunfengzhou-hub over 1 year ago - 2 comments

#141 - Introduce MAP and JSON_STRING builtin functions

Pull Request - State: closed - Opened by Sxnan over 1 year ago - 3 comments

#140 - Support COLLECT_LIST in Flink and local processor

Pull Request - State: closed - Opened by yunfengzhou-hub over 1 year ago - 2 comments

#139 - [hotfix] Update RedisSink write and flush logic

Pull Request - State: closed - Opened by yunfengzhou-hub over 1 year ago - 2 comments

#138 - Support python 3.8, 3.9 and 3.10 with nightly CI

Issue - State: closed - Opened by lindong28 over 1 year ago

#137 - Add from_json to TableDescriptors

Pull Request - State: closed - Opened by yunfengzhou-hub over 1 year ago - 1 comment

#136 - Add support for MySqlRegistry

Pull Request - State: closed - Opened by yunfengzhou-hub over 1 year ago - 1 comment

#135 - Support Redis data types in Redis connector

Pull Request - State: closed - Opened by yunfengzhou-hub over 1 year ago - 1 comment

#134 - Support user defined attributes in Feature and FeatureView

Pull Request - State: closed - Opened by Sxnan over 1 year ago - 3 comments

#133 - PythonUdfTransform supports default value on exception

Pull Request - State: closed - Opened by Sxnan over 1 year ago - 4 comments

#132 - Support cluster mode in Redis connector

Pull Request - State: closed - Opened by yunfengzhou-hub over 1 year ago - 1 comment

#131 - [hotfix] Set up jupyter dependency in e2e CI

Pull Request - State: closed - Opened by yunfengzhou-hub over 1 year ago - 1 comment

#130 - The QR code has expired，how to connect you ？

Issue - State: closed - Opened by VencentZhou over 1 year ago - 4 comments

#129 - Support HiveSource and HiveSink in FlinkProcessor

Pull Request - State: closed - Opened by yunfengzhou-hub over 1 year ago - 1 comment

#127 - FlinkProcessor FileSystem/Kakfa source/sink support protobuf format

Pull Request - State: closed - Opened by Sxnan over 1 year ago - 3 comments

#126 - Bump Flink version to 1.16

Pull Request - State: closed - Opened by Sxnan over 1 year ago - 3 comments

#125 - Support existing connectors with Spark local mode in LocalProcessor

Pull Request - State: closed - Opened by yunfengzhou-hub over 1 year ago - 3 comments

#123 - Support Hive as source and sink

Issue - State: closed - Opened by lindong28 over 1 year ago - 1 comment

#122 - Support commonly used formats for Kafka and FileSystem

Issue - State: open - Opened by lindong28 over 1 year ago - 1 comment
Labels: type:feature

#121 - Support sinking multiple feature tables into the same online store table

Issue - State: open - Opened by yunfengzhou-hub over 1 year ago
Labels: type:feature

#120 - Support handling columns with none values in OnlineMemoryStore

Issue - State: open - Opened by yunfengzhou-hub over 1 year ago
Labels: type:improvement

#119 - Apply Flink native configuration before creating tableEnv instance

Issue - State: closed - Opened by yunfengzhou-hub over 1 year ago - 1 comment

#118 - Improve document of timestamp and aggregation functions

Pull Request - State: closed - Opened by yunfengzhou-hub over 1 year ago - 2 comments

#117 - Add feature embedding and fraud detection notebook example

Pull Request - State: closed - Opened by yunfengzhou-hub over 1 year ago - 1 comment

#116 - Update validations of Spark/FlinkProcessor and FeatureView

Pull Request - State: closed - Opened by Sxnan over 1 year ago - 5 comments

#115 - Add notebook for quickstart example

Pull Request - State: closed - Opened by yunfengzhou-hub over 1 year ago - 1 comment

#114 - Update FlinkProcessor sink utils to avoid registering source/sink at table env

Pull Request - State: closed - Opened by Sxnan over 1 year ago - 2 comments

#113 - Cleanup staled or unnecessary TODOs

Pull Request - State: closed - Opened by Sxnan over 1 year ago - 2 comments

#112 - Update LocalProcessor to support FileSystemSink

Pull Request - State: closed - Opened by Sxnan over 1 year ago - 2 comments

#111 - Raise exception if the timestamp_field is specified but not found in the schema

Pull Request - State: closed - Opened by jiangxin369 over 1 year ago - 3 comments

#110 - LocalProcessor supports filtering in Derived/SlidingFeatureView

Pull Request - State: closed - Opened by Sxnan over 1 year ago - 5 comments

#109 - Add Notebook demo that users can use try directly online

Issue - State: closed - Opened by lindong28 over 1 year ago - 1 comment

#108 - Fix FlinkProcessor SlidingWindow deduplication logic with limit

Pull Request - State: closed - Opened by yunfengzhou-hub over 1 year ago

#107 - Support CASE and filtering in SparkProcessor

Pull Request - State: closed - Opened by yunfengzhou-hub over 1 year ago - 3 comments

#106 - Add filesystem connector docs

Pull Request - State: closed - Opened by jiangxin369 over 1 year ago - 3 comments

#105 - Update LocalProcessor to support CASE FeatHub expression

Pull Request - State: closed - Opened by Sxnan over 1 year ago - 4 comments

#104 - Add doc describing the built-in optimizations

Pull Request - State: closed - Opened by lindong28 over 1 year ago - 1 comment

#103 - Check if the schema contains timestamp field if timestamp_field is not None

Issue - State: open - Opened by jiangxin369 over 1 year ago
Labels: type:improvement

#102 - Update FlinkProcessor to_pandas to handle column with none values

Pull Request - State: closed - Opened by Sxnan over 1 year ago - 3 comments

#101 - Add Kafka connector docs

Pull Request - State: closed - Opened by Sxnan over 1 year ago - 2 comments

#100 - Improve docs of connectors

Pull Request - State: closed - Opened by Sxnan over 1 year ago - 2 comments

#99 - Add quickstart documentation for Spark processor

Pull Request - State: closed - Opened by jiangxin369 over 1 year ago - 3 comments

#98 - Add document for Redis connector

Pull Request - State: closed - Opened by yunfengzhou-hub over 1 year ago - 2 comments

#96 - Support creating FeathubClient from configuration file

Issue - State: open - Opened by yunfengzhou-hub over 1 year ago
Labels: type:feature

#95 - Update README.md

Pull Request - State: closed - Opened by lindong28 over 1 year ago - 3 comments

#94 - Support reordering of output features in feature view

Pull Request - State: closed - Opened by jiangxin369 over 1 year ago - 1 comment

#93 - LocalProcessor supports SlidingWindowTransform

Pull Request - State: closed - Opened by Sxnan over 1 year ago - 2 comments

#92 - MySQL source supports bounded scan and cdc

Issue - State: open - Opened by Sxnan over 1 year ago
Labels: type:feature

#91 - Introduce MySQLSource and MySQLSink

Pull Request - State: closed - Opened by Sxnan over 1 year ago - 5 comments

#90 - Support MemoryStoreSink in SparkProcessor and add quickstart document

Pull Request - State: closed - Opened by yunfengzhou-hub over 1 year ago - 3 comments

#89 - Disable generating .parser.out file when running Feathub programs.

Issue - State: open - Opened by yunfengzhou-hub over 1 year ago
Labels: type:improvement

#88 - Update examples and docs

Pull Request - State: closed - Opened by Sxnan over 1 year ago - 3 comments

#87 - Recognize empty sliding window record in sink and perform delete operation

Issue - State: open - Opened by yunfengzhou-hub over 1 year ago
Labels: type:feature

#86 - Add a class to keep track of all the built-in and user-defined func and agg func

Issue - State: open - Opened by Sxnan over 1 year ago
Labels: type:improvement

#85 - Allow users to use join transform and expression transform in the same string expression

Issue - State: open - Opened by lindong28 over 1 year ago
Labels: type:feature

#84 - Support materialize multiple feature views to multiple sinks in one feature job

Issue - State: closed - Opened by Sxnan over 1 year ago - 1 comment

#81 - Add check for Feathub license in Java and Python files

Issue - State: open - Opened by yunfengzhou-hub over 1 year ago
Labels: type:improvement

#80 - Refactor FlinkProcessor's sliding window logic

Pull Request - State: closed - Opened by yunfengzhou-hub over 1 year ago - 5 comments

#79 - Provide utility function to verify DataFrames

Issue - State: open - Opened by yunfengzhou-hub over 1 year ago
Labels: type:improvement

#78 - Verify that all Flink Processor tests can be run with kryo disabled and object-reuse enabled

Issue - State: open - Opened by lindong28 over 1 year ago - 1 comment
Labels: type:improvement

#77 - Support adding late data to sliding window in FlinkProcessor

Pull Request - State: closed - Opened by yunfengzhou-hub over 1 year ago - 4 comments

#76 - Supports join transformation on Spark processor

Pull Request - State: closed - Opened by jiangxin369 over 1 year ago - 2 comments

#75 - FeatureView overwrites feature in source

Pull Request - State: closed - Opened by Sxnan almost 2 years ago - 5 comments

#74 - Support SqlFeatureView in FlinkProcessor

Pull Request - State: closed - Opened by yunfengzhou-hub almost 2 years ago - 3 comments

#73 - Make Feature dtype optional

Pull Request - State: closed - Opened by Sxnan almost 2 years ago - 5 comments

#72 - Provide public API for users to register Python/Java UDF to be used in FeatHub expression

Issue - State: open - Opened by lindong28 almost 2 years ago
Labels: type:feature

#71 - Support reordering of features in FeatureView

Issue - State: closed - Opened by yunfengzhou-hub almost 2 years ago - 1 comment

#70 - Decouple connector plugin from framework code

Issue - State: open - Opened by yunfengzhou-hub almost 2 years ago
Labels: type:improvement

#69 - Support feature versioning

Issue - State: open - Opened by lindong28 almost 2 years ago
Labels: type:feature

#68 - Make Feature#dtype optional

Issue - State: closed - Opened by lindong28 almost 2 years ago

#66 - Support more generic filtering functionality

Issue - State: closed - Opened by yunfengzhou-hub almost 2 years ago - 1 comment

#65 - Support PythonUdfTransform in SparkProcessor

Pull Request - State: closed - Opened by yunfengzhou-hub almost 2 years ago - 1 comment

#64 - Document and test the timestamp_format supported by SlidingFeatureView and various sources

Issue - State: open - Opened by lindong28 almost 2 years ago
Labels: type:improvement

#63 - Support UNIX_TIMESTAMP in SparkProcessor

Pull Request - State: closed - Opened by yunfengzhou-hub almost 2 years ago - 2 comments

#62 - Add DataGenSource and BlackHoleSink for SparkProcessor

Pull Request - State: closed - Opened by yunfengzhou-hub almost 2 years ago - 1 comment

#61 - Fix FlinkProcessor IT failures by reorg file structure

Pull Request - State: closed - Opened by yunfengzhou-hub almost 2 years ago - 1 comment

#60 - Add test for BlackHoleSink and update sliding window test

Pull Request - State: closed - Opened by Sxnan almost 2 years ago - 2 comments

#59 - Unify tests for different Processors

Pull Request - State: closed - Opened by yunfengzhou-hub almost 2 years ago - 1 comment

#58 - Add OverWindowTransform for SparkProcessor

Pull Request - State: closed - Opened by jiangxin369 almost 2 years ago - 2 comments