Package com.illumon.intradaylogger

Class CurrentDatePartitionedBinaryStoreWriterFactory

java.lang.Object

com.illumon.intradaylogger.CurrentDatePartitionedBinaryStoreWriterFactory

All Implemented Interfaces:

IntradayLogger.TableWriterFactory

public class CurrentDatePartitionedBinaryStoreWriterFactory
extends Object
implements IntradayLogger.TableWriterFactory

Extend the default factory to add date to the rolling format. The default factory only appends the time portion, the date is part of the static prefix. That breaks pretty badly since for processes that stay alive past midnight.

Constructor Summary

Constructors

Constructor	Description
CurrentDatePartitionedBinaryStoreWriterFactory(com.fishlib.io.logger.Logger log, String logDir, String namespace, String tableName, TableIdentifier.NamespaceSet namespaceSet, String internalPartition, int version, ZoneId zoneId)

Method Summary

Modifier and Type	Method	Description
TableWriter	buildWriter(String[] columnNames, SupportedType[] loggerTypes, Class[] columnTypes, Object[] typeMetadata)	Creates a new table writer.
TableWriter	buildWriter(String[] columnNames, SupportedType[] loggerTypes, Class[] columnTypes, Object[] typeMetadata, Map<String,Object> constantValues)	Creates a new table writer.
TableWriter	buildWriter(String[] columnNames, SupportedType[] loggerTypes, Class[] columnTypes, Object[] typeMetadata, Map<String,Object> constantValues, int applicationVersion)	Creates a new table writer.

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.illumon.intradaylogger.IntradayLogger.TableWriterFactory

supportsDynamicPartitioning

Constructor Details

CurrentDatePartitionedBinaryStoreWriterFactory

public CurrentDatePartitionedBinaryStoreWriterFactory(com.fishlib.io.logger.Logger log,
 String logDir,
 String namespace,
 String tableName,
 TableIdentifier.NamespaceSet namespaceSet,
 String internalPartition,
 int version,
 ZoneId zoneId)

Method Details

buildWriter

public TableWriter buildWriter(String[] columnNames,
 SupportedType[] loggerTypes,
 Class[] columnTypes,
 Object[] typeMetadata)
                        throws IOException

Description copied from interface: IntradayLogger.TableWriterFactory

Creates a new table writer.

Specified by:

buildWriter in interface IntradayLogger.TableWriterFactory

Parameters:

columnNames - column names

loggerTypes - column types for the intraday logger

columnTypes - column types for the table

typeMetadata - metadata for encoding and decoding a type

Returns:

new table writer

Throws:

IOException - problem creating the table writer

buildWriter

public TableWriter buildWriter(String[] columnNames,
 SupportedType[] loggerTypes,
 Class[] columnTypes,
 Object[] typeMetadata,
 Map<String,Object> constantValues)
                        throws IOException

Description copied from interface: IntradayLogger.TableWriterFactory

Creates a new table writer.

Specified by:

buildWriter in interface IntradayLogger.TableWriterFactory

Parameters:

columnNames - column names

loggerTypes - column types for the intraday logger

columnTypes - column types for the table

typeMetadata - metadata for encoding and decoding a type

constantValues - values that do not change for each row

Returns:

new table writer

Throws:

IOException - problem creating the table writer

buildWriter

public TableWriter buildWriter(String[] columnNames,
 SupportedType[] loggerTypes,
 Class[] columnTypes,
 Object[] typeMetadata,
 Map<String,Object> constantValues,
 int applicationVersion)
                        throws IOException

Description copied from interface: IntradayLogger.TableWriterFactory

Creates a new table writer.

Specified by:

buildWriter in interface IntradayLogger.TableWriterFactory

Parameters:

columnNames - column names

loggerTypes - column types for the intraday logger

columnTypes - column types for the table

typeMetadata - metadata for encoding and decoding a type

constantValues - values that do not change for each row

applicationVersion - application version number used to select listener for reading this file

Returns:

new table writer

Throws:

IOException - problem creating the table writer