ExternalTableSpec |
BaseInputSourceDefn.AdHocTableFunction.apply(String fnName,
Map<String,Object> args,
List<ColumnSpec> columns,
com.fasterxml.jackson.databind.ObjectMapper jsonMapper) |
|
ExternalTableSpec |
BaseInputSourceDefn.PartialTableFunction.apply(String fnName,
Map<String,Object> args,
List<ColumnSpec> columns,
com.fasterxml.jackson.databind.ObjectMapper jsonMapper) |
|
ExternalTableSpec |
TableFunction.apply(String fnName,
Map<String,Object> args,
List<ColumnSpec> columns,
com.fasterxml.jackson.databind.ObjectMapper jsonMapper) |
|
TableBuilder |
TableBuilder.columns(List<ColumnSpec> columns) |
|
protected org.apache.druid.data.input.InputFormat |
BaseInputSourceDefn.convertArgsToFormat(Map<String,Object> args,
List<ColumnSpec> columns,
com.fasterxml.jackson.databind.ObjectMapper jsonMapper) |
Convert SQL arguments, and the column schema, to an input format, if required.
|
protected org.apache.druid.data.input.InputFormat |
FormattedInputSourceDefn.convertArgsToFormat(Map<String,Object> args,
List<ColumnSpec> columns,
com.fasterxml.jackson.databind.ObjectMapper jsonMapper) |
|
protected ExternalTableSpec |
BaseInputSourceDefn.convertArgsToTable(Map<String,Object> args,
List<ColumnSpec> columns,
com.fasterxml.jackson.databind.ObjectMapper jsonMapper) |
Define a table "from scratch" using SQL function arguments.
|
protected void |
InputFormats.BaseFormatDefn.convertColumns(Map<String,Object> jsonMap,
List<ColumnSpec> columns) |
Convert columns from the ColumnSpec format used by the catalog to the
list of names form requires by input formats.
|
protected abstract ExternalTableSpec |
BaseInputSourceDefn.convertCompletedTable(ResolvedExternalTable table,
Map<String,Object> args,
List<ColumnSpec> columns) |
Complete a partial table using the table function arguments and columns provided.
|
protected ExternalTableSpec |
HttpInputSourceDefn.convertCompletedTable(ResolvedExternalTable table,
Map<String,Object> args,
List<ColumnSpec> columns) |
|
protected ExternalTableSpec |
InlineInputSourceDefn.convertCompletedTable(ResolvedExternalTable table,
Map<String,Object> args,
List<ColumnSpec> columns) |
|
protected ExternalTableSpec |
LocalInputSourceDefn.convertCompletedTable(ResolvedExternalTable table,
Map<String,Object> args,
List<ColumnSpec> columns) |
|
org.apache.druid.data.input.InputFormat |
InputFormatDefn.convertFromArgs(Map<String,Object> args,
List<ColumnSpec> columns,
com.fasterxml.jackson.databind.ObjectMapper jsonMapper) |
Create an input format instance from the values provided as arguments that
correspond to the defined parameters.
|
org.apache.druid.data.input.InputFormat |
InputFormats.CsvFormatDefn.convertFromArgs(Map<String,Object> args,
List<ColumnSpec> columns,
com.fasterxml.jackson.databind.ObjectMapper jsonMapper) |
|
org.apache.druid.data.input.InputFormat |
InputFormats.DelimitedFormatDefn.convertFromArgs(Map<String,Object> args,
List<ColumnSpec> columns,
com.fasterxml.jackson.databind.ObjectMapper jsonMapper) |
|
org.apache.druid.data.input.InputFormat |
InputFormats.JsonFormatDefn.convertFromArgs(Map<String,Object> args,
List<ColumnSpec> columns,
com.fasterxml.jackson.databind.ObjectMapper jsonMapper) |
|
protected ExternalTableSpec |
FormattedInputSourceDefn.convertPartialFormattedTable(ResolvedExternalTable table,
Map<String,Object> args,
List<ColumnSpec> columns,
Map<String,Object> sourceMap) |
Converted a formatted external table given the table definition, function
args, columns and the merged generic JSON map representing the input source.
|
protected Map<String,Object> |
InputFormats.FlatTextFormatDefn.mapFromArgs(Map<String,Object> args,
List<ColumnSpec> columns) |
|
protected static void |
BaseTableFunction.requireSchema(String fnName,
List<ColumnSpec> columns) |
|
protected List<ColumnSpec> |
BaseInputSourceDefn.selectPartialTableColumns(ResolvedExternalTable table,
List<ColumnSpec> columns) |
Choose table or SQL-provided columns: table takes precedence.
|