[
https://issues.apache.org/jira/browse/FLINK-3874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15416892#comment-15416892
]
ASF GitHub Bot commented on FLINK-3874:
---------------------------------------
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/2244#discussion_r74386541
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/Row.scala
---
@@ -31,6 +31,10 @@ class Row(arity: Int) extends Product {
def setField(i: Int, value: Any): Unit = fields(i) = value
+ def getField(i: Int): Any = fields(i)
--- End diff --
Why did you add those methods? `productArity` and `productElement` already
do what you want.
> Add a Kafka TableSink with JSON serialization
> ---------------------------------------------
>
> Key: FLINK-3874
> URL: https://issues.apache.org/jira/browse/FLINK-3874
> Project: Flink
> Issue Type: New Feature
> Components: Table API & SQL
> Reporter: Fabian Hueske
> Assignee: Ivan Mushketyk
> Priority: Minor
>
> Add a TableSink that writes JSON serialized data to Kafka.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
