http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/e5ae88af/scripts/interface/gen-java/org/apache/blur/thrift/generated/Blur.java ---------------------------------------------------------------------- diff --git a/scripts/interface/gen-java/org/apache/blur/thrift/generated/Blur.java b/scripts/interface/gen-java/org/apache/blur/thrift/generated/Blur.java new file mode 100644 index 0000000..8edfa10 --- /dev/null +++ b/scripts/interface/gen-java/org/apache/blur/thrift/generated/Blur.java @@ -0,0 +1,54187 @@ +/** + * Autogenerated by Thrift Compiler (0.9.0) + * + * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING + * @generated + */ +package org.apache.blur.thrift.generated; + +/** + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + + + +import org.apache.blur.thirdparty.thrift_0_9_0.scheme.IScheme; +import org.apache.blur.thirdparty.thrift_0_9_0.scheme.SchemeFactory; +import org.apache.blur.thirdparty.thrift_0_9_0.scheme.StandardScheme; + +import org.apache.blur.thirdparty.thrift_0_9_0.scheme.TupleScheme; +import org.apache.blur.thirdparty.thrift_0_9_0.protocol.TTupleProtocol; +import org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocolException; +import org.apache.blur.thirdparty.thrift_0_9_0.EncodingUtils; +import org.apache.blur.thirdparty.thrift_0_9_0.TException; +import java.util.List; +import java.util.ArrayList; +import java.util.Map; +import java.util.HashMap; +import java.util.EnumMap; +import java.util.Set; +import java.util.HashSet; +import java.util.EnumSet; +import java.util.Collections; +import java.util.BitSet; +import java.nio.ByteBuffer; +import java.util.Arrays; +//import org.slf4j.Logger; +//import org.slf4j.LoggerFactory; + +public class Blur { + + /** + * The Blur service API. This API is the same for both controller servers as well as + * shards servers. Each of the methods are documented. + */ + public interface Iface { + + /** + * List the currently installed commands in the server process. + */ + public List<CommandDescriptor> listInstalledCommands() throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException; + + /** + * Executes the given command by name on the table with the provided arguments. + * + * @param commandName + * @param arguments + */ + public Response execute(String commandName, Arguments arguments) throws BlurException, TimeoutException, org.apache.blur.thirdparty.thrift_0_9_0.TException; + + /** + * If the execute command times out due to command taking longer than the configured + * network tcp timeout this method allows the client to reconnect to the already + * executing command. + * + * @param instanceExecutionId + */ + public Response reconnect(long instanceExecutionId) throws BlurException, TimeoutException, org.apache.blur.thirdparty.thrift_0_9_0.TException; + + /** + * Fetches the command status ids in the order they were submitted. + * + * @param startingAt + * @param fetch + * @param state + */ + public List<String> commandStatusList(int startingAt, short fetch, CommandStatusState state) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException; + + /** + * Retrieves the command status by the given command execution id. + * + * @param commandExecutionId + */ + public CommandStatus commandStatus(String commandExecutionId) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException; + + /** + * Cancels the command with the given command execution id. + * + * @param commandExecutionId + */ + public void commandCancel(String commandExecutionId) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException; + + /** + * Releases and refreshes the read snapshots of the indexes in the session for the + * current connection. + */ + public void refresh() throws org.apache.blur.thirdparty.thrift_0_9_0.TException; + + /** + * Creates a table with the given TableDescriptor. + * + * @param tableDescriptor the TableDescriptor. + */ + public void createTable(TableDescriptor tableDescriptor) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException; + + /** + * Enables the given table, blocking until all shards are online. + * + * @param table the table name. + */ + public void enableTable(String table) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException; + + /** + * Disables the given table, blocking until all shards are offline. + * + * @param table the table name. + */ + public void disableTable(String table) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException; + + /** + * Removes the given table, with an optional to delete the underlying index storage as well. + * + * @param table the table name. + * + * @param deleteIndexFiles true to remove the index storage and false if to preserve. + */ + public void removeTable(String table, boolean deleteIndexFiles) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException; + + /** + * Attempts to add a column definition to the given table. + * @return true if successfully defined false if not. + * + * @param table the name of the table. + * + * @param columnDefinition the ColumnDefinition. + */ + public boolean addColumnDefinition(String table, ColumnDefinition columnDefinition) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException; + + /** + * Returns a list of the table names across all shard clusters. + * @return list of all tables in all shard clusters. + */ + public List<String> tableList() throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException; + + /** + * Returns a list of the table names for the given cluster. + * @return list of all the tables within the given shard cluster. + * + * @param cluster the cluster name. + */ + public List<String> tableListByCluster(String cluster) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException; + + /** + * Returns a table descriptor for the given table. + * @return the TableDescriptor. + * + * @param table the table name. + */ + public TableDescriptor describe(String table) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException; + + /** + * Gets the schema for a given table. + * @return Schema. + * + * @param table the table name. + */ + public Schema schema(String table) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException; + + /** + * Parses the given query and returns the string that represents the query. + * @return string representation of the parsed query. + * + * @param table the table name. + * + * @param query the query to parse. + */ + public String parseQuery(String table, Query query) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException; + + /** + * Gets the table stats for the given table. + * @return TableStats. + * + * @param table the table name. + */ + public TableStats tableStats(String table) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException; + + /** + * Will perform a forced optimize on the index in the given table. + * + * @param table table the name of the table. + * + * @param numberOfSegmentsPerShard the maximum of segments per shard index after the operation is completed. + */ + public void optimize(String table, int numberOfSegmentsPerShard) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException; + + /** + * Creates a snapshot for the table with the given name + * + * @param table + * @param name + */ + public void createSnapshot(String table, String name) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException; + + /** + * Removes a previous snapshot(identified by name) of the table + * + * @param table + * @param name + */ + public void removeSnapshot(String table, String name) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException; + + /** + * Returns a map where the key is the shard, and the list is the snapshots within that shard + * + * @param table + */ + public Map<String,List<String>> listSnapshots(String table) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException; + + /** + * Sets the User for the current session. + * + * @param user the User object. + */ + public void setUser(User user) throws org.apache.blur.thirdparty.thrift_0_9_0.TException; + + /** + * Executes a query against a the given table and returns the results. If this method is + * executed against a controller the results will contain the aggregated results from all + * the shards. If this method is executed against a shard server the results will only + * contain aggregated results from the shards of the given table that are being served on + * the shard server, if any. + * @return the BlurResults. + * + * @param table the table name. + * + * @param blurQuery the query to execute. + */ + public BlurResults query(String table, BlurQuery blurQuery) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException; + + /** + * Fetches a Row or a Record in the given table with the given Selector. + * @return the FetchResult. + * + * @param table the table name. + * + * @param selector the Selector to use to fetch the Row or Record. + */ + public FetchResult fetchRow(String table, Selector selector) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException; + + /** + * Fetches a batch of Rows or Records in the given table with the given Selector list. + * @return the FetchResult. + * + * @param table the table name. + * + * @param selectors the Selector to use to fetch the Row or Record. + */ + public List<FetchResult> fetchRowBatch(String table, List<Selector> selectors) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException; + + /** + * Loads data from external location. + * + * @param table The table name. + * + * @param location Location of bulk data load. + */ + public void loadData(String table, String location) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException; + + public void validateIndex(String table, List<String> externalIndexPaths) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException; + + public void loadIndex(String table, List<String> externalIndexPaths) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException; + + /** + * Mutates a Row given the RowMutation that is provided. + * + * @param mutation the RowMutation. + */ + public void mutate(RowMutation mutation) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException; + + /** + * Enqueue a RowMutation. Note that the effect of the RowMutation will occur at some point in the future, volume and load will play a role in how much time will pass before the mutation goes into effect. + * + * @param mutation the RowMutation. + */ + public void enqueueMutate(RowMutation mutation) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException; + + /** + * Mutates a group of Rows given the list of RowMutations that are provided. Note: This is not an atomic operation. + * + * @param mutations the batch of RowMutations. + */ + public void mutateBatch(List<RowMutation> mutations) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException; + + /** + * Enqueue a batch of RowMutations. Note that the effect of the RowMutation will occur at some point in the future, volume and load will play a role in how much time will pass before the mutation goes into effect. + * + * @param mutations the batch of RowMutations. + */ + public void enqueueMutateBatch(List<RowMutation> mutations) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException; + + /** + * Starts a transaction for update (e.g. Mutate). Returns a transaction id. + * + * @param bulkId The bulk id. + */ + public void bulkMutateStart(String bulkId) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException; + + /** + * Adds to the specified transaction. + * + * @param bulkId The bulk id. + * + * @param rowMutation The row mutation. + */ + public void bulkMutateAdd(String bulkId, RowMutation rowMutation) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException; + + /** + * Adds to the specified transaction. + * + * @param bulkId The bulk id. + * + * @param rowMutations The row mutation. + */ + public void bulkMutateAddMultiple(String bulkId, List<RowMutation> rowMutations) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException; + + /** + * Finishes the bulk mutate. If apply is true the mutations are applied and committed. If false the bulk mutate is deleted and not applied. + * + * @param bulkId The bulk id. + * + * @param apply Apply the bulk mutate flag. + * + * @param blockUntilComplete If true this call will not block on bulk completion. This may be required for loader bulk loads. + */ + public void bulkMutateFinish(String bulkId, boolean apply, boolean blockUntilComplete) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException; + + /** + * Cancels a query that is executing against the given table with the given uuid. Note, the + * cancel call maybe take some time for the query actually stops executing. + * + * @param table the table name. + * + * @param uuid the uuid of the query. + */ + public void cancelQuery(String table, String uuid) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException; + + /** + * Returns a list of the query ids of queries that have recently been executed for the given table. + * @return list of all the uuids of the queries uuids. + * + * @param table the table name. + */ + public List<String> queryStatusIdList(String table) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException; + + /** + * Returns the query status for the given table and query uuid. + * @return fetches the BlurQueryStatus for the given table and uuid. + * + * @param table the table name. + * + * @param uuid the uuid of the query. + */ + public BlurQueryStatus queryStatusById(String table, String uuid) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException; + + /** + * Gets the terms list from the index for the given table, family, column using the + * startWith value to page through the results. This method only makes sense to use with + * string and text field types. + * @return the list of terms for the given column. + * + * @param table the table name. + * + * @param columnFamily the column family. If the frequency requested is a system field like "rowid", "recordid", "family", etc then columnFamily can be null. + * + * @param columnName the column name. + * + * @param startWith the term to start with assuming that you are paging through the term list. + * + * @param size the number to fetch at once. + */ + public List<String> terms(String table, String columnFamily, String columnName, String startWith, short size) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException; + + /** + * Gets the record frequency for the provided table, family, column and value. + * @return the count for the entire table. + * + * @param table the table name. + * + * @param columnFamily the column family. If the frequency requested is a system field like "rowid", "recordid", "family", etc then columnFamily can be null. + * + * @param columnName the column name. + * + * @param value the value. + */ + public long recordFrequency(String table, String columnFamily, String columnName, String value) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException; + + /** + * Returns a list of all the shard clusters. + * @return list of all the shard clusters. + */ + public List<String> shardClusterList() throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException; + + /** + * Returns a list of all the shard servers for the given cluster. + * @return list of all the shard servers within the cluster. + * + * @param cluster the cluster name. + */ + public List<String> shardServerList(String cluster) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException; + + /** + * Returns a list of all the controller servers. + * @return list of all the controllers. + */ + public List<String> controllerServerList() throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException; + + /** + * Returns a map of the layout of the given table, where the key is the shard name + * and the value is the shard server.<br><br> + * This method will return the "correct" layout for the given shard, or the + * "correct" layout of cluster if called on a controller.<br><br> + * The meaning of correct:<br>Given the current state of the shard cluster with failures taken + * into account, the correct layout is what the layout should be given the current state. In + * other words, what the shard server should be serving. The act of calling the shard + * server layout method with the NORMAL option will block until the layout shard server + * matches the correct layout. Meaning it will block until indexes that should be open are + * open and ready for queries. However indexes are lazily closed, so if a table is being + * disabled then the call will return immediately with an empty map, but the indexes may + * not be close yet.<br><br> + * @return map of shards in a table to the shard servers. + * + * @param table the table name. + */ + public Map<String,String> shardServerLayout(String table) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException; + + /** + * Returns a map of the layout of the given table, where the key is the shard name and the + * value is the shard server.<br><br> + * This method will return immediately with what shards are currently + * open in the shard server. So if a shard is being moved to another server and is being + * closed by this server it WILL be returned in the map. The shardServerLayout method would not return + * the shard given the same situation. + * @return map of shards to a map of shard servers with the state of the shard. + * + * @param table the table name. + */ + public Map<String,Map<String,ShardState>> shardServerLayoutState(String table) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException; + + /** + * Checks to see if the given cluster is in safemode. + * @return boolean. + * + * @param cluster the name of the cluster. + */ + public boolean isInSafeMode(String cluster) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException; + + /** + * Fetches the Blur configuration. + * @return Map of property name to value. + */ + public Map<String,String> configuration() throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException; + + /** + * Fetches the Blur configuration. + * @return Map of property name to value. + * + * @param thriftServerPlusPort + * @param configName + */ + public String configurationPerServer(String thriftServerPlusPort, String configName) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException; + + /** + * Fetches the Blur metrics by name. If the metrics parameter is null all the Metrics are returned. + * @return Map of metric name to Metric. + * + * @param metrics the names of the metrics to return. If null all are returned. + */ + public Map<String,Metric> metrics(Set<String> metrics) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException; + + /** + * Starts a trace with the given trace id. + * + * @param traceId the trace id. + * + * @param requestId the request id, used to connected remote calls together. Client can pass null. + */ + public void startTrace(String traceId, String requestId) throws org.apache.blur.thirdparty.thrift_0_9_0.TException; + + /** + * Get a list of all the traces. + * @return the list of trace ids. + */ + public List<String> traceList() throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException; + + /** + * Gets a request list for the given trace. + * @return the list of request ids for the given trace id. + * + * @param traceId the trace id. + */ + public List<String> traceRequestList(String traceId) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException; + + /** + * Fetches the given trace. + * @return the json for the given trace request. + * + * @param traceId the trace id. + * + * @param requestId the request id. + */ + public String traceRequestFetch(String traceId, String requestId) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException; + + /** + * Remove the trace for the given trace id. + * + * @param traceId the trace id. + */ + public void traceRemove(String traceId) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException; + + /** + * A way to ping a server to make sure the connection is still valid. + */ + public void ping() throws org.apache.blur.thirdparty.thrift_0_9_0.TException; + + /** + * Changes the logging level for the given instance dynamically at runtime. + * + * @param classNameOrLoggerName the className or Logger Name of the Logger to be changed. + * + * @param level the logging level. + */ + public void logging(String classNameOrLoggerName, Level level) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException; + + /** + * Resets the logging for this instance to match the log4j file. NOTE: This will allow for dynamically changing to logging file at runtime. + */ + public void resetLogging() throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException; + + } + + public interface AsyncIface { + + public void listInstalledCommands(org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<AsyncClient.listInstalledCommands_call> resultHandler) throws org.apache.blur.thirdparty.thrift_0_9_0.TException; + + public void execute(String commandName, Arguments arguments, org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<AsyncClient.execute_call> resultHandler) throws org.apache.blur.thirdparty.thrift_0_9_0.TException; + + public void reconnect(long instanceExecutionId, org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<AsyncClient.reconnect_call> resultHandler) throws org.apache.blur.thirdparty.thrift_0_9_0.TException; + + public void commandStatusList(int startingAt, short fetch, CommandStatusState state, org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<AsyncClient.commandStatusList_call> resultHandler) throws org.apache.blur.thirdparty.thrift_0_9_0.TException; + + public void commandStatus(String commandExecutionId, org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<AsyncClient.commandStatus_call> resultHandler) throws org.apache.blur.thirdparty.thrift_0_9_0.TException; + + public void commandCancel(String commandExecutionId, org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<AsyncClient.commandCancel_call> resultHandler) throws org.apache.blur.thirdparty.thrift_0_9_0.TException; + + public void refresh(org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<AsyncClient.refresh_call> resultHandler) throws org.apache.blur.thirdparty.thrift_0_9_0.TException; + + public void createTable(TableDescriptor tableDescriptor, org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<AsyncClient.createTable_call> resultHandler) throws org.apache.blur.thirdparty.thrift_0_9_0.TException; + + public void enableTable(String table, org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<AsyncClient.enableTable_call> resultHandler) throws org.apache.blur.thirdparty.thrift_0_9_0.TException; + + public void disableTable(String table, org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<AsyncClient.disableTable_call> resultHandler) throws org.apache.blur.thirdparty.thrift_0_9_0.TException; + + public void removeTable(String table, boolean deleteIndexFiles, org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<AsyncClient.removeTable_call> resultHandler) throws org.apache.blur.thirdparty.thrift_0_9_0.TException; + + public void addColumnDefinition(String table, ColumnDefinition columnDefinition, org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<AsyncClient.addColumnDefinition_call> resultHandler) throws org.apache.blur.thirdparty.thrift_0_9_0.TException; + + public void tableList(org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<AsyncClient.tableList_call> resultHandler) throws org.apache.blur.thirdparty.thrift_0_9_0.TException; + + public void tableListByCluster(String cluster, org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<AsyncClient.tableListByCluster_call> resultHandler) throws org.apache.blur.thirdparty.thrift_0_9_0.TException; + + public void describe(String table, org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<AsyncClient.describe_call> resultHandler) throws org.apache.blur.thirdparty.thrift_0_9_0.TException; + + public void schema(String table, org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<AsyncClient.schema_call> resultHandler) throws org.apache.blur.thirdparty.thrift_0_9_0.TException; + + public void parseQuery(String table, Query query, org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<AsyncClient.parseQuery_call> resultHandler) throws org.apache.blur.thirdparty.thrift_0_9_0.TException; + + public void tableStats(String table, org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<AsyncClient.tableStats_call> resultHandler) throws org.apache.blur.thirdparty.thrift_0_9_0.TException; + + public void optimize(String table, int numberOfSegmentsPerShard, org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<AsyncClient.optimize_call> resultHandler) throws org.apache.blur.thirdparty.thrift_0_9_0.TException; + + public void createSnapshot(String table, String name, org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<AsyncClient.createSnapshot_call> resultHandler) throws org.apache.blur.thirdparty.thrift_0_9_0.TException; + + public void removeSnapshot(String table, String name, org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<AsyncClient.removeSnapshot_call> resultHandler) throws org.apache.blur.thirdparty.thrift_0_9_0.TException; + + public void listSnapshots(String table, org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<AsyncClient.listSnapshots_call> resultHandler) throws org.apache.blur.thirdparty.thrift_0_9_0.TException; + + public void setUser(User user, org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<AsyncClient.setUser_call> resultHandler) throws org.apache.blur.thirdparty.thrift_0_9_0.TException; + + public void query(String table, BlurQuery blurQuery, org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<AsyncClient.query_call> resultHandler) throws org.apache.blur.thirdparty.thrift_0_9_0.TException; + + public void fetchRow(String table, Selector selector, org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<AsyncClient.fetchRow_call> resultHandler) throws org.apache.blur.thirdparty.thrift_0_9_0.TException; + + public void fetchRowBatch(String table, List<Selector> selectors, org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<AsyncClient.fetchRowBatch_call> resultHandler) throws org.apache.blur.thirdparty.thrift_0_9_0.TException; + + public void loadData(String table, String location, org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<AsyncClient.loadData_call> resultHandler) throws org.apache.blur.thirdparty.thrift_0_9_0.TException; + + public void validateIndex(String table, List<String> externalIndexPaths, org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<AsyncClient.validateIndex_call> resultHandler) throws org.apache.blur.thirdparty.thrift_0_9_0.TException; + + public void loadIndex(String table, List<String> externalIndexPaths, org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<AsyncClient.loadIndex_call> resultHandler) throws org.apache.blur.thirdparty.thrift_0_9_0.TException; + + public void mutate(RowMutation mutation, org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<AsyncClient.mutate_call> resultHandler) throws org.apache.blur.thirdparty.thrift_0_9_0.TException; + + public void enqueueMutate(RowMutation mutation, org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<AsyncClient.enqueueMutate_call> resultHandler) throws org.apache.blur.thirdparty.thrift_0_9_0.TException; + + public void mutateBatch(List<RowMutation> mutations, org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<AsyncClient.mutateBatch_call> resultHandler) throws org.apache.blur.thirdparty.thrift_0_9_0.TException; + + public void enqueueMutateBatch(List<RowMutation> mutations, org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<AsyncClient.enqueueMutateBatch_call> resultHandler) throws org.apache.blur.thirdparty.thrift_0_9_0.TException; + + public void bulkMutateStart(String bulkId, org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<AsyncClient.bulkMutateStart_call> resultHandler) throws org.apache.blur.thirdparty.thrift_0_9_0.TException; + + public void bulkMutateAdd(String bulkId, RowMutation rowMutation, org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<AsyncClient.bulkMutateAdd_call> resultHandler) throws org.apache.blur.thirdparty.thrift_0_9_0.TException; + + public void bulkMutateAddMultiple(String bulkId, List<RowMutation> rowMutations, org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<AsyncClient.bulkMutateAddMultiple_call> resultHandler) throws org.apache.blur.thirdparty.thrift_0_9_0.TException; + + public void bulkMutateFinish(String bulkId, boolean apply, boolean blockUntilComplete, org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<AsyncClient.bulkMutateFinish_call> resultHandler) throws org.apache.blur.thirdparty.thrift_0_9_0.TException; + + public void cancelQuery(String table, String uuid, org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<AsyncClient.cancelQuery_call> resultHandler) throws org.apache.blur.thirdparty.thrift_0_9_0.TException; + + public void queryStatusIdList(String table, org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<AsyncClient.queryStatusIdList_call> resultHandler) throws org.apache.blur.thirdparty.thrift_0_9_0.TException; + + public void queryStatusById(String table, String uuid, org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<AsyncClient.queryStatusById_call> resultHandler) throws org.apache.blur.thirdparty.thrift_0_9_0.TException; + + public void terms(String table, String columnFamily, String columnName, String startWith, short size, org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<AsyncClient.terms_call> resultHandler) throws org.apache.blur.thirdparty.thrift_0_9_0.TException; + + public void recordFrequency(String table, String columnFamily, String columnName, String value, org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<AsyncClient.recordFrequency_call> resultHandler) throws org.apache.blur.thirdparty.thrift_0_9_0.TException; + + public void shardClusterList(org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<AsyncClient.shardClusterList_call> resultHandler) throws org.apache.blur.thirdparty.thrift_0_9_0.TException; + + public void shardServerList(String cluster, org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<AsyncClient.shardServerList_call> resultHandler) throws org.apache.blur.thirdparty.thrift_0_9_0.TException; + + public void controllerServerList(org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<AsyncClient.controllerServerList_call> resultHandler) throws org.apache.blur.thirdparty.thrift_0_9_0.TException; + + public void shardServerLayout(String table, org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<AsyncClient.shardServerLayout_call> resultHandler) throws org.apache.blur.thirdparty.thrift_0_9_0.TException; + + public void shardServerLayoutState(String table, org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<AsyncClient.shardServerLayoutState_call> resultHandler) throws org.apache.blur.thirdparty.thrift_0_9_0.TException; + + public void isInSafeMode(String cluster, org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<AsyncClient.isInSafeMode_call> resultHandler) throws org.apache.blur.thirdparty.thrift_0_9_0.TException; + + public void configuration(org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<AsyncClient.configuration_call> resultHandler) throws org.apache.blur.thirdparty.thrift_0_9_0.TException; + + public void configurationPerServer(String thriftServerPlusPort, String configName, org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<AsyncClient.configurationPerServer_call> resultHandler) throws org.apache.blur.thirdparty.thrift_0_9_0.TException; + + public void metrics(Set<String> metrics, org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<AsyncClient.metrics_call> resultHandler) throws org.apache.blur.thirdparty.thrift_0_9_0.TException; + + public void startTrace(String traceId, String requestId, org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<AsyncClient.startTrace_call> resultHandler) throws org.apache.blur.thirdparty.thrift_0_9_0.TException; + + public void traceList(org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<AsyncClient.traceList_call> resultHandler) throws org.apache.blur.thirdparty.thrift_0_9_0.TException; + + public void traceRequestList(String traceId, org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<AsyncClient.traceRequestList_call> resultHandler) throws org.apache.blur.thirdparty.thrift_0_9_0.TException; + + public void traceRequestFetch(String traceId, String requestId, org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<AsyncClient.traceRequestFetch_call> resultHandler) throws org.apache.blur.thirdparty.thrift_0_9_0.TException; + + public void traceRemove(String traceId, org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<AsyncClient.traceRemove_call> resultHandler) throws org.apache.blur.thirdparty.thrift_0_9_0.TException; + + public void ping(org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<AsyncClient.ping_call> resultHandler) throws org.apache.blur.thirdparty.thrift_0_9_0.TException; + + public void logging(String classNameOrLoggerName, Level level, org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<AsyncClient.logging_call> resultHandler) throws org.apache.blur.thirdparty.thrift_0_9_0.TException; + + public void resetLogging(org.apache.blur.thirdparty.thrift_0_9_0.async.AsyncMethodCallback<AsyncClient.resetLogging_call> resultHandler) throws org.apache.blur.thirdparty.thrift_0_9_0.TException; + + } + + public static class Client extends org.apache.blur.thirdparty.thrift_0_9_0.TServiceClient implements Iface { + public static class Factory implements org.apache.blur.thirdparty.thrift_0_9_0.TServiceClientFactory<Client> { + public Factory() {} + public Client getClient(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot) { + return new Client(prot); + } + public Client getClient(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol iprot, org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol oprot) { + return new Client(iprot, oprot); + } + } + + public Client(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol prot) + { + super(prot, prot); + } + + public Client(org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol iprot, org.apache.blur.thirdparty.thrift_0_9_0.protocol.TProtocol oprot) { + super(iprot, oprot); + } + + public List<CommandDescriptor> listInstalledCommands() throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + send_listInstalledCommands(); + return recv_listInstalledCommands(); + } + + public void send_listInstalledCommands() throws org.apache.blur.thirdparty.thrift_0_9_0.TException + { + listInstalledCommands_args args = new listInstalledCommands_args(); + sendBase("listInstalledCommands", args); + } + + public List<CommandDescriptor> recv_listInstalledCommands() throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + listInstalledCommands_result result = new listInstalledCommands_result(); + receiveBase(result, "listInstalledCommands"); + if (result.isSetSuccess()) { + return result.success; + } + if (result.ex != null) { + throw result.ex; + } + throw new org.apache.blur.thirdparty.thrift_0_9_0.TApplicationException(org.apache.blur.thirdparty.thrift_0_9_0.TApplicationException.MISSING_RESULT, "listInstalledCommands failed: unknown result"); + } + + public Response execute(String commandName, Arguments arguments) throws BlurException, TimeoutException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + send_execute(commandName, arguments); + return recv_execute(); + } + + public void send_execute(String commandName, Arguments arguments) throws org.apache.blur.thirdparty.thrift_0_9_0.TException + { + execute_args args = new execute_args(); + args.setCommandName(commandName); + args.setArguments(arguments); + sendBase("execute", args); + } + + public Response recv_execute() throws BlurException, TimeoutException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + execute_result result = new execute_result(); + receiveBase(result, "execute"); + if (result.isSetSuccess()) { + return result.success; + } + if (result.bex != null) { + throw result.bex; + } + if (result.tex != null) { + throw result.tex; + } + throw new org.apache.blur.thirdparty.thrift_0_9_0.TApplicationException(org.apache.blur.thirdparty.thrift_0_9_0.TApplicationException.MISSING_RESULT, "execute failed: unknown result"); + } + + public Response reconnect(long instanceExecutionId) throws BlurException, TimeoutException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + send_reconnect(instanceExecutionId); + return recv_reconnect(); + } + + public void send_reconnect(long instanceExecutionId) throws org.apache.blur.thirdparty.thrift_0_9_0.TException + { + reconnect_args args = new reconnect_args(); + args.setInstanceExecutionId(instanceExecutionId); + sendBase("reconnect", args); + } + + public Response recv_reconnect() throws BlurException, TimeoutException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + reconnect_result result = new reconnect_result(); + receiveBase(result, "reconnect"); + if (result.isSetSuccess()) { + return result.success; + } + if (result.bex != null) { + throw result.bex; + } + if (result.tex != null) { + throw result.tex; + } + throw new org.apache.blur.thirdparty.thrift_0_9_0.TApplicationException(org.apache.blur.thirdparty.thrift_0_9_0.TApplicationException.MISSING_RESULT, "reconnect failed: unknown result"); + } + + public List<String> commandStatusList(int startingAt, short fetch, CommandStatusState state) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + send_commandStatusList(startingAt, fetch, state); + return recv_commandStatusList(); + } + + public void send_commandStatusList(int startingAt, short fetch, CommandStatusState state) throws org.apache.blur.thirdparty.thrift_0_9_0.TException + { + commandStatusList_args args = new commandStatusList_args(); + args.setStartingAt(startingAt); + args.setFetch(fetch); + args.setState(state); + sendBase("commandStatusList", args); + } + + public List<String> recv_commandStatusList() throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + commandStatusList_result result = new commandStatusList_result(); + receiveBase(result, "commandStatusList"); + if (result.isSetSuccess()) { + return result.success; + } + if (result.ex != null) { + throw result.ex; + } + throw new org.apache.blur.thirdparty.thrift_0_9_0.TApplicationException(org.apache.blur.thirdparty.thrift_0_9_0.TApplicationException.MISSING_RESULT, "commandStatusList failed: unknown result"); + } + + public CommandStatus commandStatus(String commandExecutionId) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + send_commandStatus(commandExecutionId); + return recv_commandStatus(); + } + + public void send_commandStatus(String commandExecutionId) throws org.apache.blur.thirdparty.thrift_0_9_0.TException + { + commandStatus_args args = new commandStatus_args(); + args.setCommandExecutionId(commandExecutionId); + sendBase("commandStatus", args); + } + + public CommandStatus recv_commandStatus() throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + commandStatus_result result = new commandStatus_result(); + receiveBase(result, "commandStatus"); + if (result.isSetSuccess()) { + return result.success; + } + if (result.ex != null) { + throw result.ex; + } + throw new org.apache.blur.thirdparty.thrift_0_9_0.TApplicationException(org.apache.blur.thirdparty.thrift_0_9_0.TApplicationException.MISSING_RESULT, "commandStatus failed: unknown result"); + } + + public void commandCancel(String commandExecutionId) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + send_commandCancel(commandExecutionId); + recv_commandCancel(); + } + + public void send_commandCancel(String commandExecutionId) throws org.apache.blur.thirdparty.thrift_0_9_0.TException + { + commandCancel_args args = new commandCancel_args(); + args.setCommandExecutionId(commandExecutionId); + sendBase("commandCancel", args); + } + + public void recv_commandCancel() throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + commandCancel_result result = new commandCancel_result(); + receiveBase(result, "commandCancel"); + if (result.ex != null) { + throw result.ex; + } + return; + } + + public void refresh() throws org.apache.blur.thirdparty.thrift_0_9_0.TException + { + send_refresh(); + } + + public void send_refresh() throws org.apache.blur.thirdparty.thrift_0_9_0.TException + { + refresh_args args = new refresh_args(); + sendBase("refresh", args); + } + + public void createTable(TableDescriptor tableDescriptor) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + send_createTable(tableDescriptor); + recv_createTable(); + } + + public void send_createTable(TableDescriptor tableDescriptor) throws org.apache.blur.thirdparty.thrift_0_9_0.TException + { + createTable_args args = new createTable_args(); + args.setTableDescriptor(tableDescriptor); + sendBase("createTable", args); + } + + public void recv_createTable() throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + createTable_result result = new createTable_result(); + receiveBase(result, "createTable"); + if (result.ex != null) { + throw result.ex; + } + return; + } + + public void enableTable(String table) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + send_enableTable(table); + recv_enableTable(); + } + + public void send_enableTable(String table) throws org.apache.blur.thirdparty.thrift_0_9_0.TException + { + enableTable_args args = new enableTable_args(); + args.setTable(table); + sendBase("enableTable", args); + } + + public void recv_enableTable() throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + enableTable_result result = new enableTable_result(); + receiveBase(result, "enableTable"); + if (result.ex != null) { + throw result.ex; + } + return; + } + + public void disableTable(String table) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + send_disableTable(table); + recv_disableTable(); + } + + public void send_disableTable(String table) throws org.apache.blur.thirdparty.thrift_0_9_0.TException + { + disableTable_args args = new disableTable_args(); + args.setTable(table); + sendBase("disableTable", args); + } + + public void recv_disableTable() throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + disableTable_result result = new disableTable_result(); + receiveBase(result, "disableTable"); + if (result.ex != null) { + throw result.ex; + } + return; + } + + public void removeTable(String table, boolean deleteIndexFiles) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + send_removeTable(table, deleteIndexFiles); + recv_removeTable(); + } + + public void send_removeTable(String table, boolean deleteIndexFiles) throws org.apache.blur.thirdparty.thrift_0_9_0.TException + { + removeTable_args args = new removeTable_args(); + args.setTable(table); + args.setDeleteIndexFiles(deleteIndexFiles); + sendBase("removeTable", args); + } + + public void recv_removeTable() throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + removeTable_result result = new removeTable_result(); + receiveBase(result, "removeTable"); + if (result.ex != null) { + throw result.ex; + } + return; + } + + public boolean addColumnDefinition(String table, ColumnDefinition columnDefinition) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + send_addColumnDefinition(table, columnDefinition); + return recv_addColumnDefinition(); + } + + public void send_addColumnDefinition(String table, ColumnDefinition columnDefinition) throws org.apache.blur.thirdparty.thrift_0_9_0.TException + { + addColumnDefinition_args args = new addColumnDefinition_args(); + args.setTable(table); + args.setColumnDefinition(columnDefinition); + sendBase("addColumnDefinition", args); + } + + public boolean recv_addColumnDefinition() throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + addColumnDefinition_result result = new addColumnDefinition_result(); + receiveBase(result, "addColumnDefinition"); + if (result.isSetSuccess()) { + return result.success; + } + if (result.ex != null) { + throw result.ex; + } + throw new org.apache.blur.thirdparty.thrift_0_9_0.TApplicationException(org.apache.blur.thirdparty.thrift_0_9_0.TApplicationException.MISSING_RESULT, "addColumnDefinition failed: unknown result"); + } + + public List<String> tableList() throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + send_tableList(); + return recv_tableList(); + } + + public void send_tableList() throws org.apache.blur.thirdparty.thrift_0_9_0.TException + { + tableList_args args = new tableList_args(); + sendBase("tableList", args); + } + + public List<String> recv_tableList() throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + tableList_result result = new tableList_result(); + receiveBase(result, "tableList"); + if (result.isSetSuccess()) { + return result.success; + } + if (result.ex != null) { + throw result.ex; + } + throw new org.apache.blur.thirdparty.thrift_0_9_0.TApplicationException(org.apache.blur.thirdparty.thrift_0_9_0.TApplicationException.MISSING_RESULT, "tableList failed: unknown result"); + } + + public List<String> tableListByCluster(String cluster) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + send_tableListByCluster(cluster); + return recv_tableListByCluster(); + } + + public void send_tableListByCluster(String cluster) throws org.apache.blur.thirdparty.thrift_0_9_0.TException + { + tableListByCluster_args args = new tableListByCluster_args(); + args.setCluster(cluster); + sendBase("tableListByCluster", args); + } + + public List<String> recv_tableListByCluster() throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + tableListByCluster_result result = new tableListByCluster_result(); + receiveBase(result, "tableListByCluster"); + if (result.isSetSuccess()) { + return result.success; + } + if (result.ex != null) { + throw result.ex; + } + throw new org.apache.blur.thirdparty.thrift_0_9_0.TApplicationException(org.apache.blur.thirdparty.thrift_0_9_0.TApplicationException.MISSING_RESULT, "tableListByCluster failed: unknown result"); + } + + public TableDescriptor describe(String table) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + send_describe(table); + return recv_describe(); + } + + public void send_describe(String table) throws org.apache.blur.thirdparty.thrift_0_9_0.TException + { + describe_args args = new describe_args(); + args.setTable(table); + sendBase("describe", args); + } + + public TableDescriptor recv_describe() throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + describe_result result = new describe_result(); + receiveBase(result, "describe"); + if (result.isSetSuccess()) { + return result.success; + } + if (result.ex != null) { + throw result.ex; + } + throw new org.apache.blur.thirdparty.thrift_0_9_0.TApplicationException(org.apache.blur.thirdparty.thrift_0_9_0.TApplicationException.MISSING_RESULT, "describe failed: unknown result"); + } + + public Schema schema(String table) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + send_schema(table); + return recv_schema(); + } + + public void send_schema(String table) throws org.apache.blur.thirdparty.thrift_0_9_0.TException + { + schema_args args = new schema_args(); + args.setTable(table); + sendBase("schema", args); + } + + public Schema recv_schema() throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + schema_result result = new schema_result(); + receiveBase(result, "schema"); + if (result.isSetSuccess()) { + return result.success; + } + if (result.ex != null) { + throw result.ex; + } + throw new org.apache.blur.thirdparty.thrift_0_9_0.TApplicationException(org.apache.blur.thirdparty.thrift_0_9_0.TApplicationException.MISSING_RESULT, "schema failed: unknown result"); + } + + public String parseQuery(String table, Query query) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + send_parseQuery(table, query); + return recv_parseQuery(); + } + + public void send_parseQuery(String table, Query query) throws org.apache.blur.thirdparty.thrift_0_9_0.TException + { + parseQuery_args args = new parseQuery_args(); + args.setTable(table); + args.setQuery(query); + sendBase("parseQuery", args); + } + + public String recv_parseQuery() throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + parseQuery_result result = new parseQuery_result(); + receiveBase(result, "parseQuery"); + if (result.isSetSuccess()) { + return result.success; + } + if (result.ex != null) { + throw result.ex; + } + throw new org.apache.blur.thirdparty.thrift_0_9_0.TApplicationException(org.apache.blur.thirdparty.thrift_0_9_0.TApplicationException.MISSING_RESULT, "parseQuery failed: unknown result"); + } + + public TableStats tableStats(String table) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + send_tableStats(table); + return recv_tableStats(); + } + + public void send_tableStats(String table) throws org.apache.blur.thirdparty.thrift_0_9_0.TException + { + tableStats_args args = new tableStats_args(); + args.setTable(table); + sendBase("tableStats", args); + } + + public TableStats recv_tableStats() throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + tableStats_result result = new tableStats_result(); + receiveBase(result, "tableStats"); + if (result.isSetSuccess()) { + return result.success; + } + if (result.ex != null) { + throw result.ex; + } + throw new org.apache.blur.thirdparty.thrift_0_9_0.TApplicationException(org.apache.blur.thirdparty.thrift_0_9_0.TApplicationException.MISSING_RESULT, "tableStats failed: unknown result"); + } + + public void optimize(String table, int numberOfSegmentsPerShard) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + send_optimize(table, numberOfSegmentsPerShard); + recv_optimize(); + } + + public void send_optimize(String table, int numberOfSegmentsPerShard) throws org.apache.blur.thirdparty.thrift_0_9_0.TException + { + optimize_args args = new optimize_args(); + args.setTable(table); + args.setNumberOfSegmentsPerShard(numberOfSegmentsPerShard); + sendBase("optimize", args); + } + + public void recv_optimize() throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + optimize_result result = new optimize_result(); + receiveBase(result, "optimize"); + if (result.ex != null) { + throw result.ex; + } + return; + } + + public void createSnapshot(String table, String name) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + send_createSnapshot(table, name); + recv_createSnapshot(); + } + + public void send_createSnapshot(String table, String name) throws org.apache.blur.thirdparty.thrift_0_9_0.TException + { + createSnapshot_args args = new createSnapshot_args(); + args.setTable(table); + args.setName(name); + sendBase("createSnapshot", args); + } + + public void recv_createSnapshot() throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + createSnapshot_result result = new createSnapshot_result(); + receiveBase(result, "createSnapshot"); + if (result.ex != null) { + throw result.ex; + } + return; + } + + public void removeSnapshot(String table, String name) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + send_removeSnapshot(table, name); + recv_removeSnapshot(); + } + + public void send_removeSnapshot(String table, String name) throws org.apache.blur.thirdparty.thrift_0_9_0.TException + { + removeSnapshot_args args = new removeSnapshot_args(); + args.setTable(table); + args.setName(name); + sendBase("removeSnapshot", args); + } + + public void recv_removeSnapshot() throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + removeSnapshot_result result = new removeSnapshot_result(); + receiveBase(result, "removeSnapshot"); + if (result.ex != null) { + throw result.ex; + } + return; + } + + public Map<String,List<String>> listSnapshots(String table) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + send_listSnapshots(table); + return recv_listSnapshots(); + } + + public void send_listSnapshots(String table) throws org.apache.blur.thirdparty.thrift_0_9_0.TException + { + listSnapshots_args args = new listSnapshots_args(); + args.setTable(table); + sendBase("listSnapshots", args); + } + + public Map<String,List<String>> recv_listSnapshots() throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + listSnapshots_result result = new listSnapshots_result(); + receiveBase(result, "listSnapshots"); + if (result.isSetSuccess()) { + return result.success; + } + if (result.ex != null) { + throw result.ex; + } + throw new org.apache.blur.thirdparty.thrift_0_9_0.TApplicationException(org.apache.blur.thirdparty.thrift_0_9_0.TApplicationException.MISSING_RESULT, "listSnapshots failed: unknown result"); + } + + public void setUser(User user) throws org.apache.blur.thirdparty.thrift_0_9_0.TException + { + send_setUser(user); + } + + public void send_setUser(User user) throws org.apache.blur.thirdparty.thrift_0_9_0.TException + { + setUser_args args = new setUser_args(); + args.setUser(user); + sendBase("setUser", args); + } + + public BlurResults query(String table, BlurQuery blurQuery) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + send_query(table, blurQuery); + return recv_query(); + } + + public void send_query(String table, BlurQuery blurQuery) throws org.apache.blur.thirdparty.thrift_0_9_0.TException + { + query_args args = new query_args(); + args.setTable(table); + args.setBlurQuery(blurQuery); + sendBase("query", args); + } + + public BlurResults recv_query() throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + query_result result = new query_result(); + receiveBase(result, "query"); + if (result.isSetSuccess()) { + return result.success; + } + if (result.ex != null) { + throw result.ex; + } + throw new org.apache.blur.thirdparty.thrift_0_9_0.TApplicationException(org.apache.blur.thirdparty.thrift_0_9_0.TApplicationException.MISSING_RESULT, "query failed: unknown result"); + } + + public FetchResult fetchRow(String table, Selector selector) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + send_fetchRow(table, selector); + return recv_fetchRow(); + } + + public void send_fetchRow(String table, Selector selector) throws org.apache.blur.thirdparty.thrift_0_9_0.TException + { + fetchRow_args args = new fetchRow_args(); + args.setTable(table); + args.setSelector(selector); + sendBase("fetchRow", args); + } + + public FetchResult recv_fetchRow() throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + fetchRow_result result = new fetchRow_result(); + receiveBase(result, "fetchRow"); + if (result.isSetSuccess()) { + return result.success; + } + if (result.ex != null) { + throw result.ex; + } + throw new org.apache.blur.thirdparty.thrift_0_9_0.TApplicationException(org.apache.blur.thirdparty.thrift_0_9_0.TApplicationException.MISSING_RESULT, "fetchRow failed: unknown result"); + } + + public List<FetchResult> fetchRowBatch(String table, List<Selector> selectors) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + send_fetchRowBatch(table, selectors); + return recv_fetchRowBatch(); + } + + public void send_fetchRowBatch(String table, List<Selector> selectors) throws org.apache.blur.thirdparty.thrift_0_9_0.TException + { + fetchRowBatch_args args = new fetchRowBatch_args(); + args.setTable(table); + args.setSelectors(selectors); + sendBase("fetchRowBatch", args); + } + + public List<FetchResult> recv_fetchRowBatch() throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + fetchRowBatch_result result = new fetchRowBatch_result(); + receiveBase(result, "fetchRowBatch"); + if (result.isSetSuccess()) { + return result.success; + } + if (result.ex != null) { + throw result.ex; + } + throw new org.apache.blur.thirdparty.thrift_0_9_0.TApplicationException(org.apache.blur.thirdparty.thrift_0_9_0.TApplicationException.MISSING_RESULT, "fetchRowBatch failed: unknown result"); + } + + public void loadData(String table, String location) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + send_loadData(table, location); + recv_loadData(); + } + + public void send_loadData(String table, String location) throws org.apache.blur.thirdparty.thrift_0_9_0.TException + { + loadData_args args = new loadData_args(); + args.setTable(table); + args.setLocation(location); + sendBase("loadData", args); + } + + public void recv_loadData() throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + loadData_result result = new loadData_result(); + receiveBase(result, "loadData"); + if (result.ex != null) { + throw result.ex; + } + return; + } + + public void validateIndex(String table, List<String> externalIndexPaths) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + send_validateIndex(table, externalIndexPaths); + recv_validateIndex(); + } + + public void send_validateIndex(String table, List<String> externalIndexPaths) throws org.apache.blur.thirdparty.thrift_0_9_0.TException + { + validateIndex_args args = new validateIndex_args(); + args.setTable(table); + args.setExternalIndexPaths(externalIndexPaths); + sendBase("validateIndex", args); + } + + public void recv_validateIndex() throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + validateIndex_result result = new validateIndex_result(); + receiveBase(result, "validateIndex"); + if (result.ex != null) { + throw result.ex; + } + return; + } + + public void loadIndex(String table, List<String> externalIndexPaths) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + send_loadIndex(table, externalIndexPaths); + recv_loadIndex(); + } + + public void send_loadIndex(String table, List<String> externalIndexPaths) throws org.apache.blur.thirdparty.thrift_0_9_0.TException + { + loadIndex_args args = new loadIndex_args(); + args.setTable(table); + args.setExternalIndexPaths(externalIndexPaths); + sendBase("loadIndex", args); + } + + public void recv_loadIndex() throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + loadIndex_result result = new loadIndex_result(); + receiveBase(result, "loadIndex"); + if (result.ex != null) { + throw result.ex; + } + return; + } + + public void mutate(RowMutation mutation) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + send_mutate(mutation); + recv_mutate(); + } + + public void send_mutate(RowMutation mutation) throws org.apache.blur.thirdparty.thrift_0_9_0.TException + { + mutate_args args = new mutate_args(); + args.setMutation(mutation); + sendBase("mutate", args); + } + + public void recv_mutate() throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + mutate_result result = new mutate_result(); + receiveBase(result, "mutate"); + if (result.ex != null) { + throw result.ex; + } + return; + } + + public void enqueueMutate(RowMutation mutation) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + send_enqueueMutate(mutation); + recv_enqueueMutate(); + } + + public void send_enqueueMutate(RowMutation mutation) throws org.apache.blur.thirdparty.thrift_0_9_0.TException + { + enqueueMutate_args args = new enqueueMutate_args(); + args.setMutation(mutation); + sendBase("enqueueMutate", args); + } + + public void recv_enqueueMutate() throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + enqueueMutate_result result = new enqueueMutate_result(); + receiveBase(result, "enqueueMutate"); + if (result.ex != null) { + throw result.ex; + } + return; + } + + public void mutateBatch(List<RowMutation> mutations) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + send_mutateBatch(mutations); + recv_mutateBatch(); + } + + public void send_mutateBatch(List<RowMutation> mutations) throws org.apache.blur.thirdparty.thrift_0_9_0.TException + { + mutateBatch_args args = new mutateBatch_args(); + args.setMutations(mutations); + sendBase("mutateBatch", args); + } + + public void recv_mutateBatch() throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + mutateBatch_result result = new mutateBatch_result(); + receiveBase(result, "mutateBatch"); + if (result.ex != null) { + throw result.ex; + } + return; + } + + public void enqueueMutateBatch(List<RowMutation> mutations) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + send_enqueueMutateBatch(mutations); + recv_enqueueMutateBatch(); + } + + public void send_enqueueMutateBatch(List<RowMutation> mutations) throws org.apache.blur.thirdparty.thrift_0_9_0.TException + { + enqueueMutateBatch_args args = new enqueueMutateBatch_args(); + args.setMutations(mutations); + sendBase("enqueueMutateBatch", args); + } + + public void recv_enqueueMutateBatch() throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + enqueueMutateBatch_result result = new enqueueMutateBatch_result(); + receiveBase(result, "enqueueMutateBatch"); + if (result.ex != null) { + throw result.ex; + } + return; + } + + public void bulkMutateStart(String bulkId) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + send_bulkMutateStart(bulkId); + recv_bulkMutateStart(); + } + + public void send_bulkMutateStart(String bulkId) throws org.apache.blur.thirdparty.thrift_0_9_0.TException + { + bulkMutateStart_args args = new bulkMutateStart_args(); + args.setBulkId(bulkId); + sendBase("bulkMutateStart", args); + } + + public void recv_bulkMutateStart() throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + bulkMutateStart_result result = new bulkMutateStart_result(); + receiveBase(result, "bulkMutateStart"); + if (result.ex != null) { + throw result.ex; + } + return; + } + + public void bulkMutateAdd(String bulkId, RowMutation rowMutation) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + send_bulkMutateAdd(bulkId, rowMutation); + recv_bulkMutateAdd(); + } + + public void send_bulkMutateAdd(String bulkId, RowMutation rowMutation) throws org.apache.blur.thirdparty.thrift_0_9_0.TException + { + bulkMutateAdd_args args = new bulkMutateAdd_args(); + args.setBulkId(bulkId); + args.setRowMutation(rowMutation); + sendBase("bulkMutateAdd", args); + } + + public void recv_bulkMutateAdd() throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + bulkMutateAdd_result result = new bulkMutateAdd_result(); + receiveBase(result, "bulkMutateAdd"); + if (result.ex != null) { + throw result.ex; + } + return; + } + + public void bulkMutateAddMultiple(String bulkId, List<RowMutation> rowMutations) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + send_bulkMutateAddMultiple(bulkId, rowMutations); + recv_bulkMutateAddMultiple(); + } + + public void send_bulkMutateAddMultiple(String bulkId, List<RowMutation> rowMutations) throws org.apache.blur.thirdparty.thrift_0_9_0.TException + { + bulkMutateAddMultiple_args args = new bulkMutateAddMultiple_args(); + args.setBulkId(bulkId); + args.setRowMutations(rowMutations); + sendBase("bulkMutateAddMultiple", args); + } + + public void recv_bulkMutateAddMultiple() throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + bulkMutateAddMultiple_result result = new bulkMutateAddMultiple_result(); + receiveBase(result, "bulkMutateAddMultiple"); + if (result.ex != null) { + throw result.ex; + } + return; + } + + public void bulkMutateFinish(String bulkId, boolean apply, boolean blockUntilComplete) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + send_bulkMutateFinish(bulkId, apply, blockUntilComplete); + recv_bulkMutateFinish(); + } + + public void send_bulkMutateFinish(String bulkId, boolean apply, boolean blockUntilComplete) throws org.apache.blur.thirdparty.thrift_0_9_0.TException + { + bulkMutateFinish_args args = new bulkMutateFinish_args(); + args.setBulkId(bulkId); + args.setApply(apply); + args.setBlockUntilComplete(blockUntilComplete); + sendBase("bulkMutateFinish", args); + } + + public void recv_bulkMutateFinish() throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + bulkMutateFinish_result result = new bulkMutateFinish_result(); + receiveBase(result, "bulkMutateFinish"); + if (result.ex != null) { + throw result.ex; + } + return; + } + + public void cancelQuery(String table, String uuid) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + send_cancelQuery(table, uuid); + recv_cancelQuery(); + } + + public void send_cancelQuery(String table, String uuid) throws org.apache.blur.thirdparty.thrift_0_9_0.TException + { + cancelQuery_args args = new cancelQuery_args(); + args.setTable(table); + args.setUuid(uuid); + sendBase("cancelQuery", args); + } + + public void recv_cancelQuery() throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + cancelQuery_result result = new cancelQuery_result(); + receiveBase(result, "cancelQuery"); + if (result.ex != null) { + throw result.ex; + } + return; + } + + public List<String> queryStatusIdList(String table) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + send_queryStatusIdList(table); + return recv_queryStatusIdList(); + } + + public void send_queryStatusIdList(String table) throws org.apache.blur.thirdparty.thrift_0_9_0.TException + { + queryStatusIdList_args args = new queryStatusIdList_args(); + args.setTable(table); + sendBase("queryStatusIdList", args); + } + + public List<String> recv_queryStatusIdList() throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + queryStatusIdList_result result = new queryStatusIdList_result(); + receiveBase(result, "queryStatusIdList"); + if (result.isSetSuccess()) { + return result.success; + } + if (result.ex != null) { + throw result.ex; + } + throw new org.apache.blur.thirdparty.thrift_0_9_0.TApplicationException(org.apache.blur.thirdparty.thrift_0_9_0.TApplicationException.MISSING_RESULT, "queryStatusIdList failed: unknown result"); + } + + public BlurQueryStatus queryStatusById(String table, String uuid) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + send_queryStatusById(table, uuid); + return recv_queryStatusById(); + } + + public void send_queryStatusById(String table, String uuid) throws org.apache.blur.thirdparty.thrift_0_9_0.TException + { + queryStatusById_args args = new queryStatusById_args(); + args.setTable(table); + args.setUuid(uuid); + sendBase("queryStatusById", args); + } + + public BlurQueryStatus recv_queryStatusById() throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + queryStatusById_result result = new queryStatusById_result(); + receiveBase(result, "queryStatusById"); + if (result.isSetSuccess()) { + return result.success; + } + if (result.ex != null) { + throw result.ex; + } + throw new org.apache.blur.thirdparty.thrift_0_9_0.TApplicationException(org.apache.blur.thirdparty.thrift_0_9_0.TApplicationException.MISSING_RESULT, "queryStatusById failed: unknown result"); + } + + public List<String> terms(String table, String columnFamily, String columnName, String startWith, short size) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + send_terms(table, columnFamily, columnName, startWith, size); + return recv_terms(); + } + + public void send_terms(String table, String columnFamily, String columnName, String startWith, short size) throws org.apache.blur.thirdparty.thrift_0_9_0.TException + { + terms_args args = new terms_args(); + args.setTable(table); + args.setColumnFamily(columnFamily); + args.setColumnName(columnName); + args.setStartWith(startWith); + args.setSize(size); + sendBase("terms", args); + } + + public List<String> recv_terms() throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + terms_result result = new terms_result(); + receiveBase(result, "terms"); + if (result.isSetSuccess()) { + return result.success; + } + if (result.ex != null) { + throw result.ex; + } + throw new org.apache.blur.thirdparty.thrift_0_9_0.TApplicationException(org.apache.blur.thirdparty.thrift_0_9_0.TApplicationException.MISSING_RESULT, "terms failed: unknown result"); + } + + public long recordFrequency(String table, String columnFamily, String columnName, String value) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + send_recordFrequency(table, columnFamily, columnName, value); + return recv_recordFrequency(); + } + + public void send_recordFrequency(String table, String columnFamily, String columnName, String value) throws org.apache.blur.thirdparty.thrift_0_9_0.TException + { + recordFrequency_args args = new recordFrequency_args(); + args.setTable(table); + args.setColumnFamily(columnFamily); + args.setColumnName(columnName); + args.setValue(value); + sendBase("recordFrequency", args); + } + + public long recv_recordFrequency() throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + recordFrequency_result result = new recordFrequency_result(); + receiveBase(result, "recordFrequency"); + if (result.isSetSuccess()) { + return result.success; + } + if (result.ex != null) { + throw result.ex; + } + throw new org.apache.blur.thirdparty.thrift_0_9_0.TApplicationException(org.apache.blur.thirdparty.thrift_0_9_0.TApplicationException.MISSING_RESULT, "recordFrequency failed: unknown result"); + } + + public List<String> shardClusterList() throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + send_shardClusterList(); + return recv_shardClusterList(); + } + + public void send_shardClusterList() throws org.apache.blur.thirdparty.thrift_0_9_0.TException + { + shardClusterList_args args = new shardClusterList_args(); + sendBase("shardClusterList", args); + } + + public List<String> recv_shardClusterList() throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + shardClusterList_result result = new shardClusterList_result(); + receiveBase(result, "shardClusterList"); + if (result.isSetSuccess()) { + return result.success; + } + if (result.ex != null) { + throw result.ex; + } + throw new org.apache.blur.thirdparty.thrift_0_9_0.TApplicationException(org.apache.blur.thirdparty.thrift_0_9_0.TApplicationException.MISSING_RESULT, "shardClusterList failed: unknown result"); + } + + public List<String> shardServerList(String cluster) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + send_shardServerList(cluster); + return recv_shardServerList(); + } + + public void send_shardServerList(String cluster) throws org.apache.blur.thirdparty.thrift_0_9_0.TException + { + shardServerList_args args = new shardServerList_args(); + args.setCluster(cluster); + sendBase("shardServerList", args); + } + + public List<String> recv_shardServerList() throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + shardServerList_result result = new shardServerList_result(); + receiveBase(result, "shardServerList"); + if (result.isSetSuccess()) { + return result.success; + } + if (result.ex != null) { + throw result.ex; + } + throw new org.apache.blur.thirdparty.thrift_0_9_0.TApplicationException(org.apache.blur.thirdparty.thrift_0_9_0.TApplicationException.MISSING_RESULT, "shardServerList failed: unknown result"); + } + + public List<String> controllerServerList() throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + send_controllerServerList(); + return recv_controllerServerList(); + } + + public void send_controllerServerList() throws org.apache.blur.thirdparty.thrift_0_9_0.TException + { + controllerServerList_args args = new controllerServerList_args(); + sendBase("controllerServerList", args); + } + + public List<String> recv_controllerServerList() throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + controllerServerList_result result = new controllerServerList_result(); + receiveBase(result, "controllerServerList"); + if (result.isSetSuccess()) { + return result.success; + } + if (result.ex != null) { + throw result.ex; + } + throw new org.apache.blur.thirdparty.thrift_0_9_0.TApplicationException(org.apache.blur.thirdparty.thrift_0_9_0.TApplicationException.MISSING_RESULT, "controllerServerList failed: unknown result"); + } + + public Map<String,String> shardServerLayout(String table) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + send_shardServerLayout(table); + return recv_shardServerLayout(); + } + + public void send_shardServerLayout(String table) throws org.apache.blur.thirdparty.thrift_0_9_0.TException + { + shardServerLayout_args args = new shardServerLayout_args(); + args.setTable(table); + sendBase("shardServerLayout", args); + } + + public Map<String,String> recv_shardServerLayout() throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + shardServerLayout_result result = new shardServerLayout_result(); + receiveBase(result, "shardServerLayout"); + if (result.isSetSuccess()) { + return result.success; + } + if (result.ex != null) { + throw result.ex; + } + throw new org.apache.blur.thirdparty.thrift_0_9_0.TApplicationException(org.apache.blur.thirdparty.thrift_0_9_0.TApplicationException.MISSING_RESULT, "shardServerLayout failed: unknown result"); + } + + public Map<String,Map<String,ShardState>> shardServerLayoutState(String table) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + send_shardServerLayoutState(table); + return recv_shardServerLayoutState(); + } + + public void send_shardServerLayoutState(String table) throws org.apache.blur.thirdparty.thrift_0_9_0.TException + { + shardServerLayoutState_args args = new shardServerLayoutState_args(); + args.setTable(table); + sendBase("shardServerLayoutState", args); + } + + public Map<String,Map<String,ShardState>> recv_shardServerLayoutState() throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + shardServerLayoutState_result result = new shardServerLayoutState_result(); + receiveBase(result, "shardServerLayoutState"); + if (result.isSetSuccess()) { + return result.success; + } + if (result.ex != null) { + throw result.ex; + } + throw new org.apache.blur.thirdparty.thrift_0_9_0.TApplicationException(org.apache.blur.thirdparty.thrift_0_9_0.TApplicationException.MISSING_RESULT, "shardServerLayoutState failed: unknown result"); + } + + public boolean isInSafeMode(String cluster) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + send_isInSafeMode(cluster); + return recv_isInSafeMode(); + } + + public void send_isInSafeMode(String cluster) throws org.apache.blur.thirdparty.thrift_0_9_0.TException + { + isInSafeMode_args args = new isInSafeMode_args(); + args.setCluster(cluster); + sendBase("isInSafeMode", args); + } + + public boolean recv_isInSafeMode() throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + isInSafeMode_result result = new isInSafeMode_result(); + receiveBase(result, "isInSafeMode"); + if (result.isSetSuccess()) { + return result.success; + } + if (result.ex != null) { + throw result.ex; + } + throw new org.apache.blur.thirdparty.thrift_0_9_0.TApplicationException(org.apache.blur.thirdparty.thrift_0_9_0.TApplicationException.MISSING_RESULT, "isInSafeMode failed: unknown result"); + } + + public Map<String,String> configuration() throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + send_configuration(); + return recv_configuration(); + } + + public void send_configuration() throws org.apache.blur.thirdparty.thrift_0_9_0.TException + { + configuration_args args = new configuration_args(); + sendBase("configuration", args); + } + + public Map<String,String> recv_configuration() throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + configuration_result result = new configuration_result(); + receiveBase(result, "configuration"); + if (result.isSetSuccess()) { + return result.success; + } + if (result.ex != null) { + throw result.ex; + } + throw new org.apache.blur.thirdparty.thrift_0_9_0.TApplicationException(org.apache.blur.thirdparty.thrift_0_9_0.TApplicationException.MISSING_RESULT, "configuration failed: unknown result"); + } + + public String configurationPerServer(String thriftServerPlusPort, String configName) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + send_configurationPerServer(thriftServerPlusPort, configName); + return recv_configurationPerServer(); + } + + public void send_configurationPerServer(String thriftServerPlusPort, String configName) throws org.apache.blur.thirdparty.thrift_0_9_0.TException + { + configurationPerServer_args args = new configurationPerServer_args(); + args.setThriftServerPlusPort(thriftServerPlusPort); + args.setConfigName(configName); + sendBase("configurationPerServer", args); + } + + public String recv_configurationPerServer() throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + configurationPerServer_result result = new configurationPerServer_result(); + receiveBase(result, "configurationPerServer"); + if (result.isSetSuccess()) { + return result.success; + } + if (result.ex != null) { + throw result.ex; + } + throw new org.apache.blur.thirdparty.thrift_0_9_0.TApplicationException(org.apache.blur.thirdparty.thrift_0_9_0.TApplicationException.MISSING_RESULT, "configurationPerServer failed: unknown result"); + } + + public Map<String,Metric> metrics(Set<String> metrics) throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + send_metrics(metrics); + return recv_metrics(); + } + + public void send_metrics(Set<String> metrics) throws org.apache.blur.thirdparty.thrift_0_9_0.TException + { + metrics_args args = new metrics_args(); + args.setMetrics(metrics); + sendBase("metrics", args); + } + + public Map<String,Metric> recv_metrics() throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + metrics_result result = new metrics_result(); + receiveBase(result, "metrics"); + if (result.isSetSuccess()) { + return result.success; + } + if (result.ex != null) { + throw result.ex; + } + throw new org.apache.blur.thirdparty.thrift_0_9_0.TApplicationException(org.apache.blur.thirdparty.thrift_0_9_0.TApplicationException.MISSING_RESULT, "metrics failed: unknown result"); + } + + public void startTrace(String traceId, String requestId) throws org.apache.blur.thirdparty.thrift_0_9_0.TException + { + send_startTrace(traceId, requestId); + } + + public void send_startTrace(String traceId, String requestId) throws org.apache.blur.thirdparty.thrift_0_9_0.TException + { + startTrace_args args = new startTrace_args(); + args.setTraceId(traceId); + args.setRequestId(requestId); + sendBase("startTrace", args); + } + + public List<String> traceList() throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + send_traceList(); + return recv_traceList(); + } + + public void send_traceList() throws org.apache.blur.thirdparty.thrift_0_9_0.TException + { + traceList_args args = new traceList_args(); + sendBase("traceList", args); + } + + public List<String> recv_traceList() throws BlurException, org.apache.blur.thirdparty.thrift_0_9_0.TException + { + traceList_result result = new traceList_result(); + receiveBase(result, "traceList"); + if (result.isSetSuccess()) { + return result.success; + } + if (result.ex != null) { + throw result.ex; + } + throw new org.apache.blur.thirdparty.thrift_0_9_0.TApplicationException(org.apache.blur.thirdparty.thrift_0_9_0.TApplicationException.MISSING_RESULT, "traceList failed: unknown result"); + } + + public List<String> traceRequestList(String traceId) thr
<TRUNCATED>
