streams

Type Members

1. class FileReader extends StreamReader with Logging

   FileReader is used to read data from one file of full data to simulate a stream data.

2. class FileWriter extends Configurable with Serializable

   FileWriter use generator to generate data and save to file or HDFS for simulation or test.

3. class PrintStreamWriter extends StreamWriter

   Stream writer that outputs the stream to the standard output.

4. class SocketTextStreamReader extends StreamReader

   Stream reader that gets instances from a socket stream.

5. abstract class StreamReader extends Configurable

   Abstract class for outputing a DStream of Examples to be used inside tasks.

6. abstract class StreamWriter extends Configurable

   Abstract class that defines the output from a DStream of Strings.

7. class TextStreamReader extends StreamReader

   Stream reader that gets instances from a file stream.