Skip to content

Alink version 1.1.2
Compare
Choose a tag to compare
@xuyang1706 xuyang1706 released this 08 Jun 15:21
· 205 commits to master since this release
v1.1.2
dcdd78b
  1. Add transformers among formats Vector, CSV, Json, KV, Columns and Triple #93
    • Support AnyToAny transformation
    • Unified transformation params and easy use.
  2. Support SQL select statements in the Pipeline and LocalPredictor #61
    • Support flink planner built-in functions regarding individual rows: comparison, logical, arithmetic, string, temporal, conditional, type conversion, hash, etc.
    • Add alink_shaded/shaded_protobuf_java to support usage of native Calcite.
  3. Support Hive source and sink #96
    • Support Batch/Stream source&sink of Hive.
    • Support partition of table.
    • Simplify the dependence of Hive jar.
    • Support multiple versions: 2.0, 2.1, 2.2, 2.3, 3.0
  4. Fix PyAlink starting and UDF issues on Windows #76, #77
  5. Support BigInteger type in MySql source #86
  6. Add open and close in mapper. #92
  7. Add open function in SegmentMapper and StopwordsRemoverMapper #94
  8. Unify HandleInvalid Params #95
Assets 4
Loading