co.cask.cdap.test.internal

Class LocalStreamWriter

java.lang.Object

co.cask.cdap.test.internal.LocalStreamWriter

All Implemented Interfaces:

StreamWriter

public class LocalStreamWriter
extends Object
implements StreamWriter

Implements StreamWriter to enable you to write to streams in tests without making HTTP requests

Constructor Summary

Constructors

Constructor and Description
LocalStreamWriter(co.cask.cdap.proto.Id.Run run, StreamManagerFactory streamManagerFactory)

Method Summary

Methods

Modifier and Type	Method and Description
StreamBatchWriter	createBatchWriter(String stream, String contentType)
void	write(String stream, ByteBuffer data)
void	write(String stream, co.cask.cdap.api.stream.StreamEventData data)
void	write(String stream, String data)
void	write(String stream, String data, Map<String,String> headers)
void	writeFile(String stream, File file, String contentType)

Methods inherited from class java.lang.Object

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

Constructor Detail

LocalStreamWriter

@Inject
public LocalStreamWriter(co.cask.cdap.proto.Id.Run run,
                        StreamManagerFactory streamManagerFactory)

Method Detail

write

public void write(String stream,
         String data)
           throws IOException

Specified by:

write in interface StreamWriter

Throws:

IOException

write

public void write(String stream,
         String data,
         Map<String,String> headers)
           throws IOException

Specified by:

write in interface StreamWriter

Throws:

IOException

write

public void write(String stream,
         ByteBuffer data)
           throws IOException

Specified by:

write in interface StreamWriter

Throws:

IOException

write

public void write(String stream,
         co.cask.cdap.api.stream.StreamEventData data)
           throws IOException

Specified by:

write in interface StreamWriter

Throws:

IOException

writeFile

public void writeFile(String stream,
             File file,
             String contentType)
               throws IOException

Specified by:

writeFile in interface StreamWriter

Throws:

IOException

createBatchWriter

public StreamBatchWriter createBatchWriter(String stream,
                                  String contentType)
                                    throws IOException

Specified by:

createBatchWriter in interface StreamWriter

Throws:

IOException