public class InlineSchemaProvider extends Object implements SchemaProvider
DEFAULT_SCHEMA_NAME| Constructor and Description |
|---|
InlineSchemaProvider(String schema) |
| Modifier and Type | Method and Description |
|---|---|
void |
delete()
Deletes schema.
|
boolean |
exists()
Checks if schema exists.
|
SchemaContainer |
read()
Reads schema into
SchemaContainer. |
void |
store(String schema,
Map<String,String> properties,
StorageProperties storageProperties)
Stores given schema definition and properties.
|
public InlineSchemaProvider(String schema)
public void delete()
SchemaProviderdelete in interface SchemaProviderpublic void store(String schema, Map<String,String> properties, StorageProperties storageProperties)
SchemaProviderstore in interface SchemaProviderschema - schema definitionproperties - map of propertiesstorageProperties - storage propertiespublic SchemaContainer read() throws IOException
SchemaProviderSchemaContainer. Depending on implementation, can read from a file
or from the given input.read in interface SchemaProviderIOExceptionpublic boolean exists()
SchemaProviderexists in interface SchemaProviderCopyright © 2021 The Apache Software Foundation. All rights reserved.