-
InterfaceDescriptionClient connection to an Accumulo instance.Builder methods for authenticationBuilds AccumuloClient or client Properties after all options have been specifiedBuild methods for connection optionsBuilder method for setting Accumulo instance and zookeepersBuilder methods for creating AccumuloClient using propertiesBuild methods for SASLBuild methods for SSL/TLSA configuration object that can be used with the table clone command in the
TableOperations.A CloneConfiguration builderA single file ready to compact, that will come in a set of possible candidates.Enables dynamically overriding of per table properties used to create the output file for a compaction.This class selects which files a user compaction will compact.A configuration object that can be used withTableOperations.importTable(String, Set, ImportConfiguration)A ImportConfiguration builderThis interface allows configuring where and which summary data to retrieve before retrieving it.Options giving control of how the bulk import file mapping is done.This interface exposes Accumulo system level information to plugins in a stable manner.This is an intermediate interface in a larger builder pattern.This is an intermediate interface in a larger builder pattern.This is an intermediate interface in a large builder pattern.A function that converts key values to zero or more counter objects.Instances of this interface can be configured for Accumulo tables.When Accumulo calls methods in this interface, it will callSummarizer.Collector.accept(Key, Value)zero or more times and then callSummarizer.Collector.summarize(Summarizer.StatisticConsumer)once.A Combiner is used to merge statistics emitted fromSummarizer.Collector.summarize(Summarizer.StatisticConsumer)and from previous invocations of itself.Constraint objects are used to determine if mutations will be applied to a table.The environment within which a constraint exists.Builder step used to set the columnFamily part of theKey.Builder step used to set the column qualifier part of theKey.Builder step used to set the column visibility part of theKey.Builder step used to set the row part of theKey.A function that maps a row to two table split points that contain the row.Provides methods for setting the column family of a Mutation.Provides methods for setting the value of a Mutation.Provides methods for setting the column qualifier of a Mutation.Provides methods for setting the timestamp of a Mutation.Provides methods for setting the column visibility of a Mutation.This interface is an extension ofServiceEnvironmentthat exposes system level information that is specific to tablet balancing.This class is responsible for managing the distribution of tablets throughout an Accumulo cluster.An interface for grouping parameters required for the balancer to assign unassigned tablets.An interface for grouping parameters required for the balancer to balance tablets.Block cache interface.The environment provided to the context class loader factory for its useThe ContextClassLoaderFactory provides a mechanism for various Accumulo components to use a custom ClassLoader for specific contexts, such as loading table iterators.Provides information about a configured Accumulo IteratorThis interface exposes Accumulo system level information to plugins in a stable manner.The dispatch of aCompactionDispatcherRequired service parameter forCompactionDispatchCan be configured per table to dispatch compactions to different compaction services.The method parameters forCompactionDispatcher.dispatch(DispatchParameters).The method parameters forCompactionDispatcher.init(InitParameters).An immutable object that describes what files to compact and where to compact them.The return value ofCompactionPlanner.makePlan(PlanningParameters)that is created usingCompactionPlanner.PlanningParameters.createPlanBuilder()Plans compaction work for a compaction service.This interface exists so the API can evolve and additional parameters can be passed to the method in the future.This interface exists so the API can evolve and additional parameters can be passed to the method in the future.Provider of information about configured compaction services.Offered to a Compaction Planner at initialization time so it can create executors.Useful information provided to the crypto implementationA self-contained cryptographic service.A Factory that returns a CryptoService based on the environment and configuration.Class implementation that will decrypt a file.Class implementation that will encrypt a file.Helper used to select a volume from a set of Volume URIs.The Micrometer metrics allows for different monitoring systems.Encapsulates information about how a scan should be executed.A per table scan dispatcher that decides which executor should be used to process a scan.The method parameters forScanDispatcher.dispatch(DispatchParameters).The method parameters forScanDispatcher.dispatch(DispatchParmaters).The method parameters forScanDispatcher.init(InitParameters).Interface for obtaining information about a scan executorProvides information about an active Accumulo scan against a tablet.A factory for creating comparators used for prioritizing scans.The method parameters forScanPrioritizer.createComparator(CreateParameters).This object is used to communicate what previous actions were attempted, when they were attempted, and the result of those attemptsInformation about a scan server.Returned byScanServerSelector.selectServers(ScanServerSelector.SelectorParameters)to specify what scan servers to use and how to use them.A client side plugin that determines what scan servers to use for eventually consistent scans.This interface exists so that is easier to evolve what is passed toScanServerSelector.init(InitParameters)without having to make breaking changes.This interface exists so that is easier to evolve what is passed toScanServerSelector.selectServers(SelectorParameters)without having to make breaking changes.Builder for all the information needed for the Map Reduce job.Options for builderRequired params for builderBuilder for all the information needed for the Map Reduce job.Required params for builderOptional values to set using fluent APIRequired params for builderBuilder for all the information needed for the Map Reduce job.Required params for clientBuilder options
-
ClassDescriptionThis class contains all API entry points created in 2.0.0 or later.Specifies how the output file should be created for a compaction.A compaction configurer that can adjust the compression configuration for a compaction when the sum of the input file sizes exceeds a threshold.A compaction configurer that extends CompressionConfigurer and adds the ability to control and configure how Erasure Codes work.This compaction selector works in concert with the
DeletesSummarizer.Encapsulates the configuration of an Accumulo server side plugin, which consist of a class name and options.A Lexicoder to encode/decode a Java List to/from a byte array where the concatenation of each encoded element sorts lexicographically.This a convenience class for interpreting summary data generated by implementations ofCountingSummarizerThis class counts arbitrary keys while defending against too many keys and keys that are too long.This class encapsulates the configuration needed to instantiate aSummarizer.Counts unique authorizations in column visibility labels.This summarizer tracks the total number of delete Keys seen and the total number of keys seen.Summarizer that computes summary information about field lengths.Counts column column families.Counts column visibility labels.This class encapsulates summary statistics, information about how those statistics were generated, and information about files the statistics were obtained from.An abstract identifier class for comparing equality of identifiers of the same type.A constraints that limits the size of keys to 1mb.This constraint ensures mutations do not have deletes.A constraint that checks the visibility of columns against the actor's authorizations.A strongly typed representation of an Accumulo instance ID.A builder used to buildKeys by defining their components.Information about where to load files into an Accumulo table.Mapping of a file to a row range with an associated range type.Represents two split points that exist in a table being bulk imported to.A strongly typed representation of a namespace ID.A strongly typed representation of a table ID.An optimized version ofFilter.An optimized version ofSkippingIterator.An optimized version ofWrappingIterator.A SortedKeyValueIterator similar toServerFilterbut with the implemented methods marked as synchronized.A balancer that will do nothing and warn about doing nothing.A balancer that evenly spreads groups of tablets across all tablet server.This balancer creates groups of tablet servers using user-provided regular expressions over the tablet server hostnames.AGroupBalancerthat groups tablets using a configurable regex.A simple tablet balancer that attempts to spread tablets out evenly across all available tablet servers.A unique identifier for a a compaction executor that aCompactionPlannercan schedule compactions on using aCompactionJob.A unique identifier for a compaction serviceFinds the largest continuous set of small files that meet the compaction ratio and do not prevent future compactions.AVolumeChooserthat delegates to another volume chooser based on other properties: table.custom.volume.chooser for tables, and general.custom.volume.chooser.scoped for scopes.ARandomVolumeChooserthat selects preferred volumes to use from the provided volume options.AVolumeChooserthat selects a volume at random from the list of provided volumes.APreferredVolumeChooserthat takes remaining HDFS space into account when making a volume choice rather than a simpler round-robin.The default Accumulo selector for scan servers.When configured for a scan executor, this prioritizer allows scanners to set priorities as integers.Prioritize scans based on the ratio of runTime/idleTime.This class allows MapReduce jobs to write output in the Accumulo data file format.
Care should be taken to write only sorted data (sorted byKey), as this is an important requirement of Accumulo data files.This class allows MapReduce jobs to use Accumulo as the source of data.This class allows MapReduce jobs to use Accumulo as the sink for data.This class allows MapReduce jobs to use Accumulo as the source of data.Hadoop partitioner that uses ranges based on row keys, and optionally sub-bins based on hashing.Hadoop partitioner that uses ranges, and optionally sub-bins based on hashing.
-
EnumDescriptionCreation mode for table creation.Consistency level for the scanner.A scope for the volume chooser environment; a TABLE scope should be accompanied by a tableId.Communicates how a scan should use cache.
-
MethodDescriptionOverride default handling of uncaught exceptions in client threadsFactory method to create a ConditionalWriter connected to Accumulo.Return the host where the compaction is running.Returns the path that the compaction will write to, one use of this is to know the output volume.Returns the tablet that is compacting.Enables a
CompactionConfigurerto run for this compaction on the server side.Configure aCompactionSelectorplugin to run for this compaction.List all internal and external compactions running in Accumulo.Returns the locations of the active compactorsReturns a unique ID object that identifies this instance of accumulo.Returns a unique string that identifies this instance of accumulo.Returns the location(s) of the accumulo manager and any redundant servers.Returns the locations of the active scan serversModify system properties using a Consumer that accepts a mutable map containing the current system property overrides stored in ZooKeeper.Gets a merged view of the properties of a namespace with its parent configuration.Gets properties specific to this namespace.For a detailed overview of the behavior of this method seeInstanceOperations.modifyProperties(Consumer)which operates on a different layer of properties but has the same behavior and better documentation.Configure iterator settings for a table prior to its creation.Configure iterator settings for a table prior to its creation.Create the new table in an offline state.Enables creating summary statistics usingSummarizer's for the new table.Return value indicating whether table is to be created in offline or online mode.Return Collection of split values.Configures a table's locality groups prior to initial table creation.Create a new table with pre-configured splits from the provided input collection.Enables summary generation for this table for future compactions.Clone a table from an existing table.Gets a merged view of the properties of a table with its parent configuration.Gets per-table properties of a table.Return the TimeType for the given tableBulk import the files in a directory into a table.Ignores empty bulk import source directory, rather than throwing an IllegalArgumentException.Imports a table exported viaTableOperations.exportTable(String, String)and then copied via hadoop distcp.Check if a table is online through its current goal state only.For a detailed overview of the behavior of this method seeInstanceOperations.modifyProperties(Consumer)which operates on a different layer of properties but has the same behavior and better documentation.Removes summary generation for this table for the matching summarizers.Entry point for retrieving summaries with optional restrictions.Merge this BatchWriterConfig with another.Merge this ConditionalWriterConfig with another.Creates a Connector from an AccumuloClient.Creates a new Accumulo Client from a Connector.Returns all properties with a given prefixProperties with a default value will always return something when callingPluginEnvironment.Configuration.get(String), even if a user never set the property.Entry point for reading summary data from RFiles.Enable generating summary data in the created RFile by runningSummarizer's based on the specified configuration.This method has the same behavior asRFileWriter.append(Key, Value).This method has the same behavior asRFileWriter.append(Key, Value).If no split resolver was provided when the RFileWriter was built then this method will return a simple load plan of typeLoadPlan.RangeType.FILEusing the first and last row seen.Adds a column to the list of columns that will be fetched by this scanner.Adds a column family to the list of columns that will be fetched by this scanner.Iterates through Scanner results.Get the configured consistency levelSet the desired consistency level for this scanner.Set hints for the configuredScanPrioritizerandScanDispatcher.Stream the Scanner results sequentially from this scanner's iteratorCreate aKeybuilder.Create aKeybuilder.Computes a load plan for a given rfile.Computes a load plan for a given rfile.Deserializes json to a load plan.Serializes the load plan to json that looks like the following.Fluent API for putting or deleting to a Mutation that makes it easy use different types (i.e byte[], CharSequence, etc) when specifying the family, qualifier, value, etc.Creates a multi-lined, human-readable String for this mutation.Return a TabletId object for the provided TableId in range of (prevEndRow, endRow].Compares the bytes in this object to the specified byte arrayReturns an object containing information about the server where this iterator was run.Returns an object containing information about the server where this iterator was run.Enable or disable matching on the family field of the key.Enable or disable matching on the qualifier field of the key.org.apache.accumulo.core.iterators.user.GrepIterator.matchColumnVisibility(IteratorSetting, boolean) Enable or disable matching on the visibility field of the key.Enable or disable matching on the row field of the key.Enable or disable matching on the value.This is the set of tables the balancer should consider.Accumulo may partition tables in different ways and pass subsets of tables to the balancer viaTabletBalancer.BalanceParameters.getTablesToBalance().The end row of the tablet for which a volume is being chosen.Accumulo calls this method for each scan batch to determine what executor to use and how to utilize cache for the scan.Enables the user to set the consistency levelUtility method to create anAccumuloClientwith connection to the MAC.Construct clientPropertiesusing aMiniAccumuloClusterdirectorySets the classpath elements to use when spawning processes.Configure an existing ZooKeeper instance to use.Calling this method is optional.
-
ConstructorDescriptionCreates Mutations rejected exceptionCopy constructor.