Package org.apache.drill.exec.store.splunk

Class SplunkSchema

java.lang.Object

org.apache.drill.exec.store.AbstractSchema

org.apache.drill.exec.store.splunk.SplunkSchema

All Implemented Interfaces:

AutoCloseable, org.apache.calcite.schema.Schema, SchemaPartitionExplorer

public class SplunkSchema
extends AbstractSchema

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.calcite.schema.Schema

org.apache.calcite.schema.Schema.TableType

Field Summary

Fields inherited from class org.apache.drill.exec.store.AbstractSchema

name, SCHEMA_SEPARATOR, schemaPath

Constructor Summary

Constructors

Constructor	Description
SplunkSchema(SplunkStoragePlugin plugin, String queryUserName)

Method Summary

Modifier and Type	Method	Description
CreateTableEntry	createNewTable(String tableName, List<String> partitionColumns, StorageStrategy strategy)	Creates table entry using table name, list of partition columns and storage strategy used to create table folder and files
void	dropTable(String indexName)	This function contains the logic to delete an index from Splunk.
org.apache.calcite.schema.Table	getTable(String name)
Set<String>	getTableNames()
String	getTypeName()	Returns string describing schema type which shows where the schema came from.
boolean	isMutable()
ModifyTableEntry	modifyTable(String tableName)	Returns table entry using table name to insert records into the table.
boolean	showInInformationSchema()	Reports whether to show items from this schema in INFORMATION_SCHEMA tables.

Methods inherited from class org.apache.drill.exec.store.AbstractSchema

appendToStatsTable, applyFunctionParameters, areTableNamesCaseSensitive, close, createNewTable, createStatsTable, createView, dropView, getDefaultSchema, getExpression, getFullSchemaName, getFunctionNames, getFunctionParameters, getFunctions, getName, getSchemaPath, getStatsTable, getSubPartitions, getSubSchema, getSubSchemaNames, getTableNamesAndTypes, getTablesByNames, getType, getTypeMap, getTypeNames, getUser, needToImpersonateReadingData, snapshot, toString

Methods inherited from class java.lang.Object

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

Constructor Details

SplunkSchema

public SplunkSchema(SplunkStoragePlugin plugin,
 String queryUserName)

Method Details

getTable

public org.apache.calcite.schema.Table getTable(String name)

Specified by:

getTable in interface org.apache.calcite.schema.Schema

Overrides:

getTable in class AbstractSchema

showInInformationSchema

public boolean showInInformationSchema()

Description copied from class: AbstractSchema

Reports whether to show items from this schema in INFORMATION_SCHEMA tables. (Controls ... TODO: Doc.: Mention what this typically controls or affects.)

This base implementation returns true.

Overrides:

showInInformationSchema in class AbstractSchema

getTableNames

public Set<String> getTableNames()

Specified by:

getTableNames in interface org.apache.calcite.schema.Schema

Overrides:

getTableNames in class AbstractSchema

createNewTable

public CreateTableEntry createNewTable(String tableName,
 List<String> partitionColumns,
 StorageStrategy strategy)

Description copied from class: AbstractSchema

Creates table entry using table name, list of partition columns and storage strategy used to create table folder and files

Overrides:

createNewTable in class AbstractSchema

Parameters:

tableName - : new table name.

partitionColumns - : list of partition columns. Empty list if there is no partition columns.

strategy - : storage strategy used to create table folder and files

Returns:

create table entry

dropTable

public void dropTable(String indexName)

This function contains the logic to delete an index from Splunk. The Splunk SDK does not have any kind of indication whether the operation succeeded or failed.

Overrides:

dropTable in class AbstractSchema

Parameters:

indexName - The name of the index to be deleted.

modifyTable

public ModifyTableEntry modifyTable(String tableName)

Description copied from class: AbstractSchema

Returns table entry using table name to insert records into the table.

Overrides:

modifyTable in class AbstractSchema

Parameters:

tableName - : new table name.

Returns:

insert table entry

isMutable

public boolean isMutable()

Specified by:

isMutable in interface org.apache.calcite.schema.Schema

Overrides:

isMutable in class AbstractSchema

getTypeName

public String getTypeName()

Description copied from class: AbstractSchema

Returns string describing schema type which shows where the schema came from. Good practice here is to return json type name of storage plugin's config.

Specified by:

getTypeName in class AbstractSchema

Returns:

schema type name