works now! thanks much!
On Wed, Apr 19, 2017 at 2:05 PM, kant kodali wrote:
> oops my bad. I see it now! sorry.
>
> On Wed, Apr 19, 2017 at 1:56 PM, Marcelo Vanzin
> wrote:
>
>> I see a bunch of getOrCreate methods in that class. They were all
>> added in SPARK-6752, a long time ago.
>>
>> On W
oops my bad. I see it now! sorry.
On Wed, Apr 19, 2017 at 1:56 PM, Marcelo Vanzin wrote:
> I see a bunch of getOrCreate methods in that class. They were all
> added in SPARK-6752, a long time ago.
>
> On Wed, Apr 19, 2017 at 1:51 PM, kant kodali wrote:
> > There is no getOrCreate for JavaStream
I see a bunch of getOrCreate methods in that class. They were all
added in SPARK-6752, a long time ago.
On Wed, Apr 19, 2017 at 1:51 PM, kant kodali wrote:
> There is no getOrCreate for JavaStreamingContext however I do use
> JavaStreamingContext inside createStreamingContext() from my code in th
There is no *getOrCreate *for JavaStreamingContext however I do use
JavaStreamingContext inside createStreamingContext() from my code in the
previous email.
On Wed, Apr 19, 2017 at 1:46 PM, Marcelo Vanzin wrote:
> Why are you not using JavaStreamingContext if you're writing Java?
>
> On Wed, Apr
Why are you not using JavaStreamingContext if you're writing Java?
On Wed, Apr 19, 2017 at 1:42 PM, kant kodali wrote:
> Hi All,
>
> I get the following errors whichever way I try either lambda or generics. I
> am using
> spark 2.1 and scalla 2.11.8
>
>
> StreamingContext ssc = StreamingContext.g
Hi All,
I get the following errors whichever way I try either lambda or generics. I
am using
spark 2.1 and scalla 2.11.8
StreamingContext ssc = StreamingContext.getOrCreate(hdfsCheckpointDir,
() -> {return createStreamingContext();}, null, false);
ERROR
StreamingContext ssc = StreamingContext.
