Package org.apache.drill.exec.planner.logical

Class FileSystemCreateTableEntry

java.lang.Object

org.apache.drill.exec.planner.logical.FileSystemCreateTableEntry

All Implemented Interfaces:

CreateTableEntry

public class FileSystemCreateTableEntry
extends Object
implements CreateTableEntry

Implements CreateTableEntry interface to create new tables in FileSystem storage.

Constructor Summary

Constructors

Constructor	Description
FileSystemCreateTableEntry(FileSystemConfig storageConfig, FormatPluginConfig formatConfig, String location, List<String> partitionColumns, StorageStrategy storageStrategy, StoragePluginRegistry engineRegistry)
FileSystemCreateTableEntry(FileSystemConfig storageConfig, FormatPlugin formatPlugin, String location, List<String> partitionColumns, StorageStrategy storageStrategy)

Method Summary

Modifier and Type	Method	Description
FormatPluginConfig	getFormatConfig()
List<String>	getPartitionColumns()
FileSystemConfig	getStorageConfig()
Writer	getWriter(PhysicalOperator child)

Methods inherited from class java.lang.Object

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

Constructor Details

FileSystemCreateTableEntry

public FileSystemCreateTableEntry(FileSystemConfig storageConfig,
 FormatPluginConfig formatConfig,
 String location,
 List<String> partitionColumns,
 StorageStrategy storageStrategy,
 StoragePluginRegistry engineRegistry)
                           throws ExecutionSetupException

Throws:

ExecutionSetupException

FileSystemCreateTableEntry

public FileSystemCreateTableEntry(FileSystemConfig storageConfig,
 FormatPlugin formatPlugin,
 String location,
 List<String> partitionColumns,
 StorageStrategy storageStrategy)

Method Details

getStorageConfig

public FileSystemConfig getStorageConfig()

getFormatConfig

public FormatPluginConfig getFormatConfig()

getWriter

public Writer getWriter(PhysicalOperator child)
                 throws IOException

Specified by:

getWriter in interface CreateTableEntry

Throws:

IOException

getPartitionColumns

public List<String> getPartitionColumns()

Specified by:

getPartitionColumns in interface CreateTableEntry