to me, window slide duration (4) is streaming context
batch duration (1) *2. So, what's the problem?
Spark-v1.0.0
--
From RFC 2631: In ASN.1, EXPLICIT tagging is implicit unless IMPLICIT
is explicitly specified
--
From RFC 2631: In ASN.1, EXPLICIT tagging is implicit unless IMPLICIT
()
===
Seems all right to me, window slide duration (4) is streaming context
batch duration (1) *2. So, what's the problem?
Spark-v1.0.0
--
From RFC 2631: In ASN.1, EXPLICIT tagging is implicit unless IMPLICIT
is explicitly specified
--
From RFC 2631: In ASN.1, EXPLICIT tagging is implicit unless
My relevant code is:
===
ssc = new StreamingContext(conf, Seconds(1))
val messageEvents = events.
flatMap(e = evaluatorCached.value.find(e)).
window(Seconds(8), Seconds(4))
messageEvents.print()
===
Seems all right to me, window slide duration (4
()
===
Seems all right to me, window slide duration (4) is streaming context
batch duration (1) *2. So, what's the problem?
Spark-v1.0.0
--
From RFC 2631: In ASN.1, EXPLICIT tagging is implicit unless IMPLICIT is
explicitly specified
is:
===
ssc = new StreamingContext(conf, Seconds(1))
val messageEvents = events.
flatMap(e = evaluatorCached.value.find(e)).
window(Seconds(8), Seconds(4))
messageEvents.print()
===
Seems all right to me, window slide duration (4) is streaming context
= events.
flatMap(e = evaluatorCached.value.find(e)).
window(Seconds(8), Seconds(4))
messageEvents.print()
===
Seems all right to me, window slide duration (4) is streaming context
batch duration (1) *2. So, what's the problem?
Spark-v1.0.0
--
From RFC 2631
= evaluatorCached.value.find(e)).
window(Seconds(8), Seconds(4))
messageEvents.print()
===
Seems all right to me, window slide duration (4) is streaming context
batch duration (1) *2. So, what's the problem?
Spark-v1.0.0
--
From RFC 2631: In ASN.1, EXPLICIT tagging is implicit unless