Package com.clickhouse.client
Class ClickHousePipedOutputStream
- java.lang.Object
-
- java.io.OutputStream
-
- com.clickhouse.client.ClickHouseOutputStream
-
- com.clickhouse.client.ClickHousePipedOutputStream
-
- All Implemented Interfaces:
Closeable,Flushable,AutoCloseable
- Direct Known Subclasses:
BlockingPipedOutputStream,ClickHousePipedStream,NonBlockingPipedOutputStream
public abstract class ClickHousePipedOutputStream extends ClickHouseOutputStream
SPSC(Single-producer single-consumer) channel for streaming.
-
-
Field Summary
-
Fields inherited from class com.clickhouse.client.ClickHouseOutputStream
closed, ERROR_INCOMPLETE_READ, ERROR_NULL_BYTES, ERROR_REUSE_BUFFER, ERROR_STREAM_CLOSED, file, postCloseAction
-
-
Constructor Summary
Constructors Modifier Constructor Description protectedClickHousePipedOutputStream(Runnable postCloseAction)
-
Method Summary
All Methods Instance Methods Abstract Methods Concrete Methods Deprecated Methods Modifier and Type Method Description ClickHouseInputStreamgetInput()Deprecated.will be removed in v0.3.3, please usegetInputStream()insteadClickHouseInputStreamgetInputStream()Gets input stream to reada data being written into the output stream.abstract ClickHouseInputStreamgetInputStream(Runnable postCloseAction)Gets input stream to reada data being written into the output stream.-
Methods inherited from class com.clickhouse.client.ClickHouseOutputStream
close, empty, ensureOpen, getUnderlyingFile, isClosed, of, of, of, of, transferBytes, transferBytes, transferBytes, write, write, write, writeAsciiString, writeBuffer, writeByte, writeBytes, writeBytes, writeBytes, writeCustom, writeString, writeUnicodeString, writeUnsignedVarInt, writeVarInt
-
Methods inherited from class java.io.OutputStream
flush, nullOutputStream
-
-
-
-
Constructor Detail
-
ClickHousePipedOutputStream
protected ClickHousePipedOutputStream(Runnable postCloseAction)
-
-
Method Detail
-
getInput
@Deprecated public final ClickHouseInputStream getInput()
Deprecated.will be removed in v0.3.3, please usegetInputStream()insteadGets input stream to reada data being written into the output stream.- Returns:
- non-null input stream
-
getInputStream
public final ClickHouseInputStream getInputStream()
Gets input stream to reada data being written into the output stream.- Returns:
- non-null input stream
-
getInputStream
public abstract ClickHouseInputStream getInputStream(Runnable postCloseAction)
Gets input stream to reada data being written into the output stream.- Parameters:
postCloseAction- custom action will be performed right after closing the input stream- Returns:
- non-null input stream
-
-