You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "waittting (Jira)" <ji...@apache.org> on 2021/12/14 11:30:00 UTC
[jira] [Created] (FLINK-25303) LookupTableSource/TableFunction
waittting created FLINK-25303:
---------------------------------
Summary: LookupTableSource/TableFunction
Key: FLINK-25303
URL: https://issues.apache.org/jira/browse/FLINK-25303
Project: Flink
Issue Type: Bug
Reporter: waittting
Hello, I need to implement LookupTableSource in my code, so I created a class
{code:java}
public LookupRuntimeProvider getLookupRuntimeProvider(LookupContext context) {
CCDynamicLookUpFunction = new CCDynamicLookUpFunction();
returnTableFunctionProvider.of(tableFunction);
} {code}
{code:java}
public class CCDynamicLookUpFunction extends TableFunction<RowData> {} {code}
In the class CCDynamicLookUpFunction, I have fetched my data and executed the collect func
{code:java}
public void eval(Object... keys) {
RowData row = dataReader.getNext();
System.out.println(row.toString());
collect(row);
}{code}
I'm sure the row is not null.
But I find that the data I've collected doesn't seem to have any effect
{code:java}
+I(17978,2020-03-23T00:00:00.189760,F,A,true,0,-32768,-2147483648,-9223372036854775808,-18446744073709551616,-3.1,-3.14,-3.141291000)
+I(17978,2020-03-23T00:00:00.189760,F,A,true,0,-32768,-2147483648,-9223372036854775808,-18446744073709551616,-3.1,-3.14,-3.141291000)
| +I | -2147483648 | e0f22c444f807abbd6a38ac0fc2... | 2021-12-14T11:09:46.772 | (NULL) | (NULL) | (NULL) | (NULL) | (NULL) | (NULL) | (NULL) | (NULL) | (NULL) | (NULL) | (NULL) | (NULL) | (NULL) |
{code}
Can you tell me why?
--
This message was sent by Atlassian Jira
(v8.20.1#820001)