Re: Equivalent of emptyDataFrame in StructuredStreaming

2018-11-17 Thread Arun Manivannan
Hi Jungtaek, Sorry about the delay in my response and thanks a ton for responding. I am just trying to build a data pipeline which has a bunch of stages. The goal is to use a Dataset to accumulate the transformation errors that may happen in the stages of the pipeline. As a benefit, I can pass o

Re: Equivalent of emptyDataFrame in StructuredStreaming

2018-11-05 Thread Jungtaek Lim
Could you explain what you're trying to do? It should have no batch for no data in stream, so it will end up to no-op even it is possible. - Jungtaek Lim (HeartSaVioR) 2018년 11월 6일 (화) 오전 8:29, Arun Manivannan 님이 작성: > Hi, > > I would like to create a "zero" value for a Structured Streaming Data

Equivalent of emptyDataFrame in StructuredStreaming

2018-11-05 Thread Arun Manivannan
Hi, I would like to create a "zero" value for a Structured Streaming Dataframe and unfortunately, I couldn't find any leads. With Spark batch, I can do a "emptyDataFrame" or "createDataFrame" with "emptyRDD" but with StructuredStreaming, I am lost. If I use the "emptyDataFrame" as the zero value