6 package com.mapd.calcite.parser;
11 import org.apache.calcite.linq4j.tree.Expression;
12 import org.apache.calcite.rel.type.RelProtoDataType;
13 import org.apache.calcite.schema.Function;
14 import org.apache.calcite.schema.Schema;
15 import org.apache.calcite.schema.SchemaPlus;
16 import org.apache.calcite.schema.SchemaVersion;
17 import org.apache.calcite.schema.Table;
18 import org.apache.calcite.util.ConversionUtil;
19 import org.slf4j.Logger;
20 import org.slf4j.LoggerFactory;
22 import java.util.Collection;
23 import java.util.Collections;
24 import java.util.HashSet;
32 final static Logger
MAPDLOGGER = LoggerFactory.getLogger(MapDSchema.class);
42 "saffron.default.charset", ConversionUtil.NATIVE_UTF16_CHARSET_NAME);
44 "saffron.default.nationalcharset", ConversionUtil.NATIVE_UTF16_CHARSET_NAME);
45 System.setProperty(
"saffron.default.collation.name",
46 ConversionUtil.NATIVE_UTF16_CHARSET_NAME +
"$en_US");
52 Table
table = metaConnect.getTable(string);
58 Set<String> tableSet = metaConnect.getTables();
64 Collection<Function> functionCollection =
new HashSet<Function>();
65 return functionCollection;
70 Set<String> functionSet =
new HashSet<String>();
81 Set<String> hs =
new HashSet<String>();
87 throw new UnsupportedOperationException(
"Not supported yet.");
92 throw new UnsupportedOperationException(
"Not supported yet.");
96 metaConnect.updateMetaData(schema,
table);
101 throw new UnsupportedOperationException(
"Not supported yet.");
105 public RelProtoDataType
getType(String arg0) {
106 throw new UnsupportedOperationException(
"Not supported yet.");
111 throw new UnsupportedOperationException(
"Not supported yet.");
Collection< Function > getFunctions(String string)
void updateMetaData(String schema, String table)
final MetaConnect metaConnect
static final Logger MAPDLOGGER
Expression getExpression(SchemaPlus sp, String string)
Set< String > getTypeNames()
Table getTable(String string)
Schema snapshot(SchemaVersion sv)
SockTransportProperties sock_transport_properties
Set< String > getSubSchemaNames()
Set< String > getFunctionNames()
Set< String > getTableNames()
Schema getSubSchema(String string)
RelProtoDataType getType(String arg0)
MapDSchema(String dataDir, MapDParser mp, int mapdPort, MapDUser mapdUser, SockTransportProperties skT)