/odps_sink

odps_sink for flume

Primary LanguageJava

odps_sink

A plugin for Flume to provide ODPS sink (ODPS is a product of Aliyun)

Usage

  • Run mvn clean package to build jar
  • Put the jar to lib folder of Flume, with ODPS related jar
  • Modify conf file

Roadmap

  • Support minute level partition
  • Configurable sink schema
  • Change behavior of splitting records by \n to a more general pupose way

Authors && Contributors

shaolianjie waqu