|
13 | 13 | */
|
14 | 14 | package io.prestosql.plugin.accumulo;
|
15 | 15 |
|
16 |
| -import com.facebook.presto.accumulo.conf.AccumuloConfig; |
17 |
| -import com.facebook.presto.accumulo.conf.AccumuloSessionProperties; |
18 |
| -import com.facebook.presto.accumulo.conf.AccumuloTableProperties; |
19 |
| -import com.facebook.presto.accumulo.index.IndexLookup; |
20 |
| -import com.facebook.presto.accumulo.index.Indexer; |
21 |
| -import com.facebook.presto.accumulo.io.AccumuloPageSink; |
22 |
| -import com.facebook.presto.accumulo.metadata.AccumuloTable; |
23 |
| -import com.facebook.presto.accumulo.metadata.AccumuloView; |
24 |
| -import com.facebook.presto.accumulo.metadata.ZooKeeperMetadataManager; |
25 |
| -import com.facebook.presto.accumulo.model.AccumuloColumnConstraint; |
26 |
| -import com.facebook.presto.accumulo.model.AccumuloColumnHandle; |
27 |
| -import com.facebook.presto.accumulo.model.TabletSplitMetadata; |
28 |
| -import com.facebook.presto.accumulo.serializers.AccumuloRowSerializer; |
29 |
| -import com.facebook.presto.spi.ColumnMetadata; |
30 |
| -import com.facebook.presto.spi.ConnectorSession; |
31 |
| -import com.facebook.presto.spi.ConnectorTableMetadata; |
32 |
| -import com.facebook.presto.spi.PrestoException; |
33 |
| -import com.facebook.presto.spi.SchemaTableName; |
34 |
| -import com.facebook.presto.spi.TableNotFoundException; |
35 |
| -import com.facebook.presto.spi.predicate.Domain; |
36 |
| -import com.facebook.presto.spi.predicate.Marker.Bound; |
37 | 16 | import com.google.common.base.Splitter;
|
38 | 17 | import com.google.common.collect.ImmutableList;
|
39 | 18 | import com.google.common.collect.ImmutableMap;
|
40 | 19 | import com.google.common.collect.ImmutableSet;
|
41 | 20 | import com.google.common.collect.Iterables;
|
42 | 21 | import io.airlift.log.Logger;
|
| 22 | +import io.prestosql.plugin.accumulo.conf.AccumuloConfig; |
| 23 | +import io.prestosql.plugin.accumulo.conf.AccumuloSessionProperties; |
| 24 | +import io.prestosql.plugin.accumulo.conf.AccumuloTableProperties; |
| 25 | +import io.prestosql.plugin.accumulo.index.IndexLookup; |
| 26 | +import io.prestosql.plugin.accumulo.index.Indexer; |
| 27 | +import io.prestosql.plugin.accumulo.io.AccumuloPageSink; |
| 28 | +import io.prestosql.plugin.accumulo.metadata.AccumuloTable; |
| 29 | +import io.prestosql.plugin.accumulo.metadata.AccumuloView; |
| 30 | +import io.prestosql.plugin.accumulo.metadata.ZooKeeperMetadataManager; |
| 31 | +import io.prestosql.plugin.accumulo.model.AccumuloColumnConstraint; |
| 32 | +import io.prestosql.plugin.accumulo.model.AccumuloColumnHandle; |
| 33 | +import io.prestosql.plugin.accumulo.model.TabletSplitMetadata; |
| 34 | +import io.prestosql.plugin.accumulo.serializers.AccumuloRowSerializer; |
| 35 | +import io.prestosql.spi.PrestoException; |
| 36 | +import io.prestosql.spi.connector.ColumnMetadata; |
| 37 | +import io.prestosql.spi.connector.ConnectorSession; |
| 38 | +import io.prestosql.spi.connector.ConnectorTableMetadata; |
| 39 | +import io.prestosql.spi.connector.SchemaTableName; |
| 40 | +import io.prestosql.spi.connector.TableNotFoundException; |
| 41 | +import io.prestosql.spi.predicate.Domain; |
| 42 | +import io.prestosql.spi.predicate.Marker.Bound; |
43 | 43 | import org.apache.accumulo.core.client.AccumuloException;
|
44 | 44 | import org.apache.accumulo.core.client.AccumuloSecurityException;
|
45 | 45 | import org.apache.accumulo.core.client.Connector;
|
|
68 | 68 | import java.util.Set;
|
69 | 69 | import java.util.stream.Collectors;
|
70 | 70 |
|
71 |
| -import static com.facebook.presto.accumulo.AccumuloErrorCode.ACCUMULO_TABLE_DNE; |
72 |
| -import static com.facebook.presto.accumulo.AccumuloErrorCode.ACCUMULO_TABLE_EXISTS; |
73 |
| -import static com.facebook.presto.accumulo.AccumuloErrorCode.UNEXPECTED_ACCUMULO_ERROR; |
74 |
| -import static com.facebook.presto.spi.StandardErrorCode.ALREADY_EXISTS; |
75 |
| -import static com.facebook.presto.spi.StandardErrorCode.FUNCTION_IMPLEMENTATION_ERROR; |
76 |
| -import static com.facebook.presto.spi.StandardErrorCode.INVALID_TABLE_PROPERTY; |
77 |
| -import static com.facebook.presto.spi.StandardErrorCode.INVALID_VIEW; |
78 |
| -import static com.facebook.presto.spi.StandardErrorCode.NOT_FOUND; |
79 |
| -import static com.facebook.presto.spi.StandardErrorCode.NOT_SUPPORTED; |
| 71 | +import static io.prestosql.plugin.accumulo.AccumuloErrorCode.ACCUMULO_TABLE_DNE; |
| 72 | +import static io.prestosql.plugin.accumulo.AccumuloErrorCode.ACCUMULO_TABLE_EXISTS; |
| 73 | +import static io.prestosql.plugin.accumulo.AccumuloErrorCode.UNEXPECTED_ACCUMULO_ERROR; |
| 74 | +import static io.prestosql.spi.StandardErrorCode.ALREADY_EXISTS; |
| 75 | +import static io.prestosql.spi.StandardErrorCode.FUNCTION_IMPLEMENTATION_ERROR; |
| 76 | +import static io.prestosql.spi.StandardErrorCode.INVALID_TABLE_PROPERTY; |
| 77 | +import static io.prestosql.spi.StandardErrorCode.INVALID_VIEW; |
| 78 | +import static io.prestosql.spi.StandardErrorCode.NOT_FOUND; |
| 79 | +import static io.prestosql.spi.StandardErrorCode.NOT_SUPPORTED; |
80 | 80 | import static java.lang.String.format;
|
81 | 81 | import static java.util.Objects.requireNonNull;
|
82 | 82 |
|
|
0 commit comments