tajo icon indicating copy to clipboard operation
tajo copied to clipboard

TAJO-1502: Implement SerDe for Kafka Storage.

Open hys9958 opened this issue 10 years ago • 1 comments

Hi, I have implemented for this issue and unit tests. It implemented based on TextLineSerDe. So can be use other SerDe of based in TextLineSerDe like JsonLineSerDe. You can specify SerDe when create table. like this,

CREATE TABLE <table_name> [(<column_name>
<data_type>, ... )]
using kafka with ('kafka.serde'='org.apache.tajo.storage.json.JsonLineSerDe')

Default SerDe is DelimitedSerDe.

Thanks.

hys9958 avatar Apr 01 '15 16:04 hys9958

Thanks for your contribution. I'll review this within a few days.

blrunner avatar Apr 05 '15 13:04 blrunner