co.cask.cdap.test.internal

Class DefaultStreamWriter

java.lang.Object

co.cask.cdap.test.internal.DefaultStreamWriter

All Implemented Interfaces:

StreamWriter

Deprecated.

Use DefaultStreamManager instead

@Deprecated
public final class DefaultStreamWriter
extends Object
implements StreamWriter

Constructor Summary

Constructors

Constructor and Description
DefaultStreamWriter(StreamManagerFactory streamManagerFactory, co.cask.cdap.proto.Id.Stream streamId) Deprecated.

Method Summary

Methods

Modifier and Type	Method and Description
void	createStream() Deprecated.
protected void	finalize() Deprecated.
void	send(byte[] content) Deprecated.
void	send(byte[] content, int off, int len) Deprecated.
void	send(ByteBuffer buffer) Deprecated.
void	send(Map<String,String> headers, byte[] content) Deprecated.
void	send(Map<String,String> headers, byte[] content, int off, int len) Deprecated.
void	send(Map<String,String> headers, ByteBuffer buffer) Deprecated.
void	send(Map<String,String> headers, String content) Deprecated.
void	send(String content) Deprecated.

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultStreamWriter

@Inject
public DefaultStreamWriter(StreamManagerFactory streamManagerFactory,
                          co.cask.cdap.proto.Id.Stream streamId)
                    throws IOException

Deprecated.

Throws:

IOException

Method Detail

createStream

public void createStream()
                  throws IOException

Deprecated.

Specified by:

createStream in interface StreamWriter

Throws:

IOException

send

public void send(String content)
          throws IOException

Deprecated.

Specified by:

send in interface StreamWriter

Throws:

IOException

send

public void send(byte[] content)
          throws IOException

Deprecated.

Specified by:

send in interface StreamWriter

Throws:

IOException

send

public void send(byte[] content,
        int off,
        int len)
          throws IOException

Deprecated.

Specified by:

send in interface StreamWriter

Throws:

IOException

send

public void send(ByteBuffer buffer)
          throws IOException

Deprecated.

Specified by:

send in interface StreamWriter

Throws:

IOException

send

public void send(Map<String,String> headers,
        String content)
          throws IOException

Deprecated.

Specified by:

send in interface StreamWriter

Throws:

IOException

send

public void send(Map<String,String> headers,
        byte[] content)
          throws IOException

Deprecated.

Specified by:

send in interface StreamWriter

Throws:

IOException

send

public void send(Map<String,String> headers,
        byte[] content,
        int off,
        int len)
          throws IOException

Deprecated.

Specified by:

send in interface StreamWriter

Throws:

IOException

send

public void send(Map<String,String> headers,
        ByteBuffer buffer)
          throws IOException

Deprecated.

Specified by:

send in interface StreamWriter

Throws:

IOException

finalize

protected void finalize()
                 throws Throwable

Deprecated.

Overrides:

finalize in class Object

Throws:

Throwable