Package org.odpi.openmetadata.adapters.connectors.datastore.csvfile

Class CSVTabularDataSetCollectionConnector

java.lang.Object

org.odpi.openmetadata.frameworks.connectors.Connector

org.odpi.openmetadata.frameworks.connectors.ConnectorBase

org.odpi.openmetadata.adapters.connectors.datastore.csvfile.CSVTabularDataSetConnector

org.odpi.openmetadata.adapters.connectors.datastore.csvfile.CSVTabularDataSetCollectionConnector

All Implemented Interfaces:

SecureConnectorExtension, ReadableTabularDataSource, TabularDataCollection, WritableTabularDataSource, VirtualConnectorExtension

public class CSVTabularDataSetCollectionConnector
extends CSVTabularDataSetConnector
implements TabularDataCollection

CSVTabularDataSetCollectionConnector works with collections of structured CSV files to write/retrieve simple tables of data. These files are all in the same directory (folder). The name of the folder is supplied through the configuration properties. The name of each file is derived from the supplied table name. The initial value may be supplied as a configuration property. However, the caller typically uses the setTableName() method to step from file to file.

Nested Class Summary

Nested classes/interfaces inherited from class org.odpi.openmetadata.frameworks.connectors.ConnectorBase

ConnectorBase.ProtectedConnection

Field Summary

Fields inherited from class org.odpi.openmetadata.adapters.connectors.datastore.csvfile.CSVTabularDataSetConnector

fileStoreConnector, tableDescription, tableName

Fields inherited from class org.odpi.openmetadata.frameworks.connectors.ConnectorBase

auditLog, connectionBean, connectorInstanceId, embeddedConnectors, messageFormatter, secretsStoreConnectorMap

Constructor Summary

Constructors

Constructor	Description
CSVTabularDataSetCollectionConnector()

Method Summary

Modifier and Type	Method	Description
void	setTableName(String tableName, String tableDescription)	Set up the canonical table name for this data source.

Methods inherited from class org.odpi.openmetadata.adapters.connectors.datastore.csvfile.CSVTabularDataSetConnector

appendRecord, deleteRecord, disconnect, getColumnDescriptions, getColumnNumber, getRecordCount, getTableDescription, getTableName, readRecord, setColumnDescriptions, setFileStoreName, start, writeRecord

Methods inherited from class org.odpi.openmetadata.frameworks.connectors.ConnectorBase

combineConfigurationProperties, disconnectConnectors, equals, fromCanonicalToKebabCase, fromCanonicalToSnakeCase, fromKebabToCanonicalCase, fromSnakeToCanonicalCase, getArrayConfigurationProperty, getArrayConfigurationProperty, getArrayConfigurationProperty, getBooleanConfigurationProperty, getConnection, getConnectorInstanceId, getDateConfigurationProperty, getIntConfigurationProperty, getLongConfigurationProperty, getStringConfigurationProperty, getStringConfigurationProperty, getSuppliedPlaceholderProperties, hashCode, initialize, initializeEmbeddedConnectors, initializeSecretsStoreConnector, isActive, logExceptionRecord, logRecord, logRecord, throwMissingConfigurationProperty, throwMissingEndpointAddress, throwMissingResource, throwNoAsset, throwWrongTypeOfAsset, throwWrongTypeOfResource, throwWrongTypeOfRootSchema, toString

Methods inherited from class org.odpi.openmetadata.frameworks.connectors.Connector

clearStatisticProperty, clearStatisticTimestamp, getConnectorStatistics, getStatisticCounter, getStatisticProperty, getStatisticTimestamp, incrementStatisticCounter, initializeStatisticCounter, refreshStatistics, setStatisticProperty, setStatisticTimestamp

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Details

CSVTabularDataSetCollectionConnector

public CSVTabularDataSetCollectionConnector()

Method Details

setTableName

public void setTableName(String tableName,
 String tableDescription)
                  throws ConnectorCheckedException

Set up the canonical table name for this data source. Each word in the name should be capitalized, with spaces between the words to allow translation between different naming conventions.

Specified by:

setTableName in interface TabularDataCollection

Parameters:

tableName - string

tableDescription - optional description

Throws:

ConnectorCheckedException - there is a problem accessing the data