A B C D E F G H I J K L M N O P Q R S T U V W Y Z

A

AbstractDatabase - Class in stream.lookup

This class is an abstract implementation of the LookupService which provides an in-memory lookup table that is populated from a data source.

AbstractDatabase() - Constructor for class stream.lookup.AbstractDatabase

AbstractLineStream - Class in stream.io

AbstractLineStream(SourceURL) - Constructor for class stream.io.AbstractLineStream

AbstractLineStream(InputStream) - Constructor for class stream.io.AbstractLineStream

AbstractLineStream() - Constructor for class stream.io.AbstractLineStream

AbstractMultiStream - Class in stream.io.multi

A simple multi stream implementation.

AbstractMultiStream(SourceURL) - Constructor for class stream.io.multi.AbstractMultiStream

AbstractMultiStream(InputStream) - Constructor for class stream.io.multi.AbstractMultiStream

AbstractMultiStream() - Constructor for class stream.io.multi.AbstractMultiStream

AbstractSQLProcessor - Class in stream.io

AbstractSQLProcessor() - Constructor for class stream.io.AbstractSQLProcessor

AbstractTreeFeature - Class in stream.data.tree

AbstractTreeFeature() - Constructor for class stream.data.tree.AbstractTreeFeature

activate() - Method in class stream.io.active.SimpleActiveStream

activate - Variable in class stream.io.multi.AbstractMultiStream

activator - Variable in class stream.io.active.SimpleActiveStream

activeWrapper - Variable in class stream.io.multi.AbstractMultiStream

add(Map<String, Integer>, Map<String, Integer>) - Method in class stream.data.tree.TreeEdges

add(TreeFeature) - Method in class stream.data.tree.TreeFeatures

add(Vector) - Method in class stream.data.vector.Vector

add(double, Vector) - Method in class stream.data.vector.Vector

add(Data, Data) - Static method in class stream.data.vector.VectorMath

Deprecated.

add(Data, double, Data) - Static method in class stream.data.vector.VectorMath

Deprecated.

add(Double, Stream) - Method in class stream.generator.MixedStream

add(T, T) - Method in class stream.learner.evaluation.ConfusionMatrix

Adds a classification instance (true and predicted label) to this ConfusionMatrix.

add(Data) - Method in class stream.net.DataTap.ClientHandler

add(Data) - Method in class stream.net.DataTap.ServerThread

add(Long, T) - Method in class stream.statistics.History

add(Long, Statistics) - Method in class stream.statistics.StatisticsHistory

addChild(TreeNode) - Method in class stream.parser.DefaultTreeParser.DefaultTreeNode

addData(String[], Data) - Method in class stream.data.storage.Store

addData(String[], Data) - Method in class stream.data.storage.StoreDataList

addEdge(String, String) - Method in class stream.data.graph.GraphProvider

addFalseNegative() - Method in class stream.learner.evaluation.TableOfConfusion

Short form of TableOfConfusion.addFalseNegative(1).

addFalseNegative(long) - Method in class stream.learner.evaluation.TableOfConfusion

Adds the amount specified by the argument delta to the internal data structure for the counting of false negative instances.

addFalsePositive() - Method in class stream.learner.evaluation.TableOfConfusion

Short form of TableOfConfusion.addFalsePositive(1).

addFalsePositive(long) - Method in class stream.learner.evaluation.TableOfConfusion

Adds the amount specified by the argument delta to the internal data structure for the counting of false positive instances.

additionOrder - Variable in class stream.io.multi.AbstractMultiStream

addLabel(T) - Method in class stream.learner.evaluation.ConfusionMatrix

Adds the provided label to the list of labels.

addLabels(List<T>) - Method in class stream.learner.evaluation.ConfusionMatrix

Adds the provided list of labels to the internal list of labels.

addMapping(Serializable, Serializable) - Method in class stream.data.MapValues

address - Variable in class stream.net.DataTap

address - Variable in class stream.net.TcpSender

address - Variable in class stream.net.UDPStream

addSparseVector - Variable in class stream.io.SvmLightStream

AddStatistics - Class in stream.statistics

AddStatistics() - Constructor for class stream.statistics.AddStatistics

addStream(String, Stream) - Method in class stream.io.multi.AbstractMultiStream

AddText - Class in stream.text

AddText() - Constructor for class stream.text.AddText

AddTimestamp - Class in stream.data

AddTimestamp() - Constructor for class stream.data.AddTimestamp

addTrueNegative() - Method in class stream.learner.evaluation.TableOfConfusion

Short form of TableOfConfusion.addTrueNegative(1).

addTrueNegative(long) - Method in class stream.learner.evaluation.TableOfConfusion

Adds the amount specified by the argument delta to the internal data structure for the counting of true negative instances.

addTruePositive() - Method in class stream.learner.evaluation.TableOfConfusion

Short form of TableOfConfusion.addTruePositive(1).

addTruePositive(long) - Method in class stream.learner.evaluation.TableOfConfusion

Adds the amount specified by the argument delta to the internal data structure for the counting of true positive instances.

AddUUID - Class in stream.data

This processor will add a random UUID to each data item.

AddUUID() - Constructor for class stream.data.AddUUID

addWidget(String, JComponent) - Method in class stream.service.Dashboard

addWidget(String, JComponent) - Method in interface stream.service.DashboardService

Adds the provided widget to the dashboard.

adjust(Long) - Method in class stream.statistics.History

This method maps the given timestamp to the last official timestamp, as induced by the stepSize.

amplitude - Variable in class stream.generator.NoisySinusWave

amplitude - Variable in class stream.generator.SinusWave

append - Variable in class stream.io.CsvWriter

append - Variable in class stream.io.LineWriter

ArffStream - Class in stream.io

This class implements a streaming source providing information from an ARFF file form.

ArffStream(SourceURL) - Constructor for class stream.io.ArffStream

args - Variable in class stream.util.CommandLineArgs

AsJSON - Class in stream.data

AsJSON() - Constructor for class stream.data.AsJSON

Assert - Class in stream.data.test

Assert() - Constructor for class stream.data.test.Assert

asString - Variable in class stream.data.NumericalBinning.Bucket

AT_SUBSTITUTION - Variable in class stream.io.sql.HsqlDialect

attributes - Variable in class stream.generator.ColtGaussianStream

attributes - Variable in class stream.generator.GaussianStream

attributes - Variable in class stream.generator.RandomIntegerStream

attributes - Variable in class stream.generator.RandomStream

attributes - Variable in class stream.io.AbstractLineStream

Average - Class in stream.statistics

Average() - Constructor for class stream.statistics.Average

AverageThroughput - Class in stream.monitor

AverageThroughput() - Constructor for class stream.monitor.AverageThroughput

B

backlog - Variable in class stream.net.UDPStream

BinaryLabels - Class in stream.data

This class implements a simple strategy to map labels to { -1, +1 }

BinaryLabels() - Constructor for class stream.data.BinaryLabels

BinaryLabels(String) - Constructor for class stream.data.BinaryLabels

BinaryLabels(String, String) - Constructor for class stream.data.BinaryLabels

BinaryWriter - Class in stream.io

BinaryWriter() - Constructor for class stream.io.BinaryWriter

bins - Variable in class stream.data.NumericalBinning

blockFormat - Variable in class stream.io.JSONBlockWriter

blocksCreated - Variable in class stream.io.JSONBlockWriter

blockSize - Variable in class stream.io.JSONBlockWriter

BodyText - Interface in stream.util

This interface is a marker that marks an annotated Parameter as referring to the corresponding XML body element.

buckets - Variable in class stream.data.NumericalBinning

buffer - Variable in class stream.net.Connection

the buffer holding the next items that should be transferred to the client

BufferedDataObjectStream - Class in stream.net

Adds a receive buffer to DataObjectStream for performance reasons and adds a reconnect functionality in case of an error.

BufferedDataObjectStream(InputStream) - Constructor for class stream.net.BufferedDataObjectStream

invokes DataObjectStream.DataObjectStream(InputStream)

BufferedDataObjectStream(SourceURL) - Constructor for class stream.net.BufferedDataObjectStream

invokes DataObjectStream.DataObjectStream(SourceURL)

bufferSize - Variable in class stream.net.BufferedDataObjectStream

The buffer size (in bytes) used by this stream.

bufferSize - Variable in class stream.net.Connection

bufferSize - Variable in class stream.net.ConnectionHandler

BYTE_ARRAY_CLASS - Static variable in class stream.io.sql.DatabaseDialect

bytesWritten - Variable in class stream.io.BinaryWriter

bytesWritten - Variable in class stream.io.JSONBlockWriter

C

c - Variable in class stream.data.Encrypt

calculateAccuracy() - Method in class stream.learner.evaluation.ConfusionMatrix

Calculates and returns the overall accuracy for this confusion matrix in range [0,1].

calculateAccuracy() - Method in class stream.learner.evaluation.TableOfConfusion

Calculates and returns the accuracy value.

calculateFScore() - Method in class stream.learner.evaluation.TableOfConfusion

Calculates and returns the f-score value.

calculatePrecision() - Method in class stream.learner.evaluation.TableOfConfusion

Calculates and returns the precision value.

calculateRecall() - Method in class stream.learner.evaluation.TableOfConfusion

Calculates and returns the recall value.

calculateSpecificity() - Method in class stream.learner.evaluation.TableOfConfusion

Calculates and returns the specificity value.

capacity - Variable in class stream.data.storage.Store

checkClientTrusted(X509Certificate[], String) - Method in class stream.util.TrustAllManager

CheckDataAvailability - Class in stream.data

CheckDataAvailability() - Constructor for class stream.data.CheckDataAvailability

checkServerTrusted(X509Certificate[], String) - Method in class stream.util.TrustAllManager

children - Variable in class stream.parser.DefaultTreeParser.DefaultTreeNode

children() - Method in class stream.parser.DefaultTreeParser.DefaultTreeNode

choose() - Method in class stream.generator.MixedStream

chunks - Variable in class stream.net.DataTap.ClientHandler

cipher - Variable in class stream.data.Encrypt

CIPHER_KEY - Static variable in class stream.data.Encrypt

CLASSES - Static variable in class stream.util.DocFinder

ClassFinder - Class in stream.util

ClassFinder() - Constructor for class stream.util.ClassFinder

clear() - Method in class stream.statistics.History

clientBufferSize - Variable in class stream.net.DataTapSink

The buffer size (number of items) used for each client

clientExited(DataTap.ClientHandler) - Method in class stream.net.DataTap.ServerThread

clients - Variable in class stream.net.DataTap.ServerThread

clock - Variable in class stream.monitor.DataRate

close() - Method in class stream.generator.ColtGaussianStream

close() - Method in class stream.generator.GaussianStream

close() - Method in class stream.io.AbstractLineStream

close(Connection) - Method in class stream.io.AbstractSQLProcessor

close() - Method in class stream.io.active.SimpleActiveStream

close() - Method in class stream.io.DataObjectStream

close() - Method in class stream.io.ListDataStream

close() - Method in class stream.io.multi.AbstractMultiStream

close() - Method in class stream.io.ProcessStream

close() - Method in class stream.io.SQLStream

close() - Method in class stream.io.SvmLightStream

close() - Method in class stream.monitor.VmStats

close() - Method in class stream.net.BufferedDataObjectStream

Closes / Resets this connection such that all resources are freed and the next invocation of AbstractStream.getInputStream() will return a fresh new connection to the target.

close() - Method in class stream.net.Connection

Shuts down this DataTap.ClientHandler.

close() - Method in class stream.net.ConnectionHandler

Shuts down this ConnectionHandler.

close() - Method in class stream.net.DataTapSink

close() - Method in class stream.net.UDPStream

closed - Variable in class stream.io.CsvWriter

cnt - Variable in class stream.io.DataObjectWriter

ColtGaussian - Class in stream.generator

This class implements a gaussian distributor.

ColtGaussian(Double, Double, Long) - Constructor for class stream.generator.ColtGaussian

ColtGaussian(Double, Double) - Constructor for class stream.generator.ColtGaussian

ColtGaussianStream - Class in stream.generator

ColtGaussianStream() - Constructor for class stream.generator.ColtGaussianStream

Create a new Gaussian stream with the given number of classes.

columns - Variable in class stream.io.CsvStream

columns - Variable in class stream.io.SQLStream

columns - Variable in class stream.io.SQLWriter

columnTypeDefs - Variable in class stream.io.sql.DatabaseDialect

command - Variable in class stream.io.ProcessStream

CommandLineArgs - Class in stream.util

CommandLineArgs(String[]) - Constructor for class stream.util.CommandLineArgs

compareTo(NumericalBinning.Bucket) - Method in class stream.data.NumericalBinning.Bucket

components - Variable in class stream.service.Dashboard

compute(TreeNode) - Method in class stream.data.tree.AbstractTreeFeature

compute(TreeNode) - Method in class stream.data.tree.CountLeaves

compute(TreeNode) - Method in class stream.data.tree.CountNodes

compute(TreeNode) - Method in class stream.data.tree.Height

compute(TreeNode) - Method in interface stream.data.tree.TreeFeature

computeIV(String, String) - Static method in class stream.data.Encrypt

condition - Variable in class stream.logger.Message

confusionMatrices - Variable in class stream.learner.evaluation.PredictionError

ConfusionMatrix<T extends Serializable> - Class in stream.learner.evaluation

This is a data structure for dealing with label-pair-relations.

ConfusionMatrix() - Constructor for class stream.learner.evaluation.ConfusionMatrix

Creates a new ConfusionMatrix instance with an empty list of labels.

ConfusionMatrix(List<T>) - Constructor for class stream.learner.evaluation.ConfusionMatrix

Creates a new ConfusionMatrix instance.

confusionMatrix - Variable in class stream.learner.evaluation.ConfusionMatrix

Array which stores the counts of classification instances (pairs of true and predicted labels) The first dimension represents the true labels while the second dimension represents the predicted labels.

connect() - Method in class stream.net.BufferedDataObjectStream

Connects to the specified URL.

connect() - Method in class stream.net.TcpSender

connected - Variable in class stream.net.BufferedDataObjectStream

connection - Variable in class stream.io.SQLStream

connection - Variable in class stream.io.SQLWriter

Connection - Class in stream.net

This thread represents one client.

Connection(ConnectionHandler) - Constructor for class stream.net.Connection

connectionHandler - Variable in class stream.net.Connection

ConnectionHandler - Class in stream.net

This thread maintains all clients.

ConnectionHandler(ExecutorService, ServerSocket) - Constructor for class stream.net.ConnectionHandler

connectionHandler - Variable in class stream.net.DataTapSink

the ConnectionHandler

connectionRetries - Variable in class stream.net.BufferedDataObjectStream

the maximum amount of connection retries before the general connection attempt finally fails

connections - Variable in class stream.net.ConnectionHandler

contains the DataTap.ClientHandler objects - one for each connected client

connectionSocket - Variable in class stream.net.ConnectionHandler

the ServerSocket that new clients can connect to

contains(char[], char) - Method in class stream.parser.DefaultTreeParser

count - Variable in class stream.generator.GaussianStream

count - Variable in class stream.io.SQLWriter

count - Variable in class stream.learner.evaluation.PredictionError

count - Variable in class stream.monitor.DataRate

count - Variable in class stream.statistics.Average

Count - Class in stream.statistics

Count() - Constructor for class stream.statistics.Count

count - Variable in class stream.statistics.CountServiceLearner

CountCheck - Class in stream.statistics

CountCheck() - Constructor for class stream.statistics.CountCheck

counter - Static variable in class stream.io.DirectoryStream

counter - Static variable in class stream.io.multi.DirectoryMultiStream

CountInnerNodes - Class in stream.data.tree

CountInnerNodes() - Constructor for class stream.data.tree.CountInnerNodes

CountLeaves - Class in stream.data.tree

CountLeaves() - Constructor for class stream.data.tree.CountLeaves

CountNodes - Class in stream.data.tree

CountNodes() - Constructor for class stream.data.tree.CountNodes

counts - Variable in class stream.statistics.CountServiceLearner

countService - Variable in class stream.statistics.CountCheck

CountService - Interface in stream.statistics

CountServiceLearner - Class in stream.statistics

CountServiceLearner() - Constructor for class stream.statistics.CountServiceLearner

create(String, String...) - Static method in class stream.util.Keys

createFeatureKey(String) - Method in class stream.data.tree.AbstractTreeFeature

createFeatureKey(String) - Method in class stream.data.tree.CountLeaves

createFeatureKey(String) - Method in class stream.data.tree.Height

createFeatureKey(String) - Method in interface stream.data.tree.TreeFeature

createHeader(Data) - Method in class stream.io.CsvWriter

CreateID - Class in stream.data

This class adds a single ID attribute to all processed items.

CreateID() - Constructor for class stream.data.CreateID

createSparseVector(Data) - Static method in class stream.data.vector.Vector

createSparseVector(Data) - Static method in class stream.io.SvmLightStream

createTable(String, Map<String, Class<?>>) - Method in class stream.io.AbstractSQLProcessor

createUrl(String) - Method in class stream.io.multi.DirectoryMultiStream

CsvDatabase - Class in stream.lookup

An implementation of the AbstractDatabase lookup service, that reads data from a CSV file at initialization time.

CsvDatabase() - Constructor for class stream.lookup.CsvDatabase

CsvStream - Class in stream.io

CsvStream(SourceURL) - Constructor for class stream.io.CsvStream

CsvStream(InputStream) - Constructor for class stream.io.CsvStream

CsvStream(InputStream, String) - Constructor for class stream.io.CsvStream

CsvStream(InputStream, Charset, String) - Constructor for class stream.io.CsvStream

CsvStream(SourceURL, String) - Constructor for class stream.io.CsvStream

CsvUpload - Class in stream.io

CsvUpload(URL) - Constructor for class stream.io.CsvUpload

CsvWriter - Class in stream.io

This class implements a listener which will write all its incoming data into a one-by-one line output.

CsvWriter() - Constructor for class stream.io.CsvWriter

CsvWriter(URL) - Constructor for class stream.io.CsvWriter

CsvWriter(File) - Constructor for class stream.io.CsvWriter

Create a new DataStreamWriter which writes all data to the given file.

CsvWriter(OutputStream) - Constructor for class stream.io.CsvWriter

CsvWriter(OutputStream, String) - Constructor for class stream.io.CsvWriter

CsvWriter(File, String) - Constructor for class stream.io.CsvWriter

current - Variable in class stream.io.BinaryWriter

currentBlock - Variable in class stream.io.JSONBlockWriter

currentStatistics - Variable in class stream.statistics.Count

D

Dashboard - Class in stream.service

Dashboard() - Constructor for class stream.service.Dashboard

DashboardService - Interface in stream.service

data - Variable in class stream.data.storage.Store

data - Variable in class stream.io.ListDataStream

data - Variable in class stream.parser.DefaultTreeParser

DATA_KEY - Static variable in class stream.data.Encrypt

database - Variable in class stream.lookup.AbstractDatabase

DatabaseDialect - Class in stream.io.sql

DatabaseDialect() - Constructor for class stream.io.sql.DatabaseDialect

DataObjectStream - Class in stream.io

DataObjectStream(SourceURL) - Constructor for class stream.io.DataObjectStream

DataObjectStream(InputStream) - Constructor for class stream.io.DataObjectStream

DataObjectWriter - Class in stream.io

DataObjectWriter() - Constructor for class stream.io.DataObjectWriter

DataRate - Class in stream.monitor

DataRate() - Constructor for class stream.monitor.DataRate

DataService<T extends Serializable> - Interface in stream.data.storage

dataStream - Variable in class stream.io.ProcessStream

dataStreamClass - Variable in class stream.io.ProcessStream

DataTap - Class in stream.net

DataTap() - Constructor for class stream.net.DataTap

DataTap.ClientHandler - Class in stream.net

DataTap.ClientHandler(DataTap.ServerThread, Socket, boolean) - Constructor for class stream.net.DataTap.ClientHandler

DataTap.ServerThread - Class in stream.net

DataTap.ServerThread(String, int, boolean) - Constructor for class stream.net.DataTap.ServerThread

DataTapSink - Class in stream.net

This Sink receives data items and transmit them via TCP socket connections.

DataTapSink() - Constructor for class stream.net.DataTapSink

DataUpload - Class in stream.util

DataUpload() - Constructor for class stream.util.DataUpload

dateFormat - Variable in class stream.data.FormatTimestamp

dateFormat - Variable in class stream.io.BinaryWriter

dateFormat - Variable in class stream.parser.ParseTimestamp

DAY - Static variable in class stream.statistics.History

Decrypt - Class in stream.data

Decrypt() - Constructor for class stream.data.Decrypt

defaults - Variable in class stream.parser.DefaultTreeParser

DefaultTreeParser - Class in stream.parser

DefaultTreeParser() - Constructor for class stream.parser.DefaultTreeParser

DefaultTreeParser(String) - Constructor for class stream.parser.DefaultTreeParser

DefaultTreeParser.DefaultTreeNode - Class in stream.parser

DefaultTreeParser.DefaultTreeNode(String, TreeNode) - Constructor for class stream.parser.DefaultTreeParser.DefaultTreeNode

DefaultTreeParser.DefaultTreeNode(String, TreeNode, Collection<TreeNode>) - Constructor for class stream.parser.DefaultTreeParser.DefaultTreeNode

defaultValue - Variable in class stream.data.MapValues

defaultValue - Variable in class stream.parser.ParseDouble

defaultValue - Variable in class stream.parser.ParseInteger

defaultValue - Variable in class stream.parser.ParseLong

detectClientClose - Variable in class stream.net.DataTapSink

Defines if this sink actively listens to client disconnect events (= client's input stream read-method returns '-1').

dialect - Variable in class stream.io.AbstractSQLProcessor

dialect - Variable in class stream.io.SQLStream

dir - Variable in class stream.io.DirectoryStream

dir - Variable in class stream.io.multi.DirectoryMultiStream

directory - Variable in class stream.io.JSONBlockWriter

DirectoryMultiStream - Class in stream.io.multi

DirectoryMultiStream(SourceURL) - Constructor for class stream.io.multi.DirectoryMultiStream

DirectoryMultiStream(InputStream) - Constructor for class stream.io.multi.DirectoryMultiStream

DirectoryMultiStream() - Constructor for class stream.io.multi.DirectoryMultiStream

DirectoryStream - Class in stream.io

This stream reads the filenames from the given directory.

DirectoryStream(SourceURL) - Constructor for class stream.io.DirectoryStream

dirPath - Variable in class stream.io.DirectoryStream

disconnectSlowClients - Variable in class stream.net.Connection

disconnectSlowClients - Variable in class stream.net.ConnectionHandler

disconnectSlowClients - Variable in class stream.net.DataTapSink

Defines if slow clients should be disconnected.

DistributionFunction - Interface in stream.generator

DocFinder - Class in stream.util

DocFinder() - Constructor for class stream.util.DocFinder

doRecursion(int[], int, int[], int, int[], int, int[], int, int[], int) - Method in class stream.generator.SFMT19937

Applies the recursion formula.

driver - Variable in class stream.io.SQLStream

dropTable - Variable in class stream.io.SQLWriter

dumpArgs() - Method in class stream.util.CommandLineArgs

E

elapsed - Variable in class stream.monitor.DataRate

emit(Data) - Method in class stream.data.Unfold

emptyStrings - Variable in class stream.text.FillTemplate

encoding - Variable in class stream.io.AbstractLineStream

Encrypt - Class in stream.data

Encrypt() - Constructor for class stream.data.Encrypt

escapeNewlines - Variable in class stream.io.LineWriter

every - Variable in class stream.learner.evaluation.PredictionError

every - Variable in class stream.monitor.DataRate

every - Variable in class stream.monitor.ItemRate

every - Variable in class stream.monitor.TimeRate

expandSystemProperties(Properties) - Static method in class stream.util.CommandLineArgs

F

falseNegative - Variable in class stream.learner.evaluation.TableOfConfusion

falsePositive - Variable in class stream.learner.evaluation.TableOfConfusion

features - Variable in class stream.data.tree.TreeFeatures

file - Variable in class stream.data.graph.GraphProvider

file - Variable in class stream.io.BinaryWriter

file - Variable in class stream.io.CsvWriter

file - Variable in class stream.io.DataObjectWriter

file - Variable in class stream.io.LineWriter

file - Variable in class stream.statistics.Count

file - Variable in class stream.text.AddText

fileExpression - Variable in class stream.io.CsvWriter

files - Static variable in class stream.io.DirectoryStream

files - Static variable in class stream.io.multi.DirectoryMultiStream

filesAreRead - Static variable in class stream.io.DirectoryStream

filesAreRead - Static variable in class stream.io.multi.DirectoryMultiStream

fillArray(int[]) - Method in class stream.generator.SFMT19937

Fills the given array with pseudorandom 32-bit integers.

fillArray(int[], int) - Method in class stream.generator.SFMT19937

Fills the given array with the specified number of pseudorandom 32-bit integers.

FillTemplate - Class in stream.text

FillTemplate() - Constructor for class stream.text.FillTemplate

filter - Variable in class stream.io.CsvWriter

filter - Variable in class stream.logger.Message

findClasses(JarFile, String) - Static method in class stream.util.ClassFinder

findClasses(File, String) - Static method in class stream.util.ClassFinder

Recursive method used to find all classes in a given directory and subdirs.

finish() - Method in class stream.io.CsvWriter

finish() - Method in class stream.io.DataObjectWriter

finish() - Method in class stream.io.LineWriter

finish() - Method in class stream.io.SQLWriter

finish() - Method in class stream.learner.evaluation.PredictionError

finish() - Method in class stream.lookup.AbstractDatabase

finish() - Method in class stream.monitor.DataRate

finish() - Method in class stream.monitor.TimeRate

finish() - Method in class stream.net.DataTap

finish() - Method in class stream.net.TcpSender

finish() - Method in class stream.service.Dashboard

fmt - Variable in class stream.io.BinaryWriter

fmt - Variable in class stream.io.JSONBlockWriter

fmt - Variable in class stream.monitor.DataRate

forget() - Method in class stream.statistics.History

This method removes any data that is associated with a timestamp older than historyLength milliseconds.

format - Variable in class stream.data.FormatTimestamp

format - Variable in class stream.io.LineStream

format - Variable in class stream.io.LineWriter

format - Variable in class stream.io.ProcessStream

format - Variable in class stream.parser.ParseString

format - Variable in class stream.parser.ParseTimestamp

FormatTimestamp - Class in stream.data

FormatTimestamp() - Constructor for class stream.data.FormatTimestamp

frame - Variable in class stream.service.Dashboard

frequency - Variable in class stream.generator.NoisySinusWave

frequency - Variable in class stream.generator.SinusWave

from - Variable in class stream.data.FormatTimestamp

from - Variable in class stream.data.MapValues

from - Variable in class stream.parser.ParseTimestamp

func1(int) - Method in class stream.generator.SFMT19937

Used by SFMT19937.initByArray(int...).

func2(int) - Method in class stream.generator.SFMT19937

Used by SFMT19937.initByArray(int...).

G

gap - Variable in class stream.io.TimeStream

Gaussian - Class in stream.generator

This class implements a gaussian distributor.

Gaussian() - Constructor for class stream.generator.Gaussian

Gaussian(Long) - Constructor for class stream.generator.Gaussian

Gaussian(Double, Double, Long) - Constructor for class stream.generator.Gaussian

Gaussian(Double, Double) - Constructor for class stream.generator.Gaussian

GaussianStream - Class in stream.generator

GaussianStream() - Constructor for class stream.generator.GaussianStream

Create a new Gaussian stream with the given number of classes.

generate() - Method in class stream.generator.ColtGaussianStream

generate() - Method in class stream.generator.GaussianStream

generators - Variable in class stream.generator.ColtGaussianStream

generators - Variable in class stream.generator.GaussianStream

genRandAll() - Method in class stream.generator.SFMT19937

Fills the internal state array with pseudorandom integers.

genRandArray(int[], int) - Method in class stream.generator.SFMT19937

Fills a user-specified array with pseudorandom integers.

get(int) - Method in class stream.data.vector.Vector

get(String) - Method in class stream.generator.RandomIntegerStream

get(String, Object) - Method in class stream.generator.RandomIntegerStream

get(String) - Method in class stream.generator.RandomStream

get(String, Object) - Method in class stream.generator.RandomStream

get(int) - Method in class stream.statistics.History

get(Long) - Method in class stream.statistics.History

getAcceptedIssuers() - Method in class stream.util.TrustAllManager

getActivate() - Method in class stream.io.multi.AbstractMultiStream

getAddress() - Method in class stream.net.DataTap

getAddress() - Method in class stream.net.TcpSender

getAddress() - Method in class stream.net.UDPStream

getAmplitude() - Method in class stream.generator.NoisySinusWave

getAmplitude() - Method in class stream.generator.SinusWave

getAppend() - Method in class stream.io.CsvWriter

getArguments() - Method in class stream.util.CommandLineArgs

getAttributes() - Method in class stream.generator.RandomIntegerStream

getAttributes() - Method in class stream.generator.RandomStream

getBacklog() - Method in class stream.net.UDPStream

getBins() - Method in class stream.data.NumericalBinning

getBlockSize() - Method in class stream.io.JSONBlockWriter

getBufferSize() - Method in class stream.net.BufferedDataObjectStream

getByteSize() - Method in class stream.data.vector.Vector

getCapacity() - Method in class stream.data.storage.Store

getClasses(String) - Static method in class stream.util.ClassFinder

Scans all classes accessible from the context class loader which belong to the given package and subpackages.

getClientBufferSize() - Method in class stream.net.DataTapSink

Returns the buffer size used for each client

getClock() - Method in class stream.monitor.DataRate

getColumnType(Class<?>) - Method in class stream.io.sql.DatabaseDialect

getColumnType(Class<?>) - Method in class stream.io.sql.MysqlDialect

getColumnTypes(Data) - Method in class stream.io.sql.DatabaseDialect

getCommand() - Method in class stream.io.ProcessStream

getConnectionRetries() - Method in class stream.net.BufferedDataObjectStream

getConnectionString() - Method in class stream.net.BufferedDataObjectStream

Returns a string representing the connection url (works currently only with tcp connections).

getCount() - Method in interface stream.statistics.CountService

getCount() - Method in class stream.statistics.CountServiceLearner

getCountService() - Method in class stream.statistics.CountCheck

getCreatePrimaryKeySequence(String) - Method in class stream.io.sql.DatabaseDialect

getCreateTableCommand(String, Map<String, Class<?>>) - Method in class stream.io.sql.DatabaseDialect

getCreateTableCommand(String, Map<String, Class<?>>) - Method in class stream.io.sql.MysqlDialect

getData(String) - Method in interface stream.data.storage.DataService

getData(String) - Method in class stream.data.storage.Store

getData() - Method in class stream.statistics.History

getDefault() - Method in class stream.data.MapValues

getDefault() - Method in class stream.parser.ParseDouble

getDefault() - Method in class stream.parser.ParseInteger

getDefault() - Method in class stream.parser.ParseLong

getDefaults() - Method in class stream.parser.DefaultTreeParser

getDescription() - Method in class stream.generator.ColtGaussianStream

getDescription() - Method in class stream.generator.GaussianStream

getDirectory() - Method in class stream.io.JSONBlockWriter

getEdges(TreeNode) - Method in class stream.data.tree.TreeEdges

getEncoding() - Method in class stream.io.AbstractLineStream

getEvery() - Method in class stream.monitor.DataRate

getEvery() - Method in class stream.monitor.ItemRate

getEvery() - Method in class stream.monitor.TimeRate

getFalseNegativeCount(T) - Method in class stream.learner.evaluation.ConfusionMatrix

Returns the number of "false negative" instances for the provided label.

getFalsePositiveCount(T) - Method in class stream.learner.evaluation.ConfusionMatrix

Returns the number of "false positive" instances for the provided label.

getFile() - Method in class stream.data.graph.GraphProvider

getFile() - Method in class stream.io.BinaryWriter

getFile() - Method in class stream.io.DataObjectWriter

getFile() - Method in class stream.io.LineWriter

getFile() - Method in class stream.statistics.Count

getFile() - Method in class stream.text.AddText

getFormat() - Method in class stream.data.FormatTimestamp

getFormat() - Method in class stream.io.LineStream

getFormat() - Method in class stream.io.LineWriter

getFormat() - Method in class stream.io.ProcessStream

getFormat() - Method in class stream.parser.ParseString

getFormat() - Method in class stream.parser.ParseTimestamp

getFrequency() - Method in class stream.generator.NoisySinusWave

getFrequency() - Method in class stream.generator.SinusWave

getFrom() - Method in class stream.data.FormatTimestamp

getFrom() - Method in class stream.data.MapKeys

getFrom() - Method in class stream.data.MapValues

getFrom() - Method in class stream.parser.ParseTimestamp

getGraph() - Method in class stream.data.graph.NeighborPrinter

getGroupBy() - Method in class stream.statistics.Count

getHeaderNames() - Method in class stream.io.CsvWriter

getHeight(TreeNode) - Method in class stream.data.tree.Height

getHeight() - Method in class stream.service.Dashboard

getHistory() - Method in class stream.statistics.Count

getId() - Method in class stream.data.tree.AbstractTreeFeature

getId() - Method in class stream.io.ListDataStream

getId() - Method in class stream.monitor.DataRate

getId() - Method in class stream.monitor.TimeRate

getId() - Method in class stream.net.DataTapSink

getId() - Method in class stream.net.UDPStream

getIndex() - Method in class stream.monitor.TimeRate

getIndex(Data) - Method in class stream.monitor.TimeRate

getInterval() - Method in class stream.io.TimeStream

getInterval() - Method in class stream.monitor.VmStats

getKey() - Method in class stream.data.AddTimestamp

getKey() - Method in class stream.data.AddUUID

getKey() - Method in class stream.data.AsJSON

getKey() - Method in class stream.data.CreateID

getKey() - Method in class stream.data.FormatTimestamp

getKey() - Method in class stream.data.Lookup

getKey() - Method in class stream.data.MapValues

getKey() - Method in class stream.data.MapValueToID

getKey() - Method in class stream.data.NumericalBinning

getKey() - Method in class stream.data.RandomBinaryLabel

getKey() - Method in class stream.data.Unfold

getKey() - Method in class stream.generator.NoisySinusWave

getKey() - Method in class stream.generator.SinusWave

getKey() - Method in class stream.io.LineStream

getKey() - Method in class stream.io.TimeStream

getKey() - Method in class stream.lookup.AbstractDatabase

getKey() - Method in class stream.monitor.DataRate

getKey() - Method in class stream.monitor.MemoryUsage

getKey() - Method in class stream.parser.NGrams

getKey() - Method in class stream.parser.ParseJSON

getKey() - Method in class stream.parser.ParseString

getKey() - Method in class stream.parser.ParseTimestamp

getKey() - Method in class stream.text.AddText

getKey() - Method in class stream.text.FillTemplate

getKeys() - Method in class stream.data.CheckDataAvailability

getKeys() - Method in class stream.data.NumericalBinning

getKeys() - Method in class stream.data.SelectKeys

getKeys() - Method in class stream.data.storage.Store

getKeys() - Method in class stream.data.tree.AbstractTreeFeature

getKeys() - Method in class stream.generator.RandomIntegerStream

getKeys() - Method in class stream.generator.RandomStream

getKeys() - Method in class stream.io.BinaryWriter

getKeys() - Method in class stream.io.CsvStream

getKeys() - Method in class stream.io.SQLWriter

getKeys() - Method in class stream.learner.MetaDataLearner

getKeys() - Method in class stream.lookup.CsvDatabase

getKeys() - Method in class stream.net.TcpSender

getKeys() - Method in class stream.parser.ParseDouble

getKeys() - Method in class stream.parser.ParseInteger

getKeys() - Method in class stream.parser.ParseLong

getKeys() - Method in class stream.statistics.StatisticsLearner

getLabel() - Method in class stream.data.BinaryLabels

getLabel() - Method in class stream.data.vector.InputVector

getLabel() - Method in class stream.learner.evaluation.PredictionError

getLabel() - Method in class stream.parser.DefaultTreeParser.DefaultTreeNode

getLabels() - Method in class stream.generator.ProportionalOracle

getLabels() - Method in class stream.learner.evaluation.ConfusionMatrix

Returns the list of labels this ConfusionMatrix maintains counters for.

getLearner() - Method in class stream.learner.evaluation.PredictionError

getLength() - Method in class stream.statistics.History

getLevel() - Method in class stream.logger.Message

getLimit() - Method in class stream.generator.GaussianStream

getLimit() - Method in class stream.io.ListDataStream

getLookup() - Method in class stream.data.Lookup

getMap() - Method in class stream.data.MapKeys

getMap() - Method in class stream.data.MapValues

getMapping() - Method in class stream.data.MapKeys

getMaximum() - Method in class stream.data.NumericalBinning

getMean() - Method in class stream.generator.ColtGaussian

getMean() - Method in class stream.generator.Gaussian

getMean() - Method in class stream.generator.NoisySinusWave

getMessage() - Method in class stream.logger.Message

getMinimum() - Method in class stream.data.NumericalBinning

getMissing() - Method in class stream.data.tree.AbstractTreeFeature

getN() - Method in class stream.parser.NGrams

getNeighbors(String) - Method in class stream.data.graph.GraphProvider

getNeighbors(String) - Method in interface stream.data.graph.GraphService

getNext() - Method in class stream.generator.ProportionalOracle

getNextSeed() - Method in class stream.generator.ColtGaussianStream

getNextSeed() - Method in class stream.generator.GaussianStream

getNode() - Method in class stream.data.graph.NeighborPrinter

getNodes() - Method in class stream.data.graph.GraphProvider

getNodes() - Method in interface stream.data.graph.GraphService

getNumberOfClients() - Method in class stream.net.DataTap.ServerThread

getNumberOfLeaves(TreeNode) - Method in class stream.data.tree.CountLeaves

getNumberOfLeaves(TreeNode) - Method in class stream.data.tree.Height

getNumberOfNodes(TreeNode) - Method in class stream.data.tree.CountInnerNodes

getNumberOfNodes(TreeNode) - Method in class stream.data.tree.CountNodes

getNumberOfNodes(TreeNode) - Method in class stream.data.tree.Height

getOption(String) - Method in class stream.util.CommandLineArgs

getOption(String, String) - Method in class stream.util.CommandLineArgs

getOptionName(String) - Method in class stream.util.CommandLineArgs

getOptions() - Method in class stream.util.CommandLineArgs

getOrder() - Method in class stream.io.multi.DirectoryMultiStream

getOutput() - Method in class stream.data.Unfold

getPairs() - Method in class stream.data.vector.Vector

getParent() - Method in class stream.parser.DefaultTreeParser.DefaultTreeNode

getPassword() - Method in class stream.io.AbstractSQLProcessor

getPassword() - Method in class stream.io.SQLStream

getPattern() - Method in class stream.io.JSONBlockWriter

getPort() - Method in class stream.net.DataTap

getPort() - Method in class stream.net.DataTapSink

getPort() - Method in class stream.net.TcpSender

getPort() - Method in class stream.net.UDPStream

getPosition(Long) - Method in class stream.statistics.History

getPositive() - Method in class stream.data.BinaryLabels

getPrefix() - Method in class stream.data.PrintData

getPrefix() - Method in class stream.learner.evaluation.PredictionError

getPrefix() - Method in class stream.parser.NGrams

getPrefix() - Method in class stream.parser.ParseJSON

getPrefix() - Method in class stream.statistics.Count

getPrefix() - Method in class stream.statistics.StatisticsLearner

getPrimaryKeyDefinition(String) - Method in class stream.io.sql.DatabaseDialect

getReconnectInterval() - Method in class stream.net.BufferedDataObjectStream

getRemove() - Method in class stream.data.SelectKeys

getReset() - Method in class stream.io.DataObjectWriter

getScope() - Method in class stream.data.CheckDataAvailability

getSecret() - Method in class stream.data.Decrypt

getSecret() - Method in class stream.data.Encrypt

getSeed() - Method in class stream.data.RandomBinaryLabel

getSeed() - Method in class stream.generator.ColtGaussian

getSeed() - Method in class stream.generator.ColtGaussianStream

getSeed() - Method in class stream.generator.Gaussian

getSeed() - Method in class stream.generator.GaussianStream

getSeed() - Method in class stream.generator.NoisySinusWave

getSelect() - Method in class stream.io.SQLStream

getSeparator() - Method in class stream.io.CsvStream

getSeparator() - Method in class stream.io.CsvWriter

getSeparator() - Method in class stream.lookup.CsvDatabase

getSerializer() - Method in class stream.data.Encrypt

getService() - Method in class stream.statistics.AddStatistics

getServices() - Method in class stream.statistics.AddStatistics

getSourceKey() - Method in class stream.io.multi.SequentialMultiStream

getSparseKey() - Method in class stream.io.SvmLightStream

getStart() - Method in class stream.data.CreateID

getStatistics(String) - Method in class stream.learner.MetaDataLearner

getStatistics(String) - Method in interface stream.learner.MetaDataService

getStatistics() - Method in class stream.monitor.AverageThroughput

getStatistics() - Method in class stream.monitor.DataRate

getStatistics() - Method in class stream.monitor.MemoryUsage

getStatistics() - Method in class stream.monitor.TimeRate

getStatistics() - Method in class stream.statistics.Count

getStatistics() - Method in class stream.statistics.StatisticsLearner

getStatistics() - Method in interface stream.statistics.StatisticsService

getSteps() - Method in class stream.statistics.History

getStepSize() - Method in class stream.statistics.History

Returns the step size for this history.

getStreams() - Method in class stream.io.multi.AbstractMultiStream

getSuffix() - Method in class stream.io.multi.DirectoryMultiStream

getTable() - Method in class stream.io.SQLWriter

getTableOfConfusion(T) - Method in class stream.learner.evaluation.ConfusionMatrix

Constructs and returns the TableOfConfusion for the provided label.

getTableSchema(Connection, String) - Method in class stream.io.sql.DatabaseDialect

getTablesOfConfusion() - Method in class stream.learner.evaluation.ConfusionMatrix

Returns a map which contains a TableOfConfusion per label.

getText() - Method in class stream.text.AddText

getThreshold() - Method in class stream.data.BinaryLabels

getTimeKey() - Method in class stream.io.JSONBlockWriter

getTimeKey() - Method in class stream.statistics.Count

getTimestamp(int) - Method in class stream.statistics.History

getTimezone() - Method in class stream.parser.ParseTimestamp

getTitle() - Method in class stream.service.Dashboard

getTo() - Method in class stream.data.MapKeys

getTo() - Method in class stream.data.MapValues

getTopValues(String) - Method in class stream.learner.MetaDataLearner

getTopValues(String) - Method in interface stream.learner.MetaDataService

getTrueNegativeCount(T) - Method in class stream.learner.evaluation.ConfusionMatrix

Returns the number of "true negative" instances for the provided label.

getTruePositiveCount(T) - Method in class stream.learner.evaluation.ConfusionMatrix

Returns the number of "true positive" instances for the provided label.

getType() - Method in class stream.data.vector.Vector

getUrl() - Method in class stream.io.AbstractSQLProcessor

getUrl() - Method in class stream.io.CsvWriter

getUrl() - Method in class stream.lookup.AbstractDatabase

getUsername() - Method in class stream.io.AbstractSQLProcessor

getUsername() - Method in class stream.io.SQLStream

getVariance() - Method in class stream.generator.ColtGaussian

getVariance() - Method in class stream.generator.Gaussian

getVariance() - Method in class stream.generator.NoisySinusWave

getWeight(String) - Method in class stream.generator.ProportionalOracle

getWeightForLabel(T) - Method in class stream.learner.evaluation.ConfusionMatrix

Returns the class size as a weight for per-class-calculations.

getWeights() - Method in class stream.io.multi.RandomMultiStream

getWidth() - Method in class stream.service.Dashboard

getWindow() - Method in class stream.statistics.Count

GraphProvider - Class in stream.data.graph

GraphProvider() - Constructor for class stream.data.graph.GraphProvider

GraphService - Interface in stream.data.graph

graphService - Variable in class stream.data.graph.NeighborPrinter

groupBy - Variable in class stream.statistics.Count

gzip - Variable in class stream.net.ConnectionHandler

gzip - Variable in class stream.net.DataTap

gzip - Variable in class stream.net.DataTap.ServerThread

gzip - Variable in class stream.net.DataTapSink

This parameter allows for enabling GZIP compression on the TCP stream, default is no compression.

H

hasTable(String) - Method in class stream.io.AbstractSQLProcessor

hasTable(String) - Method in class stream.io.SQLWriter

header - Variable in class stream.io.CsvStream

header - Variable in class stream.io.CsvWriter

header - Variable in class stream.lookup.CsvDatabase

headers - Variable in class stream.io.CsvWriter

headerWritten - Variable in class stream.io.CsvWriter

Height - Class in stream.data.tree

Height() - Constructor for class stream.data.tree.Height

height - Variable in class stream.service.Dashboard

history - Variable in class stream.statistics.Count

History<T> - Class in stream.statistics

This is a generic implementation of a history.

History(long, long) - Constructor for class stream.statistics.History

historyLength - Variable in class stream.statistics.History

historyStats - Variable in class stream.statistics.Count

HOUR - Static variable in class stream.statistics.History

HsqlDialect - Class in stream.io.sql

HsqlDialect() - Constructor for class stream.io.sql.HsqlDialect

I

id - Variable in class stream.data.tree.AbstractTreeFeature

id - Variable in class stream.io.ListDataStream

id - Variable in class stream.monitor.DataRate

id - Variable in class stream.monitor.TimeRate

id - Variable in class stream.net.DataTapSink

contains the ClientConnectListener that are notified when a new client connects to this server

id - Variable in class stream.net.UDPStream

ID_KEY - Static variable in class stream.data.Encrypt

idx - Variable in class stream.generator.SFMT19937

Index counter of the next int to return from SFMT19937.next().

includeAnnotations - Variable in class stream.io.SvmLightWriter

index - Variable in class stream.generator.NoisySinusWave

index - Variable in class stream.generator.SinusWave

index - Variable in class stream.io.multi.SequentialMultiStream

index - Variable in class stream.monitor.TimeRate

indexes - Variable in class stream.io.SvmLightWriter

init(ProcessContext) - Method in class stream.data.CheckDataAvailability

init(ProcessContext) - Method in class stream.data.Decrypt

init(ProcessContext) - Method in class stream.data.Encrypt

init(ProcessContext) - Method in class stream.data.FormatTimestamp

init() - Method in class stream.data.NumericalBinning

init(ProcessContext) - Method in class stream.data.storage.Store

init() - Method in class stream.generator.ColtGaussianStream

init() - Method in class stream.generator.GaussianStream

init() - Method in class stream.generator.NoisySinusWave

init() - Method in class stream.io.AbstractLineStream

init() - Method in class stream.io.active.SimpleActiveStream

init(ProcessContext) - Method in class stream.io.BinaryWriter

init() - Method in class stream.io.CsvStream

init(ProcessContext) - Method in class stream.io.CsvWriter

init() - Method in class stream.io.DataObjectStream

init(ProcessContext) - Method in class stream.io.DataObjectWriter

init() - Method in class stream.io.DirectoryStream

init() - Method in class stream.io.JSONStream

init(ProcessContext) - Method in class stream.io.LineWriter

init() - Method in class stream.io.ListDataStream

init() - Method in class stream.io.multi.AbstractMultiStream

init() - Method in class stream.io.multi.DirectoryMultiStream

init() - Method in class stream.io.multi.RandomMultiStream

init() - Method in class stream.io.ProcessStream

init() - Method in class stream.io.SQLStream

init(ProcessContext) - Method in class stream.io.SQLWriter

init() - Method in class stream.io.SQLWriter

init(ProcessContext) - Method in class stream.logger.Message

init(Context) - Method in class stream.lookup.AbstractDatabase

init(ProcessContext) - Method in class stream.monitor.DataRate

init(ProcessContext) - Method in class stream.monitor.TimeRate

init() - Method in class stream.monitor.VmStats

init() - Method in class stream.net.BufferedDataObjectStream

init(Socket, int, boolean, boolean) - Method in class stream.net.Connection

init(int, boolean, boolean) - Method in class stream.net.ConnectionHandler

init(ProcessContext) - Method in class stream.net.DataTap

init() - Method in class stream.net.DataTapSink

init(ProcessContext) - Method in class stream.net.TcpSender

init() - Method in class stream.net.UDPStream

init(ProcessContext) - Method in class stream.parser.ParseString

init(ProcessContext) - Method in class stream.parser.ParseTimestamp

init(Context) - Method in class stream.service.Dashboard

init(ProcessContext) - Method in class stream.statistics.Count

init(ProcessContext) - Method in class stream.text.AddText

initByArray(int...) - Method in class stream.generator.SFMT19937

Initializes the internal state array with an array of 32-bit integers.

innerProduct(Vector) - Method in class stream.data.vector.Vector

input - Variable in class stream.io.DataObjectStream

InputVector - Class in stream.data.vector

InputVector() - Constructor for class stream.data.vector.InputVector

InputVector(double[], boolean, double) - Constructor for class stream.data.vector.InputVector

Creates a dense vector from the given values

InputVector(HashMap<Integer, Double>, boolean, double) - Constructor for class stream.data.vector.InputVector

Creates a sparse vector from the given values

InputVector(InputVector) - Constructor for class stream.data.vector.InputVector

Copy constructor

interval - Variable in class stream.io.TimeStream

interval - Variable in class stream.monitor.VmStats

isActivelyDetectClientClose() - Method in class stream.net.DataTapSink

isAppend() - Method in class stream.io.LineWriter

isDisconnectSlowClients() - Method in class stream.net.DataTapSink

isDropTable() - Method in class stream.io.SQLWriter

isEmptyStrings() - Method in class stream.text.FillTemplate

isEscapeNewlines() - Method in class stream.io.LineWriter

isGzip() - Method in class stream.net.DataTap

isGzip() - Method in class stream.net.DataTapSink

isHeader() - Method in class stream.io.CsvStream

isHeader() - Method in class stream.io.CsvWriter

isHeader() - Method in class stream.lookup.CsvDatabase

isIncludeAnnotations() - Method in class stream.io.SvmLightWriter

isLeaf() - Method in class stream.parser.DefaultTreeParser.DefaultTreeNode

isRemove() - Method in class stream.parser.ParseJSON

isRunning() - Method in class stream.net.Connection

isSelected(String) - Method in class stream.data.SelectKeys

isSparse() - Method in class stream.data.vector.Vector

ItemRate - Class in stream.monitor

ItemRate() - Constructor for class stream.monitor.ItemRate

itemsProcessed - Variable in class stream.monitor.AverageThroughput

J

JSONBlockWriter - Class in stream.io

JSONBlockWriter() - Constructor for class stream.io.JSONBlockWriter

JSONDatabase - Class in stream.lookup

This implementation of the AbstractDatabase lookup service uses a JSON stream to populate the lookup table.

JSONDatabase() - Constructor for class stream.lookup.JSONDatabase

JSONStream - Class in stream.io

JSONStream(InputStream) - Constructor for class stream.io.JSONStream

JSONStream(SourceURL) - Constructor for class stream.io.JSONStream

JSONStream() - Constructor for class stream.io.JSONStream

JSONWriter - Class in stream.io

This is a simple JSON writer that will write all data items into JSON strings (one line for each item).

JSONWriter() - Constructor for class stream.io.JSONWriter

JSONWriter(File) - Constructor for class stream.io.JSONWriter

JSONWriter(URL) - Constructor for class stream.io.JSONWriter

JSONWriter(OutputStream) - Constructor for class stream.io.JSONWriter

K

key - Variable in class stream.data.AddTimestamp

key - Variable in class stream.data.AddUUID

key - Variable in class stream.data.AsJSON

key - Variable in class stream.data.CreateID

key - Variable in class stream.data.Encrypt

key - Variable in class stream.data.FormatTimestamp

key - Variable in class stream.data.Lookup

key - Variable in class stream.data.MapValues

key - Variable in class stream.data.MapValueToID

key - Variable in class stream.data.Unfold

key - Variable in class stream.generator.NoisySinusWave

key - Variable in class stream.generator.SinusWave

key - Variable in class stream.io.LineStream

key - Variable in class stream.io.TimeStream

key - Variable in class stream.lookup.AbstractDatabase

key - Variable in class stream.monitor.DataRate

key - Variable in class stream.monitor.MemoryUsage

key - Variable in class stream.parser.NGrams

key - Variable in class stream.parser.ParseJSON

key - Variable in class stream.parser.ParseString

key - Variable in class stream.parser.ParseTimestamp

key - Variable in class stream.text.AddText

key - Variable in class stream.text.FillTemplate

keys - Variable in class stream.data.CheckDataAvailability

keys - Variable in class stream.data.NumericalBinning

keys - Variable in class stream.data.SelectKeys

keys - Variable in class stream.data.storage.Store

keys - Variable in class stream.data.tree.AbstractTreeFeature

keys - Variable in class stream.generator.RandomIntegerStream

keys - Variable in class stream.generator.RandomStream

keys - Variable in class stream.io.BinaryWriter

keys - Variable in class stream.io.CsvStream

keys - Variable in class stream.io.CsvWriter

keys - Variable in class stream.io.SQLWriter

keys - Variable in class stream.learner.MetaDataLearner

keys - Variable in class stream.lookup.CsvDatabase

keys - Variable in class stream.monitor.VmStats

keys - Variable in class stream.net.TcpSender

keys - Variable in class stream.parser.ParseDouble

keys - Variable in class stream.parser.ParseInteger

keys - Variable in class stream.parser.ParseLong

keys - Variable in class stream.statistics.StatisticsLearner

keys - Variable in class stream.transform.TransformToInteger

Keys - Class in stream.util

Keys() - Constructor for class stream.util.Keys

keysToStore - Variable in class stream.io.SQLWriter

L

label - Variable in class stream.learner.evaluation.PredictionError

label - Variable in class stream.parser.DefaultTreeParser.DefaultTreeNode

labelAttribute - Variable in class stream.data.BinaryLabels

labelAttribute - Variable in class stream.data.RandomBinaryLabel

labels - Variable in class stream.learner.evaluation.ConfusionMatrix

The list of all labels.

largestIndex - Variable in class stream.io.SvmLightWriter

last - Variable in class stream.io.TimeStream

last - Variable in class stream.monitor.DataRate

last - Variable in class stream.statistics.History

last() - Method in class stream.statistics.History

Returns the last official timestamp for this history.

lastHeader - Variable in class stream.io.CsvWriter

lastTime - Variable in class stream.statistics.Count

lastUrlString - Variable in class stream.io.CsvWriter

learner - Variable in class stream.learner.evaluation.PredictionError

length - Variable in class stream.data.vector.Vector

length() - Method in class stream.data.vector.Vector

level - Variable in class stream.logger.Message

limit - Variable in class stream.generator.GaussianStream

limit - Variable in class stream.io.ListDataStream

lineEscape(Serializable) - Method in class stream.io.SvmLightWriter

lineNo - Variable in class stream.io.CsvStream

lineNumber - Variable in class stream.io.SvmLightStream

LineStream - Class in stream.io

This is a very simple stream that just reads from a URL line-by-line.

LineStream(SourceURL) - Constructor for class stream.io.LineStream

LineStream(InputStream) - Constructor for class stream.io.LineStream

LineWriter - Class in stream.io

A simple output processor that writes out data items to a file according to some format string.

LineWriter() - Constructor for class stream.io.LineWriter

ListDataStream - Class in stream.io

ListDataStream(Collection<? extends Data>) - Constructor for class stream.io.ListDataStream

log - Static variable in class stream.data.CheckDataAvailability

log - Static variable in class stream.data.Decrypt

log - Static variable in class stream.data.Encrypt

log - Static variable in class stream.data.FormatTimestamp

log - Static variable in class stream.data.graph.GraphProvider

log - Static variable in class stream.data.graph.NeighborPrinter

log - Variable in class stream.data.LogData

log - Static variable in class stream.data.Lookup

log - Static variable in class stream.data.MapKeys

log - Static variable in class stream.data.MapValueToID

log - Static variable in class stream.data.NumericalBinning

log - Static variable in class stream.data.SelectKeys

log - Static variable in class stream.data.storage.Store

log - Static variable in class stream.data.Unfold

log - Static variable in class stream.generator.ColtGaussianStream

log - Static variable in class stream.generator.GaussianStream

log - Static variable in class stream.generator.ProportionalOracle

log - Static variable in class stream.io.AbstractSQLProcessor

log - Variable in class stream.io.active.SimpleActiveStream

log - Static variable in class stream.io.ArffStream

log - Static variable in class stream.io.BinaryWriter

log - Static variable in class stream.io.CsvStream

log - Static variable in class stream.io.CsvWriter

log - Variable in class stream.io.DirectoryStream

log - Static variable in class stream.io.JSONBlockWriter

log - Variable in class stream.io.JSONStream

log - Static variable in class stream.io.LineStream

log - Variable in class stream.io.multi.AbstractMultiStream

log - Static variable in class stream.io.multi.DirectoryMultiStream

log - Static variable in class stream.io.multi.SequentialMultiStream

log - Static variable in class stream.io.ProcessStream

log - Static variable in class stream.io.sql.DatabaseDialect

log - Static variable in class stream.io.SQLWriter

log - Static variable in class stream.io.SvmLightStream

log - Static variable in class stream.learner.evaluation.PredictionError

log - Static variable in class stream.learner.MetaDataLearner

log - Static variable in class stream.logger.Message

log - Static variable in class stream.lookup.AbstractDatabase

log - Static variable in class stream.lookup.JSONDatabase

log - Static variable in class stream.monitor.DataRate

log - Static variable in class stream.monitor.TimeRate

log - Static variable in class stream.monitor.VmStats

log - Variable in class stream.net.BufferedDataObjectStream

log - Variable in class stream.net.Connection

log - Variable in class stream.net.ConnectionHandler

log - Static variable in class stream.net.DataTap.ClientHandler

log - Static variable in class stream.net.DataTap

log - Static variable in class stream.net.DataTap.ServerThread

log - Static variable in class stream.net.DataTapSink

log - Static variable in class stream.net.TcpSender

log - Static variable in class stream.net.UDPStream

log - Static variable in class stream.parser.NGrams

log - Static variable in class stream.parser.ParseJSON

log - Static variable in class stream.parser.ParseString

log - Static variable in class stream.parser.ParseTimestamp

log - Static variable in class stream.statistics.AddStatistics

log - Static variable in class stream.statistics.Count

log - Static variable in class stream.text.FillTemplate

log - Static variable in class stream.util.ClassFinder

log - Static variable in class stream.util.DataUpload

log - Static variable in class stream.util.DocFinder

log - Static variable in class stream.util.TrustAllManager

logBufferFull - Variable in class stream.net.DataTapSink

Defines if the event 'client buffer is full' should be logged.

LogData - Class in stream.data

LogData() - Constructor for class stream.data.LogData

Lookup - Class in stream.data

Lookup() - Constructor for class stream.data.Lookup

lookup - Variable in class stream.data.Lookup

lookup(String) - Method in class stream.lookup.AbstractDatabase

lookup(String) - Method in interface stream.service.LookupService

LookupService - Interface in stream.service

loss(T, T) - Method in interface stream.learner.evaluation.LossFunction

Compute the loss between x1 and x2.

loss - Variable in class stream.learner.evaluation.PredictionError

loss(T, T) - Method in class stream.learner.evaluation.ZeroOneLoss

LossFunction<T> - Interface in stream.learner.evaluation

This interface defines an abstract loss function.

lower - Variable in class stream.data.NumericalBinning.Bucket

M

main(String[]) - Static method in class stream.generator.ProportionalOracle

main(String[]) - Static method in class stream.monitor.VmStats

main(String[]) - Static method in class stream.parser.DefaultTreeParser

main(String[]) - Static method in class stream.util.CommandLineArgs

main(String[]) - Static method in class stream.util.DataUpload

main(String[]) - Static method in class stream.util.DocFinder

map - Variable in class stream.data.MapKeys

map - Variable in class stream.data.MapValues

map(Double) - Method in class stream.data.NumericalBinning

map - Variable in class stream.generator.ProportionalOracle

map - Variable in class stream.statistics.History

map(int) - Method in class stream.statistics.History

Returns the timestamp for the ith element of this history.

mapColumnName(String) - Method in class stream.io.sql.DatabaseDialect

mapColumnName(String) - Method in class stream.io.sql.HsqlDialect

mapColumnName(String) - Method in class stream.io.sql.MysqlDialect

MapKeys - Class in stream.data

MapKeys(String, String) - Constructor for class stream.data.MapKeys

MapKeys() - Constructor for class stream.data.MapKeys

mapping - Variable in class stream.data.MapKeys

mapping - Variable in class stream.data.MapValues

mapping - Variable in class stream.data.MapValueToID

mapTimestamp(Long) - Method in class stream.statistics.History

mapTypeToClass(int) - Method in class stream.io.sql.DatabaseDialect

MapValues - Class in stream.data

MapValues() - Constructor for class stream.data.MapValues

MapValueToID - Class in stream.data

MapValueToID() - Constructor for class stream.data.MapValueToID

max(Collection<Integer>) - Method in class stream.data.tree.CountLeaves

max(Collection<Integer>) - Method in class stream.data.tree.Height

max_index - Variable in class stream.data.vector.Vector

maxId - Variable in class stream.data.MapValueToID

Maxima - Class in stream.statistics

Maxima() - Constructor for class stream.statistics.Maxima

maximum - Variable in class stream.data.NumericalBinning

mean - Variable in class stream.generator.ColtGaussian

mean - Variable in class stream.generator.Gaussian

mean - Variable in class stream.generator.NoisySinusWave

MemoryUsage - Class in stream.monitor

A simple processor that provides statistics about the current Java VM memory usage.

MemoryUsage() - Constructor for class stream.monitor.MemoryUsage

memoryUsed - Variable in class stream.monitor.MemoryUsage

MergeAllMultiStream - Class in stream.io.multi

* A simple multi stream implementation, that merges the items of the substreams.

MergeAllMultiStream() - Constructor for class stream.io.multi.MergeAllMultiStream

Message - Class in stream.logger

Message() - Constructor for class stream.logger.Message

MetaDataLearner - Class in stream.learner

MetaDataLearner() - Constructor for class stream.learner.MetaDataLearner

MetaDataService - Interface in stream.learner

MEXP - Static variable in class stream.generator.SFMT19937

Mersenne Exponent.

MILLISECOND - Static variable in class stream.statistics.History

minArraySize() - Method in class stream.generator.SFMT19937

Returns the smallest array size allowed as an argument to SFMT19937.fillArray(int[]).

Minima - Class in stream.statistics

Minima() - Constructor for class stream.statistics.Minima

minimum - Variable in class stream.data.NumericalBinning

MINUTE - Static variable in class stream.statistics.History

missingValue - Variable in class stream.data.tree.AbstractTreeFeature

MixedStream - Class in stream.generator

MixedStream(SourceURL) - Constructor for class stream.generator.MixedStream

MONTH - Static variable in class stream.statistics.History

MSK1 - Static variable in class stream.generator.SFMT19937

A bitmask parameter, used in the recursion to break symmetry of SIMD.

MSK2 - Static variable in class stream.generator.SFMT19937

A bitmask parameter, used in the recursion to break symmetry of SIMD.

MSK3 - Static variable in class stream.generator.SFMT19937

A bitmask parameter, used in the recursion to break symmetry of SIMD.

MSK4 - Static variable in class stream.generator.SFMT19937

A bitmask parameter, used in the recursion to break symmetry of SIMD.

myCount - Variable in class stream.statistics.CountCheck

MysqlDialect - Class in stream.io.sql

MysqlDialect() - Constructor for class stream.io.sql.MysqlDialect

N

N - Static variable in class stream.generator.SFMT19937

The SFMT generator has an internal state array of 128-bit integers, and N is its size.

n - Variable in class stream.parser.NGrams

N32 - Static variable in class stream.generator.SFMT19937

N32 is the size of internal state array when regarded as an array of 32-bit integers.

nanoTime - Variable in class stream.monitor.AverageThroughput

NeighborPrinter - Class in stream.data.graph

NeighborPrinter() - Constructor for class stream.data.graph.NeighborPrinter

neighbors - Variable in class stream.data.graph.GraphProvider

newKey - Variable in class stream.data.MapKeys

next() - Method in class stream.generator.ColtGaussian

next() - Method in class stream.generator.Gaussian

next(SFMT19937) - Method in class stream.generator.RandomIntegerStream

next(Random) - Method in class stream.generator.RandomStream

next() - Method in class stream.generator.SFMT19937

Generates and returns the next 32-bit pseudorandom number.

nextGaussian() - Method in class stream.generator.Gaussian

nextId - Variable in class stream.data.CreateID

NGrams - Class in stream.parser

NGrams() - Constructor for class stream.parser.NGrams

node - Variable in class stream.data.graph.NeighborPrinter

noise - Variable in class stream.generator.NoisySinusWave

NoisySinusWave - Class in stream.generator

NoisySinusWave() - Constructor for class stream.generator.NoisySinusWave

norm() - Method in class stream.data.vector.Vector

noStream - Variable in class stream.io.multi.DirectoryMultiStream

nowIndex - Variable in class stream.monitor.TimeRate

NumericalBinning - Class in stream.data

NumericalBinning() - Constructor for class stream.data.NumericalBinning

NumericalBinning.Bucket - Class in stream.data

NumericalBinning.Bucket(double, double) - Constructor for class stream.data.NumericalBinning.Bucket

O

observed - Variable in class stream.learner.MetaDataLearner

oldKey - Variable in class stream.data.MapKeys

openConnection() - Method in class stream.io.AbstractSQLProcessor

options - Variable in class stream.util.CommandLineArgs

order - Variable in class stream.io.multi.DirectoryMultiStream

os - Variable in class stream.io.BinaryWriter

out - Variable in class stream.io.DataObjectWriter

out - Variable in class stream.io.JSONBlockWriter

out - Variable in class stream.io.LineWriter

out - Variable in class stream.net.Connection

out - Variable in class stream.net.DataTap.ClientHandler

out - Variable in class stream.net.TcpSender

output - Variable in class stream.data.Unfold

P

p(Double) - Method in class stream.generator.ColtGaussian

p(Double) - Method in interface stream.generator.DistributionFunction

p(Double) - Method in class stream.generator.Gaussian

p - Variable in class stream.io.CsvWriter

packetSize - Variable in class stream.net.UDPStream

pairs - Variable in class stream.data.vector.Vector

parent - Variable in class stream.parser.DefaultTreeParser.DefaultTreeNode

parity - Static variable in class stream.generator.SFMT19937

A parity check vector which certifies the period of 2^{SFMT19937.MEXP} .

PARITY1 - Static variable in class stream.generator.SFMT19937

Part of a 128-bit period certification vector.

PARITY2 - Static variable in class stream.generator.SFMT19937

Part of a 128-bit period certification vector.

PARITY3 - Static variable in class stream.generator.SFMT19937

Part of a 128-bit period certification vector.

PARITY4 - Static variable in class stream.generator.SFMT19937

Part of a 128-bit period certification vector.

parse(String) - Method in class stream.parser.DefaultTreeParser

ParseDouble - Class in stream.parser

ParseDouble() - Constructor for class stream.parser.ParseDouble

ParseInteger - Class in stream.parser

ParseInteger() - Constructor for class stream.parser.ParseInteger

ParseJSON - Class in stream.parser

ParseJSON() - Constructor for class stream.parser.ParseJSON

parseLine(Data, String, String) - Static method in class stream.io.SvmLightStream

This method parses a single line into a data item.

parseLine(Data, String) - Static method in class stream.io.SvmLightStream

ParseLong - Class in stream.parser

ParseLong() - Constructor for class stream.parser.ParseLong

parser - Variable in class stream.io.JSONStream

parser - Variable in class stream.io.LineStream

parser - Variable in class stream.parser.ParseString

ParseString - Class in stream.parser

ParseString() - Constructor for class stream.parser.ParseString

ParseTimestamp - Class in stream.parser

This simple processor adds a timestamp (current time in milliseconds) to all processed data items.

ParseTimestamp() - Constructor for class stream.parser.ParseTimestamp

ParseTimestamp(String, String, String) - Constructor for class stream.parser.ParseTimestamp

password - Variable in class stream.io.AbstractSQLProcessor

password - Variable in class stream.io.SQLStream

paths - Variable in class stream.monitor.VmStats

pattern - Variable in class stream.io.JSONBlockWriter

periodCertification() - Method in class stream.generator.SFMT19937

Certifies the period of 2^{SFMT19937.MEXP}.

phi(double) - Static method in class stream.generator.Gaussian

phi(double, double, double) - Static method in class stream.generator.Gaussian

Phi(double) - Static method in class stream.generator.Gaussian

Phi(double, double, double) - Static method in class stream.generator.Gaussian

pool - Variable in class stream.io.active.SimpleActiveStream

pool - Variable in class stream.io.multi.AbstractMultiStream

pool - Variable in class stream.net.ConnectionHandler

populateDatabase(SourceURL, Map<String, Data>) - Method in class stream.lookup.AbstractDatabase

populateDatabase(SourceURL, Map<String, Data>) - Method in class stream.lookup.CsvDatabase

populateDatabase(SourceURL, Map<String, Data>) - Method in class stream.lookup.JSONDatabase

populateSystemProperties(Properties) - Static method in class stream.util.CommandLineArgs

port - Variable in class stream.net.ConnectionHandler

port - Variable in class stream.net.DataTap

port - Variable in class stream.net.DataTapSink

The port to listen on for incoming tap connections, defaults to 9100.

port - Variable in class stream.net.TcpSender

port - Variable in class stream.net.UDPStream

pos - Variable in class stream.io.ListDataStream

pos - Variable in class stream.parser.DefaultTreeParser

POS1 - Static variable in class stream.generator.SFMT19937

The pick up position of the array.

positive - Variable in class stream.data.BinaryLabels

PredictionError - Class in stream.learner.evaluation

This class implements a generic prediction error evaluator.

PredictionError() - Constructor for class stream.learner.evaluation.PredictionError

prefix - Variable in class stream.data.PrintData

prefix - Variable in class stream.learner.evaluation.PredictionError

prefix - Variable in class stream.parser.NGrams

prefix - Variable in class stream.parser.ParseJSON

prefix - Variable in class stream.statistics.Count

prefix - Variable in class stream.statistics.StatisticsLearner

PrintData - Class in stream.data

PrintData() - Constructor for class stream.data.PrintData

printDataRate() - Method in class stream.monitor.DataRate

printDataRate(Long) - Method in class stream.monitor.DataRate

PrintJSON - Class in stream.data

PrintJSON() - Constructor for class stream.data.PrintJSON

printMapping(File) - Method in class stream.io.SvmLightWriter

printMapping(OutputStream) - Method in class stream.io.SvmLightWriter

process(Data) - Method in class stream.data.AddTimestamp

process(Data) - Method in class stream.data.AddUUID

process(Data) - Method in class stream.data.AsJSON

process(Data) - Method in class stream.data.BinaryLabels

process(Data) - Method in class stream.data.CheckDataAvailability

process(Data) - Method in class stream.data.CreateID

process(Data) - Method in class stream.data.Decrypt

process(Data) - Method in class stream.data.Encrypt

process(Data) - Method in class stream.data.FormatTimestamp

process(Data) - Method in class stream.data.graph.NeighborPrinter

process(Data) - Method in class stream.data.Lookup

process(Data) - Method in class stream.data.MapKeys

process(Data) - Method in class stream.data.MapValues

process(Data) - Method in class stream.data.MapValueToID

process(Data) - Method in class stream.data.NumericalBinning

process(Data) - Method in class stream.data.RandomBinaryLabel

process(Data) - Method in class stream.data.RemoveZeroes

process(Data) - Method in class stream.data.SelectKeys

process(Data) - Method in class stream.data.storage.Store

process(Data) - Method in class stream.data.test.Assert

process(Data) - Method in class stream.data.tree.AbstractTreeFeature

process(Data) - Method in class stream.data.tree.TreeFeatures

process(Data) - Method in class stream.data.TrimKeys

process(Data) - Method in class stream.data.Unfold

process(Data) - Method in class stream.io.BinaryWriter

process(Data) - Method in class stream.io.CsvUpload

process(Data) - Method in class stream.io.DataObjectWriter

process(Data) - Method in class stream.io.JSONBlockWriter

process(Data) - Method in class stream.io.LineWriter

process - Variable in class stream.io.ProcessStream

process(Data) - Method in class stream.io.SQLWriter

process(Data) - Method in class stream.learner.evaluation.PredictionError

process(Data) - Method in class stream.learner.MetaDataLearner

process(Data) - Method in class stream.monitor.AverageThroughput

process(Data) - Method in class stream.monitor.DataRate

process(Data) - Method in class stream.monitor.ItemRate

process(Data) - Method in class stream.monitor.MemoryUsage

process(Data) - Method in class stream.monitor.TimeRate

process - Variable in class stream.monitor.VmStats

process(Data) - Method in class stream.net.DataTap

process(Data) - Method in class stream.net.TcpSender

process(Data) - Method in class stream.parser.DefaultTreeParser

process(Data) - Method in class stream.parser.NGrams

process(Data) - Method in class stream.parser.ParseDouble

process(Data) - Method in class stream.parser.ParseInteger

process(Data) - Method in class stream.parser.ParseJSON

process(Data) - Method in class stream.parser.ParseLong

process(Data) - Method in class stream.parser.ParseString

process(Data) - Method in class stream.parser.ParseTimestamp

process(Data) - Method in class stream.statistics.AddStatistics

process(Data) - Method in class stream.statistics.CountCheck

process(Data) - Method in class stream.statistics.CountServiceLearner

process(Data) - Method in class stream.statistics.StatisticsLearner

process(Data) - Method in class stream.text.AddText

process(Data) - Method in class stream.text.FillTemplate

process(Data) - Method in class stream.transform.TransformToInteger

processMatchingData(Data) - Method in class stream.data.LogData

processMatchingData(Data) - Method in class stream.data.PrintData

processMatchingData(Data) - Method in class stream.data.PrintJSON

processMatchingData(Data) - Method in class stream.data.test.Assert

processMatchingData(Data) - Method in class stream.io.CsvWriter

processMatchingData(Data) - Method in class stream.logger.Message

processMatchingData(Data) - Method in class stream.statistics.Count

processors - Variable in class stream.io.ListDataStream

ProcessStream - Class in stream.io

ProcessStream() - Constructor for class stream.io.ProcessStream

processTree(String, Data) - Method in class stream.data.tree.AbstractTreeFeature

processTree(String, Data) - Method in class stream.data.tree.TreeEdges

processTree(String, Data) - Method in class stream.data.tree.TreeFeatures

ProportionalOracle - Class in stream.generator

This class is a proportional oracle, which will predict values from a fixed, nominal set, where each nominal value has a specific weight.

ProportionalOracle() - Constructor for class stream.generator.ProportionalOracle

ProportionalOracle(Long) - Constructor for class stream.generator.ProportionalOracle

Q

queue - Variable in class stream.io.active.SimpleActiveStream

queue - Variable in class stream.net.UDPStream

R

random - Variable in class stream.data.RandomBinaryLabel

random - Variable in class stream.generator.GaussianStream

random - Variable in class stream.generator.RandomIntegerStream

random - Variable in class stream.generator.RandomStream

RandomBinaryLabel - Class in stream.data

RandomBinaryLabel() - Constructor for class stream.data.RandomBinaryLabel

RandomIntegerStream - Class in stream.generator

RandomIntegerStream() - Constructor for class stream.generator.RandomIntegerStream

RandomMultiStream - Class in stream.io.multi

RandomMultiStream() - Constructor for class stream.io.multi.RandomMultiStream

RandomStream - Class in stream.generator

RandomStream() - Constructor for class stream.generator.RandomStream

rate - Variable in class stream.monitor.DataRate

rate - Variable in class stream.monitor.TimeRate

read() - Method in class stream.io.ListDataStream

read() - Method in class stream.net.UDPStream

read(String) - Method in class stream.parser.DefaultTreeParser

readDatabase(Stream, Map<String, Data>) - Method in class stream.lookup.AbstractDatabase

reader - Variable in class stream.io.AbstractLineStream

reader - Variable in class stream.monitor.VmStats

readHeader() - Method in class stream.io.ArffStream

readLine() - Method in class stream.io.AbstractLineStream

readLine() - Method in class stream.io.CsvStream

This implementation of the readLine() method simply skips all comments, i.e. lines starting with the '#' character.

readNext() - Method in class stream.generator.ColtGaussianStream

readNext() - Method in class stream.generator.GaussianStream

readNext() - Method in class stream.generator.MixedStream

readNext() - Method in class stream.generator.NoisySinusWave

readNext() - Method in class stream.generator.RandomIntegerStream

readNext() - Method in class stream.generator.RandomStream

readNext() - Method in class stream.generator.SinusWave

readNext() - Method in class stream.io.active.SimpleActiveStream

readNext() - Method in class stream.io.ArffStream

readNext() - Method in class stream.io.CsvStream

readNext() - Method in class stream.io.DataObjectStream

readNext() - Method in class stream.io.DirectoryStream

readNext() - Method in class stream.io.JSONStream

readNext() - Method in class stream.io.LineStream

readNext() - Method in class stream.io.multi.DirectoryMultiStream

readNext() - Method in class stream.io.multi.MergeAllMultiStream

readNext() - Method in class stream.io.multi.RandomMultiStream

readNext() - Method in class stream.io.multi.SequentialMultiStream

readNext() - Method in class stream.io.ProcessStream

readNext() - Method in class stream.io.SQLStream

readNext() - Method in class stream.io.SvmLightStream

readNext() - Method in class stream.io.TimeStream

readNext() - Method in class stream.monitor.VmStats

readNext() - Method in class stream.net.BufferedDataObjectStream

See BufferedDataObjectStream for details.

readNext() - Method in class stream.net.UDPStream

readSparseVector(Data) - Method in class stream.io.SvmLightStream

readSparseVector(String) - Static method in class stream.io.SvmLightStream

readToken() - Method in class stream.parser.DefaultTreeParser

readToken(char[]) - Method in class stream.parser.DefaultTreeParser

readTreeNode() - Method in class stream.parser.DefaultTreeParser

reconnectInterval - Variable in class stream.net.BufferedDataObjectStream

the time between two connection attempts if the first connection attempt was unsuccessful

register(Socket, int, boolean, boolean) - Method in class stream.net.ConnectionHandler

remove - Variable in class stream.data.SelectKeys

remove - Variable in class stream.parser.ParseJSON

removeQuotes(String) - Method in class stream.io.CsvStream

RemoveZeroes - Class in stream.data

RemoveZeroes() - Constructor for class stream.data.RemoveZeroes

reset() - Method in class stream.data.CreateID

reset() - Method in class stream.data.graph.GraphProvider

reset() - Method in class stream.data.storage.Store

reset() - Method in class stream.io.CsvWriter

reset - Variable in class stream.io.DataObjectWriter

reset() - Method in class stream.learner.MetaDataLearner

reset() - Method in class stream.lookup.AbstractDatabase

reset() - Method in class stream.monitor.AverageThroughput

reset() - Method in class stream.monitor.DataRate

reset() - Method in class stream.monitor.MemoryUsage

reset() - Method in class stream.monitor.TimeRate

reset() - Method in class stream.service.Dashboard

reset() - Method in class stream.statistics.Average

reset() - Method in class stream.statistics.Count

reset() - Method in class stream.statistics.CountServiceLearner

reset() - Method in class stream.statistics.StatisticsLearner

resetState() - Method in class stream.statistics.StatisticsLearner

result - Variable in class stream.io.SQLStream

rnd - Variable in class stream.generator.ColtGaussian

rnd - Variable in class stream.generator.Gaussian

rnd - Variable in class stream.generator.MixedStream

rnd - Variable in class stream.generator.ProportionalOracle

rndEngine - Variable in class stream.generator.ColtGaussian

rotate - Variable in class stream.io.BinaryWriter

run() - Method in class stream.io.active.SimpleActiveStream.StreamActivator

run() - Method in class stream.net.Connection

This method creates a client connection shutdown listener (if wanted) in an own thread writes the buffered data items to the output stream in an endless loop

run() - Method in class stream.net.ConnectionHandler

This methods accepts new client connections and creates a socket connection for each client in an endless loop

run() - Method in class stream.net.DataTap.ClientHandler

run() - Method in class stream.net.DataTap.ServerThread

run() - Method in class stream.net.UDPStream

running - Variable in class stream.net.Connection

flag to indicate that the corresponding client is connected and can receive data

running - Variable in class stream.net.ConnectionHandler

flag to indicate that the server is active

running - Variable in class stream.net.DataTap.ServerThread

running - Variable in class stream.net.UDPStream

S

scale - Variable in class stream.data.vector.Vector

scale(double) - Method in class stream.data.vector.Vector

scale(Data, Double) - Static method in class stream.data.vector.VectorMath

Deprecated.

scope - Variable in class stream.data.CheckDataAvailability

SECOND - Static variable in class stream.statistics.History

secret - Variable in class stream.data.Decrypt

secret - Variable in class stream.data.Encrypt

seed - Variable in class stream.data.RandomBinaryLabel

seed - Variable in class stream.generator.ColtGaussian

seed - Variable in class stream.generator.ColtGaussianStream

seed - Variable in class stream.generator.Gaussian

seed - Variable in class stream.generator.GaussianStream

seed - Variable in class stream.generator.NoisySinusWave

seedGenerator - Variable in class stream.generator.ColtGaussianStream

seedGenerator - Variable in class stream.generator.GaussianStream

select - Variable in class stream.io.SQLStream

selected - Variable in class stream.data.SelectKeys

SelectKeys - Class in stream.data

SelectKeys() - Constructor for class stream.data.SelectKeys

selectNextStream() - Method in class stream.io.multi.RandomMultiStream

separator - Variable in class stream.io.CsvWriter

separator - Variable in class stream.lookup.CsvDatabase

separator - Variable in class stream.statistics.Count

SequentialMultiStream - Class in stream.io.multi

SequentialMultiStream() - Constructor for class stream.io.multi.SequentialMultiStream

serialize - Variable in class stream.data.Encrypt

serializer - Variable in class stream.data.Decrypt

serializer - Variable in class stream.data.Encrypt

SERIALIZER_KEY - Static variable in class stream.data.Encrypt

serialVersionUID - Static variable in class stream.data.NumericalBinning.Bucket

The unique class ID

serialVersionUID - Static variable in class stream.data.vector.InputVector

serialVersionUID - Static variable in class stream.data.vector.Vector

serialVersionUID - Static variable in class stream.parser.DefaultTreeParser.DefaultTreeNode

The unique class ID

serialVersionUID - Static variable in class stream.statistics.History

The unique class ID

serialVersionUID - Static variable in class stream.statistics.StatisticsHistory

The unique class ID

server - Variable in class stream.net.DataTap.ClientHandler

server - Variable in class stream.net.DataTap

server - Variable in class stream.net.DataTap.ServerThread

service - Variable in class stream.statistics.AddStatistics

services - Variable in class stream.statistics.AddStatistics

set(int, double) - Method in class stream.data.vector.Vector

set(String, Object) - Method in class stream.generator.RandomIntegerStream

set(String, Object) - Method in class stream.generator.RandomStream

setActivate(Boolean) - Method in class stream.io.multi.AbstractMultiStream

setAddress(String) - Method in class stream.net.DataTap

setAddress(String) - Method in class stream.net.TcpSender

setAddress(String) - Method in class stream.net.UDPStream

setAmplitude(Double) - Method in class stream.generator.NoisySinusWave

setAmplitude(Double) - Method in class stream.generator.SinusWave

setAppend(Boolean) - Method in class stream.io.CsvWriter

setAppend(boolean) - Method in class stream.io.LineWriter

setAttributeFilter(String) - Method in class stream.io.CsvWriter

setAttributes(Double[]) - Method in class stream.generator.ColtGaussianStream

setAttributes(Double[]) - Method in class stream.generator.GaussianStream

setBacklog(Integer) - Method in class stream.net.UDPStream

setBins(Integer) - Method in class stream.data.NumericalBinning

setBlockSize(ByteSize) - Method in class stream.io.JSONBlockWriter

setBufferSize(int) - Method in class stream.net.BufferedDataObjectStream

setCapacity(Integer) - Method in class stream.data.storage.Store

setClientBufferSize(int) - Method in class stream.net.DataTapSink

Sets the buffer size used for each client

setClock(String) - Method in class stream.monitor.DataRate

setColumnType(Class<?>, String) - Method in class stream.io.sql.DatabaseDialect

setCommand(String) - Method in class stream.io.ProcessStream

setConnectionRetries(int) - Method in class stream.net.BufferedDataObjectStream

setCountService(CountService) - Method in class stream.statistics.CountCheck

setDefault(Serializable) - Method in class stream.data.MapValues

setDefault(Double) - Method in class stream.parser.ParseDouble

setDefault(Integer) - Method in class stream.parser.ParseInteger

setDefault(Long) - Method in class stream.parser.ParseLong

setDefaults(Map<String, String>) - Method in class stream.parser.DefaultTreeParser

setDetectClientClose(boolean) - Method in class stream.net.DataTapSink

setDirectory(File) - Method in class stream.io.JSONBlockWriter

setDisconnectSlowClients(boolean) - Method in class stream.net.DataTapSink

setDropTable(boolean) - Method in class stream.io.SQLWriter

setEmptyStrings(boolean) - Method in class stream.text.FillTemplate

setEncoding(String) - Method in class stream.io.AbstractLineStream

setEscapeNewlines(boolean) - Method in class stream.io.LineWriter

setEvery(Integer) - Method in class stream.monitor.DataRate

setEvery(Integer) - Method in class stream.monitor.ItemRate

setEvery(Integer) - Method in class stream.monitor.TimeRate

setFile(File) - Method in class stream.data.graph.GraphProvider

setFile(File) - Method in class stream.io.BinaryWriter

setFile(File) - Method in class stream.io.DataObjectWriter

setFile(File) - Method in class stream.io.LineWriter

setFile(String) - Method in class stream.statistics.Count

setFile(String) - Method in class stream.text.AddText

setFormat(String) - Method in class stream.data.FormatTimestamp

setFormat(String) - Method in class stream.io.LineStream

setFormat(String) - Method in class stream.io.LineWriter

setFormat(String) - Method in class stream.io.ProcessStream

setFormat(String) - Method in class stream.parser.ParseString

setFormat(String) - Method in class stream.parser.ParseTimestamp

setFrequency(Double) - Method in class stream.generator.NoisySinusWave

setFrequency(Double) - Method in class stream.generator.SinusWave

setFrom(String) - Method in class stream.data.FormatTimestamp

setFrom(String) - Method in class stream.data.MapKeys

setFrom(String) - Method in class stream.data.MapValues

setFrom(String) - Method in class stream.parser.ParseTimestamp

setGenerator(String, ColtGaussian) - Method in class stream.generator.ColtGaussianStream

setGenerator(String, Gaussian) - Method in class stream.generator.GaussianStream

setGraph(GraphService) - Method in class stream.data.graph.NeighborPrinter

setGroupBy(String) - Method in class stream.statistics.Count

setGzip(boolean) - Method in class stream.net.DataTap

setGzip(boolean) - Method in class stream.net.DataTapSink

setHeader(boolean) - Method in class stream.io.CsvStream

setHeader(boolean) - Method in class stream.io.CsvWriter

setHeader(boolean) - Method in class stream.lookup.CsvDatabase

setHeight(Integer) - Method in class stream.service.Dashboard

setHistory(String) - Method in class stream.statistics.Count

setId(String) - Method in class stream.data.tree.AbstractTreeFeature

setId(String) - Method in class stream.io.ListDataStream

setId(String) - Method in class stream.monitor.DataRate

setId(String) - Method in class stream.monitor.TimeRate

setId(String) - Method in class stream.net.DataTapSink

setId(String) - Method in class stream.net.UDPStream

setIncludeAnnotations(boolean) - Method in class stream.io.SvmLightWriter

setIndex(String) - Method in class stream.monitor.TimeRate

setInterval(String) - Method in class stream.io.TimeStream

setInterval(Time) - Method in class stream.monitor.VmStats

setIntSeed(int) - Method in class stream.generator.SFMT19937

Initializes the internal state array with a 32-bit seed.

setKey(String) - Method in class stream.data.AddTimestamp

setKey(String) - Method in class stream.data.AddUUID

setKey(String) - Method in class stream.data.AsJSON

setKey(String) - Method in class stream.data.CreateID

setKey(String) - Method in class stream.data.FormatTimestamp

setKey(String) - Method in class stream.data.Lookup

setKey(String) - Method in class stream.data.MapValues

setKey(String) - Method in class stream.data.MapValueToID

setKey(String) - Method in class stream.data.NumericalBinning

setKey(String) - Method in class stream.data.RandomBinaryLabel

setKey(String) - Method in class stream.data.Unfold

setKey(String) - Method in class stream.generator.NoisySinusWave

setKey(String) - Method in class stream.generator.SinusWave

setKey(String) - Method in class stream.io.BinaryWriter

setKey(String) - Method in class stream.io.LineStream

setKey(String) - Method in class stream.io.TimeStream

setKey(String) - Method in class stream.lookup.AbstractDatabase

setKey(String) - Method in class stream.monitor.DataRate

setKey(String) - Method in class stream.monitor.MemoryUsage

setKey(String) - Method in class stream.parser.NGrams

setKey(String) - Method in class stream.parser.ParseJSON

setKey(String) - Method in class stream.parser.ParseString

setKey(String) - Method in class stream.parser.ParseTimestamp

setKey(String) - Method in class stream.text.AddText

setKey(String) - Method in class stream.text.FillTemplate

setKeys(String[]) - Method in class stream.data.CheckDataAvailability

setKeys(String[]) - Method in class stream.data.NumericalBinning

setKeys(String[]) - Method in class stream.data.SelectKeys

setKeys(String[]) - Method in class stream.data.storage.Store

setKeys(String[]) - Method in class stream.data.tree.AbstractTreeFeature

setKeys(String[]) - Method in class stream.generator.RandomIntegerStream

setKeys(String[]) - Method in class stream.generator.RandomStream

setKeys(String[]) - Method in class stream.io.BinaryWriter

setKeys(String[]) - Method in class stream.io.CsvStream

setKeys(String[]) - Method in class stream.io.CsvWriter

setKeys(String[]) - Method in class stream.io.SQLWriter

setKeys(String[]) - Method in class stream.learner.MetaDataLearner

setKeys(String[]) - Method in class stream.lookup.CsvDatabase

setKeys(String[]) - Method in class stream.net.TcpSender

setKeys(String[]) - Method in class stream.parser.ParseDouble

setKeys(String[]) - Method in class stream.parser.ParseInteger

setKeys(String[]) - Method in class stream.parser.ParseLong

setKeys(String[]) - Method in class stream.statistics.StatisticsLearner

setLabel(String) - Method in class stream.data.BinaryLabels

setLabel(double) - Method in class stream.data.vector.InputVector

setLabel(String) - Method in class stream.learner.evaluation.PredictionError

setLabel(String) - Method in class stream.parser.DefaultTreeParser.DefaultTreeNode

setLearner(String[]) - Method in class stream.learner.evaluation.PredictionError

setLevel(String) - Method in class stream.logger.Message

setLimit(Long) - Method in class stream.generator.GaussianStream

setLimit(Long) - Method in class stream.io.ListDataStream

setLookup(LookupService) - Method in class stream.data.Lookup

setMap(String) - Method in class stream.data.MapKeys

setMap(String) - Method in class stream.data.MapValues

setMapping(Map<String, String>) - Method in class stream.data.MapKeys

setMaximum(Double) - Method in class stream.data.NumericalBinning

setMean(Double) - Method in class stream.generator.ColtGaussian

setMean(Double) - Method in class stream.generator.Gaussian

setMean(Double) - Method in class stream.generator.NoisySinusWave

setMessage(String) - Method in class stream.logger.Message

setMinimum(Double) - Method in class stream.data.NumericalBinning

setMissing(String) - Method in class stream.data.tree.AbstractTreeFeature

setN(Integer) - Method in class stream.parser.NGrams

setNode(String) - Method in class stream.data.graph.NeighborPrinter

setOrder(String[]) - Method in class stream.io.multi.DirectoryMultiStream

setOutput(Sink[]) - Method in class stream.data.Unfold

setPassword(String) - Method in class stream.io.AbstractSQLProcessor

setPassword(String) - Method in class stream.io.SQLStream

setPattern(String) - Method in class stream.io.JSONBlockWriter

setPort(Integer) - Method in class stream.net.DataTap

setPort(Integer) - Method in class stream.net.DataTapSink

setPort(int) - Method in class stream.net.TcpSender

setPort(Integer) - Method in class stream.net.UDPStream

setPositive(String) - Method in class stream.data.BinaryLabels

setPrefix(String) - Method in class stream.data.PrintData

setPrefix(String) - Method in class stream.learner.evaluation.PredictionError

setPrefix(String) - Method in class stream.parser.NGrams

setPrefix(String) - Method in class stream.parser.ParseJSON

setPrefix(String) - Method in class stream.statistics.Count

setPrefix(String) - Method in class stream.statistics.StatisticsLearner

setReconnectInterval(String) - Method in class stream.net.BufferedDataObjectStream

setRemove(Boolean) - Method in class stream.data.SelectKeys

setRemove(boolean) - Method in class stream.parser.ParseJSON

setReset(Integer) - Method in class stream.io.DataObjectWriter

setScope(String) - Method in class stream.data.CheckDataAvailability

setSecret(String) - Method in class stream.data.Decrypt

setSecret(String) - Method in class stream.data.Encrypt

setSeed(Long) - Method in class stream.data.RandomBinaryLabel

setSeed(Long) - Method in class stream.generator.ColtGaussian

setSeed(Long) - Method in class stream.generator.ColtGaussianStream

setSeed(Long) - Method in class stream.generator.Gaussian

setSeed(Long) - Method in class stream.generator.GaussianStream

setSeed(Long) - Method in class stream.generator.NoisySinusWave

setSeed(Long) - Method in class stream.generator.ProportionalOracle

setSeed(long) - Method in class stream.generator.SFMT19937

Initializes the internal state array with a 64-bit seed.

setSelect(String) - Method in class stream.io.SQLStream

setSeparator(String) - Method in class stream.io.CsvStream

setSeparator(String) - Method in class stream.io.CsvWriter

setSeparator(String) - Method in class stream.lookup.CsvDatabase

setSerializer(String) - Method in class stream.data.Encrypt

setService(StatisticsService) - Method in class stream.statistics.AddStatistics

setServices(StatisticsService[]) - Method in class stream.statistics.AddStatistics

setSourceKey(String) - Method in class stream.io.multi.SequentialMultiStream

setSparseKey(String) - Method in class stream.io.SvmLightStream

setStart(Long) - Method in class stream.data.CreateID

setSuffix(String) - Method in class stream.io.multi.DirectoryMultiStream

setSystemProperties(String) - Method in class stream.util.CommandLineArgs

setTable(String) - Method in class stream.io.SQLWriter

setText(String) - Method in class stream.text.AddText

setThreshold(Double) - Method in class stream.data.BinaryLabels

setTimeKey(String) - Method in class stream.io.JSONBlockWriter

setTimeKey(String) - Method in class stream.statistics.Count

setTimezone(String) - Method in class stream.parser.ParseTimestamp

setTitle(String) - Method in class stream.service.Dashboard

setTo(String) - Method in class stream.data.MapKeys

setTo(String) - Method in class stream.data.MapValues

setUrl(String) - Method in class stream.io.AbstractSQLProcessor

setUrl(String) - Method in class stream.io.CsvWriter

setUrl(SourceURL) - Method in class stream.lookup.AbstractDatabase

setUsername(String) - Method in class stream.io.AbstractSQLProcessor

setUsername(String) - Method in class stream.io.SQLStream

setVariance(Double) - Method in class stream.generator.ColtGaussian

setVariance(Double) - Method in class stream.generator.Gaussian

setVariance(Double) - Method in class stream.generator.NoisySinusWave

setWeights(Map<String, Double>) - Method in class stream.generator.ProportionalOracle

setWeights(Double[]) - Method in class stream.io.multi.RandomMultiStream

setWidth(Integer) - Method in class stream.service.Dashboard

setWindow(String) - Method in class stream.statistics.Count

sfmt - Variable in class stream.generator.SFMT19937

The internal state array.

SFMT19937 - Class in stream.generator

An adapation of SFMT (SIMD oriented Fast Mersenne Twister) version 1.3 by Mutsuo Saito (Hiroshima University) and Makoto Matsumoto (Hiroshima University).

SFMT19937() - Constructor for class stream.generator.SFMT19937

Constructor that initially uses a seed based on the time of day.

SFMT19937(long) - Constructor for class stream.generator.SFMT19937

Constructor that initializes the internal state array by calling SFMT19937.setSeed(long) with the specified argument.

shutdown() - Method in class stream.net.DataTap.ServerThread

SimpleActiveStream - Class in stream.io.active

* A simple active stream implementation.

SimpleActiveStream(Stream, ExecutorService) - Constructor for class stream.io.active.SimpleActiveStream

SimpleActiveStream.StreamActivator - Class in stream.io.active

SimpleActiveStream.StreamActivator() - Constructor for class stream.io.active.SimpleActiveStream.StreamActivator

SinusWave - Class in stream.generator

SinusWave() - Constructor for class stream.generator.SinusWave

skip() - Method in class stream.parser.DefaultTreeParser

SL1 - Static variable in class stream.generator.SFMT19937

The parameter of shift left as four 32-bit registers.

SL2 - Static variable in class stream.generator.SFMT19937

The parameter of shift left as one 128-bit register.

snorm - Variable in class stream.data.vector.Vector

snorm() - Method in class stream.data.vector.Vector

socket - Variable in class stream.net.Connection

the socket to communicate with the client.

socket - Variable in class stream.net.DataTap.ClientHandler

socket - Variable in class stream.net.TcpSender

socket - Variable in class stream.net.UDPStream

sourceKey - Variable in class stream.io.multi.SequentialMultiStream

sourceKey - Variable in class stream.parser.DefaultTreeParser

sparseKey - Variable in class stream.io.SvmLightStream

splitExpression - Variable in class stream.io.CsvStream

SQLStream - Class in stream.io

SQLStream(SourceURL) - Constructor for class stream.io.SQLStream

SQLStream() - Constructor for class stream.io.SQLStream

SQLWriter - Class in stream.io

SQLWriter() - Constructor for class stream.io.SQLWriter

SR1 - Static variable in class stream.generator.SFMT19937

The parameter of shift right as four 32-bit registers.

SR2 - Static variable in class stream.generator.SFMT19937

The parameter of shift right as one 128-bit register.

start - Variable in class stream.data.CreateID

start - Variable in class stream.monitor.DataRate

start - Variable in class stream.monitor.ItemRate

start - Variable in class stream.monitor.TimeRate

startIndex - Variable in class stream.monitor.TimeRate

startsWith(String) - Method in class stream.parser.DefaultTreeParser

statistics - Variable in class stream.statistics.StatisticsLearner

StatisticsHistory - Class in stream.statistics

StatisticsHistory(long, long) - Constructor for class stream.statistics.StatisticsHistory

StatisticsHistory(StatisticsHistory) - Constructor for class stream.statistics.StatisticsHistory

StatisticsLearner - Class in stream.statistics

StatisticsLearner() - Constructor for class stream.statistics.StatisticsLearner

StatisticsService - Interface in stream.statistics

stats - Variable in class stream.learner.MetaDataLearner

stepSize - Variable in class stream.statistics.History

Store<T extends Serializable> - Class in stream.data.storage

Store() - Constructor for class stream.data.storage.Store

store - Variable in class stream.generator.RandomIntegerStream

store - Variable in class stream.generator.RandomStream

StoreDataList - Class in stream.data.storage

StoreDataList() - Constructor for class stream.data.storage.StoreDataList

StoreList<T extends Serializable> - Class in stream.data.storage

StoreList() - Constructor for class stream.data.storage.StoreList

stream - Variable in class stream.io.active.SimpleActiveStream

stream - Variable in class stream.io.multi.DirectoryMultiStream

stream.data - package stream.data

stream.data.graph - package stream.data.graph

stream.data.storage - package stream.data.storage

stream.data.test - package stream.data.test

stream.data.tree - package stream.data.tree

stream.data.vector - package stream.data.vector

stream.generator - package stream.generator

stream.io - package stream.io

stream.io.active - package stream.io.active

stream.io.multi - package stream.io.multi

stream.io.sql - package stream.io.sql

stream.learner - package stream.learner

stream.learner.evaluation - package stream.learner.evaluation

stream.logger - package stream.logger

stream.lookup - package stream.lookup

stream.monitor - package stream.monitor

stream.net - package stream.net

stream.parser - package stream.parser

stream.service - package stream.service

stream.statistics - package stream.statistics

stream.text - package stream.text

stream.transform - package stream.transform

stream.util - package stream.util

streams - Variable in class stream.generator.MixedStream

streams - Variable in class stream.io.multi.AbstractMultiStream

substitute(String, boolean, Map<String, String>) - Method in class stream.text.FillTemplate

suffix - Variable in class stream.io.multi.DirectoryMultiStream

Sum - Class in stream.statistics

Sum() - Constructor for class stream.statistics.Sum

SvmLightStream - Class in stream.io

This class implements a simple reader to read data in the SVM light data format.

SvmLightStream(SourceURL) - Constructor for class stream.io.SvmLightStream

SvmLightStream(SourceURL, String) - Constructor for class stream.io.SvmLightStream

SvmLightStream(InputStream) - Constructor for class stream.io.SvmLightStream

SvmLightWriter - Class in stream.io

SvmLightWriter() - Constructor for class stream.io.SvmLightWriter

SvmLightWriter(OutputStream) - Constructor for class stream.io.SvmLightWriter

T

t - Variable in class stream.net.UDPStream

table - Variable in class stream.io.SQLWriter

tableExists - Variable in class stream.io.SQLWriter

TableOfConfusion - Class in stream.learner.evaluation

A data structure for computation of statistical values based on a 2x2 confusion matrix.

TableOfConfusion() - Constructor for class stream.learner.evaluation.TableOfConfusion

tableSchema - Variable in class stream.io.SQLWriter

TcpSender - Class in stream.net

TcpSender() - Constructor for class stream.net.TcpSender

text - Variable in class stream.text.AddText

threshold - Variable in class stream.data.BinaryLabels

timeFormat - Variable in class stream.io.BinaryWriter

timeFormat - Variable in class stream.statistics.Count

timeInterval - Variable in class stream.statistics.Count

timeKey - Variable in class stream.io.JSONBlockWriter

timeKey - Variable in class stream.statistics.Count

TimeRate - Class in stream.monitor

TimeRate() - Constructor for class stream.monitor.TimeRate

TimeStream - Class in stream.io

TimeStream() - Constructor for class stream.io.TimeStream

timeWindow - Variable in class stream.statistics.Count

timezone - Variable in class stream.parser.ParseTimestamp

title - Variable in class stream.service.Dashboard

to - Variable in class stream.data.MapValues

toHtml() - Method in class stream.generator.ColtGaussian

toHtml() - Method in class stream.generator.Gaussian

toHtml() - Method in class stream.learner.evaluation.ConfusionMatrix

toString() - Method in class stream.data.NumericalBinning.Bucket

toString() - Method in class stream.data.vector.Vector

toString() - Method in class stream.generator.ColtGaussian

toString() - Method in class stream.generator.Gaussian

toString() - Method in class stream.generator.ProportionalOracle

toString() - Method in class stream.learner.evaluation.ConfusionMatrix

toString() - Method in class stream.learner.evaluation.TableOfConfusion

Returns a String representation of this table of confusion.

toString() - Method in class stream.net.Connection

toString() - Method in class stream.parser.DefaultTreeParser.DefaultTreeNode

toStringOld() - Method in class stream.learner.evaluation.TableOfConfusion

total - Variable in class stream.monitor.ItemRate

totalWeight - Variable in class stream.generator.MixedStream

TransformToInteger - Class in stream.transform

Transform the values of the given keys to Integer, if the values are a instance of Number.

TransformToInteger() - Constructor for class stream.transform.TransformToInteger

TreeEdges - Class in stream.data.tree

TreeEdges() - Constructor for class stream.data.tree.TreeEdges

TreeFeature - Interface in stream.data.tree

TreeFeatures - Class in stream.data.tree

TreeFeatures() - Constructor for class stream.data.tree.TreeFeatures

TrimKeys - Class in stream.data

TrimKeys() - Constructor for class stream.data.TrimKeys

trueNegative - Variable in class stream.learner.evaluation.TableOfConfusion

truePositive - Variable in class stream.learner.evaluation.TableOfConfusion

TrustAllManager - Class in stream.util

TrustAllManager() - Constructor for class stream.util.TrustAllManager

txt - Variable in class stream.logger.Message

type - Variable in class stream.data.vector.Vector

types - Variable in class stream.generator.ColtGaussianStream

types - Variable in class stream.generator.GaussianStream

U

UDPStream - Class in stream.net

UDPStream() - Constructor for class stream.net.UDPStream

Unfold - Class in stream.data

Unfold() - Constructor for class stream.data.Unfold

uniquifier - Static variable in class stream.generator.SFMT19937

A number mixed with the time of day to provide a unique seed to each generator of this type allocated.

unmapColumnName(String) - Method in class stream.io.sql.DatabaseDialect

unmapColumnName(String) - Method in class stream.io.sql.MysqlDialect

unregister(Connection) - Method in class stream.net.ConnectionHandler

update(Statistics, Double) - Method in class stream.learner.MetaDataLearner

update(Statistics, String) - Method in class stream.learner.MetaDataLearner

updateStatistics(Data) - Method in class stream.statistics.Average

updateStatistics(Data) - Method in class stream.statistics.Maxima

updateStatistics(Data) - Method in class stream.statistics.Minima

updateStatistics(Data) - Method in class stream.statistics.StatisticsLearner

updateStatistics(Data) - Method in class stream.statistics.Sum

upper - Variable in class stream.data.NumericalBinning.Bucket

url - Variable in class stream.io.AbstractSQLProcessor

url - Variable in class stream.io.CsvUpload

url - Variable in class stream.io.CsvWriter

url - Variable in class stream.lookup.AbstractDatabase

urlCache - Variable in class stream.net.BufferedDataObjectStream

caches the return value of BufferedDataObjectStream.getConnectionString()

urlString - Variable in class stream.io.CsvWriter

username - Variable in class stream.io.AbstractSQLProcessor

username - Variable in class stream.io.SQLStream

V

vals - Variable in class stream.data.vector.Vector

valueOf(String) - Static method in enum stream.data.vector.Vector.Type

Returns the enum constant of this type with the specified name.

values() - Static method in enum stream.data.vector.Vector.Type

Returns an array containing the constants of this enum type, in the order they are declared.

VAR_PREFIX - Static variable in class stream.text.FillTemplate

VAR_SUFFIX - Static variable in class stream.text.FillTemplate

variance - Variable in class stream.generator.ColtGaussian

variance - Variable in class stream.generator.Gaussian

variance - Variable in class stream.generator.NoisySinusWave

Vector - Class in stream.data.vector

Vector() - Constructor for class stream.data.vector.Vector

Creates a sparse vector.

Vector(int) - Constructor for class stream.data.vector.Vector

Creates a dense vector of the specified length.

Vector(int[], double[]) - Constructor for class stream.data.vector.Vector

Creates a sparse vector from the given indices and values.

Vector(double[]) - Constructor for class stream.data.vector.Vector

Creates a dense vector from the given values.

Vector(double[], boolean) - Constructor for class stream.data.vector.Vector

Vector(HashMap<Integer, Double>) - Constructor for class stream.data.vector.Vector

Creates a sparse vector from a HashMap

Vector(HashMap<Integer, Double>, boolean) - Constructor for class stream.data.vector.Vector

Vector(Vector) - Constructor for class stream.data.vector.Vector

A copy constructor

Vector(int[], double[], int) - Constructor for class stream.data.vector.Vector

Creates a dense vector filling the values in the given indices of non-zero entries.

Vector.Type - Enum in stream.data.vector

Vector.Type() - Constructor for enum stream.data.vector.Vector.Type

VectorMath - Class in stream.data.vector

Deprecated.

VectorMath() - Constructor for class stream.data.vector.VectorMath

Deprecated.

vmstat - Variable in class stream.monitor.VmStats

VmStats - Class in stream.monitor

VmStats() - Constructor for class stream.monitor.VmStats

vmStats - Variable in class stream.monitor.VmStats

W

WEEK - Static variable in class stream.statistics.History

weights - Variable in class stream.generator.MixedStream

weights - Variable in class stream.generator.ProportionalOracle

weights - Variable in class stream.io.multi.RandomMultiStream

width - Variable in class stream.service.Dashboard

window - Variable in class stream.statistics.Count

windowCount - Variable in class stream.monitor.DataRate

write(Data) - Method in class stream.io.CsvWriter

write(Data) - Method in class stream.io.JSONWriter

write(Data) - Method in class stream.io.SvmLightWriter

write(Data) - Method in class stream.net.Connection

Adds the specified data item to this client's buffer.

write(Data) - Method in class stream.net.ConnectionHandler

write(Collection<Data>) - Method in class stream.net.DataTapSink

write(Data) - Method in class stream.net.DataTapSink

This operation blocks if at least one client buffer is exceeded.

writeHeader(Data) - Method in class stream.io.CsvWriter

writeHeader(Data) - Method in class stream.io.JSONWriter

writeHeader(Data) - Method in class stream.io.SvmLightWriter

Y

y - Variable in class stream.data.vector.InputVector

YEAR - Static variable in class stream.statistics.History

Z

ZeroOneLoss<T extends Serializable> - Class in stream.learner.evaluation

ZeroOneLoss() - Constructor for class stream.learner.evaluation.ZeroOneLoss

A B C D E F G H I J K L M N O P Q R S T U V W Y Z