Github user tonycox commented on a diff in the pull request:
https://github.com/apache/flink/pull/3040#discussion_r105600606
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/dataset/forwarding/FieldForwardingUtils.scala
---
@@ -0,0 +1,143
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/3040
@fhueske I fixed commented points.
Could you explain the join keys forwarding?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If
Github user tonycox commented on a diff in the pull request:
https://github.com/apache/flink/pull/3127#discussion_r105972317
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/Types.scala
---
@@ -17,29 +17,34 @@
*/
package
Github user tonycox commented on a diff in the pull request:
https://github.com/apache/flink/pull/3127#discussion_r105972293
--- Diff:
flink-core/src/main/java/org/apache/flink/api/java/typeutils/Types.java ---
@@ -0,0 +1,53 @@
+/*
+ * Licensed to the Apache Software
Github user tonycox closed the pull request at:
https://github.com/apache/flink/pull/3297
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
Github user tonycox commented on a diff in the pull request:
https://github.com/apache/flink/pull/3269#discussion_r106208275
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/util/RexProgramProjectExtractor.scala
---
@@ -84,6 +108,49 @@ object
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/3269
Hi @fhueske I've addressed all comments
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this fe
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/3127
Hi @StephanEwen
I added javadoc
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
Github user tonycox closed the pull request at:
https://github.com/apache/flink/pull/3166
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
Github user tonycox commented on a diff in the pull request:
https://github.com/apache/flink/pull/3127#discussion_r106647040
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/Types.scala
---
@@ -17,29 +17,51 @@
*/
package
Github user tonycox commented on a diff in the pull request:
https://github.com/apache/flink/pull/3127#discussion_r106668425
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/Types.scala
---
@@ -17,29 +17,51 @@
*/
package
Github user tonycox commented on a diff in the pull request:
https://github.com/apache/flink/pull/3127#discussion_r106862331
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/Types.scala
---
@@ -17,29 +17,51 @@
*/
package
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/3269
@fhueske What dou you think about this PR?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/3127
@StephanEwen I fixed
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so
GitHub user tonycox opened a pull request:
https://github.com/apache/flink/pull/2810
[FLINK-3848] Add ProjectableTableSource interface and translation rule.
Extend CsvTableSource to implement projection
You can merge this pull request into a Git repository by running:
$ git
Github user tonycox commented on a diff in the pull request:
https://github.com/apache/flink/pull/2810#discussion_r88841542
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/dataset/BatchTableProject.scala
---
@@ -0,0 +1,67
Github user tonycox commented on a diff in the pull request:
https://github.com/apache/flink/pull/2810#discussion_r88849756
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/dataset/BatchTableProject.scala
---
@@ -0,0 +1,67
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/2810
> In addition, the TableSource should know project information (including
order) not just fieldIncluded. So maybe we should also adapt RowCsvInputFormat.
Do you mean we need to shuffle fi
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/2810
@wuchong I added noticed items
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/2810
@wuchong could you review my changes?
cc @fhueske @StephanEwen
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/2810
Hi @wuchong , thank you for the review.
Do you mean only for `Stream`?
And why we shouldn't to override computeSelfCost for DataStreamRel ?
---
If your project is set up for it, yo
Github user tonycox commented on a diff in the pull request:
https://github.com/apache/flink/pull/2810#discussion_r90010696
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/rules/dataSet/BatchProjectableTableSourceScanRule.scala
---
@@ -0,0
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/2810
Hi @fhueske , I see conflicts PR check, should I rebase new commits, or
merge it?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/2810
@wuchong, @fhueske, question about field shuffling, should I shuffle it in
RowCsvInputFormat by setting an order to scan, or let LogicalCal do it?
---
If your project is set up for it, you can
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/2810
I see. @fhueske. Set an order of scaning is much better way.
I have problem when plan is choosing. Best expression is not correct. Rules
work, but planner decides to choose `MapFunction` anyway
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/2810
Hi @fhueske, your PR do solve my problem. Thanks!
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/2810
@fhueske Basically yes, but I think we need finish projection rule for
Stream, after FLINK-5251 merging
---
If your project is set up for it, you can reply to this email and have your
reply appear
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/2810
Hi @fhueske and @KurtYoung I totally agree with the plan
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/2810
#2926
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the
Github user tonycox commented on a diff in the pull request:
https://github.com/apache/flink/pull/2968#discussion_r91548803
--- Diff:
flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowComparator.java
---
@@ -0,0 +1,698 @@
+/*
+ * Licensed to the
Github user tonycox commented on a diff in the pull request:
https://github.com/apache/flink/pull/2968#discussion_r91544114
--- Diff:
flink-core/src/main/java/org/apache/flink/api/java/typeutils/RowTypeInfo.java
---
@@ -0,0 +1,176 @@
+/*
+ * Licensed to the Apache
Github user tonycox commented on a diff in the pull request:
https://github.com/apache/flink/pull/2968#discussion_r91550465
--- Diff: flink-core/src/main/java/org/apache/flink/types/Row.java ---
@@ -0,0 +1,118 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF
Github user tonycox commented on a diff in the pull request:
https://github.com/apache/flink/pull/2968#discussion_r91551621
--- Diff:
flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowComparator.java
---
@@ -0,0 +1,698 @@
+/*
+ * Licensed to the
Github user tonycox commented on a diff in the pull request:
https://github.com/apache/flink/pull/2968#discussion_r91547968
--- Diff:
flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowComparator.java
---
@@ -0,0 +1,698 @@
+/*
+ * Licensed to the
Github user tonycox commented on a diff in the pull request:
https://github.com/apache/flink/pull/2968#discussion_r91547877
--- Diff:
flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowComparator.java
---
@@ -0,0 +1,698 @@
+/*
+ * Licensed to the
Github user tonycox commented on a diff in the pull request:
https://github.com/apache/flink/pull/2968#discussion_r91546359
--- Diff:
flink-core/src/main/java/org/apache/flink/api/java/typeutils/RowTypeInfo.java
---
@@ -0,0 +1,176 @@
+/*
+ * Licensed to the Apache
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/2923
Hi @fhueske, this PR looks good to me
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
Github user tonycox commented on a diff in the pull request:
https://github.com/apache/flink/pull/2968#discussion_r91670483
--- Diff:
flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowComparator.java
---
@@ -326,8 +326,8 @@ public int getNormalizeKeyLen
Github user tonycox commented on a diff in the pull request:
https://github.com/apache/flink/pull/2968#discussion_r91674126
--- Diff:
flink-core/src/main/java/org/apache/flink/api/java/typeutils/RowTypeInfo.java
---
@@ -0,0 +1,202 @@
+/*
+ * Licensed to the Apache
Github user tonycox commented on a diff in the pull request:
https://github.com/apache/flink/pull/2968#discussion_r91704437
--- Diff:
flink-core/src/main/java/org/apache/flink/api/java/typeutils/RowTypeInfo.java
---
@@ -0,0 +1,202 @@
+/*
+ * Licensed to the Apache
Github user tonycox commented on a diff in the pull request:
https://github.com/apache/flink/pull/2968#discussion_r91721721
--- Diff:
flink-core/src/main/java/org/apache/flink/api/java/typeutils/RowTypeInfo.java
---
@@ -0,0 +1,202 @@
+/*
+ * Licensed to the Apache
Github user tonycox commented on a diff in the pull request:
https://github.com/apache/flink/pull/2968#discussion_r91748535
--- Diff: flink-core/src/main/java/org/apache/flink/types/Row.java ---
@@ -0,0 +1,110 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/2968
Hi @wuchong, maybe we should move `RowCsvInputFormat` also
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not
Github user tonycox commented on a diff in the pull request:
https://github.com/apache/flink/pull/2968#discussion_r91941722
--- Diff: flink-core/src/main/java/org/apache/flink/types/Row.java ---
@@ -0,0 +1,110 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/2968
@fhueske Yes. I already started
https://github.com/tonycox/flink/tree/FLINK-5188
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/2810
Hi @fhueske , what should I finish first, this PR or FLINK-5188 ?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project
GitHub user tonycox opened a pull request:
https://github.com/apache/flink/pull/3003
[Flink-5188] Create analog of RowCsvInputFormat in java and adjust all the
imports of Row and RowTypeInfo
Thanks for contributing to Apache Flink. Before you open your pull request,
please take
GitHub user tonycox opened a pull request:
https://github.com/apache/flink/pull/3004
[Flink-5189] Delete Row and its related classes from table api
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideration
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/3003
Hi @fhueske okay, as you wish
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/2926
@fhueske is there any sense to createcost optimization for Stream?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project
GitHub user tonycox opened a pull request:
https://github.com/apache/flink/pull/3012
[FLINK-2186] Add readCsvAsRow methods to CsvReader and scala ExecutionEnv
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/2810
@fhueske I update this PR according to last changes in master
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does
GitHub user tonycox opened a pull request:
https://github.com/apache/flink/pull/3018
[FLINK-5336] Remove IOReadableWritable interface from Path
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideration
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/3020
Hi @wuchong , in this case I think you should adapt `getFieldIndex`
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/3020
@wuchong sorry, my fault, didn't spot duplicate field names checkers. What
about cases, Is flink-table case-sensitive?
---
If your project is set up for it, you can reply to this email and
GitHub user tonycox opened a pull request:
https://github.com/apache/flink/pull/3027
[FLINK-5358] add RowTypeInfo exctraction in TypeExtractor
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideration.
If
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/3012
Hi @StephanEwen could you look at this PR?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/3760
@ramkrish86 Hi, Thank you for the PR. Could you repush commit?
```
git commit --amend
gut push origin FLINK-5752 -f
```
---
If your project is set up for it, you can reply to this
GitHub user tonycox opened a pull request:
https://github.com/apache/flink/pull/2686
[FLINK-4743] The sqrt/power function not accept the real data types.
Add supporting of variety types on "power" function. Add casting for Float
and BigDecimal.
You can merge this pull re
Github user tonycox commented on a diff in the pull request:
https://github.com/apache/flink/pull/2686#discussion_r85514611
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/api/table/expressions/PowerExpressionTest.scala
---
@@ -0,0 +1,149
GitHub user tonycox opened a pull request:
https://github.com/apache/flink/pull/2720
[FLINK-4623] Create Physical Execution Plan of a DataStream
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/tonycox/flink FLINK-4623
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/2686
Hi @wuchong
I agree that users can cast types manually. And that
BuiltInMethods.POWER_DEC should be bound power(double, BigDecimal), but it's
trouble of Calcite https://issues.apach
Github user tonycox closed the pull request at:
https://github.com/apache/flink/pull/2686
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
GitHub user tonycox reopened a pull request:
https://github.com/apache/flink/pull/2686
[FLINK-4743] The sqrt/power function not accept the real data types.
Add supporting of variety types on "power" function. Add casting for Float
and BigDecimal.
You can merge this pu
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/2686
Hi @wuchong , native java implementation of "power" function suits to most
cases. So i deleted POWER_DEC from flink, because it has no proper types.
Actually we don't make use
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/2686
@wuchong if choosing second option, why not to solve this issue
https://issues.apache.org/jira/browse/CALCITE-1468 instead of solve on flink
side ?
---
If your project is set up for it, you can
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/2686
I agree with @wuchong that we need create a new issue in JIRA for
supporting `BigDecimal` in functions (`log`,`ln`,`exp` etc), but I suppose that
if problem in calcite with `DECIMAL` is done we will
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/2686
@wuchong, second option supports only in SQL. in table api we still cast
manually.
in first option where should I create power(double, BigDecimal) function,
which package or util class
Github user tonycox commented on a diff in the pull request:
https://github.com/apache/flink/pull/2686#discussion_r86081029
--- Diff:
flink-libraries/flink-table/src/main/java/org/apache/flink/api/table/functions/utils/MathFunctions.java
---
@@ -0,0 +1,29
Github user tonycox commented on a diff in the pull request:
https://github.com/apache/flink/pull/2686#discussion_r86090398
--- Diff:
flink-libraries/flink-table/src/main/java/org/apache/flink/api/table/functions/utils/MathFunctions.java
---
@@ -0,0 +1,29
Github user tonycox commented on a diff in the pull request:
https://github.com/apache/flink/pull/2686#discussion_r86108721
--- Diff:
flink-libraries/flink-table/src/main/java/org/apache/flink/api/table/functions/utils/MathFunctions.java
---
@@ -0,0 +1,29
Github user tonycox commented on a diff in the pull request:
https://github.com/apache/flink/pull/3012#discussion_r100337562
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/io/CsvReaderITCase.java ---
@@ -122,6 +127,80 @@ public void testValueTypes() throws Exception
Github user tonycox commented on a diff in the pull request:
https://github.com/apache/flink/pull/3012#discussion_r10033
--- Diff:
flink-scala/src/main/scala/org/apache/flink/api/scala/ExecutionEnvironment.scala
---
@@ -348,6 +349,47 @@ class ExecutionEnvironment(javaEnv
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/3012
@ex00 Thank you for review,
If typeMap does not match with fields type in file it will fall with
`ParseException`.
But if `Double parser` try to parse an integer it will be okay.
Do
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/3149
@ramkrish86 what is your environment?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/3149
@ramkrish86 Try to add
```
-XX:+HeapDumpOnOutOfMemoryError
-XX:HeapDumpPath="/tmp"
```
as parameter of JVM
---
If your project is set up for it, you can reply to
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/3127
I think I should rename this issuea to "Simplify Row creation".
What do you think?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitH
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/3271
Hi @huawei-flink,
please name your PR with "[FLINK-XXX] Jira title text" pattern
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitH
GitHub user tonycox opened a pull request:
https://github.com/apache/flink/pull/3297
[FLINK-5431] Add configurable timePattern for client akka status
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideration
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/3149
@ramkrish86 You can use jhat to read hprof dump file.
If set `-XX:MaxPermSize=128m`
```xml
org.apache.maven.plugins
maven-surefire-plugin
2.19.1
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/3012
@ex00 default value of any empty field is null
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/3149
@ramkrish86 java8 has different memory model,
https://dzone.com/articles/java-8-permgen-metaspace
---
If your project is set up for it, you can reply to this email and have your
reply appear on
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/3166
Hi @fhueske,
what do you think about this PR?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/3040
Hi,
Do we need field forwarding in `DataSetMinus`, `DataSetIntersect` and
`DataSetSort`?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/3166
@fhueske could you look at this approach of transfering `RexNode` to
`Expression`, it's stil in wip state, but I need your adjustment
---
If your project is set up for it, you can reply to
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/3127
@StephanEwen @twalthr What do you think about this PR ?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/3040
@fhueske @KurtYoung @twalthr What do you think about this PR ?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/3297
@zentol What do you think about this PR ?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/3166
Hi @fhueske I cant continue on this PR, have not enough time for now. If
you need implementation of it immediately I will unassign
---
If your project is set up for it, you can reply to this email
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/3027
Hi @fhueske could you look at this PR?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
Github user tonycox commented on a diff in the pull request:
https://github.com/apache/flink/pull/3027#discussion_r93848593
--- Diff:
flink-core/src/test/java/org/apache/flink/api/java/typeutils/TypeExtractorTest.java
---
@@ -345,8 +346,25 @@ public CustomType cross(CustomType
GitHub user tonycox opened a pull request:
https://github.com/apache/flink/pull/3044
[FLINK-5388] Change private Graph.() to protected
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideration.
If your
Github user tonycox closed the pull request at:
https://github.com/apache/flink/pull/3018
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
GitHub user tonycox opened a pull request:
https://github.com/apache/flink/pull/3127
[FLINK-5481] Add type extraction from collection
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideration.
If your
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/243
Is this PR still alive?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/243
Ok, cool. I can go through abandoned PRs and add them to
https://issues.apache.org/jira/browse/FLINK-5384. Wouldn't you mind @fhueske ?
---
If your project is set up for it, you can reply to
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/3127
@zentol I rewrite as you pointed
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/3149
You need to recompile `TableSource` trait manually and implement
`DefinedFieldNames` in `HBaseTableSource`
---
If your project is set up for it, you can reply to this email and have your
reply
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/3149
@ramkrish86 @fhueske what do you think about to throw `Tuple` (`T extends
Tuple`) out of `org.apache.flink.addons.hbase.TableInputFormat` and implement
this abstract class in your
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/3149
I think it can be solved in different issue to provide a new api in
`table.api` for selecting from HBase
---
If your project is set up for it, you can reply to this email and have your
reply appear
1 - 100 of 142 matches
Mail list logo
