Package io.deephaven.enterprise.binlog.buffered.impl

Class MultiPartitionLoggerThreadSafeBase

java.lang.Object

io.deephaven.enterprise.binlog.buffered.impl.MultiPartitionLoggerThreadSafeBase

All Implemented Interfaces:

Logger, Closeable, Flushable, AutoCloseable

Direct Known Subclasses:

PersistentQueryConfigurationLoggerImpl, PersistentQueryStateLoggerImpl, QueryUserAssignmentLoggerImpl, ResourceUtilizationLoggerImpl

@InternalUseOnly
public abstract class MultiPartitionLoggerThreadSafeBase
extends Object
implements Logger

The base class for thread-safe, multi-partition buffered loggers. While this class is public, it is used as a code generation target and not for public extension. See package-info.

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	MultiPartitionLoggerThreadSafeBase(ByteBuffer buffer, MultiPartitionWriter multiPartitionWriter, int maxEntrySize)

Method Summary

Modifier and Type	Method	Description
protected final void	abortBuffer()
final void	close()	Flushes any buffered data to the output sink and then closes this logger.
protected final void	commitBuffer()
protected final void	commitBuffers(int numRows)
final void	flush()	Flushes any buffered data to the output sink.
protected final void	partition(String partition)
protected final ByteBuffer	takeBuffer()

Methods inherited from class java.lang.Object

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

Constructor Details

MultiPartitionLoggerThreadSafeBase

protected MultiPartitionLoggerThreadSafeBase(ByteBuffer buffer,
 MultiPartitionWriter multiPartitionWriter,
 int maxEntrySize)

Method Details

flush

public final void flush()
                 throws IOException

Description copied from interface: Logger

Flushes any buffered data to the output sink.

Specified by:

flush in interface Flushable

Specified by:

flush in interface Logger

Throws:

IOException - if an IO exception occurs

close

public final void close()
                 throws IOException

Description copied from interface: Logger

Flushes any buffered data to the output sink and then closes this logger.

If this logger has already been closed then this method returns immediately.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in interface Logger

Throws:

IOException - if an IO exception occurs

partition

protected final void partition(String partition)
                        throws IOException

Throws:

IOException

takeBuffer

protected final ByteBuffer takeBuffer()
                               throws IOException

Throws:

IOException

abortBuffer

protected final void abortBuffer()

commitBuffer

protected final void commitBuffer()
                           throws IOException

Throws:

IOException

commitBuffers

protected final void commitBuffers(int numRows)
                            throws IOException

Throws:

IOException