Github user stczwd commented on the issue:
https://github.com/apache/spark/pull/22575
I hive send an email to Ryan Blue.
> > > Can you send a mail to Ryan blue for adding this SPIP topic in
tomorrow meeting. Meeting will be conducted tomorrow 05:00 pm PST. If you
confirm
Github user sujith71955 commented on the issue:
https://github.com/apache/spark/pull/22575
> > Can you send a mail to Ryan blue for adding this SPIP topic in tomorrow
meeting. Meeting will be conducted tomorrow 05:00 pm PST. If you confirm then
we can also attend the meeting.
>
Github user stczwd commented on the issue:
https://github.com/apache/spark/pull/22575
> Can you send a mail to Ryan blue for adding this SPIP topic in tomorrow
meeting. Meeting will be conducted tomorrow 05:00 pm PST. If you confirm then
we can also attend the meeting.
I
Github user sujith71955 commented on the issue:
https://github.com/apache/spark/pull/22575
Can you send a mail to Ryan blue for adding this SPIP topic in tomorrow
meeting. Meeting will be conducted tomorrow 05:00 pm PST. If you confirm
then we can also attend the meeting.
Github user stczwd commented on the issue:
https://github.com/apache/spark/pull/22575
>
I have removed the 'stream' keyword.
> There is a DatasourceV2 community
Github user sujith71955 commented on the issue:
https://github.com/apache/spark/pull/22575
cc @koeninger
---
-
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional commands, e-mail:
Github user sujith71955 commented on the issue:
https://github.com/apache/spark/pull/22575
There is a DatasourceV2 community synch meetup tomorrow which is
Github user stczwd commented on the issue:
https://github.com/apache/spark/pull/22575
@sujithjay
Please refer
[SPARK-24630](https://issues.apache.org/jira/browse/SPARK-24630) for more
details.
---
-
To
Github user sujith71955 commented on the issue:
https://github.com/apache/spark/pull/22575
@stczwd Can you provide a detail design document for this PR, by mentioning
the cenarios is been handled and constraints if any. this wll give a complete
pitcture about this PR. Thanks
---
Github user stczwd commented on the issue:
https://github.com/apache/spark/pull/22575
@cloud-fan @zsxwing @tdas @xuanyuanking
This patch has been submitted for a long time. Do you have any questions?
Can this patch be merged in?
---
Github user stczwd commented on the issue:
https://github.com/apache/spark/pull/22575
> Currently Dataframe API support "writeStream.start()" api to run
streaming in background, so that query can be executed on that sink, also
multiple stream to stream processing can happen in single
Github user gvramana commented on the issue:
https://github.com/apache/spark/pull/22575
> > How should we do if we wanna join two kafka stream and sink the result
to another stream?
> > `insert into kafka_sql_out select stream t1.value from (select
cast(value as string),
Github user stczwd commented on the issue:
https://github.com/apache/spark/pull/22575
@tdas @zsxwing @cloud-fan
Hi, any other questions block this patch for merge in?
---
-
To unsubscribe, e-mail:
Github user shijinkui commented on the issue:
https://github.com/apache/spark/pull/22575
@cloud-fan Hi, Wenchen. Is it ready for merge in? This PR is very useful
and is what I want to develop and need.
Once Spark support StreamSQL, it will be easier for developping streaming
job.
Github user WangTaoTheTonic commented on the issue:
https://github.com/apache/spark/pull/22575
Nice! I am looking forward to it.
---
-
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional
Github user stczwd commented on the issue:
https://github.com/apache/spark/pull/22575
@WangTaoTheTonic @cloud-fan @xuanyuanking
I have removed the stream keyword. Table API is supoorted in SQLStreaming
now.
---
Github user AmplabJenkins commented on the issue:
https://github.com/apache/spark/pull/22575
Can one of the admins verify this patch?
---
-
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional
Github user stczwd commented on the issue:
https://github.com/apache/spark/pull/22575
> ql and normal sql? how could users define watermark with SQL?
Yes, the 'stream' keyword is the only difference from normal sql.
We can use configuration to define watermark.
---
Github user cloud-fan commented on the issue:
https://github.com/apache/spark/pull/22575
do we have a full story about stream sql? is the `STREAM` keyword the only
difference between stream sql and normal sql?
also cc @tdas @zsxwing
---
Github user cloud-fan commented on the issue:
https://github.com/apache/spark/pull/22575
do we have a full story about stream sql? is the `STREAM` keyword the only
difference between stream sql and normal sql? how could users define watermark
with SQL?
also cc @tdas @zsxwing
Github user cloud-fan commented on the issue:
https://github.com/apache/spark/pull/22575
do we have a full story about stream sql? is the `STREAM` keyword the only
difference between stream sql and normal sql? how could users define watermark
with SQL?
also cc @tdas @zsxwing
Github user cloud-fan commented on the issue:
https://github.com/apache/spark/pull/22575
do we have a full story about stream sql? is the `STREAM` keyword the only
difference between stream sql and normal sql? how could users define watermark
with SQL?
also cc @tdas @zsxwing
Github user cloud-fan commented on the issue:
https://github.com/apache/spark/pull/22575
do we have a full story about stream sql? is the `STREAM` keyword the only
difference between stream sql and normal sql? how could users define watermark
with SQL?
also cc @tdas @zsxwing
Github user cloud-fan commented on the issue:
https://github.com/apache/spark/pull/22575
Do we have a full story about streaming SQL? is the `STREAM` keyword the
only difference between stream sql and normal sql?
also cc @tdas @zsxwing
---
Github user stczwd commented on the issue:
https://github.com/apache/spark/pull/22575
cc @xuanyuanking
---
-
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional commands, e-mail:
Github user stczwd commented on the issue:
https://github.com/apache/spark/pull/22575
> How should we do if we wanna join two kafka stream and sink the result to
another stream?
`insert into kafka_sql_out select stream t1.value from (select cast(value
as string), timestamp as
Github user WangTaoTheTonic commented on the issue:
https://github.com/apache/spark/pull/22575
How should we do if we wanna join two kafka stream and sink the result to
another stream?
---
-
To unsubscribe, e-mail:
Github user stczwd commented on the issue:
https://github.com/apache/spark/pull/22575
@WangTaoTheTonic
Adding 'stream' keyword has two purposes:
- **Mark the entire sql query as a stream query and generate the
SQLStreaming plan tree.**
- **Mark the table type as
28 matches
Mail list logo
