org.apache.drill.exec.store.mock

Class MockBreakageStorage

java.lang.Object

org.apache.drill.exec.store.AbstractStoragePlugin

org.apache.drill.exec.store.mock.MockStorageEngine

org.apache.drill.exec.store.mock.MockBreakageStorage

All Implemented Interfaces:

AutoCloseable, SchemaFactory, StoragePlugin

public class MockBreakageStorage
extends MockStorageEngine

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	MockBreakageStorage.MockBreakageStorageEngineConfig Each storage plugin requires a unique config class to allow config --> impl lookups to be unique.

Field Summary

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

context

Fields inherited from interface org.apache.drill.exec.store.SchemaFactory

DEFAULT_WS_NAME

Constructor Summary

Constructors

Constructor and Description
MockBreakageStorage(MockBreakageStorage.MockBreakageStorageEngineConfig configuration, DrillbitContext context, String name)

Method Summary

Modifier and Type	Method and Description
void	registerSchemas(SchemaConfig schemaConfig, org.apache.calcite.schema.SchemaPlus parent) Register the schemas provided by this SchemaFactory implementation under the given parent schema.
void	setBreakRegister(boolean breakRegister)

Methods inherited from class org.apache.drill.exec.store.mock.MockStorageEngine

getConfig, getPhysicalScan, supportsRead

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

close, getContext, getFormatPlugin, getLogicalOptimizerRules, getName, getOptimizerRules, getOptimizerRules, getPhysicalOptimizerRules, getPhysicalScan, getPhysicalScan, getPhysicalScan, getPhysicalScan, getPhysicalScan, start, supportsWrite

Methods inherited from class java.lang.Object

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

Constructor Detail

MockBreakageStorage

public MockBreakageStorage(MockBreakageStorage.MockBreakageStorageEngineConfig configuration,
                           DrillbitContext context,
                           String name)

Method Detail

setBreakRegister

public void setBreakRegister(boolean breakRegister)

registerSchemas

public void registerSchemas(SchemaConfig schemaConfig,
                            org.apache.calcite.schema.SchemaPlus parent)
                     throws IOException

Description copied from interface: SchemaFactory

Register the schemas provided by this SchemaFactory implementation under the given parent schema.

Specified by:

registerSchemas in interface SchemaFactory

Overrides:

registerSchemas in class MockStorageEngine

Parameters:

schemaConfig - Configuration for schema objects.

parent - Reference to parent schema.

Throws:

IOException - in case of error during schema registration