Package com.illumon.intradaylogger

Interface IntradayLogger.TableWriterFactory

All Known Implementing Classes:

BinaryStoreWriterFactory, CurrentDatePartitionedBinaryStoreWriterFactory, DynamicPartitionedBinaryStoreWriterFactory, FixedPartitionBinaryStoreWriterFactory, IntradayLogger.TableWriterFactoryImpl, LogAggregatorServiceBinaryStoreWriterFactory, LongLivedProcessBinaryStoreWriterFactory

Enclosing interface:

IntradayLogger

public static interface IntradayLogger.TableWriterFactory

TableWriterFactory to build a table writer.

Method Summary

Modifier and Type	Method	Description
TableWriter	buildWriter(String[] columnNames, SupportedType[] intradayTypes, Class[] columnTypes, Object[] typeMetadata)	Creates a new table writer.
default TableWriter	buildWriter(String[] columnNames, SupportedType[] intradayTypes, Class[] columnTypes, Object[] typeMetadata, Map<String,Object> constantColumnValues)	Creates a new table writer.
default TableWriter	buildWriter(String[] columnNames, SupportedType[] intradayTypes, Class[] columnTypes, Object[] typeMetadata, Map<String,Object> constantColumnValues, int applicationVersion)	Creates a new table writer.
default boolean	supportsDynamicPartitioning()	This must indicate whether or not the TableWriter instances supplied by this factory support dynamic column partition values.

Method Details

buildWriter

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

Creates a new table writer.

Parameters:

columnNames - column names

intradayTypes - 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

default TableWriter buildWriter(String[] columnNames,
 SupportedType[] intradayTypes,
 Class[] columnTypes,
 Object[] typeMetadata,
 Map<String,Object> constantColumnValues)
                         throws IOException

Creates a new table writer.

Parameters:

columnNames - column names

intradayTypes - column types for the intraday logger

columnTypes - column types for the table

typeMetadata - metadata for encoding and decoding a type

constantColumnValues - values that do not change for each row

Returns:

new table writer

Throws:

IOException - problem creating the table writer

buildWriter

default TableWriter buildWriter(String[] columnNames,
 SupportedType[] intradayTypes,
 Class[] columnTypes,
 Object[] typeMetadata,
 Map<String,Object> constantColumnValues,
 int applicationVersion)
                         throws IOException

Creates a new table writer.

Parameters:

columnNames - column names

intradayTypes - column types for the intraday logger

columnTypes - column types for the table

typeMetadata - metadata for encoding and decoding a type

constantColumnValues - 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

supportsDynamicPartitioning

default boolean supportsDynamicPartitioning()

This must indicate whether or not the TableWriter instances supplied by this factory support dynamic column partition values. Support of dynamic column partitions means that the underlying writers must be able to determine the column partition values based on each supplied row.

Returns:

true if the factory supports dynamic column partitions, false otherwise.