Package 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	Description
static class	MockBreakageStorage.MockBreakageStorageEngineConfig	Each storage plugin requires a unique config class to allow config --> impl lookups to be unique.

Field Summary

Fields

Modifier and Type	Field	Description
int	registerAttemptCount

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	Description
MockBreakageStorage(MockBreakageStorage.MockBreakageStorageEngineConfig configuration, DrillbitContext context, String name)

Method Summary

Modifier and Type	Method	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, getName, getPhysicalScan, getPhysicalScan, getPhysicalScan, getPhysicalScan, getPhysicalScan, onDisabled, onEnabled, start, supportsInsert, supportsWrite, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.drill.exec.store.StoragePlugin

getOptimizerRules

Field Details

registerAttemptCount

public int registerAttemptCount

Constructor Details

MockBreakageStorage

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

Method Details

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