Index (Kite Development Kit 1.1.0 API)

A B C D E F G H I J K L M N O P R S T U V W X Y Z

A

AbstractCommand - Class in org.kitesdk.morphline.base: Base class for convenient implementation of Command classes.
AbstractCommand(CommandBuilder, Config, Command, Command, MorphlineContext) - Constructor for class org.kitesdk.morphline.base.AbstractCommand: Using the given builder, constructs a command rooted at the given morphline JSON config.
AbstractCommand(Config, Command, Command, MorphlineContext) - Constructor for class org.kitesdk.morphline.base.AbstractCommand: Deprecated.
AbstractFieldTransformCommand - Class in org.kitesdk.morphline.stdlib: Base class for convenient implementation of commands that do in-place updates on a field.
AbstractFieldTransformCommand(CommandBuilder, Config, Command, Command, MorphlineContext) - Constructor for class org.kitesdk.morphline.stdlib.AbstractFieldTransformCommand
AbstractFieldTransformCommand(Config, Command, Command, MorphlineContext) - Constructor for class org.kitesdk.morphline.stdlib.AbstractFieldTransformCommand: Deprecated.
AbstractParser - Class in org.kitesdk.morphline.stdio: Base class for convenient implementation of morphline parsers.
AbstractParser(CommandBuilder, Config, Command, Command, MorphlineContext) - Constructor for class org.kitesdk.morphline.stdio.AbstractParser
AbstractParser(Config, Command, Command, MorphlineContext) - Constructor for class org.kitesdk.morphline.stdio.AbstractParser: Deprecated.
add(String, Object) - Method in class org.kitesdk.data.Key.Builder: Add a key value for the named field.
AddCurrentTimeBuilder - Class in org.kitesdk.morphline.stdlib: A command that adds the result of System.currentTimeMillis() to a given output field.
AddCurrentTimeBuilder() - Constructor for class org.kitesdk.morphline.stdlib.AddCurrentTimeBuilder
addJarForClass(Class<?>) - Method in class org.kitesdk.tools.TaskUtil.ConfigBuilder: Finds the jar that contains the required class and adds it to the distributed cache configuration.
addJarPathForClass(Class<?>) - Method in class org.kitesdk.tools.TaskUtil.ConfigBuilder: Finds the jar that contains the required class and adds its containing directory to the distributed cache configuration.
addJars(List<String>) - Method in class org.kitesdk.tools.TaskUtil.ConfigBuilder: Adds a set of jar paths to the distributed cache.
AddLocalHostBuilder - Class in org.kitesdk.morphline.stdlib: A command that adds the name or IP of the local host to a given output field.
AddLocalHostBuilder() - Constructor for class org.kitesdk.morphline.stdlib.AddLocalHostBuilder
addService(Class<? extends Service>) - Method in class org.kitesdk.minicluster.MiniCluster.Builder
addSupportedMimeType(String) - Method in class org.kitesdk.morphline.stdio.AbstractParser
AddValuesBuilder - Class in org.kitesdk.morphline.stdlib: For each input field value, add the value to the given record output field.
AddValuesBuilder() - Constructor for class org.kitesdk.morphline.stdlib.AddValuesBuilder
AddValuesIfAbsentBuilder - Class in org.kitesdk.morphline.stdlib: For each input field value, add the value to the given record output field if the value isn't already contained in that field.
AddValuesIfAbsentBuilder() - Constructor for class org.kitesdk.morphline.stdlib.AddValuesIfAbsentBuilder
append(Path, int, Progressable) - Method in class org.kitesdk.morphline.hadoop.rcfile.SingleStreamFileSystem
appendTo(URI) - Method in class org.kitesdk.data.mapreduce.DatasetKeyOutputFormat.ConfigBuilder: Adds configuration for DatasetKeyOutputFormat to append to the given dataset or view URI, leaving any existing data intact.
appendTo(View<?>) - Method in class org.kitesdk.data.mapreduce.DatasetKeyOutputFormat.ConfigBuilder: Adds configuration for DatasetKeyOutputFormat to append to the given dataset or view URI, leaving any existing data intact.
appendTo(String) - Method in class org.kitesdk.data.mapreduce.DatasetKeyOutputFormat.ConfigBuilder: Adds configuration for DatasetKeyOutputFormat to append to the given dataset or view URI, leaving any existing data intact.
asSchema(Schema) - Method in interface org.kitesdk.data.View: Creates a copy of this View that projects entities to the given Schema.
asSource(View<E>) - Static method in class org.kitesdk.data.crunch.CrunchDatasets: Expose the given View as a Crunch ReadableSource.
asSource(URI, Class<E>) - Static method in class org.kitesdk.data.crunch.CrunchDatasets: Expose the View or Dataset represented by the URI as a Crunch ReadableSource.
asSource(String, Class<E>) - Static method in class org.kitesdk.data.crunch.CrunchDatasets: Expose the View or Dataset represented by the URI as a Crunch ReadableSource.
asTarget(View<E>) - Static method in class org.kitesdk.data.crunch.CrunchDatasets: Expose the given View as a Crunch Target.
asTarget(String) - Static method in class org.kitesdk.data.crunch.CrunchDatasets: Expose the Dataset or View represented by the given URI as a Crunch Target.
asTarget(URI) - Static method in class org.kitesdk.data.crunch.CrunchDatasets: Expose the Dataset or View represented by the given URI as a Crunch Target.
asType(Class<T>) - Method in interface org.kitesdk.data.View: Creates a copy of this View that reads and writes entities of the given type class.
ATTACHMENT_BODY - Static variable in class org.kitesdk.morphline.base.Fields
ATTACHMENT_CHARSET - Static variable in class org.kitesdk.morphline.base.Fields
ATTACHMENT_MIME_TYPE - Static variable in class org.kitesdk.morphline.base.Fields
ATTACHMENT_NAME - Static variable in class org.kitesdk.morphline.base.Fields
AVRO - Static variable in class org.kitesdk.data.Formats: AVRO: the Avro row-oriented format
AVRO_MEMORY_MIME_TYPE - Static variable in class org.kitesdk.morphline.avro.ReadAvroBuilder: The MIME type identifier that will be filled into output records
AVRO_MEMORY_MIME_TYPE - Static variable in class org.kitesdk.morphline.hadoop.parquet.avro.ReadAvroParquetFileBuilder: The MIME type identifier that will be filled into output records

B

BASE_ID - Static variable in class org.kitesdk.morphline.base.Fields
beginTransaction() - Method in interface org.kitesdk.morphline.solr.DocumentLoader: Begins a transaction
beginTransaction() - Method in class org.kitesdk.morphline.solr.SolrServerDocumentLoader
BIND_IP_KEY - Static variable in class org.kitesdk.minicluster.MiniCluster
bindIP(String) - Method in class org.kitesdk.minicluster.MiniCluster.Builder
build() - Method in class org.kitesdk.data.ColumnMapping.Builder: Builds and returns a ColumnMapping from the fields mappings added to this builder.
build() - Method in class org.kitesdk.data.DatasetDescriptor.Builder: Build an instance of the configured dataset descriptor.
build() - Method in class org.kitesdk.data.Key.Builder: Build an instance of the configured key.
build() - Method in class org.kitesdk.data.PartitionStrategy.Builder: Build a configured PartitionStrategy instance.
build(String, String, String) - Static method in class org.kitesdk.data.URIBuilder: Builds a dataset URI from the given repository URI string, namespace, and dataset name.
build(URI, String, String) - Static method in class org.kitesdk.data.URIBuilder: Builds a dataset URI from the given repository URI, namespace, and dataset name.
build() - Method in class org.kitesdk.data.URIBuilder: Returns a dataset or view URI encompassing the given constraints.
build() - Method in class org.kitesdk.minicluster.MiniCluster.Builder
build(Config, Command, Command, MorphlineContext) - Method in interface org.kitesdk.morphline.api.CommandBuilder: Creates and returns a command rooted at the given morphline JSON config.
build() - Method in class org.kitesdk.morphline.api.MorphlineContext.Builder
build(Config, Command, Command, MorphlineContext) - Method in class org.kitesdk.morphline.avro.ExtractAvroPathsBuilder
build(Config, Command, Command, MorphlineContext) - Method in class org.kitesdk.morphline.avro.ExtractAvroTreeBuilder
build(Config, Command, Command, MorphlineContext) - Method in class org.kitesdk.morphline.avro.ReadAvroBuilder
build(Config, Command, Command, MorphlineContext) - Method in class org.kitesdk.morphline.avro.ReadAvroContainerBuilder
build(Config, Command, Command, MorphlineContext) - Method in class org.kitesdk.morphline.avro.ToAvroBuilder
build(Config, Command, Command, MorphlineContext) - Method in class org.kitesdk.morphline.avro.ToAvroMapBuilder
build(Config, Command, Command, MorphlineContext) - Method in class org.kitesdk.morphline.avro.WriteAvroToByteArrayBuilder
build(Config, Command, Command, MorphlineContext) - Method in class org.kitesdk.morphline.hadoop.core.DownloadHdfsFileBuilder
build(Config, Command, Command, MorphlineContext) - Method in class org.kitesdk.morphline.hadoop.core.OpenHdfsFileBuilder
build(Config, Command, Command, MorphlineContext) - Method in class org.kitesdk.morphline.hadoop.parquet.avro.ReadAvroParquetFileBuilder
build(Config, Command, Command, MorphlineContext) - Method in class org.kitesdk.morphline.hadoop.rcfile.ReadRCFileBuilder
build(Config, Command, Command, MorphlineContext) - Method in class org.kitesdk.morphline.hadoop.sequencefile.ReadSequenceFileBuilder
build(Config, Command, Command, MorphlineContext) - Method in class org.kitesdk.morphline.json.ExtractJsonPathsBuilder
build(Config, Command, Command, MorphlineContext) - Method in class org.kitesdk.morphline.json.ReadJsonBuilder
build(Config, Command, Command, MorphlineContext) - Method in class org.kitesdk.morphline.maxmind.GeoIPBuilder
build(Config, Command, Command, MorphlineContext) - Method in class org.kitesdk.morphline.metrics.servlets.RegisterJVMMetricsBuilder
build(Config, Command, Command, MorphlineContext) - Method in class org.kitesdk.morphline.metrics.servlets.StartReportingMetricsToHTTPBuilder
build(Config, Command, Command, MorphlineContext) - Method in class org.kitesdk.morphline.protobuf.ExtractProtobufPathsBuilder
build(Config, Command, Command, MorphlineContext) - Method in class org.kitesdk.morphline.protobuf.ReadProtobufBuilder
build(Config, Command, Command, MorphlineContext) - Method in class org.kitesdk.morphline.saxon.ConvertHTMLBuilder
build(Config, Command, Command, MorphlineContext) - Method in class org.kitesdk.morphline.saxon.XQueryBuilder
build(Config, Command, Command, MorphlineContext) - Method in class org.kitesdk.morphline.saxon.XSLTBuilder
build(Config, Command, Command, MorphlineContext) - Method in class org.kitesdk.morphline.solr.GenerateSolrSequenceKeyBuilder
build(Config, Command, Command, MorphlineContext) - Method in class org.kitesdk.morphline.solr.LoadSolrBuilder
build(Config, Command, Command, MorphlineContext) - Method in class org.kitesdk.morphline.solr.SanitizeUnknownSolrFieldsBuilder
build() - Method in class org.kitesdk.morphline.solr.SolrMorphlineContext.Builder
build(Config, Command, Command, MorphlineContext) - Method in class org.kitesdk.morphline.solr.TokenizeTextBuilder
build(Config, Command, Command, MorphlineContext) - Method in class org.kitesdk.morphline.solrcell.SolrCellBuilder
build(Config, Command, Command, MorphlineContext) - Method in class org.kitesdk.morphline.stdio.ReadBlobBuilder
build(Config, Command, Command, MorphlineContext) - Method in class org.kitesdk.morphline.stdio.ReadClobBuilder
build(Config, Command, Command, MorphlineContext) - Method in class org.kitesdk.morphline.stdio.ReadCSVBuilder
build(Config, Command, Command, MorphlineContext) - Method in class org.kitesdk.morphline.stdio.ReadLineBuilder
build(Config, Command, Command, MorphlineContext) - Method in class org.kitesdk.morphline.stdio.ReadMultiLineBuilder
build(Config, Command, Command, MorphlineContext) - Method in class org.kitesdk.morphline.stdlib.AddCurrentTimeBuilder
build(Config, Command, Command, MorphlineContext) - Method in class org.kitesdk.morphline.stdlib.AddLocalHostBuilder
build(Config, Command, Command, MorphlineContext) - Method in class org.kitesdk.morphline.stdlib.AddValuesBuilder
build(Config, Command, Command, MorphlineContext) - Method in class org.kitesdk.morphline.stdlib.AddValuesIfAbsentBuilder
build(Config, Command, Command, MorphlineContext) - Method in class org.kitesdk.morphline.stdlib.CallParentPipeBuilder
build(Config, Command, Command, MorphlineContext) - Method in class org.kitesdk.morphline.stdlib.ContainsBuilder
build(Config, Command, Command, MorphlineContext) - Method in class org.kitesdk.morphline.stdlib.ConvertTimestampBuilder
build(Config, Command, Command, MorphlineContext) - Method in class org.kitesdk.morphline.stdlib.DecodeBase64Builder
build(Config, Command, Command, MorphlineContext) - Method in class org.kitesdk.morphline.stdlib.DropRecordBuilder
build(Config, Command, Command, MorphlineContext) - Method in class org.kitesdk.morphline.stdlib.EqualsBuilder
build(Config, Command, Command, MorphlineContext) - Method in class org.kitesdk.morphline.stdlib.ExtractURIComponentBuilder
build(Config, Command, Command, MorphlineContext) - Method in class org.kitesdk.morphline.stdlib.ExtractURIComponentsBuilder
build(Config, Command, Command, MorphlineContext) - Method in class org.kitesdk.morphline.stdlib.ExtractURIQueryParametersBuilder
build(Config, Command, Command, MorphlineContext) - Method in class org.kitesdk.morphline.stdlib.FindReplaceBuilder
build(Config, Command, Command, MorphlineContext) - Method in class org.kitesdk.morphline.stdlib.GenerateUUIDBuilder
build(Config, Command, Command, MorphlineContext) - Method in class org.kitesdk.morphline.stdlib.GrokBuilder
build(Config, Command, Command, MorphlineContext) - Method in class org.kitesdk.morphline.stdlib.HeadBuilder
build(Config, Command, Command, MorphlineContext) - Method in class org.kitesdk.morphline.stdlib.IfThenElseBuilder
build(Config, Command, Command, MorphlineContext) - Method in class org.kitesdk.morphline.stdlib.JavaBuilder
build(Config, Command, Command, MorphlineContext) - Method in class org.kitesdk.morphline.stdlib.LogDebugBuilder
build(Config, Command, Command, MorphlineContext) - Method in class org.kitesdk.morphline.stdlib.LogErrorBuilder
build(Config, Command, Command, MorphlineContext) - Method in class org.kitesdk.morphline.stdlib.LogInfoBuilder
build(Config, Command, Command, MorphlineContext) - Method in class org.kitesdk.morphline.stdlib.LogTraceBuilder
build(Config, Command, Command, MorphlineContext) - Method in class org.kitesdk.morphline.stdlib.LogWarnBuilder
build(Config, Command, Command, MorphlineContext) - Method in class org.kitesdk.morphline.stdlib.NotBuilder
build(Config, Command, Command, MorphlineContext) - Method in class org.kitesdk.morphline.stdlib.PipeBuilder
build(Config, Command, Command, MorphlineContext) - Method in class org.kitesdk.morphline.stdlib.RemoveFieldsBuilder
build(Config, Command, Command, MorphlineContext) - Method in class org.kitesdk.morphline.stdlib.RemoveValuesBuilder
build(Config, Command, Command, MorphlineContext) - Method in class org.kitesdk.morphline.stdlib.ReplaceValuesBuilder
build(Config, Command, Command, MorphlineContext) - Method in class org.kitesdk.morphline.stdlib.SampleBuilder
build(Config, Command, Command, MorphlineContext) - Method in class org.kitesdk.morphline.stdlib.SeparateAttachmentsBuilder
build(Config, Command, Command, MorphlineContext) - Method in class org.kitesdk.morphline.stdlib.SetValuesBuilder
build(Config, Command, Command, MorphlineContext) - Method in class org.kitesdk.morphline.stdlib.SplitBuilder
build(Config, Command, Command, MorphlineContext) - Method in class org.kitesdk.morphline.stdlib.SplitKeyValueBuilder
build(Config, Command, Command, MorphlineContext) - Method in class org.kitesdk.morphline.stdlib.StartReportingMetricsToCSVBuilder
build(Config, Command, Command, MorphlineContext) - Method in class org.kitesdk.morphline.stdlib.StartReportingMetricsToJMXBuilder
build(Config, Command, Command, MorphlineContext) - Method in class org.kitesdk.morphline.stdlib.StartReportingMetricsToSLF4JBuilder
build(Config, Command, Command, MorphlineContext) - Method in class org.kitesdk.morphline.stdlib.ToByteArrayBuilder
build(Config, Command, Command, MorphlineContext) - Method in class org.kitesdk.morphline.stdlib.ToStringBuilder
build(Config, Command, Command, MorphlineContext) - Method in class org.kitesdk.morphline.stdlib.TranslateBuilder
build(Config, Command, Command, MorphlineContext) - Method in class org.kitesdk.morphline.stdlib.TryRulesBuilder
build(Config, Command, Command, MorphlineContext) - Method in class org.kitesdk.morphline.tika.decompress.DecompressBuilder
build(Config, Command, Command, MorphlineContext) - Method in class org.kitesdk.morphline.tika.decompress.UnpackBuilder
build(Config, Command, Command, MorphlineContext) - Method in class org.kitesdk.morphline.tika.DetectMimeTypeBuilder
build(Config, Command, Command, MorphlineContext) - Method in class org.kitesdk.morphline.twitter.ReadJsonTestTweetsBuilder
build(Config, Command, Command, MorphlineContext) - Method in class org.kitesdk.morphline.useragent.UserAgentBuilder
buildCommand(Config, Command, Command) - Method in class org.kitesdk.morphline.base.AbstractCommand: Factory method to create a command rooted at the given cmdConfig.
buildCommandChain(Config, String, Command, boolean) - Method in class org.kitesdk.morphline.base.AbstractCommand: Factory method to create the chain of commands rooted at the given rootConfig.

C

CallParentPipeBuilder - Class in org.kitesdk.morphline.stdlib: Command that routes records to the enclosing pipe morphline object.
CallParentPipeBuilder() - Constructor for class org.kitesdk.morphline.stdlib.CallParentPipeBuilder
check(boolean, String, Object...) - Static method in exception org.kitesdk.data.DatasetRecordException: Precondition-style validation that throws a DatasetRecordException.
check(boolean, String, Object...) - Static method in exception org.kitesdk.data.IncompatibleSchemaException: Precondition-style validation that throws a ValidationException.
check(boolean, String, Object...) - Static method in exception org.kitesdk.data.ValidationException: Precondition-style validation that throws a ValidationException.
checkOutputSpecs(JobContext) - Method in class org.kitesdk.data.mapreduce.DatasetKeyOutputFormat
clean(boolean) - Method in class org.kitesdk.minicluster.MiniCluster.Builder
CLEAN_KEY - Static variable in class org.kitesdk.minicluster.MiniCluster
close() - Method in interface org.kitesdk.data.DatasetReader: Close the reader and release any system resources.
close() - Method in interface org.kitesdk.data.DatasetWriter: Close the writer and release any system resources.
column(String, String, String) - Method in class org.kitesdk.data.ColumnMapping.Builder: Adds a mapping to store the record field name in a column using the family and qualifier.
column(String, String, String) - Static method in class org.kitesdk.data.FieldMapping
ColumnMapping - Class in org.kitesdk.data: A descriptor for an entity's column mappings, which defines how an entity maps to a columnar store.
columnMapping(ColumnMapping) - Method in class org.kitesdk.data.DatasetDescriptor.Builder: Configure the dataset's column mapping descriptor (optional)
columnMapping(File) - Method in class org.kitesdk.data.DatasetDescriptor.Builder: Configure the dataset's column mapping descriptor from a File.
columnMapping(InputStream) - Method in class org.kitesdk.data.DatasetDescriptor.Builder: Configure the dataset's column mapping descriptor from an InputStream.
ColumnMapping.Builder - Class in org.kitesdk.data: A fluent builder to aid in constructing a ColumnMapping.
ColumnMapping.Builder() - Constructor for class org.kitesdk.data.ColumnMapping.Builder
columnMappingLiteral(String) - Method in class org.kitesdk.data.DatasetDescriptor.Builder: Configure the dataset's column mappings from a String literal.
columnMappingUri(URI) - Method in class org.kitesdk.data.DatasetDescriptor.Builder: Configure the dataset's column mappings from a URI.
columnMappingUri(String) - Method in class org.kitesdk.data.DatasetDescriptor.Builder: Configure the dataset's column mappings from a String URI.
Command - Interface in org.kitesdk.morphline.api: A command transforms a record into zero or more records.
CommandBuilder - Interface in org.kitesdk.morphline.api: Interface to create instances of morphline commands.
commitTransaction() - Method in interface org.kitesdk.morphline.solr.DocumentLoader: Sends any outstanding documents to the destination and waits for a positive or negative ack (i.e.
commitTransaction() - Method in class org.kitesdk.morphline.solr.SolrServerDocumentLoader
CompactionTask<T> - Class in org.kitesdk.tools
CompactionTask(View<T>) - Constructor for class org.kitesdk.tools.CompactionTask
compile(File, String, MorphlineContext, Command, Config...) - Method in class org.kitesdk.morphline.base.Compiler: Parses the given morphlineFile, then finds the morphline with the given morphlineId within, then compiles the morphline and returns the corresponding morphline command.
compile(Config, MorphlineContext, Command) - Method in class org.kitesdk.morphline.base.Compiler: Compiles the given morphline config using the given morphline context.
Compiler - Class in org.kitesdk.morphline.base: Tool to parse and compile a morphline file or morphline config.
Compiler() - Constructor for class org.kitesdk.morphline.base.Compiler
CompressionType - Enum in org.kitesdk.data: Contains constant definitions for the standard compression types we support.
compressionType(CompressionType) - Method in class org.kitesdk.data.DatasetDescriptor.Builder: Configure the dataset's compression format (optional).
compressionType(String) - Method in class org.kitesdk.data.DatasetDescriptor.Builder: Configure the dataset's compression format (optional).
ConcurrentSchemaModificationException - Exception in org.kitesdk.data: Exception thrown when a schema modification collides with another client trying to modify the schema of the same dataset.
ConcurrentSchemaModificationException(String) - Constructor for exception org.kitesdk.data.ConcurrentSchemaModificationException
ConcurrentSchemaModificationException(Throwable) - Constructor for exception org.kitesdk.data.ConcurrentSchemaModificationException
ConcurrentSchemaModificationException(String, Throwable) - Constructor for exception org.kitesdk.data.ConcurrentSchemaModificationException
CONFIG_KEY_FIELD - Static variable in class org.kitesdk.morphline.hadoop.sequencefile.ReadSequenceFileBuilder
CONFIG_VALUE_FIELD - Static variable in class org.kitesdk.morphline.hadoop.sequencefile.ReadSequenceFileBuilder
Configs - Class in org.kitesdk.morphline.base: Helpers to traverse and read parts of a HOCON data structure.
Configs() - Constructor for class org.kitesdk.morphline.base.Configs
configure(Job) - Static method in class org.kitesdk.data.mapreduce.DatasetKeyInputFormat: Configures the Job to use the DatasetKeyInputFormat and returns a helper to add further configuration.
configure(Configuration) - Static method in class org.kitesdk.data.mapreduce.DatasetKeyInputFormat: Adds settings to Configuration to use DatasetKeyInputFormat and returns a helper to add further configuration.
configure(Job) - Static method in class org.kitesdk.data.mapreduce.DatasetKeyOutputFormat: Configures the Job to use the DatasetKeyOutputFormat and returns a helper to add further configuration.
configure(Configuration) - Static method in class org.kitesdk.data.mapreduce.DatasetKeyOutputFormat: Returns a helper to add output options to the given Configuration.
configure(Service.ServiceConfig) - Method in class org.kitesdk.minicluster.FlumeService
configure(Service.ServiceConfig) - Method in class org.kitesdk.minicluster.HBaseService
configure(Service.ServiceConfig) - Method in class org.kitesdk.minicluster.HdfsService
configure(Service.ServiceConfig) - Method in class org.kitesdk.minicluster.HiveService
configure(Service.ServiceConfig) - Method in interface org.kitesdk.minicluster.Service: Configure this service with the ServiceConfig
configure(Service.ServiceConfig) - Method in class org.kitesdk.minicluster.ZookeeperService
configure(Job) - Static method in class org.kitesdk.tools.TaskUtil: Returns a configuration builder for the given Job.
configure(Configuration) - Static method in class org.kitesdk.tools.TaskUtil: Returns a configuration builder for the given Configuration.
contains(String) - Method in class org.kitesdk.minicluster.Service.ServiceConfig
ContainsBuilder - Class in org.kitesdk.morphline.stdlib: Command that succeeds if one of the field values of the given named field is equal to one of the the given values, and fails otherwise; Multiple fields can be named, in which case the results are ANDed.
ContainsBuilder() - Constructor for class org.kitesdk.morphline.stdlib.ContainsBuilder
containsLifecycleEvent(Record, Notifications.LifecycleEvent) - Static method in class org.kitesdk.morphline.base.Notifications: Determine whether or not the given notification contains the given lifecycle event.
context - Variable in class org.kitesdk.morphline.api.MorphlineContext.Builder
ConvertHTMLBuilder - Class in org.kitesdk.morphline.saxon: Command that converts HTML to XHTML using the TagSoup library.
ConvertHTMLBuilder() - Constructor for class org.kitesdk.morphline.saxon.ConvertHTMLBuilder
ConvertTimestampBuilder - Class in org.kitesdk.morphline.stdlib: Command that converts the timestamps in a given field from one of a set of input date formats (in an input timezone) to an output date format (in an output timezone), while respecting daylight savings time rules.
ConvertTimestampBuilder() - Constructor for class org.kitesdk.morphline.stdlib.ConvertTimestampBuilder
copy() - Method in class org.kitesdk.morphline.api.Record: Returns a shallow copy of this record.
CopyTask<E> - Class in org.kitesdk.tools
CopyTask(View<E>, View<E>) - Constructor for class org.kitesdk.tools.CopyTask
counter(String, String, String) - Method in class org.kitesdk.data.ColumnMapping.Builder: Adds a counter mapping to store record field name in a column using the family and qualifier.
counter(String, String, String) - Static method in class org.kitesdk.data.FieldMapping
create(URI, DatasetDescriptor, Class<E>) - Static method in class org.kitesdk.data.Datasets: Create a Dataset for the given dataset or view URI.
create(URI, DatasetDescriptor) - Static method in class org.kitesdk.data.Datasets: Create a Dataset for the given dataset or view URI.
create(String, DatasetDescriptor, Class<E>) - Static method in class org.kitesdk.data.Datasets: Create a Dataset for the given dataset or view URI string.
create(String, DatasetDescriptor) - Static method in class org.kitesdk.data.Datasets: Create a Dataset for the given dataset or view URI string.
create(URI, Configuration) - Method in class org.kitesdk.data.oozie.KiteLauncherURIHandler
create() - Method in class org.kitesdk.morphline.api.MorphlineContext.Builder
create(Path, FsPermission, boolean, int, short, long, Progressable) - Method in class org.kitesdk.morphline.hadoop.rcfile.SingleStreamFileSystem
create() - Method in class org.kitesdk.morphline.solr.SolrMorphlineContext.Builder
createRecordReader(InputSplit, TaskAttemptContext) - Method in class org.kitesdk.data.mapreduce.DatasetKeyInputFormat
createSolrContentHandler(Metadata, SolrParams, IndexSchema) - Method in class org.kitesdk.morphline.solrcell.StripNonCharSolrContentHandlerFactory
createSolrContentHandler(Metadata, SolrParams, IndexSchema) - Method in class org.kitesdk.morphline.solrcell.TrimSolrContentHandlerFactory
CrunchDatasets - Class in org.kitesdk.data.crunch: A helper class for exposing Datasets and Views as Crunch ReadableSources or Targets.
CrunchDatasets() - Constructor for class org.kitesdk.data.crunch.CrunchDatasets
CSV - Static variable in class org.kitesdk.data.Formats: CSV: comma-separated values (read-only).

D

DATANODE_HTTP_PORT - Static variable in class org.kitesdk.minicluster.HdfsService
DATANODE_IPC_PORT - Static variable in class org.kitesdk.minicluster.HdfsService
DATANODE_PORT - Static variable in class org.kitesdk.minicluster.HdfsService
Dataset<E> - Interface in org.kitesdk.data: A logical representation of a set of data entities.
dataset(String) - Method in class org.kitesdk.data.URIBuilder: Sets the dataset name that is used to construct the dataset URI.
DATASET_NAME_OPTION - Static variable in class org.kitesdk.data.URIBuilder
DATASET_SCHEME - Static variable in class org.kitesdk.data.URIBuilder
DatasetDescriptor - Class in org.kitesdk.data: The structural definition of a Dataset.
DatasetDescriptor(Schema, URL, Format, URI, Map<String, String>, PartitionStrategy) - Constructor for class org.kitesdk.data.DatasetDescriptor: Create an instance of this class with the supplied Schema, optional URL, Format, optional location URL, and optional PartitionStrategy.
DatasetDescriptor(Schema, URL, Format, URI, Map<String, String>, PartitionStrategy, ColumnMapping) - Constructor for class org.kitesdk.data.DatasetDescriptor: Create an instance of this class with the supplied Schema, optional URL, Format, optional location URL, optional PartitionStrategy, and optional ColumnMapping.
DatasetDescriptor(Schema, URI, Format, URI, Map<String, String>, PartitionStrategy, ColumnMapping, CompressionType) - Constructor for class org.kitesdk.data.DatasetDescriptor: Create an instance of this class with the supplied Schema, optional URL, Format, optional location URL, optional PartitionStrategy, optional ColumnMapping, and optional CompressionType.
DatasetDescriptor.Builder - Class in org.kitesdk.data: A fluent builder to aid in the construction of DatasetDescriptors.
DatasetDescriptor.Builder() - Constructor for class org.kitesdk.data.DatasetDescriptor.Builder
DatasetDescriptor.Builder(DatasetDescriptor) - Constructor for class org.kitesdk.data.DatasetDescriptor.Builder: Creates a Builder configured to copy descriptor, if it is not modified.
DatasetException - Exception in org.kitesdk.data: Exception thrown for dataset-related failures.
DatasetException() - Constructor for exception org.kitesdk.data.DatasetException
DatasetException(String) - Constructor for exception org.kitesdk.data.DatasetException
DatasetException(String, Throwable) - Constructor for exception org.kitesdk.data.DatasetException
DatasetException(Throwable) - Constructor for exception org.kitesdk.data.DatasetException
DatasetExistsException - Exception in org.kitesdk.data: Exception thrown when trying to create a dataset that already exists.
DatasetExistsException(String) - Constructor for exception org.kitesdk.data.DatasetExistsException
DatasetExistsException(String, Throwable) - Constructor for exception org.kitesdk.data.DatasetExistsException
DatasetExistsException(Throwable) - Constructor for exception org.kitesdk.data.DatasetExistsException
DatasetIOException - Exception in org.kitesdk.data: Exception thrown for dataset IO-related failures.
DatasetIOException(String, IOException) - Constructor for exception org.kitesdk.data.DatasetIOException
DatasetKeyInputFormat<E> - Class in org.kitesdk.data.mapreduce: A MapReduce InputFormat for reading from a Dataset.
DatasetKeyInputFormat() - Constructor for class org.kitesdk.data.mapreduce.DatasetKeyInputFormat
DatasetKeyInputFormat.ConfigBuilder - Class in org.kitesdk.data.mapreduce
DatasetKeyOutputFormat<E> - Class in org.kitesdk.data.mapreduce: A MapReduce OutputFormat for writing to a Dataset.
DatasetKeyOutputFormat() - Constructor for class org.kitesdk.data.mapreduce.DatasetKeyOutputFormat
DatasetKeyOutputFormat.ConfigBuilder - Class in org.kitesdk.data.mapreduce
DatasetKeyOutputFormat.WriteMode - Enum in org.kitesdk.data.mapreduce
DatasetNotFoundException - Exception in org.kitesdk.data: Exception thrown to indicate that a dataset was not found.
DatasetNotFoundException(String) - Constructor for exception org.kitesdk.data.DatasetNotFoundException
DatasetNotFoundException(String, Throwable) - Constructor for exception org.kitesdk.data.DatasetNotFoundException
DatasetNotFoundException(Throwable) - Constructor for exception org.kitesdk.data.DatasetNotFoundException
DatasetOperationException - Exception in org.kitesdk.data: DatasetException thrown when an implementation-specific step fails and prevents a dataset operation from completing successfully.
DatasetOperationException(String, Object...) - Constructor for exception org.kitesdk.data.DatasetOperationException
DatasetOperationException(Throwable, String, Object...) - Constructor for exception org.kitesdk.data.DatasetOperationException
DatasetOperationException(String, Throwable) - Constructor for exception org.kitesdk.data.DatasetOperationException
DatasetReader<E> - Interface in org.kitesdk.data: A stream-oriented dataset reader.
DatasetRecordException - Exception in org.kitesdk.data: A DatasetException that signals that an individual record has failed.
DatasetRecordException(String) - Constructor for exception org.kitesdk.data.DatasetRecordException
DatasetRecordException(String, Throwable) - Constructor for exception org.kitesdk.data.DatasetRecordException
Datasets - Class in org.kitesdk.data: Methods for working with Dataset instances.
Datasets() - Constructor for class org.kitesdk.data.Datasets
DatasetWriter<E> - Interface in org.kitesdk.data: A stream-oriented dataset writer.
dateFormat(String, String, String) - Method in class org.kitesdk.data.PartitionStrategy.Builder: Configure a partitioner that applies a custom date format to a timestamp field.
day(String, String) - Method in class org.kitesdk.data.PartitionStrategy.Builder: Configure a partitioner for extracting the day from a timestamp field.
day(String) - Method in class org.kitesdk.data.PartitionStrategy.Builder: Configure a partitioner for extracting the day from a timestamp field.
DecodeBase64Builder - Class in org.kitesdk.morphline.stdlib: Command that converts a Base64 encoded String to a byte[] per Section 6.8.
DecodeBase64Builder() - Constructor for class org.kitesdk.morphline.stdlib.DecodeBase64Builder
DecompressBuilder - Class in org.kitesdk.morphline.tika.decompress: Command that decompresses the first attachment.
DecompressBuilder() - Constructor for class org.kitesdk.morphline.tika.decompress.DecompressBuilder
delete(URI) - Static method in class org.kitesdk.data.Datasets: Delete a Dataset identified by the given dataset URI.
delete(String) - Static method in class org.kitesdk.data.Datasets: Delete a Dataset identified by the given dataset URI string.
delete(URI, Configuration) - Method in class org.kitesdk.data.oozie.KiteLauncherURIHandler
delete(Key) - Method in interface org.kitesdk.data.RandomAccessDataset: Deletes the entity in the dataset with Key key.
delete(E) - Method in interface org.kitesdk.data.RandomAccessDataset: Deletes the entity passed to this method in the dataset.
delete(Path, boolean) - Method in class org.kitesdk.morphline.hadoop.rcfile.SingleStreamFileSystem
delete(Path) - Method in class org.kitesdk.morphline.hadoop.rcfile.SingleStreamFileSystem
deleteAll() - Method in interface org.kitesdk.data.PartitionView: Deletes the entities included in this View.
deleteAll() - Method in interface org.kitesdk.data.View: Deletes the entities included in this View or throws an UnsupportedOperationException.
deleteById(String) - Method in interface org.kitesdk.morphline.solr.DocumentLoader: Deletes the document with the given id from the destination
deleteById(String) - Method in class org.kitesdk.morphline.solr.SolrServerDocumentLoader
deleteByQuery(String) - Method in interface org.kitesdk.morphline.solr.DocumentLoader: Deletes the documents matching the given query from the destination
deleteByQuery(String) - Method in class org.kitesdk.morphline.solr.SolrServerDocumentLoader
dependencies() - Method in class org.kitesdk.minicluster.FlumeService
dependencies() - Method in class org.kitesdk.minicluster.HBaseService
dependencies() - Method in class org.kitesdk.minicluster.HdfsService
dependencies() - Method in class org.kitesdk.minicluster.HiveService
dependencies() - Method in interface org.kitesdk.minicluster.Service: Get the other Service implementations this Service has as a dependency.
dependencies() - Method in class org.kitesdk.minicluster.ZookeeperService
destroy() - Method in class org.kitesdk.data.oozie.KiteURIHandler
detectCharset(Record, Charset) - Method in class org.kitesdk.morphline.stdio.AbstractParser
DetectMimeTypeBuilder - Class in org.kitesdk.morphline.tika: Command that auto-detects the MIME type of the first attachment, if no MIME type is defined yet.
DetectMimeTypeBuilder() - Constructor for class org.kitesdk.morphline.tika.DetectMimeTypeBuilder
DocumentLoader - Interface in org.kitesdk.morphline.solr: A vehicle to load (or delete) Solr documents into some kind of destination, such as a SolrServer or MapReduce RecordWriter; This class should be considered private and it's API is subject to change without notice.
doNotify(Record) - Method in class org.kitesdk.morphline.base.AbstractCommand: Processes the given notification on the control plane of the subtree rooted at this command.
doProcess(Record) - Method in class org.kitesdk.morphline.base.AbstractCommand: Processes the given record on the data plane of this command.
doProcess(Record) - Method in class org.kitesdk.morphline.stdio.AbstractParser
doProcess(Record, InputStream) - Method in class org.kitesdk.morphline.stdio.AbstractParser
doProcess(Record) - Method in class org.kitesdk.morphline.stdlib.AbstractFieldTransformCommand
DownloadHdfsFileBuilder - Class in org.kitesdk.morphline.hadoop.core: Command for transferring HDFS files, for example to help with centralized configuration file management.
DownloadHdfsFileBuilder() - Constructor for class org.kitesdk.morphline.hadoop.core.DownloadHdfsFileBuilder
DropRecordBuilder - Class in org.kitesdk.morphline.stdlib: Command that silently consumes records without ever emitting any record - think /dev/null.
DropRecordBuilder() - Constructor for class org.kitesdk.morphline.stdlib.DropRecordBuilder
DRY_RUN_SETTING_NAME - Static variable in class org.kitesdk.morphline.api.TypedSettings

E

ELAPSED_TIME - Static variable in class org.kitesdk.morphline.base.Metrics
equals(Object) - Method in class org.kitesdk.data.ColumnMapping
equals(Object) - Method in class org.kitesdk.data.DatasetDescriptor
equals(Object) - Method in class org.kitesdk.data.FieldMapping
equals(Object) - Method in class org.kitesdk.data.Format
equals(Object) - Method in class org.kitesdk.data.Key
equals(Object) - Method in class org.kitesdk.data.PartitionStrategy
equals(Object) - Method in class org.kitesdk.morphline.api.Record
EqualsBuilder - Class in org.kitesdk.morphline.stdlib: Command that succeeds if all field values of the given named fields are equal to the the given values, and fails otherwise.
EqualsBuilder() - Constructor for class org.kitesdk.morphline.stdlib.EqualsBuilder
evaluate(Record) - Method in class org.kitesdk.morphline.base.FieldExpression: Returns the values of a Record referred to by the given field expression
evaluate(Object...) - Method in class org.kitesdk.morphline.scriptengine.java.ScriptEvaluator
ExceptionHandler - Interface in org.kitesdk.morphline.api: Morphline-wide default handler that commands can choose to use to handle exceptions.
exists(URI) - Static method in class org.kitesdk.data.Datasets: Check whether a Dataset identified by the given URI exists.
exists(String) - Static method in class org.kitesdk.data.Datasets: Check whether a Dataset identified by the given URI string exists.
exists(URI, URIHandler.Context) - Method in class org.kitesdk.data.oozie.KiteURIHandler
exists(URI, Configuration, String) - Method in class org.kitesdk.data.oozie.KiteURIHandler
ExtractAvroPathsBuilder - Class in org.kitesdk.morphline.avro: Command that uses zero or more avro path expressions to extract values from an Avro object.
ExtractAvroPathsBuilder() - Constructor for class org.kitesdk.morphline.avro.ExtractAvroPathsBuilder
ExtractAvroTreeBuilder - Class in org.kitesdk.morphline.avro: Command that converts an attached Avro datum to a morphline record by recursively walking the Avro tree and extracting all data into a single morphline record, with fields named by their path in the Avro tree.
ExtractAvroTreeBuilder() - Constructor for class org.kitesdk.morphline.avro.ExtractAvroTreeBuilder
ExtractJsonPathsBuilder - Class in org.kitesdk.morphline.json: Command that uses zero or more JSON path expressions to extract values from a JSON object.
ExtractJsonPathsBuilder() - Constructor for class org.kitesdk.morphline.json.ExtractJsonPathsBuilder
ExtractProtobufPathsBuilder - Class in org.kitesdk.morphline.protobuf: Command that uses zero or more protocol buffer path expressions to extract values from a protocol buffer object.
ExtractProtobufPathsBuilder() - Constructor for class org.kitesdk.morphline.protobuf.ExtractProtobufPathsBuilder
ExtractURIComponentBuilder - Class in org.kitesdk.morphline.stdlib: A command that extracts a subcomponent from the URIs contained in the given input field and appends it to the given output fields.
ExtractURIComponentBuilder() - Constructor for class org.kitesdk.morphline.stdlib.ExtractURIComponentBuilder
ExtractURIComponentsBuilder - Class in org.kitesdk.morphline.stdlib: A command that extracts subcomponents from the URIs contained in the given input field and appends them to output fields with the given prefix, namely scheme, authority, host, port, path, query, fragment, schemeSpecificPart, userInfo.
ExtractURIComponentsBuilder() - Constructor for class org.kitesdk.morphline.stdlib.ExtractURIComponentsBuilder
ExtractURIQueryParametersBuilder - Class in org.kitesdk.morphline.stdlib: A command that extracts the query parameters with a given name from the URIs contained in the given input field and appends them to the given output field.
ExtractURIQueryParametersBuilder() - Constructor for class org.kitesdk.morphline.stdlib.ExtractURIQueryParametersBuilder

F

FaultTolerance - Class in org.kitesdk.morphline.base: Mission critical, large-scale online production systems need to make progress without downtime despite some issues.
FaultTolerance(boolean, boolean) - Constructor for class org.kitesdk.morphline.base.FaultTolerance
FaultTolerance(boolean, boolean, String) - Constructor for class org.kitesdk.morphline.base.FaultTolerance
FIELD_NAME - Static variable in class org.kitesdk.morphline.stdlib.AddCurrentTimeBuilder
FIELD_NAME - Static variable in class org.kitesdk.morphline.stdlib.AddLocalHostBuilder
FIELD_NAME - Static variable in class org.kitesdk.morphline.stdlib.GenerateUUIDBuilder
FieldExpression - Class in org.kitesdk.morphline.base: Helper to fetch the values of a field of a Record referred to by a field expression, which is a String of the form @{fieldname}.
FieldExpression(String, Config) - Constructor for class org.kitesdk.morphline.base.FieldExpression
fieldMapping(FieldMapping) - Method in class org.kitesdk.data.ColumnMapping.Builder: Adds a FieldMapping.
FieldMapping - Class in org.kitesdk.data: Represents how to store a Schema field.
FieldMapping.MappingType - Enum in org.kitesdk.data: The supported Mapping Types, which control how an entity field maps to columns in an HBase table.
fieldMappings(Collection<FieldMapping>) - Method in class org.kitesdk.data.ColumnMapping.Builder: Adds each FieldMapping from a collection.
Fields - Class in org.kitesdk.morphline.base: Common record field names.
Fields() - Constructor for class org.kitesdk.morphline.base.Fields
FILE_UPLOAD_URL - Static variable in class org.kitesdk.morphline.hadoop.parquet.avro.ReadAvroParquetFileBuilder: The morphline record field containing the HDFS Path of the Parquet file to read
find(String, Config, String) - Method in class org.kitesdk.morphline.base.Compiler: Finds the given morphline id within the given morphline config, using the given nameForErrorMsg for error reporting.
FindReplaceBuilder - Class in org.kitesdk.morphline.stdlib: Command that examines each string value in a given field and replaces each substring of the string value that matches the given string literal or grok pattern with the given replacement.
FindReplaceBuilder() - Constructor for class org.kitesdk.morphline.stdlib.FindReplaceBuilder
fixedSizeRange(String, long) - Method in class org.kitesdk.data.PartitionStrategy.Builder: Configure a range partitioner with fixed-size ranges.
fixedSizeRange(String, String, long) - Method in class org.kitesdk.data.PartitionStrategy.Builder: Configure a range partitioner with fixed-size ranges.
FLUME_AGENT_NAME - Static variable in class org.kitesdk.minicluster.MiniCluster
FLUME_CONFIGURATION - Static variable in class org.kitesdk.minicluster.MiniCluster
flumeAgentName(String) - Method in class org.kitesdk.minicluster.MiniCluster.Builder
flumeConfiguration(String) - Method in class org.kitesdk.minicluster.MiniCluster.Builder
FlumeService - Class in org.kitesdk.minicluster
FlumeService() - Constructor for class org.kitesdk.minicluster.FlumeService
flush() - Method in interface org.kitesdk.data.Flushable: Ensure that data has been flushed to OS buffers on all replica data nodes.
Flushable - Interface in org.kitesdk.data: A writer that can guarantee data is present on data nodes.
format(Format) - Method in class org.kitesdk.data.DatasetDescriptor.Builder: Configure the dataset's format (optional).
format(String) - Method in class org.kitesdk.data.DatasetDescriptor.Builder: Configure the dataset's format from a format name String (optional).
format(String, Object...) - Static method in exception org.kitesdk.data.DatasetException
Format - Class in org.kitesdk.data: The data format used for encoding the data in a Dataset.
Formats - Class in org.kitesdk.data: Contains constant definitions for the standard Format instances supported by the library.
forName(String) - Static method in enum org.kitesdk.data.CompressionType: Return a CompressionType for the compression type name specified.
from(String, Comparable) - Method in interface org.kitesdk.data.RefinableView: Creates a sub-View, restricted to entities whose name field is greater than or equal to the given value.
fromAfter(String, Comparable) - Method in interface org.kitesdk.data.RefinableView: Creates a sub-View, restricted to entities whose name field is greater than the given value.
fromString(String) - Static method in class org.kitesdk.data.Formats: Return a Format for the format name specified.

G

GenerateSolrSequenceKeyBuilder - Class in org.kitesdk.morphline.solr: A command that assigns a record unique key that is the concatenation of the given baseIdField record field, followed by a running count of the record number within the current session.
GenerateSolrSequenceKeyBuilder() - Constructor for class org.kitesdk.morphline.solr.GenerateSolrSequenceKeyBuilder
GenerateUUIDBuilder - Class in org.kitesdk.morphline.stdlib: A command that sets a universally unique identifier on all records that are intercepted.
GenerateUUIDBuilder() - Constructor for class org.kitesdk.morphline.stdlib.GenerateUUIDBuilder
GeoIPBuilder - Class in org.kitesdk.morphline.maxmind: Command that returns Geolocation information for a given IP address, using an efficient in-memory Maxmind database lookup.
GeoIPBuilder() - Constructor for class org.kitesdk.morphline.maxmind.GeoIPBuilder
get(int) - Method in class org.kitesdk.data.Key: Returns the value for index.
get(Key) - Method in interface org.kitesdk.data.RandomAccessDataset: Return the entity stored in the dataset at the row specified with Key key.
get(String) - Method in class org.kitesdk.minicluster.Service.ServiceConfig
get(String) - Method in class org.kitesdk.morphline.api.Record: Returns a view of the values associated with the given key.
getBatchSize() - Method in class org.kitesdk.morphline.solr.SolrLocator
getBoolean(String, boolean) - Method in class org.kitesdk.morphline.api.TypedSettings
getBoolean(Config, String, boolean) - Method in class org.kitesdk.morphline.base.Configs
getBoolean(Config, String) - Method in class org.kitesdk.morphline.base.Configs
getCardinality() - Method in class org.kitesdk.data.PartitionStrategy: Return the cardinality produced by the contained field partitioners.
getCharset(Config, String, Charset) - Method in class org.kitesdk.morphline.base.Configs
getChild() - Method in class org.kitesdk.morphline.base.AbstractCommand: Returns the child of this command.
getClassesForLauncher() - Method in class org.kitesdk.data.oozie.KiteLauncherURIHandler
getClassesForLauncher() - Method in class org.kitesdk.data.oozie.KiteURIHandler
getCollectionName() - Method in class org.kitesdk.morphline.solr.SolrLocator
getColumnMapping() - Method in class org.kitesdk.data.DatasetDescriptor: Get the ColumnMapping.
getCommandBuilder(String) - Method in class org.kitesdk.morphline.api.MorphlineContext
getCompressionType() - Method in class org.kitesdk.data.DatasetDescriptor: Get the CompressionType
getConf() - Method in class org.kitesdk.data.mapreduce.DatasetKeyInputFormat
getConf() - Method in class org.kitesdk.tools.CompactionTask
getConfig() - Method in class org.kitesdk.morphline.base.AbstractCommand: Returns the JSON configuration of this command.
getConfig(Config, String, Config) - Method in class org.kitesdk.morphline.base.Configs
getConfig(Config, String) - Method in class org.kitesdk.morphline.base.Configs
getConfigList(Config, String, List<? extends Config>) - Method in class org.kitesdk.morphline.base.Configs
getConfigList(Config, String) - Method in class org.kitesdk.morphline.base.Configs
getConfigs() - Method in class org.kitesdk.morphline.base.AbstractCommand: Returns a helper for convenient access to the JSON configuration of this command.
getContext(URI, Configuration, String) - Method in class org.kitesdk.data.oozie.KiteURIHandler
getContext() - Method in class org.kitesdk.morphline.base.AbstractCommand: Returns the context of this command.
getCount() - Method in class org.kitesdk.tools.CompactionTask
getCount() - Method in class org.kitesdk.tools.TransformTask
getCounter(String...) - Method in class org.kitesdk.morphline.base.AbstractCommand: Returns a counter for maintaining main-memory metrics.
getCoveringPartitions() - Method in interface org.kitesdk.data.View: Returns an Iterable of non-overlapping View objects that partition the underlying Dataset and cover this View.
getDataset() - Method in interface org.kitesdk.data.View: Returns the underlying Dataset for the View.
getDefaultCompressionType() - Method in class org.kitesdk.data.Format: Get the default CompressionType supported by this Format.
getDependencyType(URI) - Method in class org.kitesdk.data.oozie.KiteURIHandler
getDescriptor() - Method in interface org.kitesdk.data.Dataset: Get the DatasetDescriptor associated with this dataset.
getDocumentLoader() - Method in class org.kitesdk.morphline.solr.SolrMorphlineContext
getDouble(String, double) - Method in class org.kitesdk.morphline.api.TypedSettings
getDouble(Config, String, double) - Method in class org.kitesdk.morphline.base.Configs
getDouble(Config, String) - Method in class org.kitesdk.morphline.base.Configs
getEntrySet(Config) - Method in class org.kitesdk.morphline.base.Configs
getExceptionHandler() - Method in class org.kitesdk.morphline.api.MorphlineContext
getExtension() - Method in class org.kitesdk.data.Format: Get the extension for use in filenames.
getFamily() - Method in class org.kitesdk.data.FieldMapping
getFamilyAsString() - Method in class org.kitesdk.data.FieldMapping
getFieldMapping(String) - Method in class org.kitesdk.data.ColumnMapping
getFieldMappings() - Method in class org.kitesdk.data.ColumnMapping
getFieldName() - Method in class org.kitesdk.data.FieldMapping
getFields() - Method in class org.kitesdk.morphline.api.Record: Returns the fields that are stored in this record.
getFileStatus(Path) - Method in class org.kitesdk.morphline.hadoop.rcfile.SingleStreamFileSystem
getFirstValue(String) - Method in class org.kitesdk.morphline.api.Record: Returns the first value associated with the given key, or null if no such value exists
getFloat(String, float) - Method in class org.kitesdk.morphline.api.TypedSettings
getFormat() - Method in class org.kitesdk.data.DatasetDescriptor: Get the associated Format the data is stored in.
getHadoopConf() - Method in class org.kitesdk.minicluster.FlumeService
getHadoopConf() - Method in class org.kitesdk.minicluster.HBaseService
getHadoopConf() - Method in class org.kitesdk.minicluster.HdfsService
getHadoopConf() - Method in class org.kitesdk.minicluster.HiveService
getHadoopConf() - Method in interface org.kitesdk.minicluster.Service: Get the Hadoop configuration object for this service.
getHadoopConf() - Method in class org.kitesdk.minicluster.Service.ServiceConfig
getHadoopConf() - Method in class org.kitesdk.minicluster.ZookeeperService
getHealthCheckRegistry() - Method in class org.kitesdk.morphline.api.MorphlineContext
getHistogram(String...) - Method in class org.kitesdk.morphline.base.AbstractCommand: Returns a histogram for maintaining main-memory metrics.
getIndexSchema() - Method in class org.kitesdk.morphline.solr.SolrLocator
getIndexSchema() - Method in class org.kitesdk.morphline.solr.SolrMorphlineContext
getInt(String, int) - Method in class org.kitesdk.morphline.api.TypedSettings
getInt(Config, String, int) - Method in class org.kitesdk.morphline.base.Configs
getInt(Config, String) - Method in class org.kitesdk.morphline.base.Configs
getIOException() - Method in exception org.kitesdk.data.DatasetIOException
getLauncherURIHandlerClass() - Method in class org.kitesdk.data.oozie.KiteURIHandler
getLifecycleEvents(Record) - Static method in class org.kitesdk.morphline.base.Notifications: Get all lifecycle events from the given record.
getLoader() - Method in class org.kitesdk.morphline.solr.SolrLocator
getLocale(Config, String, Locale) - Method in class org.kitesdk.morphline.base.Configs
getLocale(Config, String) - Method in class org.kitesdk.morphline.base.Configs
getLocation() - Method in class org.kitesdk.data.DatasetDescriptor: Get the URL location where the data for this Dataset is stored (optional).
getLocation() - Method in interface org.kitesdk.data.PartitionView: Returns the location of this partition as a URI.
getLong(String, int) - Method in class org.kitesdk.morphline.api.TypedSettings
getLong(Config, String, long) - Method in class org.kitesdk.morphline.base.Configs
getLong(Config, String) - Method in class org.kitesdk.morphline.base.Configs
getMappingType() - Method in class org.kitesdk.data.FieldMapping
getMeter(String...) - Method in class org.kitesdk.morphline.base.AbstractCommand: Returns a meter for maintaining main-memory metrics.
getMetricRegistry() - Method in class org.kitesdk.morphline.api.MorphlineContext
getName() - Method in enum org.kitesdk.data.CompressionType: Get the String name for this compression type.
getName() - Method in interface org.kitesdk.data.Dataset: Get the name of a Dataset.
getName() - Method in class org.kitesdk.data.Format: Get the format's name.
getNames() - Method in interface org.kitesdk.morphline.api.CommandBuilder: Returns the names with which this command can be invoked.
getNames() - Method in class org.kitesdk.morphline.avro.ExtractAvroPathsBuilder
getNames() - Method in class org.kitesdk.morphline.avro.ExtractAvroTreeBuilder
getNames() - Method in class org.kitesdk.morphline.avro.ReadAvroBuilder
getNames() - Method in class org.kitesdk.morphline.avro.ReadAvroContainerBuilder
getNames() - Method in class org.kitesdk.morphline.avro.ToAvroBuilder
getNames() - Method in class org.kitesdk.morphline.avro.ToAvroMapBuilder
getNames() - Method in class org.kitesdk.morphline.avro.WriteAvroToByteArrayBuilder
getNames() - Method in class org.kitesdk.morphline.hadoop.core.DownloadHdfsFileBuilder
getNames() - Method in class org.kitesdk.morphline.hadoop.core.OpenHdfsFileBuilder
getNames() - Method in class org.kitesdk.morphline.hadoop.parquet.avro.ReadAvroParquetFileBuilder
getNames() - Method in class org.kitesdk.morphline.hadoop.rcfile.ReadRCFileBuilder
getNames() - Method in class org.kitesdk.morphline.hadoop.sequencefile.ReadSequenceFileBuilder
getNames() - Method in class org.kitesdk.morphline.json.ExtractJsonPathsBuilder
getNames() - Method in class org.kitesdk.morphline.json.ReadJsonBuilder
getNames() - Method in class org.kitesdk.morphline.maxmind.GeoIPBuilder
getNames() - Method in class org.kitesdk.morphline.metrics.servlets.RegisterJVMMetricsBuilder
getNames() - Method in class org.kitesdk.morphline.metrics.servlets.StartReportingMetricsToHTTPBuilder
getNames() - Method in class org.kitesdk.morphline.protobuf.ExtractProtobufPathsBuilder
getNames() - Method in class org.kitesdk.morphline.protobuf.ReadProtobufBuilder
getNames() - Method in class org.kitesdk.morphline.saxon.ConvertHTMLBuilder
getNames() - Method in class org.kitesdk.morphline.saxon.XQueryBuilder
getNames() - Method in class org.kitesdk.morphline.saxon.XSLTBuilder
getNames() - Method in class org.kitesdk.morphline.solr.GenerateSolrSequenceKeyBuilder
getNames() - Method in class org.kitesdk.morphline.solr.LoadSolrBuilder
getNames() - Method in class org.kitesdk.morphline.solr.SanitizeUnknownSolrFieldsBuilder
getNames() - Method in class org.kitesdk.morphline.solr.TokenizeTextBuilder
getNames() - Method in class org.kitesdk.morphline.solrcell.SolrCellBuilder
getNames() - Method in class org.kitesdk.morphline.stdio.ReadBlobBuilder
getNames() - Method in class org.kitesdk.morphline.stdio.ReadClobBuilder
getNames() - Method in class org.kitesdk.morphline.stdio.ReadCSVBuilder
getNames() - Method in class org.kitesdk.morphline.stdio.ReadLineBuilder
getNames() - Method in class org.kitesdk.morphline.stdio.ReadMultiLineBuilder
getNames() - Method in class org.kitesdk.morphline.stdlib.AddCurrentTimeBuilder
getNames() - Method in class org.kitesdk.morphline.stdlib.AddLocalHostBuilder
getNames() - Method in class org.kitesdk.morphline.stdlib.AddValuesBuilder
getNames() - Method in class org.kitesdk.morphline.stdlib.AddValuesIfAbsentBuilder
getNames() - Method in class org.kitesdk.morphline.stdlib.CallParentPipeBuilder
getNames() - Method in class org.kitesdk.morphline.stdlib.ContainsBuilder
getNames() - Method in class org.kitesdk.morphline.stdlib.ConvertTimestampBuilder
getNames() - Method in class org.kitesdk.morphline.stdlib.DecodeBase64Builder
getNames() - Method in class org.kitesdk.morphline.stdlib.DropRecordBuilder
getNames() - Method in class org.kitesdk.morphline.stdlib.EqualsBuilder
getNames() - Method in class org.kitesdk.morphline.stdlib.ExtractURIComponentBuilder
getNames() - Method in class org.kitesdk.morphline.stdlib.ExtractURIComponentsBuilder
getNames() - Method in class org.kitesdk.morphline.stdlib.ExtractURIQueryParametersBuilder
getNames() - Method in class org.kitesdk.morphline.stdlib.FindReplaceBuilder
getNames() - Method in class org.kitesdk.morphline.stdlib.GenerateUUIDBuilder
getNames() - Method in class org.kitesdk.morphline.stdlib.GrokBuilder
getNames() - Method in class org.kitesdk.morphline.stdlib.HeadBuilder
getNames() - Method in class org.kitesdk.morphline.stdlib.IfThenElseBuilder
getNames() - Method in class org.kitesdk.morphline.stdlib.JavaBuilder
getNames() - Method in class org.kitesdk.morphline.stdlib.LogDebugBuilder
getNames() - Method in class org.kitesdk.morphline.stdlib.LogErrorBuilder
getNames() - Method in class org.kitesdk.morphline.stdlib.LogInfoBuilder
getNames() - Method in class org.kitesdk.morphline.stdlib.LogTraceBuilder
getNames() - Method in class org.kitesdk.morphline.stdlib.LogWarnBuilder
getNames() - Method in class org.kitesdk.morphline.stdlib.NotBuilder
getNames() - Method in class org.kitesdk.morphline.stdlib.PipeBuilder
getNames() - Method in class org.kitesdk.morphline.stdlib.RemoveFieldsBuilder
getNames() - Method in class org.kitesdk.morphline.stdlib.RemoveValuesBuilder
getNames() - Method in class org.kitesdk.morphline.stdlib.ReplaceValuesBuilder
getNames() - Method in class org.kitesdk.morphline.stdlib.SampleBuilder
getNames() - Method in class org.kitesdk.morphline.stdlib.SeparateAttachmentsBuilder
getNames() - Method in class org.kitesdk.morphline.stdlib.SetValuesBuilder
getNames() - Method in class org.kitesdk.morphline.stdlib.SplitBuilder
getNames() - Method in class org.kitesdk.morphline.stdlib.SplitKeyValueBuilder
getNames() - Method in class org.kitesdk.morphline.stdlib.StartReportingMetricsToCSVBuilder
getNames() - Method in class org.kitesdk.morphline.stdlib.StartReportingMetricsToJMXBuilder
getNames() - Method in class org.kitesdk.morphline.stdlib.StartReportingMetricsToSLF4JBuilder
getNames() - Method in class org.kitesdk.morphline.stdlib.ToByteArrayBuilder
getNames() - Method in class org.kitesdk.morphline.stdlib.ToStringBuilder
getNames() - Method in class org.kitesdk.morphline.stdlib.TranslateBuilder
getNames() - Method in class org.kitesdk.morphline.stdlib.TryRulesBuilder
getNames() - Method in class org.kitesdk.morphline.tika.decompress.DecompressBuilder
getNames() - Method in class org.kitesdk.morphline.tika.decompress.UnpackBuilder
getNames() - Method in class org.kitesdk.morphline.tika.DetectMimeTypeBuilder
getNames() - Method in class org.kitesdk.morphline.twitter.ReadJsonTestTweetsBuilder
getNames() - Method in class org.kitesdk.morphline.useragent.UserAgentBuilder
getNamespace() - Method in interface org.kitesdk.data.Dataset: Get the namespace that contains this Dataset.
getNanoseconds(Config, String, long) - Method in class org.kitesdk.morphline.base.Configs
getNanoseconds(Config, String) - Method in class org.kitesdk.morphline.base.Configs
getObject(String, Object) - Method in class org.kitesdk.morphline.api.TypedSettings
getOutputCommitter(TaskAttemptContext) - Method in class org.kitesdk.data.mapreduce.DatasetKeyOutputFormat
getParent() - Method in interface org.kitesdk.morphline.api.Command: Returns the parent of this command.
getParent() - Method in class org.kitesdk.morphline.base.AbstractCommand
getPartitionStrategy() - Method in class org.kitesdk.data.DatasetDescriptor: Get the PartitionStrategy, if this dataset is partitioned.
getPrefix() - Method in class org.kitesdk.data.FieldMapping
getProperty(String) - Method in class org.kitesdk.data.DatasetDescriptor: Get a named property.
getQualifier() - Method in class org.kitesdk.data.FieldMapping
getQualifierAsString() - Method in class org.kitesdk.data.FieldMapping
getRecordWriter(TaskAttemptContext) - Method in class org.kitesdk.data.mapreduce.DatasetKeyOutputFormat
getRequiredColumnFamilies() - Method in class org.kitesdk.data.ColumnMapping: Get the column families required by this schema.
getRequiredColumns() - Method in class org.kitesdk.data.ColumnMapping: Get the columns required by this schema.
getSchema() - Method in class org.kitesdk.data.DatasetDescriptor: Get the associated Schema.
getSchema() - Method in interface org.kitesdk.data.View: Get the schema of entities contained in this View.
getSchemaUrl() - Method in class org.kitesdk.data.DatasetDescriptor: Get a URL from which the Schema can be retrieved (optional).
getServerUrl() - Method in class org.kitesdk.morphline.solr.SolrLocator
getSettings() - Method in class org.kitesdk.morphline.api.MorphlineContext
getSolrHomeDir() - Method in class org.kitesdk.morphline.solr.SolrLocator
getSolrServer() - Method in class org.kitesdk.morphline.solr.SolrLocator
getSolrServer() - Method in class org.kitesdk.morphline.solr.SolrServerDocumentLoader
getSplits(JobContext) - Method in class org.kitesdk.data.mapreduce.DatasetKeyInputFormat
getString(String, String) - Method in class org.kitesdk.morphline.api.TypedSettings
getString(Config, String, String) - Method in class org.kitesdk.morphline.base.Configs
getString(Config, String) - Method in class org.kitesdk.morphline.base.Configs
getStringList(Config, String, List<String>) - Method in class org.kitesdk.morphline.base.Configs
getStringList(Config, String) - Method in class org.kitesdk.morphline.base.Configs
getSupportedCompressionTypes() - Method in class org.kitesdk.data.Format: Get the CompressionTypes supported by this Format.
getSupportedSchemes() - Method in class org.kitesdk.data.oozie.KiteURIHandler
getTimer(String...) - Method in class org.kitesdk.morphline.base.AbstractCommand: Returns a timer for maintaining main-memory metrics.
getTimeUnit(Config, String, TimeUnit) - Method in class org.kitesdk.morphline.base.Configs
getTimeUnit(Config, String) - Method in class org.kitesdk.morphline.base.Configs
getTimeUnit(String) - Method in class org.kitesdk.morphline.base.Configs
getType() - Method in interface org.kitesdk.data.View: Get the runtime type of entities contained in this View.
getTypedSettings() - Method in class org.kitesdk.morphline.api.MorphlineContext
getUri() - Method in interface org.kitesdk.data.Dataset: Return a URI for this Dataset.
getUri() - Method in interface org.kitesdk.data.View: Get a URI that identifies this View.
getUri() - Method in class org.kitesdk.morphline.hadoop.rcfile.SingleStreamFileSystem
getURIWithDoneFlag(String, String) - Method in class org.kitesdk.data.oozie.KiteURIHandler
getWorkingDirectory() - Method in class org.kitesdk.morphline.hadoop.rcfile.SingleStreamFileSystem
getZkHost() - Method in class org.kitesdk.morphline.solr.SolrLocator
GrokBuilder - Class in org.kitesdk.morphline.stdlib: The Grok command uses regular expression pattern matching to extract structured fields from unstructured log data.
GrokBuilder() - Constructor for class org.kitesdk.morphline.stdlib.GrokBuilder

H

hadoopConf(Configuration) - Method in class org.kitesdk.minicluster.MiniCluster.Builder
handleException(Throwable, Record) - Method in interface org.kitesdk.morphline.api.ExceptionHandler: Handle the given exception resulting from the given input record (the record can be null)
handleException(Throwable, Record) - Method in class org.kitesdk.morphline.base.FaultTolerance
hash(String, int) - Method in class org.kitesdk.data.PartitionStrategy.Builder: Configure a hash partitioner with the specified number of buckets.
hash(String, String, int) - Method in class org.kitesdk.data.PartitionStrategy.Builder: Configure a hash partitioner with the specified number of buckets.
hashCode() - Method in class org.kitesdk.data.ColumnMapping
hashCode() - Method in class org.kitesdk.data.DatasetDescriptor
hashCode() - Method in class org.kitesdk.data.FieldMapping
hashCode() - Method in class org.kitesdk.data.Format
hashCode() - Method in class org.kitesdk.data.Key
hashCode() - Method in class org.kitesdk.data.PartitionStrategy
hashCode() - Method in class org.kitesdk.morphline.api.Record
hasNext() - Method in interface org.kitesdk.data.DatasetReader: Tests the reader to see if additional entities can be read.
hasProperty(String) - Method in class org.kitesdk.data.DatasetDescriptor: Check if a named property exists.
HBaseService - Class in org.kitesdk.minicluster: An HBase minicluster service implementation.
HBaseService() - Constructor for class org.kitesdk.minicluster.HBaseService
HdfsService - Class in org.kitesdk.minicluster: An HDFS minicluster service implementation.
HdfsService() - Constructor for class org.kitesdk.minicluster.HdfsService
HeadBuilder - Class in org.kitesdk.morphline.stdlib: Command that ignores all input records beyond the N-th record, thus emitting at most N records, akin to the Unix head command.
HeadBuilder() - Constructor for class org.kitesdk.morphline.stdlib.HeadBuilder
HIVE_METASTORE_PORT - Static variable in class org.kitesdk.minicluster.MiniCluster
HIVE_SERVER_PORT - Static variable in class org.kitesdk.minicluster.MiniCluster
hiveMetastorePort(int) - Method in class org.kitesdk.minicluster.MiniCluster.Builder
hiveServerPort(int) - Method in class org.kitesdk.minicluster.MiniCluster.Builder
HiveService - Class in org.kitesdk.minicluster
HiveService() - Constructor for class org.kitesdk.minicluster.HiveService
hour(String, String) - Method in class org.kitesdk.data.PartitionStrategy.Builder: Configure a partitioner for extracting the hour from a timestamp field.
hour(String) - Method in class org.kitesdk.data.PartitionStrategy.Builder: Configure a partitioner for extracting the hour from a timestamp field.

I

ID - Static variable in class org.kitesdk.morphline.base.Fields
identity(String) - Method in class org.kitesdk.data.PartitionStrategy.Builder: Configure an identity partitioner.
identity(String, String) - Method in class org.kitesdk.data.PartitionStrategy.Builder: Configure an identity partitioner.
identity(String, int) - Method in class org.kitesdk.data.PartitionStrategy.Builder: Configure an identity partitioner with a cardinality hint of cardinalityHint.
identity(String, String, int) - Method in class org.kitesdk.data.PartitionStrategy.Builder: Configure an identity partitioner with a cardinality hint of cardinalityHint.
IfThenElseBuilder - Class in org.kitesdk.morphline.stdlib: An If-Then-Else command consists of a chain of zero or more conditions commands, as well as a chain of zero or or more commands that are processed if all conditions succeed ("then commands"), as well as a chain of zero or more commands that are processed if one of the conditions fails ("else commands").
IfThenElseBuilder() - Constructor for class org.kitesdk.morphline.stdlib.IfThenElseBuilder
importCommandBuilders(Collection<String>) - Method in class org.kitesdk.morphline.api.MorphlineContext
includes(E) - Method in interface org.kitesdk.data.View: Returns whether an entity Object would be included in this View if it were present in the Dataset.
IncompatibleSchemaException - Exception in org.kitesdk.data: Exception thrown when a schema update is not compatible with the previous schema (or schemas) or with existing datasets (if shared storage is used, for example).
IncompatibleSchemaException(String) - Constructor for exception org.kitesdk.data.IncompatibleSchemaException
IncompatibleSchemaException(String, Throwable) - Constructor for exception org.kitesdk.data.IncompatibleSchemaException
IncompatibleSchemaException(Throwable) - Constructor for exception org.kitesdk.data.IncompatibleSchemaException
increment(Key, String, long) - Method in interface org.kitesdk.data.RandomAccessDataset: Increment a field named fieldName on the entity by the specified amount.
incrementNumRecords() - Method in class org.kitesdk.morphline.stdio.AbstractParser
init(Configuration) - Method in class org.kitesdk.data.oozie.KiteURIHandler
INPUTFORMAT - Static variable in class org.kitesdk.data.Formats: INPUTFORMAT: a mapreduce InputFormat (read-only).
IS_IGNORING_RECOVERABLE_EXCEPTIONS - Static variable in class org.kitesdk.morphline.base.FaultTolerance
IS_PRODUCTION_MODE - Static variable in class org.kitesdk.morphline.base.FaultTolerance
isColumnMapped() - Method in class org.kitesdk.data.DatasetDescriptor: Returns true if an associated dataset is column mapped (that is, has an associated ColumnMapping), false otherwise.
isEmpty() - Method in interface org.kitesdk.data.View: Check whether this View contains any records.
isMeasuringMetrics() - Method in class org.kitesdk.morphline.base.AbstractCommand: Returns whether or not metrics should be measured.
isOpen() - Method in interface org.kitesdk.data.DatasetReader
isOpen() - Method in interface org.kitesdk.data.DatasetWriter
isPartitioned() - Method in class org.kitesdk.data.DatasetDescriptor: Returns true if an associated dataset is partitioned (that is, has an associated PartitionStrategy), false otherwise.
isReady() - Method in interface org.kitesdk.data.Signalable: Returns true if the view's data is ready for consumption.

J

JavaBuilder - Class in org.kitesdk.morphline.stdlib: The "java" command compiles the given Java code block, wrapped into a Java method with a boolean return type and several parameters, along with a Java class definition that contains the given import statements.
JavaBuilder() - Constructor for class org.kitesdk.morphline.stdlib.JavaBuilder
JobClasspathHelper - Class in org.kitesdk.tools: This class is an helper to copy the jars needed by the job in the Distributed cache.
JobClasspathHelper() - Constructor for class org.kitesdk.tools.JobClasspathHelper
JSON - Static variable in class org.kitesdk.data.Formats: JSON: white-space separated json values (read-only).

K

key(String) - Method in class org.kitesdk.data.ColumnMapping.Builder: Adds a mapping to store the record field name in the record key.
key(String) - Static method in class org.kitesdk.data.FieldMapping
Key - Class in org.kitesdk.data: A key for retrieving entities from a RandomAccessDataset.
Key.Builder - Class in org.kitesdk.data: A fluent builder to aid in the construction of Key objects.
Key.Builder(RandomAccessDataset) - Constructor for class org.kitesdk.data.Key.Builder: Construct a Key.Builder for a RandomAccessDataset.
keyAsColumn(String, String) - Method in class org.kitesdk.data.ColumnMapping.Builder: Adds a key-as-column mapping to store the record field name in the given family, using its keys or fields as column qualifiers.
keyAsColumn(String, String, String) - Method in class org.kitesdk.data.ColumnMapping.Builder: Adds a key-as-column mapping to store the record field name in the given family, using column qualifiers built from its keys or field names appended to the qualifierPrefix.
keyAsColumn(String, String) - Static method in class org.kitesdk.data.FieldMapping
keyAsColumn(String, String, String) - Static method in class org.kitesdk.data.FieldMapping
KITE_COPY_RECORDS - Static variable in class org.kitesdk.data.mapreduce.DatasetKeyOutputFormat
KITE_INPUT_URI - Static variable in class org.kitesdk.data.mapreduce.DatasetKeyInputFormat
KITE_OUTPUT_URI - Static variable in class org.kitesdk.data.mapreduce.DatasetKeyOutputFormat
KITE_PARTITION_DIR - Static variable in class org.kitesdk.data.mapreduce.DatasetKeyInputFormat
KITE_PARTITION_DIR - Static variable in class org.kitesdk.data.mapreduce.DatasetKeyOutputFormat
KITE_READER_SCHEMA - Static variable in class org.kitesdk.data.mapreduce.DatasetKeyInputFormat
KITE_TYPE - Static variable in class org.kitesdk.data.mapreduce.DatasetKeyInputFormat
KITE_TYPE - Static variable in class org.kitesdk.data.mapreduce.DatasetKeyOutputFormat
KITE_WRITE_MODE - Static variable in class org.kitesdk.data.mapreduce.DatasetKeyOutputFormat
KiteLauncherURIHandler - Class in org.kitesdk.data.oozie
KiteLauncherURIHandler() - Constructor for class org.kitesdk.data.oozie.KiteLauncherURIHandler
KiteURIHandler - Class in org.kitesdk.data.oozie: A Kite URI handler that works with Signalable views.
KiteURIHandler() - Constructor for class org.kitesdk.data.oozie.KiteURIHandler

L

LIFE_CYCLE - Static variable in class org.kitesdk.morphline.base.Notifications: The field in which the notification of the lifecycle is stored.
LIFE_CYLCLE - Static variable in class org.kitesdk.morphline.base.Notifications: Deprecated.
(since 0.10.1) Use Notifications.LIFE_CYCLE instead.
list(URI) - Static method in class org.kitesdk.data.Datasets: List the Dataset URIs in the repository identified by the URI.
list(String) - Static method in class org.kitesdk.data.Datasets: List the Dataset URIs in the repository identified by the URI string.
listProperties() - Method in class org.kitesdk.data.DatasetDescriptor: List the names of all custom properties set.
listStatus(Path) - Method in class org.kitesdk.morphline.hadoop.rcfile.SingleStreamFileSystem
load(URI, Class<E>) - Static method in class org.kitesdk.data.Datasets: Load a Dataset or View for the given URI.
load(URI) - Static method in class org.kitesdk.data.Datasets: Load a Dataset or View for the given URI.
load(String, Class<E>) - Static method in class org.kitesdk.data.Datasets: Load a Dataset or View for the given URI.
load(String) - Static method in class org.kitesdk.data.Datasets: Load a Dataset or View for the given URI.
load(SolrInputDocument) - Method in interface org.kitesdk.morphline.solr.DocumentLoader: Loads the given document into the destination
load(SolrInputDocument) - Method in class org.kitesdk.morphline.solr.SolrServerDocumentLoader
LOAD_SOLR_CHILD_DOCUMENTS - Static variable in class org.kitesdk.morphline.solr.LoadSolrBuilder
LOAD_SOLR_DELETE_BY_ID - Static variable in class org.kitesdk.morphline.solr.LoadSolrBuilder
LOAD_SOLR_DELETE_BY_QUERY - Static variable in class org.kitesdk.morphline.solr.LoadSolrBuilder
LoadSolrBuilder - Class in org.kitesdk.morphline.solr: A command that loads (or deletes) a record into a SolrServer or MapReduce SolrOutputFormat.
LoadSolrBuilder() - Constructor for class org.kitesdk.morphline.solr.LoadSolrBuilder
location(URI) - Method in class org.kitesdk.data.DatasetDescriptor.Builder: Configure the dataset's location (optional).
location(Path) - Method in class org.kitesdk.data.DatasetDescriptor.Builder: Configure the dataset's location (optional).
location(String) - Method in class org.kitesdk.data.DatasetDescriptor.Builder: Configure the dataset's location (optional).
LOG - Variable in class org.kitesdk.morphline.base.AbstractCommand
Log4jAppender - Class in org.kitesdk.data.flume
Log4jAppender() - Constructor for class org.kitesdk.data.flume.Log4jAppender
Log4jAppender(String, int) - Constructor for class org.kitesdk.data.flume.Log4jAppender: Sets the hostname and port.
LogDebugBuilder - Class in org.kitesdk.morphline.stdlib: Command that logs to slf4j at DEBUG level.
LogDebugBuilder() - Constructor for class org.kitesdk.morphline.stdlib.LogDebugBuilder
LogErrorBuilder - Class in org.kitesdk.morphline.stdlib: Command that logs to slf4j at ERROR level.
LogErrorBuilder() - Constructor for class org.kitesdk.morphline.stdlib.LogErrorBuilder
LogInfoBuilder - Class in org.kitesdk.morphline.stdlib: Command that logs to slf4j at INFO level.
LogInfoBuilder() - Constructor for class org.kitesdk.morphline.stdlib.LogInfoBuilder
LogTraceBuilder - Class in org.kitesdk.morphline.stdlib: Command that logs to slf4j at TRACE level.
LogTraceBuilder() - Constructor for class org.kitesdk.morphline.stdlib.LogTraceBuilder
LogWarnBuilder - Class in org.kitesdk.morphline.stdlib: Command that logs to slf4j at WARN level.
LogWarnBuilder() - Constructor for class org.kitesdk.morphline.stdlib.LogWarnBuilder

M

main(String[]) - Static method in class org.kitesdk.morphline.base.PrettyPrinter
map(E) - Method in class org.kitesdk.tools.TransformTask.CheckEntityClass
MASTER_PORT_KEY - Static variable in class org.kitesdk.minicluster.HBaseService: Service configuration keys
MESSAGE - Static variable in class org.kitesdk.morphline.base.Fields
Metrics - Class in org.kitesdk.morphline.base: Common metric names.
Metrics() - Constructor for class org.kitesdk.morphline.base.Metrics
MIME_TYPE - Static variable in class org.kitesdk.morphline.avro.ReadAvroContainerBuilder: The MIME type that input attachments shall have
MIME_TYPE - Static variable in class org.kitesdk.morphline.json.ReadJsonBuilder: The MIME type identifier that will be filled into output records
MIME_TYPE - Static variable in class org.kitesdk.morphline.protobuf.ReadProtobufBuilder: The MIME type identifier that will be filled into output records
MiniCluster - Class in org.kitesdk.minicluster: A in process MiniCluster implementation for Kite that is configurable with Services that make up the MiniCluster.
MiniCluster.Builder - Class in org.kitesdk.minicluster: A MiniCluster Builder.
MiniCluster.Builder() - Constructor for class org.kitesdk.minicluster.MiniCluster.Builder
minute(String, String) - Method in class org.kitesdk.data.PartitionStrategy.Builder: Configure a partitioner for extracting the minute from a timestamp field.
minute(String) - Method in class org.kitesdk.data.PartitionStrategy.Builder: Configure a partitioner for extracting the minute from a timestamp field.
mkdirs(Path, FsPermission) - Method in class org.kitesdk.morphline.hadoop.rcfile.SingleStreamFileSystem
month(String, String) - Method in class org.kitesdk.data.PartitionStrategy.Builder: Configure a partitioner for extracting the month from a timestamp field.
month(String) - Method in class org.kitesdk.data.PartitionStrategy.Builder: Configure a partitioner for extracting the month from a timestamp field.
MORPHLINE_APP - Static variable in class org.kitesdk.morphline.base.Metrics
MorphlineCompilationException - Exception in org.kitesdk.morphline.api: Indicates a parse error.
MorphlineCompilationException(String, Config) - Constructor for exception org.kitesdk.morphline.api.MorphlineCompilationException
MorphlineCompilationException(String, Config, Throwable) - Constructor for exception org.kitesdk.morphline.api.MorphlineCompilationException
MorphlineCompilationException(String, Config, Throwable, CommandBuilder) - Constructor for exception org.kitesdk.morphline.api.MorphlineCompilationException
MorphlineContext - Class in org.kitesdk.morphline.api: Additional user defined parameters that will be passed to all morphline commands.
MorphlineContext() - Constructor for class org.kitesdk.morphline.api.MorphlineContext: For public access use MorphlineContext.Builder.build() instead
MorphlineContext.Builder - Class in org.kitesdk.morphline.api: Helper to construct a MorphlineContext instance.
MorphlineContext.Builder() - Constructor for class org.kitesdk.morphline.api.MorphlineContext.Builder
MorphlineRuntimeException - Exception in org.kitesdk.morphline.api: Base class of all morphline exceptions.
MorphlineRuntimeException(String) - Constructor for exception org.kitesdk.morphline.api.MorphlineRuntimeException
MorphlineRuntimeException(String, Throwable) - Constructor for exception org.kitesdk.morphline.api.MorphlineRuntimeException
MorphlineRuntimeException(Throwable) - Constructor for exception org.kitesdk.morphline.api.MorphlineRuntimeException

N

NAMENODE_HTTP_PORT - Static variable in class org.kitesdk.minicluster.HdfsService: Service configuration keys
NAMENODE_RPC_PORT - Static variable in class org.kitesdk.minicluster.MiniCluster
namenodeRpcPort(int) - Method in class org.kitesdk.minicluster.MiniCluster.Builder
namespace(String) - Method in class org.kitesdk.data.URIBuilder: Sets the namespace that is used to construct the dataset URI.
NAMESPACE_DEFAULT - Static variable in class org.kitesdk.data.URIBuilder
NAMESPACE_OPTION - Static variable in class org.kitesdk.data.URIBuilder
newReader() - Method in interface org.kitesdk.data.View: Get an appropriate DatasetReader implementation based on this View of the underlying Dataset implementation.
newWriter() - Method in interface org.kitesdk.data.PartitionView: Get an appropriate DatasetWriter implementation based on the constraints for this View of the underlying Dataset.
newWriter() - Method in interface org.kitesdk.data.View: Get an appropriate DatasetWriter implementation based on this View of the underlying Dataset implementation.
next() - Method in interface org.kitesdk.data.DatasetReader: Fetch the next entity from the reader.
noCompaction() - Method in class org.kitesdk.tools.TransformTask: Do not shuffle data to writers to minimize the number of files.
NotBuilder - Class in org.kitesdk.morphline.stdlib: A Not command consists of one nested command, the boolean return value of which is inverted.
NotBuilder() - Constructor for class org.kitesdk.morphline.stdlib.NotBuilder
Notifications - Class in org.kitesdk.morphline.base: Tools for notifications on the control plane.
Notifications() - Constructor for class org.kitesdk.morphline.base.Notifications
Notifications.LifecycleEvent - Enum in org.kitesdk.morphline.base: Enumerations of the standard lifecycle events.
notify(Record) - Method in interface org.kitesdk.morphline.api.Command: Processes the given notification on the control plane of the subtree rooted at this command.
notify(Record) - Method in class org.kitesdk.morphline.base.AbstractCommand
notifyBeginTransaction(Command) - Static method in class org.kitesdk.morphline.base.Notifications: Notify the given command that a transaction has begun.
notifyCommitTransaction(Command) - Static method in class org.kitesdk.morphline.base.Notifications: Notify the given command that a transaction has been committed.
notifyRollbackTransaction(Command) - Static method in class org.kitesdk.morphline.base.Notifications: Notify the given command that a transaction has been rolled back.
notifyShutdown(Command) - Static method in class org.kitesdk.morphline.base.Notifications: Notify the given command that a shutdown command has been issued.
notifyStartSession(Command) - Static method in class org.kitesdk.morphline.base.Notifications: Notify the given command that a session has started.
NUM_CACHE_HITS - Static variable in class org.kitesdk.morphline.base.Metrics
NUM_CACHE_MISSES - Static variable in class org.kitesdk.morphline.base.Metrics
NUM_EXCEPTION_RECORDS - Static variable in class org.kitesdk.morphline.base.Metrics
NUM_FAILED_RECORDS - Static variable in class org.kitesdk.morphline.base.Metrics
NUM_FINAL_CHILD_RECORDS - Static variable in class org.kitesdk.morphline.base.Metrics
NUM_NOTIFY_CALLS - Static variable in class org.kitesdk.morphline.base.Metrics
NUM_PROCESS_CALLS - Static variable in class org.kitesdk.morphline.base.Metrics
NUM_RECORDS - Static variable in class org.kitesdk.morphline.base.Metrics

O

occ(String) - Method in class org.kitesdk.data.ColumnMapping.Builder: Adds an OCC version mapping for the record field name.
occ(String) - Static method in class org.kitesdk.data.FieldMapping
open(Path, int) - Method in class org.kitesdk.morphline.hadoop.rcfile.SingleStreamFileSystem
OpenHdfsFileBuilder - Class in org.kitesdk.morphline.hadoop.core: Opens an HDFS file for read and return a corresponding InputStream.
OpenHdfsFileBuilder() - Constructor for class org.kitesdk.morphline.hadoop.core.OpenHdfsFileBuilder
org.kitesdk.data - package org.kitesdk.data: Provides interfaces and classes for reading and writing datasets.
org.kitesdk.data.crunch - package org.kitesdk.data.crunch: Provides helper classes for working with datasets using Crunch.
org.kitesdk.data.flume - package org.kitesdk.data.flume: Provides classes for writing datasets via Flume.
org.kitesdk.data.mapreduce - package org.kitesdk.data.mapreduce: Provides helper classes for working with datasets using MapReduce.
org.kitesdk.data.oozie - package org.kitesdk.data.oozie
org.kitesdk.minicluster - package org.kitesdk.minicluster
org.kitesdk.morphline.api - package org.kitesdk.morphline.api: This package contains the heart of the morphline API.
org.kitesdk.morphline.avro - package org.kitesdk.morphline.avro
org.kitesdk.morphline.base - package org.kitesdk.morphline.base
org.kitesdk.morphline.hadoop.core - package org.kitesdk.morphline.hadoop.core
org.kitesdk.morphline.hadoop.parquet.avro - package org.kitesdk.morphline.hadoop.parquet.avro
org.kitesdk.morphline.hadoop.rcfile - package org.kitesdk.morphline.hadoop.rcfile
org.kitesdk.morphline.hadoop.sequencefile - package org.kitesdk.morphline.hadoop.sequencefile
org.kitesdk.morphline.json - package org.kitesdk.morphline.json
org.kitesdk.morphline.maxmind - package org.kitesdk.morphline.maxmind
org.kitesdk.morphline.metrics.servlets - package org.kitesdk.morphline.metrics.servlets
org.kitesdk.morphline.protobuf - package org.kitesdk.morphline.protobuf
org.kitesdk.morphline.saxon - package org.kitesdk.morphline.saxon
org.kitesdk.morphline.scriptengine.java - package org.kitesdk.morphline.scriptengine.java
org.kitesdk.morphline.solr - package org.kitesdk.morphline.solr
org.kitesdk.morphline.solrcell - package org.kitesdk.morphline.solrcell
org.kitesdk.morphline.stdio - package org.kitesdk.morphline.stdio
org.kitesdk.morphline.stdlib - package org.kitesdk.morphline.stdlib
org.kitesdk.morphline.tika - package org.kitesdk.morphline.tika
org.kitesdk.morphline.tika.decompress - package org.kitesdk.morphline.tika.decompress
org.kitesdk.morphline.twitter - package org.kitesdk.morphline.twitter
org.kitesdk.morphline.useragent - package org.kitesdk.morphline.useragent
org.kitesdk.tools - package org.kitesdk.tools
OUTPUT_MEDIA_TYPE - Static variable in class org.kitesdk.morphline.hadoop.rcfile.ReadRCFileBuilder
OUTPUT_MEDIA_TYPE - Static variable in class org.kitesdk.morphline.hadoop.sequencefile.ReadSequenceFileBuilder
overwrite(URI) - Method in class org.kitesdk.data.mapreduce.DatasetKeyOutputFormat.ConfigBuilder: Adds configuration for DatasetKeyOutputFormat to write to the given dataset or view URI after removing any existing data.
overwrite(View<?>) - Method in class org.kitesdk.data.mapreduce.DatasetKeyOutputFormat.ConfigBuilder: Adds configuration for DatasetKeyOutputFormat to write to the given Dataset or View instance after removing any existing data.
overwrite(String) - Method in class org.kitesdk.data.mapreduce.DatasetKeyOutputFormat.ConfigBuilder: Adds configuration for DatasetKeyOutputFormat to write to the given dataset or view URI string after removing any existing data.

P

PARQUET - Static variable in class org.kitesdk.data.Formats: PARQUET: the Parquet columnar format
parse(File, Config...) - Method in class org.kitesdk.morphline.base.Compiler: Loads the given config file from the local file system
partition(PCollection<E>, View<E>) - Static method in class org.kitesdk.data.crunch.CrunchDatasets: Partitions collection to be stored efficiently in View.
partition(PCollection<E>, Dataset<E>) - Static method in class org.kitesdk.data.crunch.CrunchDatasets: Partitions collection to be stored efficiently in dataset.
partition(PCollection<E>, View<E>, int) - Static method in class org.kitesdk.data.crunch.CrunchDatasets: Partitions collection to be stored efficiently in View.
partition(PCollection<E>, View<E>, int, int) - Static method in class org.kitesdk.data.crunch.CrunchDatasets: Partitions collection to be stored efficiently in View.
partitionStrategy(PartitionStrategy) - Method in class org.kitesdk.data.DatasetDescriptor.Builder: Configure the dataset's partitioning strategy (optional).
partitionStrategy(File) - Method in class org.kitesdk.data.DatasetDescriptor.Builder: Configure the dataset's partition strategy from a File.
partitionStrategy(InputStream) - Method in class org.kitesdk.data.DatasetDescriptor.Builder: Configure the dataset's partition strategy from an InputStream.
PartitionStrategy - Class in org.kitesdk.data: The strategy used to determine how a dataset is partitioned.
PartitionStrategy.Builder - Class in org.kitesdk.data: A fluent builder to aid in the construction of PartitionStrategys.
PartitionStrategy.Builder() - Constructor for class org.kitesdk.data.PartitionStrategy.Builder
partitionStrategyLiteral(String) - Method in class org.kitesdk.data.DatasetDescriptor.Builder: Configure the dataset's partition strategy from a String literal.
partitionStrategyUri(URI) - Method in class org.kitesdk.data.DatasetDescriptor.Builder: Configure the dataset's partition strategy from a URI.
partitionStrategyUri(String) - Method in class org.kitesdk.data.DatasetDescriptor.Builder: Configure the dataset's partition strategy from a String URI.
PartitionView<E> - Interface in org.kitesdk.data: A PartitionView is a subset of a Dataset that corresponds to a single partition, with a location.
ping() - Method in interface org.kitesdk.morphline.solr.DocumentLoader: Issues a ping request to check if the server is alive
ping() - Method in class org.kitesdk.morphline.solr.SolrServerDocumentLoader
PipeBuilder - Class in org.kitesdk.morphline.stdlib: Factory to create morphline pipe instances.
PipeBuilder() - Constructor for class org.kitesdk.morphline.stdlib.PipeBuilder
populateAvroHeaders(Map<String, String>, Schema, Object) - Method in class org.kitesdk.data.flume.Log4jAppender
PREFIX_NAME - Static variable in class org.kitesdk.morphline.stdlib.GenerateUUIDBuilder
prepareClasspath(Configuration, Path, Class<?>...) - Method in class org.kitesdk.tools.JobClasspathHelper
PRESERVE_EXISTING_NAME - Static variable in class org.kitesdk.morphline.stdlib.AddCurrentTimeBuilder
PRESERVE_EXISTING_NAME - Static variable in class org.kitesdk.morphline.stdlib.AddLocalHostBuilder
PRESERVE_EXISTING_NAME - Static variable in class org.kitesdk.morphline.stdlib.GenerateUUIDBuilder
PrettyPrinter - Class in org.kitesdk.morphline.base: Utility to nicely indent and format a morphline config file.
PrettyPrinter() - Constructor for class org.kitesdk.morphline.base.PrettyPrinter
process(Record) - Method in interface org.kitesdk.morphline.api.Command: Processes the given record on the data plane of this command.
process(Record) - Method in class org.kitesdk.morphline.base.AbstractCommand
property(String, String) - Method in class org.kitesdk.data.DatasetDescriptor.Builder: Add a key-value property to the descriptor.
provided(String) - Method in class org.kitesdk.data.PartitionStrategy.Builder: Configure a partitioner that uses values always provided at runtime.
provided(String, String) - Method in class org.kitesdk.data.PartitionStrategy.Builder: Configure a partitioner that uses values always provided at runtime.
put(E) - Method in interface org.kitesdk.data.RandomAccessDataset: Put the entity into the dataset.
put(String, Object) - Method in class org.kitesdk.morphline.api.Record: Adds the given value to the values currently associated with the given key.
putIfAbsent(String, Object) - Method in class org.kitesdk.morphline.api.Record: Adds the given value to the values currently associated with the given key, iff the key isn't already associated with that same value.

R

RandomAccessDataset<E> - Interface in org.kitesdk.data: A Dataset that supports random access operations on entities.
range(String, int...) - Method in class org.kitesdk.data.PartitionStrategy.Builder: Configure a range partitioner with a set of upperBounds.
range(String, String...) - Method in class org.kitesdk.data.PartitionStrategy.Builder: Configure a range partitioner for strings with a set of upperBounds.
RC_FILE_META_DATA - Static variable in class org.kitesdk.morphline.hadoop.rcfile.ReadRCFileBuilder
ReadAvroBuilder - Class in org.kitesdk.morphline.avro: Command that parses an InputStream that contains Avro data; for each Avro datum, the command emits a morphline record containing the datum as an attachment in Fields.ATTACHMENT_BODY.
ReadAvroBuilder() - Constructor for class org.kitesdk.morphline.avro.ReadAvroBuilder
ReadAvroContainerBuilder - Class in org.kitesdk.morphline.avro: Command that parses an InputStream that contains Avro binary container file data; for each Avro datum, the command emits a morphline record containing the datum as an attachment in Fields.ATTACHMENT_BODY.
ReadAvroContainerBuilder() - Constructor for class org.kitesdk.morphline.avro.ReadAvroContainerBuilder
ReadAvroParquetFileBuilder - Class in org.kitesdk.morphline.hadoop.parquet.avro: Command that parses a Hadoop File that contains Parquet data; for each Parquet Avro datum, the command emits a morphline record containing the record as an attachment in Fields.ATTACHMENT_BODY.
ReadAvroParquetFileBuilder() - Constructor for class org.kitesdk.morphline.hadoop.parquet.avro.ReadAvroParquetFileBuilder
ReadBlobBuilder - Class in org.kitesdk.morphline.stdio: Command that emits one record for the entire input stream of the first attachment, interpreting the stream as a Binary Large Object (BLOB), i.e.
ReadBlobBuilder() - Constructor for class org.kitesdk.morphline.stdio.ReadBlobBuilder
ReadClobBuilder - Class in org.kitesdk.morphline.stdio: Command that emits one record for the entire input stream of the first attachment, interpreting the stream as a Character Large Object (CLOB).
ReadClobBuilder() - Constructor for class org.kitesdk.morphline.stdio.ReadClobBuilder
ReadCSVBuilder - Class in org.kitesdk.morphline.stdio: Command that extracts zero or more records from the input stream of the first attachment, representing a Comma Separated Values (CSV) file.
ReadCSVBuilder() - Constructor for class org.kitesdk.morphline.stdio.ReadCSVBuilder
readFrom(URI) - Method in class org.kitesdk.data.mapreduce.DatasetKeyInputFormat.ConfigBuilder: Adds configuration for DatasetKeyInputFormat to read from the given dataset or view URI.
readFrom(View<?>) - Method in class org.kitesdk.data.mapreduce.DatasetKeyInputFormat.ConfigBuilder: Adds configuration for DatasetKeyInputFormat to read from the given Dataset or View instance.
readFrom(String) - Method in class org.kitesdk.data.mapreduce.DatasetKeyInputFormat.ConfigBuilder: Adds configuration for DatasetKeyInputFormat to read from the given dataset or view URI string.
ReadJsonBuilder - Class in org.kitesdk.morphline.json: Command that parses an InputStream that contains JSON data; for each JSON object in the stream, the command emits a morphline record containing the object as an attachment in Fields.ATTACHMENT_BODY.
ReadJsonBuilder() - Constructor for class org.kitesdk.morphline.json.ReadJsonBuilder
ReadJsonTestTweetsBuilder - Class in org.kitesdk.morphline.twitter: JSON parser that extracts search documents from twitter tweets obtained from the twitter 1% sample firehose with the delimited=length option.
ReadJsonTestTweetsBuilder() - Constructor for class org.kitesdk.morphline.twitter.ReadJsonTestTweetsBuilder
ReadLineBuilder - Class in org.kitesdk.morphline.stdio: Command that emits one record per line in the input stream of the first attachment.
ReadLineBuilder() - Constructor for class org.kitesdk.morphline.stdio.ReadLineBuilder
ReadMultiLineBuilder - Class in org.kitesdk.morphline.stdio: Multiline log parser that collapse multiline messages into a single record; supports "regex", "what" and "negate" configuration parameters similar to logstash.
ReadMultiLineBuilder() - Constructor for class org.kitesdk.morphline.stdio.ReadMultiLineBuilder
ReadProtobufBuilder - Class in org.kitesdk.morphline.protobuf: Command that parses an InputStream that contains Protocol buffer data; the command emits a morphline record containing the object as an attachment in Fields.ATTACHMENT_BODY.
ReadProtobufBuilder() - Constructor for class org.kitesdk.morphline.protobuf.ReadProtobufBuilder
ReadRCFileBuilder - Class in org.kitesdk.morphline.hadoop.rcfile: Command for reading Record Columnar (RC) Files.
ReadRCFileBuilder() - Constructor for class org.kitesdk.morphline.hadoop.rcfile.ReadRCFileBuilder
ReadSequenceFileBuilder - Class in org.kitesdk.morphline.hadoop.sequencefile: Command that emits one record per sequence file entry in the input stream of the first attachment.
ReadSequenceFileBuilder() - Constructor for class org.kitesdk.morphline.hadoop.sequencefile.ReadSequenceFileBuilder
Record - Class in org.kitesdk.morphline.api: A record is a set of named fields where each field has a list of one or more values.
Record() - Constructor for class org.kitesdk.morphline.api.Record: Creates a new empty record.
RECOVERABLE_EXCEPTION_CLASSES - Static variable in class org.kitesdk.morphline.base.FaultTolerance
RefinableView<E> - Interface in org.kitesdk.data: A RefinableView specifies a subset of a Dataset by one or more logical constraints.
REGIONSERVER_PORT_KEY - Static variable in class org.kitesdk.minicluster.HBaseService
registerForNotification(URI, Configuration, String, String) - Method in class org.kitesdk.data.oozie.KiteURIHandler
RegisterJVMMetricsBuilder - Class in org.kitesdk.morphline.metrics.servlets: Command that registers metrics that are related to the Java Virtual Machine with the MorphlineContext of the morphline.
RegisterJVMMetricsBuilder() - Constructor for class org.kitesdk.morphline.metrics.servlets.RegisterJVMMetricsBuilder
registerService(Class<? extends Service>) - Static method in class org.kitesdk.minicluster.MiniCluster
remove() - Method in interface org.kitesdk.data.DatasetReader: Remove the last entity from the reader (OPTIONAL).
removeAll(String) - Method in class org.kitesdk.morphline.api.Record: Removes all values that are associated with the given key
removeAttachments(Record) - Static method in class org.kitesdk.morphline.stdio.AbstractParser
RemoveFieldsBuilder - Class in org.kitesdk.morphline.stdlib: Removes all record fields for which the field name matches at least one of the given blacklist predicates but none of the given whitelist predicates.
RemoveFieldsBuilder() - Constructor for class org.kitesdk.morphline.stdlib.RemoveFieldsBuilder
RemoveValuesBuilder - Class in org.kitesdk.morphline.stdlib: Removes all record field values for which all of the following conditions hold: 1) the field name matches at least one of the given nameBlacklist predicates but none of the given nameWhitelist predicates.
RemoveValuesBuilder() - Constructor for class org.kitesdk.morphline.stdlib.RemoveValuesBuilder
rename(Path, Path) - Method in class org.kitesdk.morphline.hadoop.rcfile.SingleStreamFileSystem
replaceValues(String, Object) - Method in class org.kitesdk.morphline.api.Record: Removes all values that are associated with the given key, and then associates the given value with the given key.
ReplaceValuesBuilder - Class in org.kitesdk.morphline.stdlib: Replaces all record field values for which all of the following conditions hold: 1) the field name matches at least one of the given nameBlacklist predicates but none of the given nameWhitelist predicates.
ReplaceValuesBuilder() - Constructor for class org.kitesdk.morphline.stdlib.ReplaceValuesBuilder
REPO_SCHEME - Static variable in class org.kitesdk.data.URIBuilder
requiresLayout() - Method in class org.kitesdk.data.flume.Log4jAppender
rollbackTransaction() - Method in interface org.kitesdk.morphline.solr.DocumentLoader: Performs a rollback of all non-committed documents pending.
rollbackTransaction() - Method in class org.kitesdk.morphline.solr.SolrServerDocumentLoader
run() - Method in class org.kitesdk.tools.CompactionTask
run() - Method in class org.kitesdk.tools.TransformTask

S

SampleBuilder - Class in org.kitesdk.morphline.stdlib: Command that forwards each input record with a given probability to its child command, and silently ignores all other input records.
SampleBuilder() - Constructor for class org.kitesdk.morphline.stdlib.SampleBuilder
SanitizeUnknownSolrFieldsBuilder - Class in org.kitesdk.morphline.solr: Command that sanitizes record fields that are unknown to Solr schema.xml by either deleting them (renameToPrefix is absent or a zero length string), or by moving them to a field prefixed with the given renameToPrefix (e.g.
SanitizeUnknownSolrFieldsBuilder() - Constructor for class org.kitesdk.morphline.solr.SanitizeUnknownSolrFieldsBuilder
schema(Schema) - Method in class org.kitesdk.data.DatasetDescriptor.Builder: Configure the dataset's schema.
schema(File) - Method in class org.kitesdk.data.DatasetDescriptor.Builder: Configure the dataset's schema from a File.
schema(InputStream) - Method in class org.kitesdk.data.DatasetDescriptor.Builder: Configure the dataset's schema from an InputStream.
schema(Class<T>) - Method in class org.kitesdk.data.DatasetDescriptor.Builder: Configure the dataset's schema via a Java class type.
schemaFromAvroDataFile(File) - Method in class org.kitesdk.data.DatasetDescriptor.Builder: Configure the dataset's schema by using the schema from an existing Avro data file.
schemaFromAvroDataFile(InputStream) - Method in class org.kitesdk.data.DatasetDescriptor.Builder: Configure the dataset's schema by using the schema from an existing Avro data file.
schemaFromAvroDataFile(URI) - Method in class org.kitesdk.data.DatasetDescriptor.Builder: Configure the dataset's schema by using the schema from an existing Avro data file.
schemaLiteral(String) - Method in class org.kitesdk.data.DatasetDescriptor.Builder: Configure the dataset's schema from a String.
SchemaNotFoundException - Exception in org.kitesdk.data: Exception thrown to indicate that there is a problem finding a particular version of a schema.
SchemaNotFoundException(String) - Constructor for exception org.kitesdk.data.SchemaNotFoundException
SchemaNotFoundException(String, Throwable) - Constructor for exception org.kitesdk.data.SchemaNotFoundException
SchemaNotFoundException(Throwable) - Constructor for exception org.kitesdk.data.SchemaNotFoundException
schemaUri(URI) - Method in class org.kitesdk.data.DatasetDescriptor.Builder: Configure the Dataset's schema from a URI.
schemaUri(String) - Method in class org.kitesdk.data.DatasetDescriptor.Builder: Configure the Dataset's schema from a String URI.
ScriptEvaluator<T> - Class in org.kitesdk.morphline.scriptengine.java: Creates and compiles the given Java code block, wrapped into a Java method with the given return type and parameter types, along with a Java class definition that contains the given import statements.
ScriptEvaluator(String, String, Class<T>, String[], Class[], String) - Constructor for class org.kitesdk.morphline.scriptengine.java.ScriptEvaluator
ScriptEvaluator(String, String, Class<T>, String[], Class[], Class[], String) - Constructor for class org.kitesdk.morphline.scriptengine.java.ScriptEvaluator
SeparateAttachmentsBuilder - Class in org.kitesdk.morphline.stdlib: Command that emits one output record for each attachment in the input record's list of attachments; The result is a list of records, each of which has at most one attachment.
SeparateAttachmentsBuilder() - Constructor for class org.kitesdk.morphline.stdlib.SeparateAttachmentsBuilder
SEQUENCE_FILE_META_DATA - Static variable in class org.kitesdk.morphline.hadoop.sequencefile.ReadSequenceFileBuilder
SerializationException - Exception in org.kitesdk.data: Exception thrown when an object cannot be serialized to, or deserialized from, its binary representation.
SerializationException(String, Throwable) - Constructor for exception org.kitesdk.data.SerializationException
Service - Interface in org.kitesdk.minicluster: Interface for MiniCluster Service implementations.
Service.ServiceConfig - Class in org.kitesdk.minicluster: A class that holds configuration settings for minicluster services.
Service.ServiceConfig() - Constructor for class org.kitesdk.minicluster.Service.ServiceConfig
set(String, String) - Method in class org.kitesdk.minicluster.Service.ServiceConfig
setBatchSize(int) - Method in class org.kitesdk.morphline.solr.SolrLocator
setCollectionName(String) - Method in class org.kitesdk.morphline.solr.SolrLocator
setConf(Configuration) - Method in class org.kitesdk.data.mapreduce.DatasetKeyInputFormat
setConf(Configuration) - Method in class org.kitesdk.tools.CompactionTask
setDatasetName(String) - Method in class org.kitesdk.data.flume.Log4jAppender
setDatasetNamespace(String) - Method in class org.kitesdk.data.flume.Log4jAppender
setDatasetRepositoryClass(String) - Method in class org.kitesdk.data.flume.Log4jAppender: Deprecated.
Use datasetRepositoryUri with a 'repo:' URI.
setDatasetRepositoryUri(String) - Method in class org.kitesdk.data.flume.Log4jAppender
setDocumentLoader(DocumentLoader) - Method in class org.kitesdk.morphline.solr.SolrMorphlineContext.Builder
setExceptionHandler(ExceptionHandler) - Method in class org.kitesdk.morphline.api.MorphlineContext.Builder
setFilesPerPartition(int) - Method in class org.kitesdk.tools.CompactionTask
setFilesPerPartition(int) - Method in class org.kitesdk.tools.TransformTask: Set the number of files to create in each output partition.
setHadoopConf(Configuration) - Method in class org.kitesdk.minicluster.Service.ServiceConfig
setHealthCheckRegistry(HealthCheckRegistry) - Method in class org.kitesdk.morphline.api.MorphlineContext.Builder
setIndexSchema(IndexSchema) - Method in class org.kitesdk.morphline.solr.SolrMorphlineContext.Builder
setMetricRegistry(MetricRegistry) - Method in class org.kitesdk.morphline.api.MorphlineContext.Builder
setNumWriters(int) - Method in class org.kitesdk.tools.CompactionTask
setNumWriters(int) - Method in class org.kitesdk.tools.TransformTask: Set the number of concurrent writer processes.
setServerUrl(String) - Method in class org.kitesdk.morphline.solr.SolrLocator
setServiceConfig(String, String) - Method in class org.kitesdk.minicluster.MiniCluster.Builder: Service configs are dynamic config name-value pairs that can be interpreted by the services.
setSettings(Map<String, Object>) - Method in class org.kitesdk.morphline.api.MorphlineContext.Builder
setSolrHomeDir(String) - Method in class org.kitesdk.morphline.solr.SolrLocator
SetValuesBuilder - Class in org.kitesdk.morphline.stdlib: For each input field, set the given record output field to the same values.
SetValuesBuilder() - Constructor for class org.kitesdk.morphline.stdlib.SetValuesBuilder
setWorkingDirectory(Path) - Method in class org.kitesdk.morphline.hadoop.rcfile.SingleStreamFileSystem
setWriteMode(Target.WriteMode) - Method in class org.kitesdk.tools.TransformTask: Set the output write mode: default, overwrite, or append.
setZkHost(String) - Method in class org.kitesdk.morphline.solr.SolrLocator
shutdown() - Method in interface org.kitesdk.morphline.solr.DocumentLoader: Releases allocated resources
shutdown() - Method in class org.kitesdk.morphline.solr.SolrServerDocumentLoader
Signalable<E> - Interface in org.kitesdk.data: Signalable views may signal consumers when their underlying data is ready for consumption.
signalReady() - Method in interface org.kitesdk.data.Signalable: Signal that the view's data is ready for consumption.
SingleStreamFileSystem - Class in org.kitesdk.morphline.hadoop.rcfile: Very simple Filesystem Implementation which serves an InputStream for a given path.
SingleStreamFileSystem(InputStream, Path) - Constructor for class org.kitesdk.morphline.hadoop.rcfile.SingleStreamFileSystem
SOLR_LOCATOR_PARAM - Static variable in class org.kitesdk.morphline.solr.LoadSolrBuilder
SolrCellBuilder - Class in org.kitesdk.morphline.solrcell: Command that pipes the first attachment of a record into one of the given Tika parsers, then maps the Tika output back to a record using SolrCell.
SolrCellBuilder() - Constructor for class org.kitesdk.morphline.solrcell.SolrCellBuilder
SolrLocator - Class in org.kitesdk.morphline.solr: Set of configuration parameters that identify the location and schema of a Solr server or SolrCloud; Based on this information this class can return the schema and a corresponding DocumentLoader.
SolrLocator(MorphlineContext) - Constructor for class org.kitesdk.morphline.solr.SolrLocator
SolrLocator(Config, MorphlineContext) - Constructor for class org.kitesdk.morphline.solr.SolrLocator
SolrMorphlineContext - Class in org.kitesdk.morphline.solr: A context that is specific to Solr.
SolrMorphlineContext() - Constructor for class org.kitesdk.morphline.solr.SolrMorphlineContext: For public access use SolrMorphlineContext.Builder.build() instead
SolrMorphlineContext.Builder - Class in org.kitesdk.morphline.solr: Helper to construct a SolrMorphlineContext instance.
SolrMorphlineContext.Builder() - Constructor for class org.kitesdk.morphline.solr.SolrMorphlineContext.Builder
SolrServerDocumentLoader - Class in org.kitesdk.morphline.solr: A vehicle to load (or delete) documents into a local or remote SolrServer.
SolrServerDocumentLoader(SolrServer, int) - Constructor for class org.kitesdk.morphline.solr.SolrServerDocumentLoader
SplitBuilder - Class in org.kitesdk.morphline.stdlib: Command that divides strings into substrings, by recognizing a separator (a.k.a.
SplitBuilder() - Constructor for class org.kitesdk.morphline.stdlib.SplitBuilder
SplitKeyValueBuilder - Class in org.kitesdk.morphline.stdlib: Command that iterates over the items in a given record input field, interprets each item as a key-value pair where the key and value are separated by the given separator character, and adds the pair's value to the record field named after the pair's key.
SplitKeyValueBuilder() - Constructor for class org.kitesdk.morphline.stdlib.SplitKeyValueBuilder
start() - Method in class org.kitesdk.minicluster.FlumeService
start() - Method in class org.kitesdk.minicluster.HBaseService
start() - Method in class org.kitesdk.minicluster.HdfsService
start() - Method in class org.kitesdk.minicluster.HiveService
start() - Method in class org.kitesdk.minicluster.MiniCluster: Starts the services in order, passing the previous service's modified Configuration object to the next.
start() - Method in interface org.kitesdk.minicluster.Service: Start the service.
start() - Method in class org.kitesdk.minicluster.ZookeeperService
startMetaStore(String, int, HiveConf) - Method in class org.kitesdk.minicluster.HiveService
StartReportingMetricsToCSVBuilder - Class in org.kitesdk.morphline.stdlib: Command that starts periodically appending the metrics of the com.codahale.metrics.MetricRegistry of the morphline context to a set of CSV files, configured via a com.codahale.metrics.CsvReporter.Builder.
StartReportingMetricsToCSVBuilder() - Constructor for class org.kitesdk.morphline.stdlib.StartReportingMetricsToCSVBuilder
StartReportingMetricsToHTTPBuilder - Class in org.kitesdk.morphline.metrics.servlets: Command that exposes liveness status, health check status, metrics state and thread dumps via a set of HTTP URLs served by Jetty, using the AdminServlet.
StartReportingMetricsToHTTPBuilder() - Constructor for class org.kitesdk.morphline.metrics.servlets.StartReportingMetricsToHTTPBuilder
StartReportingMetricsToJMXBuilder - Class in org.kitesdk.morphline.stdlib: Command that starts publishing the metrics of the com.codahale.metrics.MetricRegistry of the morphline context to JMX, configured via a com.codahale.metrics.JmxReporter.Builder.
StartReportingMetricsToJMXBuilder() - Constructor for class org.kitesdk.morphline.stdlib.StartReportingMetricsToJMXBuilder
StartReportingMetricsToSLF4JBuilder - Class in org.kitesdk.morphline.stdlib: Command that starts periodically logging the metrics of the com.codahale.metrics.MetricRegistry of the morphline context to SLF4j, configured via a com.codahale.metrics.Slf4jReporter.Builder.
StartReportingMetricsToSLF4JBuilder() - Constructor for class org.kitesdk.morphline.stdlib.StartReportingMetricsToSLF4JBuilder
stop() - Method in class org.kitesdk.minicluster.FlumeService
stop() - Method in class org.kitesdk.minicluster.HBaseService
stop() - Method in class org.kitesdk.minicluster.HdfsService
stop() - Method in class org.kitesdk.minicluster.HiveService
stop() - Method in class org.kitesdk.minicluster.MiniCluster: Stops the services in reverse of their run order.
stop() - Method in interface org.kitesdk.minicluster.Service: Stop the service.
stop() - Method in class org.kitesdk.minicluster.ZookeeperService
StripNonCharSolrContentHandlerFactory - Class in org.kitesdk.morphline.solrcell: SolrContentHandler and associated factory that strips non-characters anhd trims on output.
StripNonCharSolrContentHandlerFactory(Collection<String>) - Constructor for class org.kitesdk.morphline.solrcell.StripNonCharSolrContentHandlerFactory
SUPPORTED_MIME_TYPES - Static variable in class org.kitesdk.morphline.stdio.AbstractParser
sync() - Method in interface org.kitesdk.data.Syncable: Ensure that data has been synced to disk on all replica data nodes.
Syncable - Interface in org.kitesdk.data: A writer that can guarantee data is persisted to disk.

T

TASK_CONTEXT_SETTING_NAME - Static variable in class org.kitesdk.morphline.api.TypedSettings
TaskUtil - Class in org.kitesdk.tools
TaskUtil() - Constructor for class org.kitesdk.tools.TaskUtil
TaskUtil.ConfigBuilder - Class in org.kitesdk.tools
TIMESTAMP - Static variable in class org.kitesdk.morphline.base.Fields
to(String, Comparable) - Method in interface org.kitesdk.data.RefinableView: Creates a sub-View, restricted to entities whose name field is less than or equal to the given value.
ToAvroBuilder - Class in org.kitesdk.morphline.avro: Command that converts a morphline record to an Avro record.
ToAvroBuilder() - Constructor for class org.kitesdk.morphline.avro.ToAvroBuilder
ToAvroMapBuilder - Class in org.kitesdk.morphline.avro: Command that converts a morphline record to an Avro record that contains a Map with string keys and array values where the array values can be null, boolean, int, long, float, double, string, bytes.
ToAvroMapBuilder() - Constructor for class org.kitesdk.morphline.avro.ToAvroMapBuilder
toBefore(String, Comparable) - Method in interface org.kitesdk.data.RefinableView: Creates a sub-View, restricted to entities whose name field is less than the given value.
ToByteArrayBuilder - Class in org.kitesdk.morphline.stdlib: Command that converts the Java objects in a given field via Object.toString() to their string representation, and then via String.getBytes(Charset) to their byte array representation.
ToByteArrayBuilder() - Constructor for class org.kitesdk.morphline.stdlib.ToByteArrayBuilder
toConfig(String) - Method in class org.kitesdk.morphline.solr.SolrLocator
TokenizeTextBuilder - Class in org.kitesdk.morphline.solr: A command that uses the embedded Solr/Lucene Analyzer library to generate tokens from a text string, without sending data to a Solr server.
TokenizeTextBuilder() - Constructor for class org.kitesdk.morphline.solr.TokenizeTextBuilder
toString() - Method in class org.kitesdk.data.ColumnMapping
toString(boolean) - Method in class org.kitesdk.data.ColumnMapping
toString() - Method in enum org.kitesdk.data.CompressionType
toString() - Method in class org.kitesdk.data.DatasetDescriptor
toString() - Method in class org.kitesdk.data.FieldMapping
toString() - Method in class org.kitesdk.data.Format
toString() - Method in class org.kitesdk.data.Key
toString() - Method in class org.kitesdk.data.PartitionStrategy
toString(boolean) - Method in class org.kitesdk.data.PartitionStrategy
toString() - Method in class org.kitesdk.morphline.api.Record
toString() - Method in class org.kitesdk.morphline.solr.SolrLocator
ToStringBuilder - Class in org.kitesdk.morphline.stdlib: Command that converts the Java objects in a given field via Object.toString() to their string representation, and optionally also applies String.trim().
ToStringBuilder() - Constructor for class org.kitesdk.morphline.stdlib.ToStringBuilder
transformFieldValue(Object) - Method in class org.kitesdk.morphline.stdlib.AbstractFieldTransformCommand: Transforms the given input value to some output value
TransformTask<S,T> - Class in org.kitesdk.tools
TransformTask(View<S>, View<T>, DoFn<S, T>) - Constructor for class org.kitesdk.tools.TransformTask
TransformTask.CheckEntityClass<E> - Class in org.kitesdk.tools
TransformTask.CheckEntityClass(Class<?>) - Constructor for class org.kitesdk.tools.TransformTask.CheckEntityClass
TranslateBuilder - Class in org.kitesdk.morphline.stdlib: Command that examines each string value in a given field and replaces it with the replacement value defined in a given dictionary aka hash table.
TranslateBuilder() - Constructor for class org.kitesdk.morphline.stdlib.TranslateBuilder
TrimSolrContentHandlerFactory - Class in org.kitesdk.morphline.solrcell: SolrContentHandler and associated factory that trims field values on output.
TrimSolrContentHandlerFactory(Collection<String>) - Constructor for class org.kitesdk.morphline.solrcell.TrimSolrContentHandlerFactory
TryRulesBuilder - Class in org.kitesdk.morphline.stdlib: A tryRules command consists of zero or more rules.
TryRulesBuilder() - Constructor for class org.kitesdk.morphline.stdlib.TryRulesBuilder
TypedSettings - Class in org.kitesdk.morphline.api: A Map with convenient typed accessors for reading values.
TypeNotFoundException - Exception in org.kitesdk.data: Exception thrown to indicate that there is a problem finding a given type.
TypeNotFoundException(String) - Constructor for exception org.kitesdk.data.TypeNotFoundException
TypeNotFoundException(String, Throwable) - Constructor for exception org.kitesdk.data.TypeNotFoundException
TypeNotFoundException(Throwable) - Constructor for exception org.kitesdk.data.TypeNotFoundException

U

UnknownFormatException - Exception in org.kitesdk.data: Exception thrown when a Dataset is in an unknown format.
UnknownFormatException(String) - Constructor for exception org.kitesdk.data.UnknownFormatException
UnknownFormatException(String, Throwable) - Constructor for exception org.kitesdk.data.UnknownFormatException
UnknownFormatException(Throwable) - Constructor for exception org.kitesdk.data.UnknownFormatException
UnpackBuilder - Class in org.kitesdk.morphline.tika.decompress: Command that unpacks the first attachment.
UnpackBuilder() - Constructor for class org.kitesdk.morphline.tika.decompress.UnpackBuilder
unregisterFromNotification(URI, String) - Method in class org.kitesdk.data.oozie.KiteURIHandler
update(URI, DatasetDescriptor, Class<E>) - Static method in class org.kitesdk.data.Datasets: Update a Dataset for the given dataset or view URI.
update(URI, DatasetDescriptor) - Static method in class org.kitesdk.data.Datasets: Update a Dataset for the given dataset or view URI.
update(String, DatasetDescriptor, Class<E>) - Static method in class org.kitesdk.data.Datasets: Update a Dataset for the given dataset or view URI string.
update(String, DatasetDescriptor) - Static method in class org.kitesdk.data.Datasets: Update a Dataset for the given dataset or view URI string.
URIBuilder - Class in org.kitesdk.data: Builds dataset and view URIs
URIBuilder(String, String, String) - Constructor for class org.kitesdk.data.URIBuilder: Constructs a builder based on the given repository URI and dataset name.
URIBuilder(URI, String, String) - Constructor for class org.kitesdk.data.URIBuilder: Constructs a builder based on the given repository URI and dataset name.
URIBuilder(String) - Constructor for class org.kitesdk.data.URIBuilder: Constructs a builder based on the given dataset or view URI string.
URIBuilder(URI) - Constructor for class org.kitesdk.data.URIBuilder: Constructs a builder based on the given dataset or view URI.
USE_IP - Static variable in class org.kitesdk.morphline.stdlib.AddLocalHostBuilder
UserAgentBuilder - Class in org.kitesdk.morphline.useragent: Command that parses user agent strings and returns structured higher level data like user agent family, operating system, version, and device type, using the underlying API and regexes.yaml BrowserScope database from https://github.com/tobie/ua-parser.
UserAgentBuilder() - Constructor for class org.kitesdk.morphline.useragent.UserAgentBuilder

V

validate(String) - Method in class org.kitesdk.data.oozie.KiteURIHandler
validateArguments() - Method in class org.kitesdk.morphline.base.AbstractCommand: Helper that checks if the user provided configuration parameters are valid.
validateArguments(Config) - Method in class org.kitesdk.morphline.base.Configs
validateEnum(Config, String, Class<T>, T...) - Method in class org.kitesdk.morphline.base.Validator: Validates that an enum of the given type with the given value exists, and that this enum is contained in the given list of permitted choices; finally returns that enum object.
validateRange(Config, T, Comparable<T>, Comparable<T>) - Method in class org.kitesdk.morphline.base.Validator: Validates that the given value is contained in the range [min, max]
ValidationException - Exception in org.kitesdk.data: Exception thrown to indicate that there was a problem parsing or validating a schema, partition strategy, or column mapping.
ValidationException(String) - Constructor for exception org.kitesdk.data.ValidationException
ValidationException(Throwable) - Constructor for exception org.kitesdk.data.ValidationException
ValidationException(String, Throwable) - Constructor for exception org.kitesdk.data.ValidationException
Validator<T> - Class in org.kitesdk.morphline.base: Simple helper to validate user configurable parameters.
Validator() - Constructor for class org.kitesdk.morphline.base.Validator
valueOf(String) - Static method in enum org.kitesdk.data.CompressionType: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.kitesdk.data.FieldMapping.MappingType: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.kitesdk.data.mapreduce.DatasetKeyOutputFormat.WriteMode: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.kitesdk.morphline.base.Notifications.LifecycleEvent: Returns the enum constant of this type with the specified name.
values() - Static method in enum org.kitesdk.data.CompressionType: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.kitesdk.data.FieldMapping.MappingType: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.kitesdk.data.mapreduce.DatasetKeyOutputFormat.WriteMode: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.kitesdk.morphline.base.Notifications.LifecycleEvent: Returns an array containing the constants of this enum type, in the order they are declared.
version(String) - Method in class org.kitesdk.data.ColumnMapping.Builder: Adds an OCC version mapping for the record field name.
version(String) - Static method in class org.kitesdk.data.FieldMapping
View<E> - Interface in org.kitesdk.data: A View is a subset of a Dataset.
VIEW_SCHEME - Static variable in class org.kitesdk.data.URIBuilder

W

with(String, Object...) - Method in interface org.kitesdk.data.RefinableView: Creates a sub-View, restricted to entities whose name field is equal to any of the given values.
with(String, Object) - Method in class org.kitesdk.data.URIBuilder: Adds a view constraint equivalent to RefinableView.with(String, Object...)
withSchema(Schema) - Method in class org.kitesdk.data.mapreduce.DatasetKeyInputFormat.ConfigBuilder: Sets the expected schema to use when reading records from the Dataset.
withType(Class<E>) - Method in class org.kitesdk.data.mapreduce.DatasetKeyInputFormat.ConfigBuilder: Sets the entity Class that the input Dataset should produce.
withType(Class<E>) - Method in class org.kitesdk.data.mapreduce.DatasetKeyOutputFormat.ConfigBuilder: Sets the entity Class that will be output by the Job.
WORK_DIR_KEY - Static variable in class org.kitesdk.minicluster.MiniCluster
workDir(String) - Method in class org.kitesdk.minicluster.MiniCluster.Builder
write(E) - Method in interface org.kitesdk.data.DatasetWriter: Write an entity to the underlying dataset.
WriteAvroToByteArrayBuilder - Class in org.kitesdk.morphline.avro: Command that serializes the Avro records contained in the _attachment_body field into a byte array and replaces the _attachment_body field with that byte array.
WriteAvroToByteArrayBuilder() - Constructor for class org.kitesdk.morphline.avro.WriteAvroToByteArrayBuilder
writeTo(URI) - Method in class org.kitesdk.data.mapreduce.DatasetKeyOutputFormat.ConfigBuilder: Adds configuration for DatasetKeyOutputFormat to write to the given dataset or view URI.
writeTo(View<?>) - Method in class org.kitesdk.data.mapreduce.DatasetKeyOutputFormat.ConfigBuilder: Adds configuration for DatasetKeyOutputFormat to write to the given Dataset or View instance.
writeTo(String) - Method in class org.kitesdk.data.mapreduce.DatasetKeyOutputFormat.ConfigBuilder: Adds configuration for DatasetKeyOutputFormat to write to the given dataset or view URI string.

X

XQueryBuilder - Class in org.kitesdk.morphline.saxon: Command that parses an InputStream that contains an XML document and runs the given XQuery over the XML document.
XQueryBuilder() - Constructor for class org.kitesdk.morphline.saxon.XQueryBuilder
XSLTBuilder - Class in org.kitesdk.morphline.saxon: Command that parses an InputStream that contains an XML document and runs the given XSL Transform over the XML document.
XSLTBuilder() - Constructor for class org.kitesdk.morphline.saxon.XSLTBuilder

Y

year(String, String) - Method in class org.kitesdk.data.PartitionStrategy.Builder: Configure a partitioner for extracting the year from a timestamp field.
year(String) - Method in class org.kitesdk.data.PartitionStrategy.Builder: Configure a partitioner for extracting the year from a timestamp field.

Z

ZK_PORT_KEY - Static variable in class org.kitesdk.minicluster.MiniCluster
zkPort(int) - Method in class org.kitesdk.minicluster.MiniCluster.Builder
ZookeeperService - Class in org.kitesdk.minicluster: A Zookeeper minicluster service implementation.
ZookeeperService() - Constructor for class org.kitesdk.minicluster.ZookeeperService

A B C D E F G H I J K L M N O P R S T U V W X Y Z