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