Skip to content
This repository was archived by the owner on May 12, 2021. It is now read-only.

TAJO-1502: Implement SerDe for Kafka Storage.#495

Open
hys9958 wants to merge 3 commits intoapache:masterfrom
hys9958:TAJO-1502
Open

TAJO-1502: Implement SerDe for Kafka Storage.#495
hys9958 wants to merge 3 commits intoapache:masterfrom
hys9958:TAJO-1502

Conversation

@hys9958
Copy link
Contributor

@hys9958 hys9958 commented Apr 1, 2015

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.

@blrunner
Copy link
Contributor

blrunner commented Apr 5, 2015

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

Sign up for free to subscribe to this conversation on GitHub. Already have an account? Sign in.

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants