Package org.yamcs.yarch

Class TableWriter

java.lang.Object

org.yamcs.yarch.TableWriter

All Implemented Interfaces:

StreamSubscriber

Direct Known Subclasses:

RdbTableWriter

public abstract class TableWriter
extends Object
implements StreamSubscriber

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	TableWriter.InsertMode

Field Summary

Fields

Modifier and Type	Field	Description
protected final TableWriter.InsertMode	mode
protected final Table	table
protected final YarchDatabaseInstance	ydb

Constructor Summary

Constructors

Constructor	Description
TableWriter(YarchDatabaseInstance ydb, Table table, TableWriter.InsertMode mode)

Method Summary

Modifier and Type	Method	Description
void	close()	close writer and any open resources
CompletableFuture<Void>	closeFuture()	future which will be called (completed) when the writer is closed.
protected abstract void	doClose()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.yamcs.yarch.StreamSubscriber

onTuple, streamClosed

Field Details

table

protected final Table table

mode

protected final TableWriter.InsertMode mode

ydb

protected final YarchDatabaseInstance ydb

Constructor Details

TableWriter

public TableWriter(YarchDatabaseInstance ydb,
 Table table,
 TableWriter.InsertMode mode)

Method Details

closeFuture

public CompletableFuture<Void> closeFuture()

future which will be called (completed) when the writer is closed.

Returns:

close

public void close()

close writer and any open resources

call the close future after closing has been completed

doClose

protected abstract void doClose()