Package io.crate.metadata

Examples of io.crate.metadata.ColumnIdent

118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
    }

    @Override
    public Void visitPartitionedBy(PartitionedBy node, CreateTableAnalysis context) {
        for (Expression partitionByColumn : node.columns()) {
            ColumnIdent partitionedByIdent = ColumnIdent.fromPath(
                    ExpressionToStringVisitor.convert(partitionByColumn, context.parameters()));
            context.analyzedTableElements().changeToPartitionedByColumn(partitionedByIdent, false);
            ColumnIdent routing = context.routing();
            if (routing != null && routing.equals(partitionedByIdent)) {
                throw new IllegalArgumentException(
                        "Cannot use CLUSTERED BY column in PARTITIONED BY clause");
            }
        }
        return null;
View Full Code Here
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
    protected static Map<String,Object> toNestedStringObjectMap(Map<ColumnIdent, Object> columnIdentObjectMap) {
        Map<String, Object> nestedMap = new HashMap<>();
        Map<String, Object> parent = nestedMap;

        for (Map.Entry<ColumnIdent, Object> entry : columnIdentObjectMap.entrySet()) {
            ColumnIdent key = entry.getKey();
            Object value = entry.getValue();

            if (key.path().isEmpty()) {
                nestedMap.put(key.name(), value);
            } else {
                LinkedList<String> path = new LinkedList<>(key.path());
                path.add(0, key.name());

                while (true) {
                    String currentKey = path.pop();
                    if (path.isEmpty()) {
                        parent.put(currentKey, value);
View Full Code Here
133
134
135
136
137
138
139
140
141
142
143
        ESFieldExtractor[] extractors = new ESFieldExtractor[outputs.size()];
        int i = 0;
        for (Symbol output : outputs) {
            assert output instanceof Reference;
            Reference reference = ((Reference) output);
            final ColumnIdent columnIdent = reference.info().ident().columnIdent();
            if (DocSysColumns.VERSION.equals(columnIdent)) {
                extractors[i] = new ESFieldExtractor() {
                    @Override
                    public Object extract(SearchHit hit) {
                        return hit.getVersion();
View Full Code Here
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
        List<String> fields = new ArrayList<>(outputs.size());
        boolean needWholeSource = false;
        for (Symbol output : outputs) {
            assert output instanceof Reference;
            Reference ref = (Reference) output;
            ColumnIdent columnIdent = ref.info().ident().columnIdent();
            if (columnIdent.isSystemColumn()){
                if (DocSysColumns.VERSION.equals(columnIdent)){
                    builder.field("version", true);
                } else if (DocSysColumns.RAW.equals(columnIdent)|| DocSysColumns.DOC.equals(columnIdent)){
                    needWholeSource = true;
                }
            } else if (node.partitionBy().indexOf(ref.info()) < 0) { // do not include partitioned by columns
                fields.add(columnIdent.fqn());
            }
        }

        if (!needWholeSource){
            if (fields.size() > 0){
View Full Code Here
TOP

Related Classes of io.crate.metadata.ColumnIdent

  • io.crate.action.sql.query.CrateSearchService$OutputSymbolVisitor
  • io.crate.action.sql.query.CrateSearchService$SortSymbolVisitor
  • io.crate.analyze.AlterTableAddColumnAnalyzerTest
  • io.crate.analyze.AnalyzedColumnDefinition
  • io.crate.analyze.AnalyzedTableElements
  • io.crate.analyze.CreateTableStatementAnalyzer
  • io.crate.analyze.IdTest
  • io.crate.analyze.InsertFromValuesAnalyzer
  • io.crate.analyze.InsertFromValuesAnalyzerTest
  • io.crate.analyze.PrimaryKeyVisitor
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.