specify it. If it is only a readable table, an
> > >> exception can be thrown when write to it. As the source/sink tag can
> be
> > >> omitted in CREATE TABLE, could we skip it and only support CREATE
> TABLE
> > in
> > >> the first version, and add it b
sed for?
> >>>>>>>>
> >>>>>>>>
> >>>>>>>> The features could be supported and discussed in the future:
> >>>>>>>> (1) period definition on table
> >>>>>>>> (2) Type DDL
> >>>&
gt;> I think summarizing it into a google doc is a good idea. We
> >> will
> >>>>>> prepare
> >>>>>>> it
> >>>>>>>> in the next few days.
> >>>>>>>>
> >>>>>
this field
> > > should
> > > > already exist in the schema (we can use computed-column to derive
> from
> > > > other fields). The “AS” keyword defines watermark strategy, such as
> > > BOUNDED
> > > > WITH OFFSET (covers almost all the requirements) and AS
@Shuyi
Thanks for the proposal! We have a simple DDL implementation (extends
Calcite's parser) which been running for almost two years on production and
works well.
I think the most valued things we'd learned is keeping simplicity and
standard compliance.
Here's the approximate grammar, FYI
CREATE
Hi XiangWei,
Currently one could implement a udtf to achieve that. (see
https://ci.apache.org/projects/flink/flink-docs-release-1.4/dev/table/udfs.
html#table-functions)
BTW, this udtf should carefully dealing with the connections to database
server(s), and enable caching if possible can reduce se
Hi everybody,
I'd like to propose and discuss some api changes to support DML
operations like ‘insert into’ clause in TableAPI&SQL.
Originally this was discussed with Fabian in the PR conversations(see
https://github.com/apache/flink/pull/3829), considering it makes several
api changes, so star
. Please go
> ahead and open an issue for re-adding the throw.
>
> On Wed, 22 Feb 2017 at 13:28 Lin Li wrote:
>
> > Thank you for the answer!
> >
> > The discussion on FLINK-1023 is very clear to me. I agree with that
> throws
> > a TraversableOnceExceptio
Thank you for the answer!
The discussion on FLINK-1023 is very clear to me. I agree with that throws
a TraversableOnceException when the iterator is requested the second time.
@Aljoscha git history shows you removed the exception-thrown code from
FLINK-1110, would you mind me create an issue and
Hi,
When I try to implement https://issues.apache.org/jira/browse/FLINK-5498
via "dataset.coGroup(another dataset)" with a generated
CoGroupFunction.(CoGroupFunction
interface: public void coGroup(Iterable first, Iterable second,
Collector out)
I couldn't get the right results, then I sa
10 matches
Mail list logo
