org.apache.spark.mllib.stat.test

Class StreamingTest

java.lang.Object

org.apache.spark.mllib.stat.test.StreamingTest

All Implemented Interfaces:

java.io.Serializable, Logging

public class StreamingTest
extends java.lang.Object
implements Logging, scala.Serializable

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
StreamingTest()

Method Summary

Methods

Modifier and Type	Method and Description
DStream<org.apache.spark.mllib.stat.test.StreamingTestResult>	registerStream(DStream<BinarySample> data)
JavaDStream<org.apache.spark.mllib.stat.test.StreamingTestResult>	registerStream(JavaDStream<BinarySample> data)
StreamingTest	setPeacePeriod(int peacePeriod)
StreamingTest	setTestMethod(java.lang.String method)
StreamingTest	setWindowSize(int windowSize)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.spark.Logging

initializeIfNecessary, initializeLogging, isTraceEnabled, log_, log, logDebug, logDebug, logError, logError, logInfo, logInfo, logName, logTrace, logTrace, logWarning, logWarning

Constructor Detail

StreamingTest

public StreamingTest()

Method Detail

setPeacePeriod

public StreamingTest setPeacePeriod(int peacePeriod)

setWindowSize

public StreamingTest setWindowSize(int windowSize)

setTestMethod

public StreamingTest setTestMethod(java.lang.String method)

registerStream

public DStream<org.apache.spark.mllib.stat.test.StreamingTestResult> registerStream(DStream<BinarySample> data)

registerStream

public JavaDStream<org.apache.spark.mllib.stat.test.StreamingTestResult> registerStream(JavaDStream<BinarySample> data)