Package com.illumon.iris.db.v2.logaggregator

Class BinaryStoreAggregatorWriterBase

java.lang.Object

com.illumon.iris.binarystore.AbstractBinaryStoreWriter<BinaryRowV2>

com.illumon.iris.binarystore.BinaryStoreWriterV2

com.illumon.iris.db.v2.logaggregator.BinaryStoreAggregatorWriterBase

All Implemented Interfaces:

Entry, Record, Row, TableWriter<BinaryRowV2>

Direct Known Subclasses:

BinaryStoreAggregatorWriterMultiPartition, BinaryStoreAggregatorWriterStandard

public abstract class BinaryStoreAggregatorWriterBase
extends BinaryStoreWriterV2

This class provides a common ancestor for BinaryStoreAggregator implementations. This can be used where a client may hold one of several subtypes.

Nested Class Summary

Nested classes/interfaces inherited from class com.illumon.iris.binarystore.BinaryStoreWriterV2

BinaryStoreWriterV2.DeferrableRowPartition

Nested classes/interfaces inherited from interface com.illumon.iris.binarystore.Record

Record.RecordSetter<T extends RecordData>

Nested classes/interfaces inherited from interface com.illumon.iris.binarystore.Row

Row.Flags

Field Summary

Fields inherited from class com.illumon.iris.binarystore.BinaryStoreWriterV2

log, primaryRecordWriter, primaryRowWriter

Fields inherited from interface com.illumon.iris.binarystore.TableWriter

NULL_SETTER

Constructor Summary

Constructors

Constructor	Description
BinaryStoreAggregatorWriterBase(String[] columnNames, SupportedType[] intradayTypes, Object[] typeMetadata, Map<String,Object> constantColumnValues, int applicationVersion, int targetWriteSize, com.fishlib.io.logger.Logger log)	Intermediate constructor for subclasses to initialize the base BinaryStoreWriterV2 class.

Method Summary

Modifier and Type	Method	Description
long	getTransactionSizeLimit()	Get the row limit for atomic appends the connected LogAggregator.

Methods inherited from class com.illumon.iris.binarystore.BinaryStoreWriterV2

computeHeaderBuffer, createBinaryRecord, createBinaryRow, flushDeferredRows, flushDeferredRows, getColumnNames, getColumnPartitionValue, getColumnTypes, getRecordSetter, getRecordSetter, getRecordWriter, getRowWriter, getSetter, init, makeCurrentDatePartitionedBinaryStoreWriter, makeMultiPartitionFileManagerBinaryStoreWriter, makeSpecifiedPartitionBinaryStoreWriter, setColumnPartitionValue, setFlags, setRecordData, writeDeferredRow, writeMulti, writeRecord, writeRow

Methods inherited from class com.illumon.iris.binarystore.AbstractBinaryStoreWriter

close, flush, setChannelManager, supportAllTypes

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.illumon.iris.binarystore.TableWriter

getSetter

Constructor Details

BinaryStoreAggregatorWriterBase

public BinaryStoreAggregatorWriterBase(String[] columnNames,
 SupportedType[] intradayTypes,
 Object[] typeMetadata,
 Map<String,Object> constantColumnValues,
 int applicationVersion,
 int targetWriteSize,
 com.fishlib.io.logger.Logger log)

Intermediate constructor for subclasses to initialize the base BinaryStoreWriterV2 class.

Parameters:

columnNames - pass through to BinaryStoreWriterV2 constructor

intradayTypes - pass through to BinaryStoreWriterV2 constructor

typeMetadata - pass through to BinaryStoreWriterV2 constructor

constantColumnValues - pass through to BinaryStoreWriterV2 constructor

applicationVersion - pass through to BinaryStoreWriterV2 constructor

targetWriteSize - pass through to BinaryStoreWriterV2 constructor

log - pass through to BinaryStoreWriterV2 constructor

Method Details

getTransactionSizeLimit

public long getTransactionSizeLimit()

Get the row limit for atomic appends the connected LogAggregator.

This is currently a property-driven static, but this method enables per-connection configuration in the future.

Returns:

the max number of rows that can be written to the LAS atomically