public class StreamingLogisticRegressionSuite extends org.apache.spark.SparkFunSuite implements TestSuiteBase
Constructor and Description |
---|
StreamingLogisticRegressionSuite() |
Modifier and Type | Method and Description |
---|---|
void |
afterFunction() |
int |
maxWaitTimeMillis() |
StreamingContext |
ssc() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
actuallyWait, batchDuration, beforeFunction, checkpointDir, conf, eventuallyTimeout, framework, master, numInputPartitions, runStreams, runStreamsWithPartitions, setupStreams, setupStreams, testOperation, testOperation, testOperation, testOperation, useManualClock, verifyOutput, withStreamingContext, withTestServer
initializeIfNecessary, initializeLogging, isTraceEnabled, log_, log, logDebug, logDebug, logError, logError, logInfo, logInfo, logName, logTrace, logTrace, logWarning, logWarning
public int maxWaitTimeMillis()
maxWaitTimeMillis
in interface TestSuiteBase
public StreamingContext ssc()
public void afterFunction()
afterFunction
in interface TestSuiteBase