- WAITING_FOR_DATA - Static variable in interface ds.granules.scheduler.TaskLifecycleMetrics
-
- wakeup() - Method in interface ds.funnel.data.channel.ChannelManager
-
Wake up reader and writer tasks.
- wakeup() - Method in class ds.funnel.data.channel.ChannelManagerImpl
-
- warning(String) - Method in class ds.funnel.node.FunnelLogger
-
- warning(Exception) - Method in class ds.funnel.node.FunnelLogger
-
- WEIGHT - Static variable in interface ds.funnel.overlay.graph.GraphBuilder
-
- WeightedTree - Class in ds.funnel.overlay.topology
-
- WeightedTree() - Constructor for class ds.funnel.overlay.topology.WeightedTree
-
- WindowDataSource - Class in ds.synapse.data.source
-
- WindowDataSource(FileLifecycle, FileStorage, String, long, int) - Constructor for class ds.synapse.data.source.WindowDataSource
-
- WordCountDeployer - Class in ds.granules.samples.wordcount
-
The deployer for the WORD Count information retrieval example, which allows
one to histogram words from given set of files over a distributed set of
resources.
- WordCountDeployer() - Constructor for class ds.granules.samples.wordcount.WordCountDeployer
-
Initializes the deployer.
- WordCountMap - Class in ds.granules.samples.wordcount
-
An example demonstrating the Map role within a Word Count
operation.
- WordCountMap() - Constructor for class ds.granules.samples.wordcount.WordCountMap
-
- WordCountReduce - Class in ds.granules.samples.wordcount
-
An example demonstrating the Reduce role within a Word Count
operation.
- WordCountReduce() - Constructor for class ds.granules.samples.wordcount.WordCountReduce
-
- write(String, ByteBuffer) - Method in interface ds.granules.dataset.FileAccess
-
Deprecated.
Write the specified Buffer to the file corresponding to the specified
file.
- write(String, byte[]) - Method in interface ds.granules.dataset.FileAccess
-
Deprecated.
Writes a byte[] to a give file.
- write(String, byte[]) - Method in interface ds.granules.dataset.FileDataset
-
Writes a byte[] to a give file.
- write(String, ByteBuffer) - Method in interface ds.granules.dataset.FileDataset
-
Write the specified Buffer to the file corresponding to the specified
file.
- write(String, byte[]) - Method in class ds.granules.dataset.FileDatasetImpl
-
- write(String, ByteBuffer) - Method in class ds.granules.dataset.FileDatasetImpl
-
- write(String, byte[]) - Method in class ds.granules.dataset.FileDatasetImplLegacy
-
Deprecated.
- write(String, ByteBuffer) - Method in class ds.granules.dataset.FileDatasetImplLegacy
-
Deprecated.
- writeBool(boolean) - Method in interface ds.funnel.data.format.FormatWriter
-
Writes a boolean to the underlying buffer.
- writeBool(boolean) - Method in class ds.funnel.data.msglink.protocol3.MessageFormat
-
- writeByte(byte) - Method in interface ds.funnel.data.format.FormatWriter
-
Writes a byte to the underlying buffer.
- writeByte(byte) - Method in class ds.funnel.data.msglink.protocol3.MessageFormat
-
- writeBytes(byte[]) - Method in interface ds.funnel.data.format.FormatWriter
-
Writes a byte array to the underlying buffer.
- writeBytes(byte[]) - Method in class ds.funnel.data.msglink.protocol3.MessageFormat
-
- writeBytesNoCopy(byte[]) - Method in interface ds.funnel.data.format.FormatWriter
-
Write the bytes to the final buffer.
- writeBytesNoCopy(byte[]) - Method in class ds.funnel.data.msglink.protocol3.MessageFormat
-
- writeDouble(double) - Method in interface ds.funnel.data.format.FormatWriter
-
Writes a double to the underlying buffer.
- writeDouble(double) - Method in class ds.funnel.data.msglink.protocol3.MessageFormat
-
- writeEnum(T) - Method in interface ds.funnel.data.format.FormatWriter
-
Writes an enum to the underlying buffer.
- writeEnum(T) - Method in class ds.funnel.data.msglink.protocol3.MessageFormat
-
- writeFloat(float) - Method in interface ds.funnel.data.format.FormatWriter
-
Writes a float to the underlying buffer.
- writeFloat(float) - Method in class ds.funnel.data.msglink.protocol3.MessageFormat
-
- writeInt(int) - Method in interface ds.funnel.data.format.FormatWriter
-
Writes an integer to the underlying buffer.
- writeInt(int) - Method in class ds.funnel.data.msglink.protocol3.MessageFormat
-
- writeIntMatrixColumn(int, int[]) - Method in class ds.granules.util.Matrix
-
Write a column of the matrix to the underlying file.
- writeIntMatrixColumn(int, int[]) - Method in class ds.granules.util.MatrixColumnMajor
-
- writeIntMatrixElement(int, int, int) - Method in class ds.granules.util.Matrix
-
Write a specific matrix element code>[rowId, columnId] to the
file.
- writeIntMatrixElement(int, int, int) - Method in class ds.granules.util.MatrixColumnMajor
-
- writeIntMatrixRow(int, int[]) - Method in class ds.granules.util.Matrix
-
Write a row of the matrix to the underlying file.
- writeIntMatrixRow(int, int[]) - Method in class ds.granules.util.MatrixColumnMajor
-
- writeLong(long) - Method in interface ds.funnel.data.format.FormatWriter
-
Writes a long to the underlying buffer.
- writeLong(long) - Method in class ds.funnel.data.msglink.protocol3.MessageFormat
-
- writeLongMatrixColumn(int, long[]) - Method in class ds.granules.util.Matrix
-
Write a column of the matrix to the underlying file.
- writeLongMatrixColumn(int, long[]) - Method in class ds.granules.util.MatrixColumnMajor
-
- writeLongMatrixElement(int, int, long) - Method in class ds.granules.util.Matrix
-
Write a specific matrix element code>[rowId, columnId] to the
file.
- writeLongMatrixElement(int, int, long) - Method in class ds.granules.util.MatrixColumnMajor
-
- writeLongMatrixRow(int, long[]) - Method in class ds.granules.util.Matrix
-
Write a row of the matrix to the underlying file.
- writeLongMatrixRow(int, long[]) - Method in class ds.granules.util.MatrixColumnMajor
-
- writeObject(Object, DataOutputStream) - Static method in class cgl.narada.event.ObjectMarshaller
-
Deprecated.
Writes an object onto a DataOutputStream
- writeObject(T) - Method in interface ds.funnel.data.format.FormatWriter
-
Writes an object to the underlying buffer.
- writeObject(T) - Method in class ds.funnel.data.msglink.protocol3.MessageFormat
-
- writeObjectMarshalled(Object) - Method in interface ds.funnel.data.format.FormatWriter
-
Writes an object to the underlying buffer using an object marshaller.
- writeObjectMarshalled(Object) - Method in class ds.funnel.data.msglink.protocol3.MessageFormat
-
- writeObjectSerialized(Serializable) - Method in interface ds.funnel.data.format.FormatWriter
-
Writes an object to the underlying buffer by serializing it.
- writeObjectSerialized(Serializable) - Method in class ds.funnel.data.msglink.protocol3.MessageFormat
-
- writeProperties(DataOutputStream, Properties) - Method in class ds.granules.util.MarshallingUtil
-
Writes a java.util.Properties object to the underlying DataOutputStream
- writeResults(Results) - Method in interface ds.granules.operation.MapReduce
-
Writes the specified results to the default output stream.
- writeResults(Topic, Results) - Method in interface ds.granules.operation.MapReduce
-
Writes the specified results to a specific output stream.
- writeResults(String, Results) - Method in interface ds.granules.operation.MapReduce
-
Deprecated.
- writeResults(int, String, Results) - Method in interface ds.granules.operation.MapReduce
-
Deprecated.
- writeResults(Results) - Method in class ds.granules.operation.MapReduceBase
-
- writeResults(Topic, Results) - Method in class ds.granules.operation.MapReduceBase
-
- writeResults(String, Results) - Method in class ds.granules.operation.MapReduceBase
-
Deprecated.
- writeResults(int, String, Results) - Method in class ds.granules.operation.MapReduceBase
-
Deprecated.
- writeShort(short) - Method in interface ds.funnel.data.format.FormatWriter
-
Writes a short to the underlying buffer.
- writeShort(short) - Method in class ds.funnel.data.msglink.protocol3.MessageFormat
-
- writeStreamingData(TopicDataEvent) - Method in interface ds.granules.dataset.StreamDataset
-
This method writes data to the output dataset.
- writeStreamingData(Topic, byte[]) - Method in interface ds.granules.dataset.StreamDataset
-
This method writes data to the output dataset.
- writeStreamingData(TopicDataEvent) - Method in class ds.granules.dataset.StreamDatasetImpl
-
- writeStreamingData(Topic, byte[]) - Method in class ds.granules.dataset.StreamDatasetImpl
-
- writeStreamingData(NBEvent) - Method in class ds.granules.dataset.StreamDatasetImplLegacy
-
Deprecated.
- writeStreamingData(Object, byte[]) - Method in class ds.granules.dataset.StreamDatasetImplLegacy
-
Deprecated.
- writeStreamingData(int, Object, byte[]) - Method in class ds.granules.dataset.StreamDatasetImplLegacy
-
Deprecated.
- writeStreamingData(NBEvent) - Method in interface ds.granules.dataset.StreamingAccess
-
Deprecated.
This method writes data to the output dataset.
- writeStreamingData(Object, byte[]) - Method in interface ds.granules.dataset.StreamingAccess
-
Deprecated.
This method writes data to the output dataset.
- writeStreamingData(int, Object, byte[]) - Method in interface ds.granules.dataset.StreamingAccess
-
Deprecated.
This method writes data to the output dataset.
- writeString(String) - Method in interface ds.funnel.data.format.FormatWriter
-
Writes a string to the underlying buffer.
- writeString(String) - Method in class ds.funnel.data.msglink.protocol3.MessageFormat
-
- writeString(DataOutputStream, String) - Method in class ds.granules.util.MarshallingUtil
-
Writes a String to the underlying DataOutputStream