Index

A

A3 - Enum constant in enum class com.northconcepts.datapipeline.microsoft.word.MicrosoftWordWriter.PageSize

 

A3 - Enum constant in enum class com.northconcepts.datapipeline.pdf.PdfWriter.PageSize

 

A4 - Enum constant in enum class com.northconcepts.datapipeline.microsoft.word.MicrosoftWordWriter.PageSize

 

A4 - Enum constant in enum class com.northconcepts.datapipeline.pdf.PdfWriter.PageSize

 

A5 - Enum constant in enum class com.northconcepts.datapipeline.microsoft.word.MicrosoftWordWriter.PageSize

 

A5 - Enum constant in enum class com.northconcepts.datapipeline.pdf.PdfWriter.PageSize

 

abs(Number) - Static method in class com.northconcepts.datapipeline.jsonata.Functions

Absolute value of a number

AbstractFieldMapping - Class in com.northconcepts.datapipeline.foundations.datamapping

Base class for field mappings that set one target field, with an optional condition, default value expression and type conversion.

AbstractFieldMapping - Enum constant in enum class com.northconcepts.datapipeline.foundations.datamapping.DataMappingPartType

 

AbstractFieldMapping() - Constructor for class com.northconcepts.datapipeline.foundations.datamapping.AbstractFieldMapping

 

AbstractJob - Class in com.northconcepts.datapipeline.job

Used to run, pause, and cancel Runnables.

AbstractJob() - Constructor for class com.northconcepts.datapipeline.job.AbstractJob

 

AbstractJobCallback<R,W> - Class in com.northconcepts.datapipeline.job

A default, abstract implementation of JobCallback.

AbstractJobCallback() - Constructor for class com.northconcepts.datapipeline.job.AbstractJobCallback

 

AbstractPipeline - Class in com.northconcepts.datapipeline.foundations.pipeline

Base class for declarative pipelines that read records from a PipelineInput, process them and write them to a PipelineOutput.

AbstractPipeline() - Constructor for class com.northconcepts.datapipeline.foundations.pipeline.AbstractPipeline

 

AbstractReader - Class in com.northconcepts.datapipeline.core

Abstract super-class, with some common logic, for reading records.

AbstractReader() - Constructor for class com.northconcepts.datapipeline.core.AbstractReader

 

AbstractTwitterReader - Class in com.northconcepts.datapipeline.twitter2

Base class for Twitter API v2 readers; each page from AbstractTwitterReader.search() yields one record per data element.

AbstractTwitterReader(TwitterCredentials) - Constructor for class com.northconcepts.datapipeline.twitter2.AbstractTwitterReader

 

AbstractWriter - Class in com.northconcepts.datapipeline.core

Abstract super-class, with some common logic, for writing records.

AbstractWriter() - Constructor for class com.northconcepts.datapipeline.core.AbstractWriter

 

accept(Record) - Method in class com.northconcepts.datapipeline.group.AggregateReader.AggregateOperation

Deprecated.

Updates this operation's result with a record passing through the reader.

accept(ZipFile, ZipEntry) - Method in class com.northconcepts.datapipeline.filesystem.zip.RegexZipEntryFilter

 

accept(ZipFile, ZipEntry) - Method in class com.northconcepts.datapipeline.filesystem.zip.WildcardZipEntryFilter

 

accept(ZipFile, ZipEntry) - Method in interface com.northconcepts.datapipeline.filesystem.zip.ZipEntryFilter

 

ACCESS_KEY - Static variable in class com.northconcepts.datapipeline.security.Credentials

 

accessToken - Variable in class com.northconcepts.datapipeline.twitter.TwitterProvider

 

accessToken - Variable in class com.northconcepts.datapipeline.twitter.TwitterStreamProvider

 

AccessToken(String) - Constructor for class com.northconcepts.datapipeline.shopify.client.ShopifyClient.AccessToken

 

accessTokenSecret - Variable in class com.northconcepts.datapipeline.twitter.TwitterProvider

 

accessTokenSecret - Variable in class com.northconcepts.datapipeline.twitter.TwitterStreamProvider

 

ActionGroup - Enum Class in com.northconcepts.datapipeline.foundations.pipeline.action

Categories of built-in PipelineActions (transform, convert, aggregate, filter and validate), each holding a default instance of the actions it lists.

ACTIVE - Enum constant in enum class com.northconcepts.datapipeline.jira.JiraSprintReader.SprintState

 

ACTIVE - Enum constant in enum class com.northconcepts.datapipeline.shopify.client.ProductStatus

 

ACTIVE_LOCAL - Enum constant in enum class com.northconcepts.datapipeline.filesystem.ftp.DataConnectionMode

Data transfer mode where the server connects to the client's data port.

add() - Method in class com.northconcepts.datapipeline.meter.Meter

Adds one unit to the count.

add(boolean, boolean, String, Object...) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.QueryCriteria

ANDs (if andConjunction is true) or ORs a condition with its parameter values, first if first is true, and returns the root part.

add(boolean, String, Object...) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.QueryCriteria

ANDs (if andConjunction is true) or ORs a condition with its parameter values and returns the root part.

add(int, Record) - Method in class com.northconcepts.datapipeline.core.ConcurrentRecordList

 

add(int, Record) - Method in class com.northconcepts.datapipeline.core.RecordList

Inserts a record at the specified position in this list, shifting any record at or after index to the right.

add(long) - Method in class com.northconcepts.datapipeline.meter.Meter

Adds the given number of units to the count.

add(DataEndpoint...) - Method in class com.northconcepts.datapipeline.core.DataEndpointGroup

Adds endpoints to this group; DataEndpointGroup.open() opens them in the order added and DataEndpointGroup.close() closes them in reverse order.

add(DataReader) - Method in class com.northconcepts.datapipeline.core.SequenceReader

Appends a reader to the sequence; must be called before SequenceReader.open().

add(DataReader...) - Method in class com.northconcepts.datapipeline.core.AsyncMultiReader

Adds source readers, each read on its own thread that also opens and closes it; must be called before AsyncMultiReader.open().

add(DataReader, String) - Method in class com.northconcepts.datapipeline.filter.rule.ValueMatch

Adds the named field's value from every record in source, which is opened, read to the end and closed here.

add(DataWriter...) - Method in class com.northconcepts.datapipeline.core.MultiWriter

Adds target writers; must be called before MultiWriter.open().

add(FieldList) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.QueryOrder

Appends the fields in ascending order; null is ignored.

add(Record) - Method in class com.northconcepts.datapipeline.buffer.RecordBuffer

Appends the record and updates the last-added time; only allowed while the buffer is open.

add(Record) - Method in class com.northconcepts.datapipeline.group.Window

Adds the record to the group(s) selected by its group-by field values; only allowed while this window is open.

add(Record) - Method in class com.northconcepts.datapipeline.memory.MemoryReader

Appends the record to the underlying list, which is the caller's list when one was passed to the constructor.

add(Record) - Method in class com.northconcepts.datapipeline.meter.RecordMeter

Counts the record according to the measure (its estimated size in bytes or one) and returns it; null is ignored.

add(Record...) - Method in class com.northconcepts.datapipeline.core.ConcurrentRecordList

 

add(Record...) - Method in class com.northconcepts.datapipeline.core.RecordList

Appends all the specified records to the end of this list.

add(FieldFilterRule...) - Method in class com.northconcepts.datapipeline.filter.rule.OrRule

 

add(Filter...) - Method in class com.northconcepts.datapipeline.filter.FilteringReader

Adds filters that every record must pass to be kept; they are applied in the order added.

add(AggregateGroupFieldsAction.GroupByField) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.aggregate.AggregateGroupFieldsAction

Adds a field to group by or to aggregate, depending on its operator.

add(CopyFieldsAction.FieldMapping) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.transform.CopyFieldsAction

 

add(AggregateReader.AggregateOperation...) - Method in class com.northconcepts.datapipeline.group.AggregateReader

Deprecated.

Adds operations to apply to each record; an operation replaces any existing one with the same name and field.

add(GroupOperation<?>) - Method in class com.northconcepts.datapipeline.group.GroupByReader

 

add(QueryCriteriaPart) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.AndPart

 

add(QueryCriteriaPart) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.ConjunctivePart

 

add(QueryCriteriaPart) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.OrPart

 

add(QueryCriteriaPart) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.QueryCriteriaPart

 

add(Select...) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.Union

Appends queries to the union; at least one must be given.

add(BasicFieldTransformer.Operation...) - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer

Appends operations that run, in the order added, on each named field.

add(Transformer...) - Method in class com.northconcepts.datapipeline.transform.TransformingReader

Appends transformers; each record passes through them in the order added.

add(Transformer...) - Method in class com.northconcepts.datapipeline.transform.TransformingWriter

Appends transformers; each record passes through them in the order added.

add(Class<?>, String, String...) - Static method in class com.northconcepts.datapipeline.core.Functions

Creates aliases for one or more public, static methods on the specified class using their simple names (for example java.lang.Math.abs() will be aliased as abs).

add(Object[], Object) - Method in class com.northconcepts.datapipeline.transform.lookup.BasicLookup

Adds a result record for the composite key with value as its only field; requires exactly one result field.

add(Object[], Object[]) - Method in class com.northconcepts.datapipeline.transform.lookup.BasicLookup

Adds a result record for the composite key with one value per result field, in order.

add(Object, Object) - Method in class com.northconcepts.datapipeline.transform.lookup.BasicLookup

Adds a result record for the key with value as its only field; requires exactly one result field.

add(Object, Object[]) - Method in class com.northconcepts.datapipeline.transform.lookup.BasicLookup

Adds a result record for the key with one value per result field, in order.

add(String) - Method in class com.northconcepts.datapipeline.core.RecordComparator

Adds an ascending comparison on the given field name or FieldPath expression.

add(String) - Method in class com.northconcepts.datapipeline.core.SortingReader

Adds an ascending sort on the given field name or FieldPath expression, after any fields already added.

add(String) - Method in class com.northconcepts.datapipeline.csv.CommaSeparatedValues

 

add(String) - Method in class com.northconcepts.datapipeline.foundations.core.Tags

 

add(String) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.validate.ValidateFieldsExistsAction

 

add(String) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.validate.ValidateFieldsNotNullAction

 

add(String...) - Method in class com.northconcepts.datapipeline.core.FieldList

Appends all the specified fields to the end of this list.

add(String...) - Method in class com.northconcepts.datapipeline.filter.rule.PatternMatch

 

add(String...) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.convert.ConvertDateTimeToStringAction

 

add(String...) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.convert.ConvertNumberToStringAction

 

add(String...) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.convert.ConvertStringToBooleanAction

 

add(String...) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.convert.ConvertStringToDateTimeAction

 

add(String...) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.convert.ConvertStringToNumberAction

 

add(String...) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.convert.ConvertValueToStringAction

 

add(String...) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.filter.FilterFieldExistsAction

 

add(String...) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.filter.FilterFieldNotNullAction

 

add(String...) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.transform.RemoveDuplicatesAction

 

add(String...) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.transform.SelectArrangeFieldsAction

 

add(String...) - Method in class com.northconcepts.datapipeline.jdbc.sql.insert.Insert

Adds columns with null parameter values to the current (last) row.

add(String...) - Method in class com.northconcepts.datapipeline.jdbc.sql.insert.InsertRow

Adds columns with null parameter values; a null array is ignored.

add(String...) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.QueryGrouping

 

add(String...) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.QueryOrder

Appends the fields in ascending order.

add(String...) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.QuerySelection

 

add(String...) - Method in class com.northconcepts.datapipeline.transform.RemoveFields

Adds more fields to remove.

add(String...) - Method in class com.northconcepts.datapipeline.transform.SelectFields

Appends fields to select, placed after those already added.

add(String, boolean) - Method in class com.northconcepts.datapipeline.core.RecordComparator

Adds an ascending or descending comparison on the given field name or FieldPath expression.

add(String, boolean) - Method in class com.northconcepts.datapipeline.core.SortingReader

Adds an ascending or descending sort on the given field name or FieldPath expression, after any fields already added.

add(String, boolean) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.transform.SortFieldsAction

 

add(String, boolean) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.QueryOrder

 

add(String, boolean, Boolean) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.QueryOrder

Appends a field in the given order, adding NULLS FIRST or NULLS LAST unless nullsFirst is null.

add(String, boolean, Collator) - Method in class com.northconcepts.datapipeline.core.RecordComparator

Adds a comparison on the given field name or FieldPath expression that uses the collator for string values.

add(String, boolean, Collator) - Method in class com.northconcepts.datapipeline.core.SortingReader

Adds a sort on the given field name or FieldPath expression that uses the collator for string values, after any fields already added.

add(String, int) - Method in class com.northconcepts.datapipeline.filter.rule.PatternMatch

Adds a regular expression compiled with the given Pattern flags, such as Pattern.CASE_INSENSITIVE.

add(String, ConvertNullToValueAction.FieldType, String) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.convert.ConvertNullToValueAction

Replaces nulls in the field with the value converted to the given type, or evaluated for EXPRESSION; a blank value is ignored.

add(String, AddFieldsAction.FieldType, String) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.transform.AddFieldsAction

Sets the field to the value converted to the given type, or evaluated for EXPRESSION; for the other types a blank value sets a typed null.

add(String, CredentialsResolver) - Method in class com.northconcepts.datapipeline.security.CredentialsResolverRegistry

Registers the resolver under the given id, replacing any resolver already registered with that id.

add(String, Class<?>, String) - Static method in class com.northconcepts.datapipeline.core.Functions

Creates a new alias for a public, static method on the specified class.

add(String, Object) - Method in class com.northconcepts.datapipeline.jdbc.sql.insert.Insert

Adds a column and its parameter value to the current (last) row.

add(String, Object) - Method in class com.northconcepts.datapipeline.jdbc.sql.insert.InsertRow

 

add(String, Object) - Method in class com.northconcepts.datapipeline.sql.h2.Insert

Adds a column-value pair to the current row.

add(String, Object) - Method in class com.northconcepts.datapipeline.sql.h2.InsertRow

Adds a column-value pair to this row.

add(String, Object) - Method in class com.northconcepts.datapipeline.sql.h2.Upsert

Adds a column-value pair to the current row.

add(String, Object) - Method in class com.northconcepts.datapipeline.sql.mysql.Insert

Adds a column value (an SQL literal, written as-is) to the current row; only the first row's column names are used.

add(String, Object) - Method in class com.northconcepts.datapipeline.sql.mysql.InsertRow

 

add(String, Object) - Method in class com.northconcepts.datapipeline.sql.mysql.Upsert

Adds a column value (an SQL literal, written as-is) to the current row; only the first row's column names are used.

add(String, Object) - Method in class com.northconcepts.datapipeline.sql.postgresql.Insert

Adds a column value (an SQL literal, written as-is) to the current row; only the first row's column names are used.

add(String, Object) - Method in class com.northconcepts.datapipeline.sql.postgresql.InsertRow

 

add(String, Object) - Method in class com.northconcepts.datapipeline.sql.postgresql.Upsert

Adds a column value (an SQL literal, written as-is) to the current row; only the first row's column names are used.

add(String, Object...) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.AndPart

 

add(String, Object...) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.ConjunctivePart

 

add(String, Object...) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.OrPart

 

add(String, Object...) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.QueryCriteriaPart

Appends a condition and its parameter values as a child part.

add(String, String) - Static method in class com.northconcepts.datapipeline.core.Functions

Creates a new alias for a fully-qualified, public, static method.

add(String, String) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.transform.CopyFieldsAction

Copies the source field to the target field, leaving the target unchanged if it already exists.

add(String, String) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.transform.RenameFieldsAction

Renames the source field to the target name; a blank or identical target leaves the field unchanged.

add(String, String) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.transform.SortFieldsAction

Adds a sort field with the direction "ascending" or "descending"; any other non-null value sorts descending, while null is not supported.

add(String, String) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.validate.ValidateFieldsMatchPatternAction

Sets the regular expression the field's whole value must match, replacing any previous pattern for it.

add(String, String...) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.filter.FilterFieldMatchesPatternAction

Requires each of the given fields to match the regular expression, replacing any pattern already set for them.

add(String, String, boolean) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.transform.CopyFieldsAction

Copies the source field to the target field; overwrite replaces an existing target instead of leaving it unchanged.

add(Collection<String>) - Method in class com.northconcepts.datapipeline.core.FieldList

Appends all the fields in the specified collection to the end of this list.

add(Collection<String>) - Method in class com.northconcepts.datapipeline.transform.RemoveFields

Adds more fields to remove; a null collection is ignored.

add(Collection<String>) - Method in class com.northconcepts.datapipeline.transform.SelectFields

Appends fields to select, placed after those already added; a null collection is ignored.

add(T) - Method in class com.northconcepts.datapipeline.json.builder.JsonNode

Appends the node as a child and returns the added node.

add(T) - Method in class com.northconcepts.datapipeline.xml.builder.XmlNodeContainer

Appends the node as a child and returns the added node.

add(T...) - Method in class com.northconcepts.datapipeline.filter.rule.ValueMatch

 

addAction(PipelineAction) - Method in enum class com.northconcepts.datapipeline.foundations.pipeline.action.ActionGroup

 

addAction(PipelineAction) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.CompositePipelineAction

Appends a nested action and attaches it to this action's pipeline.

addAction(PipelineAction) - Method in class com.northconcepts.datapipeline.foundations.pipeline.Pipeline

Appends an action, attaches it to this pipeline and clears the redo history.

addAction(Integer, PipelineAction) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.CompositePipelineAction

Inserts a nested action at the given 0-based index (or appends it if the index is null) and attaches it to this action's pipeline.

addAction(Integer, PipelineAction) - Method in class com.northconcepts.datapipeline.foundations.pipeline.Pipeline

Inserts an action at the given 0-based index (or appends it if the index is null), attaches it to this pipeline and clears the redo history.

addAll(ArrayValue) - Method in class com.northconcepts.datapipeline.core.ArrayValue

Appends cloned copies of all elements from the specified array to this array.

addAll(DataReader) - Method in class com.northconcepts.datapipeline.core.ConcurrentRecordList

 

addAll(DataReader) - Method in class com.northconcepts.datapipeline.core.RecordList

Writes all the records in the specified reader to the end of this list.

addAll(RecordList) - Method in class com.northconcepts.datapipeline.core.RecordList

Appends all the records in the specified recordList to the end of this list.

addAll(Class<?>, boolean, String...) - Static method in class com.northconcepts.datapipeline.core.Functions

Creates aliases either for all public, static methods on the specified class and superclass using their simple names (for example java.lang.Math.abs() will be aliased as abs) or just the specified methods.

addAll(Collection<?>) - Method in class com.northconcepts.datapipeline.core.ArrayValue

Adds all elements from the specified collection to this array.

addAll(Collection<? extends Number>) - Method in class com.northconcepts.datapipeline.jsonata.Utils.RangeList

 

addAll(Collection<Record>) - Method in class com.northconcepts.datapipeline.core.RecordList

Appends all the records in the specified collection to the end of this list.

addAll(Collection<String>) - Method in class com.northconcepts.datapipeline.csv.CommaSeparatedValues

 

addBatch() - Method in interface com.northconcepts.datapipeline.jdbc.insert.IInsert

Adds the applied values to the batch; called instead of IInsert.executeUpdate() when the writer is batching.

addBatch() - Method in class com.northconcepts.datapipeline.jdbc.insert.MultiRowPreparedStatementInsert

 

addBatch() - Method in class com.northconcepts.datapipeline.jdbc.insert.MultiRowStatementInsert

 

addBatch() - Method in class com.northconcepts.datapipeline.jdbc.insert.PreparedStatementInsert

 

addBatch() - Method in class com.northconcepts.datapipeline.jdbc.upsert.GenericUpsert

 

addBatch() - Method in interface com.northconcepts.datapipeline.jdbc.upsert.IUpsert

Adds the applied values to the batch; called instead of IUpsert.executeUpdate() when the writer is batching.

addBatch() - Method in class com.northconcepts.datapipeline.jdbc.upsert.MergeUpsert

 

addBatch() - Method in class com.northconcepts.datapipeline.jdbc.upsert.MySqlUpsert

 

addBatch() - Method in class com.northconcepts.datapipeline.jdbc.upsert.OracleUpsert

 

addBatch() - Method in class com.northconcepts.datapipeline.jdbc.upsert.PostgreSqlUpsert

 

addBatch() - Method in class com.northconcepts.datapipeline.jdbc.upsert.SybaseUpsert

 

addBatch() - Method in class com.northconcepts.datapipeline.jdbc.upsert.VariableFieldsUpsert

 

addBlacklistPrefix(String...) - Static method in class com.northconcepts.datapipeline.core.Functions

Prevents methods whose fully-qualified name starts with any of the supplied prefixes from executing.

addChild(int, String) - Method in class com.northconcepts.datapipeline.foundations.pipeline.tree.TreeNode

Inserts a new child with the given name at the 0-based index and returns the child.

addChild(Diff<?>) - Method in class com.northconcepts.datapipeline.foundations.difference.Diff

Adds a child diff, changing this diff's type from DiffType.NONE to DiffType.CHANGED if the child is not NONE.

addChild(TreeNode) - Method in class com.northconcepts.datapipeline.foundations.pipeline.tree.TreeNode

Moves the node from its current parent to the end of this node's children and returns it.

addChild(String) - Method in class com.northconcepts.datapipeline.foundations.pipeline.tree.TreeNode

Appends a new child with the given name and returns the child.

addChildProperty(DiffType, String, Object, Object) - Method in class com.northconcepts.datapipeline.foundations.difference.Diff

Adds a PropertyDiff child built from the arguments, updating this diff's type as Diff.addChild(Diff) does.

addColumn(JdbcQueryColumn) - Method in class com.northconcepts.datapipeline.foundations.jdbc.JdbcQuery

 

addColumn(JdbcTableColumn) - Method in class com.northconcepts.datapipeline.foundations.jdbc.JdbcTable

Adds the column and sets this as its table.

addColumn(CreateTableColumn) - Method in class com.northconcepts.datapipeline.sql.h2.CreateTable

Adds a column to this table.

addColumn(CreateTableColumn) - Method in class com.northconcepts.datapipeline.sql.mysql.CreateTable

 

addColumn(CreateTableColumn) - Method in class com.northconcepts.datapipeline.sql.postgresql.CreateTable

 

addCommonPatterns() - Method in class com.northconcepts.datapipeline.foundations.time.DateTimePatternDetector

Adds the built-in common patterns (new detectors already have them); duplicates are ignored.

addCondition(DecisionTableCondition) - Method in class com.northconcepts.datapipeline.foundations.decisiontable.DecisionTableRule

 

addCondition(String) - Method in class com.northconcepts.datapipeline.foundations.decisiontable.DecisionTableRule

Adds a condition without a variable, so its expression should not use the ? placeholder.

addCondition(String, String) - Method in class com.northconcepts.datapipeline.foundations.decisiontable.DecisionTableRule

Adds a condition whose expression can use ? for variable, as in ? > 0.

addCondition(Collection<DecisionTableCondition>) - Method in class com.northconcepts.datapipeline.foundations.decisiontable.DecisionTableRule

 

addCondition(Collection<LogicalExpression>) - Method in class com.northconcepts.datapipeline.foundations.datamapping.DataMapping

Adds conditions that must all be true for a record to be mapped; otherwise the result has no target record.

addCondition(LogicalExpression) - Method in class com.northconcepts.datapipeline.foundations.datamapping.DataMapping

Adds a condition that must be true for a record to be mapped; otherwise the result has no target record.

addConfig(String, String) - Method in class com.northconcepts.datapipeline.orc.input.OrcPipelineInput

Adds a parameter to the Hadoop

invalid reference

Configuration

used to read the file.

addConfig(Map<String, String>) - Method in class com.northconcepts.datapipeline.orc.input.OrcPipelineInput

Sets the Orc configuration parameters.

addConfiguration(String, String) - Method in class com.northconcepts.datapipeline.orc.output.OrcPipelineOutput

Sets the Orc configuration parameters.

addConfiguration(Map<String, String>) - Method in class com.northconcepts.datapipeline.orc.output.OrcPipelineOutput

Sets the Orc configuration parameters.

addCustomField(String, Object) - Method in class com.northconcepts.datapipeline.jira.JiraIssue

Sets a field, such as a custom field, in the issue's fields record, replacing any existing value.

addDataCellStyle(FieldLocationPredicate, ExcelCellStyleDecorator) - Method in class com.northconcepts.datapipeline.excel.ExcelWriter

Adds cell styles to data cells matching the specified predicate.

addDataHyperlink(FieldLocationPredicate, ExcelHyperlinkFunction) - Method in class com.northconcepts.datapipeline.excel.ExcelWriter

Adds hyperlinks to data cells matching the specified predicate.

addDataMetadata(Record) - Method in class com.northconcepts.datapipeline.excel.ExcelWriter

Attaches the hyperlinks and cell styles registered for data cells to the record's fields; called only when metadata writing is enabled.

addDateRange(String, String) - Method in class com.northconcepts.datapipeline.google.analytics.GoogleAnalyticsReportReader

Adds a date range to the report, such as GoogleAnalyticsReportReader.DATE_30_DAYS_AGO to GoogleAnalyticsReportReader.DATE_TODAY; must be called before GoogleAnalyticsReportReader.open().

addDebug(String, boolean) - Method in class com.northconcepts.datapipeline.core.Messages

Adds a debug message, optionally capturing the caller's current stack trace.

addDebug(String, Throwable) - Method in class com.northconcepts.datapipeline.core.Messages

Adds a debug message that carries the given exception.

addDefaultOutcome(DecisionTableOutcome) - Method in class com.northconcepts.datapipeline.foundations.decisiontable.DecisionTable

Adds an outcome used when no rule fires.

addDefaultOutcome(String, String) - Method in class com.northconcepts.datapipeline.foundations.decisiontable.DecisionTable

Adds an outcome, used when no rule fires, that sets variable to the value of expression.

addDefaultOutcome(Collection<DecisionTableOutcome>) - Method in class com.northconcepts.datapipeline.foundations.decisiontable.DecisionTable

Adds outcomes used when no rule fires.

addDimension(String) - Method in class com.northconcepts.datapipeline.google.analytics.GoogleAnalyticsReportReader

Adds a dimension to the report; must be called before GoogleAnalyticsReportReader.open().

ADDED - Enum constant in enum class com.northconcepts.datapipeline.foundations.difference.DiffType

 

addElapsedtime(long) - Method in class com.northconcepts.datapipeline.core.Endpoint

Adds time milliseconds to the total returned by Endpoint.getElapsedTime().

addEntity(EntityDef) - Method in class com.northconcepts.datapipeline.foundations.schema.SchemaDef

Appends the entity and makes this schema its parent.

addEntityRelationship(EntityRelationshipDef) - Method in class com.northconcepts.datapipeline.foundations.schema.SchemaDef

Appends the entity relationship and makes this schema its parent.

addEventBusLifecycleListener(EventBusLifecycleListener) - Static method in class com.northconcepts.datapipeline.eventbus.EventBus

Registers a listener notified, via the system event bus, when any event bus is created or begins shutting down.

addExceptionListener(EventFilter, ExceptionListener) - Method in class com.northconcepts.datapipeline.eventbus.EventBus

Registers an exception listener that only receives the exception events the filter allows.

addExceptionListener(ExceptionListener) - Method in class com.northconcepts.datapipeline.eventbus.EventBus

Registers a listener notified when a listener on this bus throws an exception while receiving an event.

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.avro.AvroReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.avro.AvroWriter

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.bloomberg.BloombergMessageReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.buffer.BufferedReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.buffer.RecordBuffer

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.core.AbstractReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.core.AbstractWriter

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.core.AsyncMultiReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.core.AsyncReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.core.AsyncTaskReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.core.AsyncWriter

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.core.BinaryWriter

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.core.DataEndpoint

 

addExceptionProperties(DataException) - Method in interface com.northconcepts.datapipeline.core.DataExceptionContributor

Adds this object's current state to a DataException.

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.core.DataObject

Adds this object's current state to a DataException.

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.core.DataReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.core.DataWriter

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.core.Endpoint

Adds this endpoint's current state to a DataException.

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.core.LimitReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.core.LinedTextWriter

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.core.MultiWriter

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.core.ParsingReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.core.PipedReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.core.PipedWriter

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.core.ProxyReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.core.ProxyWriter

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.core.RemoveDuplicatesReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.core.SequenceReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.core.SequenceWriter

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.core.TextReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.core.TextStreamWriter

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.core.TextWriter

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.core.TimedReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.csv.CSVReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.csv.CSVWriter

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.email.EmailReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.eventbus.EventBusReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.eventbus.EventBusWriter

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.excel.ExcelReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.excel.ExcelWriter

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.excel.PoiSxssfProvider

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.excel.PoiXssfSaxProvider

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.excel.PoiXssfbProvider

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.file.FileReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.file.FileSystemInfoReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.file.FileWriter

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.filter.FieldCount

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.filter.FieldExists

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.filter.FieldFilter

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.filter.FieldNotExists

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.filter.Filter

Adds this filter's settings to the given exception and returns it; subclasses override it to add their own.

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.filter.FilteringReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.fixedwidth.FixedWidthReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.fixedwidth.FixedWidthWriter

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.foundations.core.Bean

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.foundations.core.FoundationObject

Adds this object's current state to a DataException.

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.foundations.datamapping.AbstractFieldMapping

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.foundations.datamapping.DataMapping

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.foundations.datamapping.DataMappingReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.foundations.datamapping.DataMappingWriter

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.foundations.datamapping.FieldMapping

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.foundations.decisiontable.DecisionTable

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.foundations.decisiontable.DecisionTableCondition

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.foundations.decisiontable.DecisionTableOutcome

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.foundations.decisiontable.DecisionTableReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.foundations.decisiontable.DecisionTableRule

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.foundations.decisiontable.DecisionTableWriter

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.foundations.decisiontree.DecisionTree

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.foundations.decisiontree.DecisionTreeOutcome

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.foundations.decisiontree.DecisionTreeReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.foundations.decisiontree.DecisionTreeWriter

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.foundations.expression.CalculatedField

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.foundations.pipeline.dataset.Column

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.foundations.pipeline.dataset.JdbcDataset

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.foundations.pipeline.dataset.LocalFileDataset

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.foundations.schema.SchemaFilter

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.google.analytics.GoogleAnalyticsReportReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.google.calendar.GoogleCalendarReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.google.contacts.GoogleContactsReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.google.gmail.GmailMessageReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.google.GoogleApiReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.google.sheets.GoogleSheetReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.google.sheets.GoogleSheetWriter

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.group.AggregateReader

Deprecated.

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.group.GroupByReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.group.Window

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.instagram.InstagramLocationMediaReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.instagram.InstagramLocationReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.instagram.InstagramSelfFollowedByReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.instagram.InstagramSelfFollowsReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.instagram.InstagramSelfMediaReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.instagram.InstagramTagMediaReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.instagram.InstagramTagReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.instagram.InstagramUserMediaReader

 

addExceptionProperties(DataException) - Method in interface com.northconcepts.datapipeline.jdbc.insert.IInsert

Adds this strategy's details, such as the generated SQL, to the exception and returns it.

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.jdbc.insert.MultiRowPreparedStatementInsert

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.jdbc.insert.MultiRowStatementInsert

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.jdbc.insert.PreparedStatementInsert

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.jdbc.JdbcMultiUpsertWriter

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.jdbc.JdbcMultiWriter

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.jdbc.JdbcReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.jdbc.JdbcUpsertWriter

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.jdbc.JdbcWriter

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.jdbc.upsert.GenericUpsert

 

addExceptionProperties(DataException) - Method in interface com.northconcepts.datapipeline.jdbc.upsert.IUpsert

Adds this strategy's details, such as the generated SQL, to the exception.

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.jdbc.upsert.MergeUpsert

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.jdbc.upsert.MySqlUpsert

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.jdbc.upsert.OracleUpsert

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.jdbc.upsert.PostgreSqlUpsert

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.jdbc.upsert.SybaseUpsert

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.jdbc.upsert.VariableFieldsUpsert

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.jira.JiraEpicReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.jira.JiraIssueReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.jira.JiraProjectReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.jira.JiraReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.jira.JiraSprintReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.jms.JmsConnection

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.jms.JmsReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.jms.JmsSettings

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.jms.JmsWriter

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.job.DataReaderIterator

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.json.JsonReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.json.JsonRecordReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.json.JsonRecordWriter

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.json.SimpleJsonReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.kafka.KafkaReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.kafka.KafkaWriter

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.latex.LatexWriter

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.mailchimp.MailChimpListMemberReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.memory.CollectionReader

Adds exception properties for debugging purposes.

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.memory.TailProxyReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.meter.Meter

Adds this meter's count and timer state to the given exception and returns it.

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.meter.MeteredReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.meter.MeteredWriter

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.meter.RecordMeter

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.microsoft.word.MicrosoftWordWriter

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.mongodb.MongoReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.mongodb.MongoWriter

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.openfinancialexchange.OpenFinancialExchangeReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.orc.OrcDataReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.orc.OrcDataWriter

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.parquet.ParquetDataReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.parquet.ParquetDataWriter

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.pdf.PdfReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.pdf.PdfWriter

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.retry.RetryingReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.retry.RetryingWriter

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.security.AsymmetricDecryptingReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.security.AsymmetricEncryptingReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.security.DecryptingReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.security.EncryptingReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.security.SymmetricDecryptingReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.security.SymmetricEncryptingReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.shopify.ShopifyApiReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.shopify.ShopifyCustomerReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.shopify.ShopifyEventReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.shopify.ShopifyInventoryItemReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.shopify.ShopifyInventoryLevelReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.shopify.ShopifyOrderReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.shopify.ShopifyProductReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.sql.h2.H2InsertWriter

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.sql.mysql.MySqlInsertWriter

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.sql.postgresql.PostgreSqlInsertWriter

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.template.TemplateWriter

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.texttable.TextTableWriter

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.throttle.Throttle

Adds this throttle's limit, peak rate and meter state to the given exception and returns it.

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.throttle.ThrottledReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.throttle.ThrottledWriter

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer.Operation

Adds this operation's details to an exception raised while it runs; returns the same exception.

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer.SingleValueOperation

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.transform.FieldTransformer

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.transform.FlattenRecord

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.transform.Transformer

Adds this transformer's details to an exception raised by its host reader or writer; returns the same exception.

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.transform.TransformingReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.transform.TransformingWriter

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.trello.TrelloApiReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.trello.TrelloBoardCardsReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.trello.TrelloBoardListsReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.trello.TrelloBoardsReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.trello.TrelloCardWriter

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.trello.TrelloListCardsReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.twitter.TwitterFilterStreamReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.twitter.TwitterFollowerIDsReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.twitter.TwitterFollowerListReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.twitter.TwitterFollowingIDsReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.twitter.TwitterFollowingListReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.twitter.TwitterFollowWriter

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.twitter.TwitterListMemberReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.twitter.TwitterListOwnershipReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.twitter.TwitterPageableReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.twitter.TwitterProvider

Returns the exception unchanged; subclasses can override to add provider details.

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.twitter.TwitterProxyReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.twitter.TwitterReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.twitter.TwitterSearchReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.twitter.TwitterStreamProvider

Returns the exception unchanged; subclasses can override to add provider details.

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.twitter.TwitterUnfollowWriter

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.twitter.TwitterUserLookupReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.twitter.TwitterWriter

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.twitter2.AbstractTwitterReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.twitter2.TwitterFilterStreamReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.twitter2.TwitterFollowerReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.twitter2.TwitterFollowingReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.twitter2.TwitterSearchReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.twitter2.TwitterTimelineReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.validate.ValidatingReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.xml.SimpleXmlReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.xml.XmlReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.xml.XmlRecordReader

 

addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.xml.XmlRecordWriter

 

addExceptionProperties(DataException, String) - Method in interface com.northconcepts.datapipeline.core.DataExceptionContributor

Adds this object's current state to a DataException.

addExceptionProperties(DataException, String) - Method in class com.northconcepts.datapipeline.core.SequenceWriter.Sequence

Adds this sequence's index, start time and starting record count to the exception, under names prefixed with name.

addExceptionPropertiesImpl(DataException) - Method in class com.northconcepts.datapipeline.core.AsyncReader

Adds this reader's own state, but not the nested reader's (it runs on another thread), to the exception; subclasses override this instead of the final AsyncReader.addExceptionProperties(DataException).

addExceptionPropertiesImpl(DataException) - Method in class com.northconcepts.datapipeline.core.AsyncWriter

Adds this writer's own state, but not the nested writer's (it runs on another thread), to the exception; subclasses override this instead of the final AsyncWriter.addExceptionProperties(DataException).

addExcludedFields(String...) - Method in class com.northconcepts.datapipeline.foundations.datamapping.DataMapping

Adds fields to be removed from the target.

addExcludedFields(Collection<String>) - Method in class com.northconcepts.datapipeline.foundations.datamapping.DataMapping

Adds fields to be removed from the target.

addExcludedTables(String...) - Method in class com.northconcepts.datapipeline.foundations.tools.GenerateTableDaoClasses

Adds names of tables to skip, matched exactly against unqualified table names.

addExportedKey(JdbcExportedKey) - Method in class com.northconcepts.datapipeline.foundations.jdbc.JdbcTable

Adds the exported key and sets this as its table.

addField() - Method in class com.northconcepts.datapipeline.core.Record

Adds a new, unnamed field to this record and returns it for further configuration.

addField(int, FixedWidthAlign, char) - Method in class com.northconcepts.datapipeline.fixedwidth.FixedWidthWriter

 

addField(Field, Dataset) - Method in class com.northconcepts.datapipeline.foundations.pipeline.dataset.Column

Adds the field's value (or each array element) to this column's stats, inferring string types as configured on the dataset.

addField(Record, Field, int) - Method in class com.northconcepts.datapipeline.foundations.pipeline.dataset.Dataset

Adds the field to the stats of its column, creating the column if needed; runs on a column stats worker thread.

addField(Record, Field, int) - Method in class com.northconcepts.datapipeline.foundations.pipeline.dataset.MvStoreDataset

 

addField(FixedWidthField) - Method in class com.northconcepts.datapipeline.fixedwidth.FixedWidthReader

 

addField(FixedWidthField) - Method in class com.northconcepts.datapipeline.fixedwidth.FixedWidthWriter

Appends a column; each record written must have exactly one field per column, matched by position.

addField(FixedWidthField) - Method in class com.northconcepts.datapipeline.foundations.pipeline.input.FixedWidthPipelineInput

 

addField(FixedWidthField) - Method in class com.northconcepts.datapipeline.foundations.pipeline.output.FixedWidthPipelineOutput

 

addField(CalculatedField) - Method in class com.northconcepts.datapipeline.foundations.decisiontable.DecisionTable

Adds a calculated field, evaluated before the rules and available to them as a variable.

addField(CalculatedField) - Method in class com.northconcepts.datapipeline.foundations.decisiontree.DecisionTree

Adds a calculated field, evaluated before the tree is walked and available to it as a variable.

addField(FieldDef) - Method in class com.northconcepts.datapipeline.foundations.schema.EntityDef

Appends the field and makes this entity its parent.

addField(XmlField) - Method in class com.northconcepts.datapipeline.foundations.pipeline.input.JsonPipelineInput

 

addField(XmlField) - Method in class com.northconcepts.datapipeline.foundations.pipeline.input.XmlPipelineInput

 

addField(XmlField) - Method in class com.northconcepts.datapipeline.json.JsonReader

 

addField(XmlField) - Method in class com.northconcepts.datapipeline.xml.XmlReader

 

addField(String) - Method in class com.northconcepts.datapipeline.bloomberg.BloombergMessageFields

 

addField(String, int) - Method in class com.northconcepts.datapipeline.fixedwidth.FixedWidthReader

Appends a left-aligned column that uses the reader's fill character.

addField(String, int) - Method in class com.northconcepts.datapipeline.foundations.pipeline.input.FixedWidthPipelineInput

Appends a left-aligned column that uses the input's fill character.

addField(String, int) - Method in class com.northconcepts.datapipeline.foundations.pipeline.output.FixedWidthPipelineOutput

Appends a left-aligned column that uses the output's fill character.

addField(String, int, FixedWidthAlign, char) - Method in class com.northconcepts.datapipeline.fixedwidth.FixedWidthReader

 

addField(String, int, FixedWidthAlign, Character) - Method in class com.northconcepts.datapipeline.foundations.pipeline.input.FixedWidthPipelineInput

Appends a column with its own alignment and fill character; a null fill character uses the input's.

addField(String, int, FixedWidthAlign, Character) - Method in class com.northconcepts.datapipeline.foundations.pipeline.output.FixedWidthPipelineOutput

Appends a column with its own alignment and fill character (null uses the output's).

addField(String, Object) - Method in class com.northconcepts.datapipeline.core.Record

Adds a new field with the specified value to this record.

addField(String, Object) - Method in class com.northconcepts.datapipeline.jira.JiraIssue

Deprecated.

Use JiraIssue.setField(String, Object) instead.

addField(String, Object, boolean) - Method in class com.northconcepts.datapipeline.core.Record

Adds a new field with the specified value to this record.

addField(String, String) - Method in class com.northconcepts.datapipeline.foundations.decisiontable.DecisionTable

Adds a calculated field that sets variable to the value of expression before the rules are evaluated.

addField(String, String) - Method in class com.northconcepts.datapipeline.foundations.decisiontree.DecisionTree

Adds a calculated field that sets variable to the value of expression before the tree is walked.

addField(String, String) - Method in class com.northconcepts.datapipeline.foundations.pipeline.input.JsonPipelineInput

 

addField(String, String) - Method in class com.northconcepts.datapipeline.foundations.pipeline.input.XmlPipelineInput

Adds a field read from the nodes matching a location path such as /teachers/teacher/@memberid.

addField(String, String) - Method in class com.northconcepts.datapipeline.json.JsonReader

 

addField(String, String) - Method in class com.northconcepts.datapipeline.xml.XmlReader

Identifies a new field using XPath in the XML stream.

addField(String, String, boolean) - Method in class com.northconcepts.datapipeline.foundations.decisiontable.DecisionTable

 

addField(String, String, boolean) - Method in class com.northconcepts.datapipeline.foundations.decisiontree.DecisionTree

 

addField(String, String, boolean) - Method in class com.northconcepts.datapipeline.foundations.pipeline.input.JsonPipelineInput

 

addField(String, String, boolean) - Method in class com.northconcepts.datapipeline.foundations.pipeline.input.XmlPipelineInput

Adds a field; with cascadeValues its last value is carried into later records until the path matches again.

addField(String, String, boolean) - Method in class com.northconcepts.datapipeline.json.JsonReader

 

addField(String, String, boolean) - Method in class com.northconcepts.datapipeline.xml.XmlReader

Identifies a new field using XPath in the XML stream.

addField(String, String, String) - Method in class com.northconcepts.datapipeline.foundations.pipeline.input.JsonPipelineInput

 

addField(String, String, String) - Method in class com.northconcepts.datapipeline.foundations.pipeline.input.XmlPipelineInput

Adds a field whose last value is carried into later records until a node matching cascadeResetLocationPath clears it; a blank reset path turns cascading off.

addField(String, String, String) - Method in class com.northconcepts.datapipeline.json.JsonReader

 

addField(String, String, String) - Method in class com.northconcepts.datapipeline.xml.XmlReader

Identifies a new field using XPath in the XML stream.

addField(Collection<CalculatedField>) - Method in class com.northconcepts.datapipeline.foundations.decisiontable.DecisionTable

Adds calculated fields, evaluated before the rules and available to them as variables.

addField(Collection<CalculatedField>) - Method in class com.northconcepts.datapipeline.foundations.decisiontree.DecisionTree

Adds calculated fields, evaluated before the tree is walked and available to it as variables.

addFieldIndex(JdbcFieldIndex) - Method in class com.northconcepts.datapipeline.foundations.jdbc.JdbcIndex

 

addFieldMapping(IFieldMapping) - Method in class com.northconcepts.datapipeline.foundations.datamapping.DataMapping

 

addFieldMapping(String, String) - Method in class com.northconcepts.datapipeline.foundations.datamapping.DataMapping

Adds a FieldMapping that sets targetFieldName to the value of the sourceExpression expression.

addFieldMapping(Collection<IFieldMapping>) - Method in class com.northconcepts.datapipeline.foundations.datamapping.DataMapping

 

addFields(int...) - Method in class com.northconcepts.datapipeline.fixedwidth.FixedWidthReader

Appends unnamed, left-aligned columns of the given widths that use the reader's fill character.

addFields(int...) - Method in class com.northconcepts.datapipeline.fixedwidth.FixedWidthWriter

Appends left-aligned columns of the given widths that use the writer's fill character.

addFields(int...) - Method in class com.northconcepts.datapipeline.foundations.pipeline.input.FixedWidthPipelineInput

Appends unnamed, left-aligned columns of the given widths that use the input's fill character.

addFields(int...) - Method in class com.northconcepts.datapipeline.foundations.pipeline.output.FixedWidthPipelineOutput

Appends left-aligned columns of the given widths that use the output's fill character.

addFields(String...) - Method in class com.northconcepts.datapipeline.security.AsymmetricDecryptingReader

 

addFields(String...) - Method in class com.northconcepts.datapipeline.security.AsymmetricEncryptingReader

 

addFields(String...) - Method in class com.northconcepts.datapipeline.security.DecryptingReader

Adds fields to decrypt; only allowed before the reader is opened.

addFields(String...) - Method in class com.northconcepts.datapipeline.security.EncryptingReader

Adds fields to encrypt; only allowed before the reader is opened.

addFields(String...) - Method in class com.northconcepts.datapipeline.security.SymmetricDecryptingReader

 

addFields(String...) - Method in class com.northconcepts.datapipeline.security.SymmetricEncryptingReader

 

addFields(Collection<String>) - Method in class com.northconcepts.datapipeline.security.AsymmetricDecryptingReader

 

addFields(Collection<String>) - Method in class com.northconcepts.datapipeline.security.AsymmetricEncryptingReader

 

addFields(Collection<String>) - Method in class com.northconcepts.datapipeline.security.DecryptingReader

Adds fields to decrypt; only allowed before the reader is opened.

addFields(Collection<String>) - Method in class com.northconcepts.datapipeline.security.EncryptingReader

Adds fields to encrypt; only allowed before the reader is opened.

addFields(Collection<String>) - Method in class com.northconcepts.datapipeline.security.SymmetricDecryptingReader

 

addFields(Collection<String>) - Method in class com.northconcepts.datapipeline.security.SymmetricEncryptingReader

 

AddFieldsAction - Class in com.northconcepts.datapipeline.foundations.pipeline.action.transform

A PipelineAction that sets fields on every record, replacing existing ones, to a typed constant or the result of an expression.

AddFieldsAction() - Constructor for class com.northconcepts.datapipeline.foundations.pipeline.action.transform.AddFieldsAction

 

AddFieldsAction.FieldType - Enum Class in com.northconcepts.datapipeline.foundations.pipeline.action.transform

The type a field's value is converted to, or EXPRESSION to evaluate it as an expression.

AddFieldsAction.TypeValue - Class in com.northconcepts.datapipeline.foundations.pipeline.action.transform

A field's value and the type it is converted to.

addFieldValue(Field, Object) - Method in class com.northconcepts.datapipeline.xml.XmlReader

 

addFirst(QueryCriteriaPart) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.AndPart

 

addFirst(QueryCriteriaPart) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.ConjunctivePart

 

addFirst(QueryCriteriaPart) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.OrPart

 

addFirst(QueryCriteriaPart) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.QueryCriteriaPart

 

addFirst(String, Object...) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.AndPart

 

addFirst(String, Object...) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.ConjunctivePart

 

addFirst(String, Object...) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.OrPart

 

addFirst(String, Object...) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.QueryCriteriaPart

Inserts a condition and its parameter values as the first child part.

addForeignKeyFieldNames(String) - Method in class com.northconcepts.datapipeline.foundations.schema.EntityRelationshipDef

Appends one foreign key field name; null is rejected.

addHeaderCellStyle(FieldLocationPredicate, ExcelCellStyleDecorator) - Method in class com.northconcepts.datapipeline.excel.ExcelWriter

Adds cell styles to header cells matching the specified predicate.

addHeaderHyperlink(FieldLocationPredicate, ExcelHyperlinkFunction) - Method in class com.northconcepts.datapipeline.excel.ExcelWriter

Adds hyperlinks to header cells matching the specified predicate.

addHeaderMetadata(Record) - Method in class com.northconcepts.datapipeline.excel.ExcelWriter

Attaches the hyperlinks and cell styles registered for header cells to the header record's fields; called only when metadata writing is enabled.

addImport(JavaCodeBuilder, AddFieldsAction.TypeValue) - Method in enum class com.northconcepts.datapipeline.foundations.pipeline.action.transform.AddFieldsAction.FieldType

Adds the imports needed by the generated code for the given value.

addImport(Class<?>) - Method in class com.northconcepts.datapipeline.sourcecode.JavaCodeBuilder

Add an import for an individual class.

addImport(Class<?>, boolean) - Method in class com.northconcepts.datapipeline.sourcecode.JavaCodeBuilder

Add an import for an individual class or all all classes in the specified class' package (if allClassesInPackage is true).

addImport(String) - Method in class com.northconcepts.datapipeline.sourcecode.JavaCodeBuilder

Add an import for a package, package wildcard, or individual class.

addImportedKey(JdbcImportedKey) - Method in class com.northconcepts.datapipeline.foundations.jdbc.JdbcTable

Adds the imported key and sets this as its table.

addImports(JavaCodeBuilder, boolean, boolean, List<String>) - Method in class com.northconcepts.datapipeline.foundations.tools.GenerateTableDaoClasses

Adds a generated class's imports, and the interfaces it implements to implementsList; the flags tell if the superclass is already Serializable or RecordSerializable.

addIndex(JdbcIndex) - Method in class com.northconcepts.datapipeline.foundations.jdbc.JdbcTable

Adds the index and sets this as its table.

addIndex(IndexDef) - Method in class com.northconcepts.datapipeline.foundations.schema.EntityDef

Appends the index and makes this entity its parent.

addIndexField(IndexFieldDef) - Method in class com.northconcepts.datapipeline.foundations.schema.IndexDef

Appends the index field and makes this index its parent.

addIndexFields(String...) - Method in class com.northconcepts.datapipeline.foundations.schema.IndexDef

Appends an ascending index field for each of the named entity fields; a null or empty array is ignored.

addInsertValue(String, Object, boolean) - Method in class com.northconcepts.datapipeline.jdbc.sql.merge.Merge

Adds a column and its parameter value to the INSERT clause, rendered as column=? unless isInsert is true.

addInsertValues(String...) - Method in class com.northconcepts.datapipeline.jdbc.sql.merge.Merge

Adds columns with null parameter values to the INSERT clause.

addIssueComment(String, String) - Method in class com.northconcepts.datapipeline.jira.client.JiraService

 

addJobLifecycleListener(JobLifecycleListener) - Static method in class com.northconcepts.datapipeline.job.Job

 

addLabelIds(String...) - Method in class com.northconcepts.datapipeline.google.gmail.GmailMessageReader

 

addLineage(Record) - Method in class com.northconcepts.datapipeline.core.DataReader

Called by DataReader.read() for each record from DataReader.readImpl() while lineage is saved; the default copies recordLineage into every field along with its original index and name.

addLineage(Record) - Method in class com.northconcepts.datapipeline.core.ParsingReader

 

addLineage(Record) - Method in class com.northconcepts.datapipeline.core.TextReader

 

addLineage(Record) - Method in class com.northconcepts.datapipeline.csv.CSVReader

 

addLineage(Record) - Method in class com.northconcepts.datapipeline.excel.ExcelReader

 

addLineage(Record) - Method in class com.northconcepts.datapipeline.fixedwidth.FixedWidthReader

 

addLineage(Record) - Method in class com.northconcepts.datapipeline.jdbc.JdbcReader

 

addLineage(Record) - Method in class com.northconcepts.datapipeline.json.JsonReader

 

addLineage(Record) - Method in class com.northconcepts.datapipeline.json.JsonRecordReader

 

addLineage(Record) - Method in class com.northconcepts.datapipeline.json.SimpleJsonReader

 

addLineage(Record) - Method in class com.northconcepts.datapipeline.orc.OrcDataReader

 

addLineage(Record) - Method in class com.northconcepts.datapipeline.parquet.ParquetDataReader

 

addLineage(Record) - Method in class com.northconcepts.datapipeline.xml.SimpleXmlReader

 

addLineage(Record) - Method in class com.northconcepts.datapipeline.xml.XmlReader

 

addLineage(Record) - Method in class com.northconcepts.datapipeline.xml.XmlRecordReader

 

addListener(EventFilter, UntypedEventListener) - Method in class com.northconcepts.datapipeline.eventbus.EventBus

Deprecated.

Use EventBus.addUntypedEventListener(EventFilter, UntypedEventListener) instead.

addListener(EventFilter, UntypedEventListener, Object) - Method in class com.northconcepts.datapipeline.eventbus.EventBus

Deprecated.

Use EventBus.addUntypedEventListener(EventFilter, UntypedEventListener, Object) instead.

addListener(UntypedEventListener) - Method in class com.northconcepts.datapipeline.eventbus.EventBus

Deprecated.

Use EventBus.addUntypedEventListener(UntypedEventListener) instead.

addListener(Class<T>, EventFilter, T) - Method in class com.northconcepts.datapipeline.eventbus.EventBus

Subscribes a listener to the events of its listener interface that the filter allows (null allows all).

addListener(Class<T>, EventFilter, T, Object) - Method in class com.northconcepts.datapipeline.eventbus.EventBus

Subscribes a listener to the events of its listener interface that the filter allows and, unless topic is null, that carry an equal topic.

addListener(Class<T>, T) - Method in class com.northconcepts.datapipeline.eventbus.EventBus

Subscribes a listener to every event of its listener interface, whatever the topic.

addListMember(String, ListMember) - Method in interface com.northconcepts.datapipeline.mailchimp.MailChimpClient

Adds the member to the list and returns the response as raw JSON.

addMessage(Message) - Method in class com.northconcepts.datapipeline.core.Messages

 

addMessageHeader(Message, Record) - Method in class com.northconcepts.datapipeline.jms.JmsReader

Adds the message's JMS headers as jms_* fields and each message property as a jms_property_ prefixed field.

addMetric(String) - Method in class com.northconcepts.datapipeline.google.analytics.GoogleAnalyticsReportReader

Adds a metric expression to the report; must be called before GoogleAnalyticsReportReader.open().

addMetric(String, String) - Method in class com.northconcepts.datapipeline.google.analytics.GoogleAnalyticsReportReader

Adds a metric expression with an alias to the report; must be called before GoogleAnalyticsReportReader.open().

addNode(DecisionTreeNode) - Method in class com.northconcepts.datapipeline.foundations.decisiontree.DecisionTreeNode

Adds a child node, which must have a condition.

addNode(Collection<DecisionTreeNode>) - Method in class com.northconcepts.datapipeline.foundations.decisiontree.DecisionTreeNode

Adds child nodes, which must all have conditions.

addNodeNameRule(NodeNameRule) - Method in class com.northconcepts.datapipeline.foundations.pipeline.tree.detect.TreeDetectionStrategy

Adds a rule that classifies node names as dynamic; a name is dynamic if any rule says so.

addNotRule(FieldFilterRule) - Method in class com.northconcepts.datapipeline.filter.FieldFilter

Adds a rule requiring the given rule to fail.

addNull(int, FieldType) - Method in class com.northconcepts.datapipeline.core.ArrayValue

Inserts a typed null value at the given index.

addNull(FieldType) - Method in class com.northconcepts.datapipeline.core.ArrayValue

Adds a typed null value to this container.

addNull(FieldType) - Method in class com.northconcepts.datapipeline.core.Field

 

addNull(FieldType) - Method in interface com.northconcepts.datapipeline.core.ValueNodeContainer

Adds a typed null value to this container.

addOrUpdateListMember(String, String, ListMember) - Method in interface com.northconcepts.datapipeline.mailchimp.MailChimpClient

Adds or updates the member with the given subscriber hash; returns raw JSON.

addOutcome(DecisionTableOutcome) - Method in class com.northconcepts.datapipeline.foundations.decisiontable.DecisionTableRule

 

addOutcome(DecisionTreeOutcome) - Method in class com.northconcepts.datapipeline.foundations.decisiontree.DecisionTreeNode

 

addOutcome(String, String) - Method in class com.northconcepts.datapipeline.foundations.decisiontable.DecisionTableRule

Adds an outcome that sets variable to the value of expression when the rule fires.

addOutcome(String, String) - Method in class com.northconcepts.datapipeline.foundations.decisiontree.DecisionTreeNode

Adds an outcome that sets variable to the value of expression when this node is visited.

addOutcome(Collection<DecisionTableOutcome>) - Method in class com.northconcepts.datapipeline.foundations.decisiontable.DecisionTableRule

 

addOutcome(Collection<DecisionTreeOutcome>) - Method in class com.northconcepts.datapipeline.foundations.decisiontree.DecisionTreeNode

 

addPageToBuffer(<any>, LinkedList<User>) - Method in class com.northconcepts.datapipeline.twitter.TwitterFollowerListReader

 

addPageToBuffer(<any>, LinkedList<User>) - Method in class com.northconcepts.datapipeline.twitter.TwitterFollowingListReader

 

addPageToBuffer(<any>, LinkedList<User>) - Method in class com.northconcepts.datapipeline.twitter.TwitterListMemberReader

 

addPageToBuffer(<any>, LinkedList<UserList>) - Method in class com.northconcepts.datapipeline.twitter.TwitterListOwnershipReader

 

addPageToBuffer(C, LinkedList<E>) - Method in class com.northconcepts.datapipeline.twitter.TwitterPageableReader

Appends the elements of a fetched page to the buffer of elements still to be returned.

addPageToBuffer(IDs, LinkedList<Long>) - Method in class com.northconcepts.datapipeline.twitter.TwitterFollowerIDsReader

 

addPageToBuffer(IDs, LinkedList<Long>) - Method in class com.northconcepts.datapipeline.twitter.TwitterFollowingIDsReader

 

addParameter(JdbcQueryParameter) - Method in class com.northconcepts.datapipeline.foundations.jdbc.JdbcQuery

Adds a parameter for the next ? placeholder in the query.

addParameter(String, Class<?>, Integer, String) - Method in class com.northconcepts.datapipeline.foundations.jdbc.JdbcQuery

Adds a parameter for the next ? placeholder; sqlType is a java.sql.Types code or null.

addParameter(String, Class<?>, String) - Method in class com.northconcepts.datapipeline.foundations.jdbc.JdbcQuery

Adds a parameter for the next ? placeholder with no SQL type, letting the driver infer it.

addPattern(DateTimePattern) - Method in class com.northconcepts.datapipeline.foundations.time.DateTimePatternDetector

Adds a pattern to try after the existing ones; duplicates are ignored.

addPattern(String) - Method in class com.northconcepts.datapipeline.foundations.time.DateTimePatternDetector

Adds a case-insensitive DateTimePattern to try after the existing ones; duplicates are ignored.

addProperty(Property) - Method in class com.northconcepts.datapipeline.foundations.jdbc.JdbcConnection

Adds a property passed to the JDBC driver by JdbcConnection.createConnection().

addProperty(String, String) - Method in class com.northconcepts.datapipeline.bloomberg.BloombergMessageFooter

Adds a value to the named property, keeping any values it already has.

addProperty(String, String) - Method in class com.northconcepts.datapipeline.bloomberg.BloombergMessageHeader

Adds a value to the named property, keeping any values it already has.

addProperty(String, String) - Method in class com.northconcepts.datapipeline.foundations.jdbc.JdbcConnection

Adds a property passed to the JDBC driver by JdbcConnection.createConnection().

addQuery(JdbcQuery) - Method in class com.northconcepts.datapipeline.foundations.jdbc.JdbcConnection

Adds the query and sets this as its connection.

addQuery(String, String) - Method in class com.northconcepts.datapipeline.foundations.jdbc.JdbcConnection

Adds a named SQL query; JdbcConnection.loadQueries() reads its result columns.

addRecord(Record) - Method in class com.northconcepts.datapipeline.bloomberg.BloombergMessageData

 

addRecordBreak(String) - Method in class com.northconcepts.datapipeline.foundations.pipeline.input.JsonPipelineInput

 

addRecordBreak(String) - Method in class com.northconcepts.datapipeline.foundations.pipeline.input.JsonRecordPipelineInput

Adds a location path, such as /object/users/array/object, whose matching nodes are each read as a record.

addRecordBreak(String) - Method in class com.northconcepts.datapipeline.foundations.pipeline.input.XmlPipelineInput

Adds a location path, such as /teachers/teacher, whose matching nodes delimit records.

addRecordBreak(String) - Method in class com.northconcepts.datapipeline.foundations.pipeline.input.XmlRecordPipelineInput

Adds a location path, such as /teachers/teacher, whose matching elements are each read as a record.

addRecordBreak(String) - Method in class com.northconcepts.datapipeline.json.JsonReader

 

addRecordBreak(String) - Method in class com.northconcepts.datapipeline.json.JsonRecordReader

Adds a location path (for example //array/object) matching the JSON objects, arrays or fields to read as records.

addRecordBreak(String) - Method in class com.northconcepts.datapipeline.xml.XmlReader

Adds a location path (for example //book); a record is completed each time a matching element ends.

addRecordBreak(String) - Method in class com.northconcepts.datapipeline.xml.XmlRecordReader

Adds a location path (for example //book) whose matching elements are each read as one record.

addRecordBreakOnArray(TreeNode) - Method in class com.northconcepts.datapipeline.foundations.pipeline.tree.detect.OptimizeTreeStructure

Marks the node as a record break if its parent is a JSON array.

addRegexNodeNameRule(String) - Method in class com.northconcepts.datapipeline.foundations.pipeline.tree.detect.TreeDetectionStrategy

Adds a RegexNodeNameRule so names matching the whole-name regular expression collapse to wildcards.

addRows(int, boolean) - Method in class com.northconcepts.datapipeline.jdbc.sql.insert.Insert

Appends rowCount rows, each pre-filled with the previous row's columns and values if copyLastRowValues is true.

addRule(FieldFilterRule...) - Method in class com.northconcepts.datapipeline.filter.FieldFilter

Adds rules that every checked field must pass for the record to be kept.

addRule(DecisionTableRule) - Method in class com.northconcepts.datapipeline.foundations.decisiontable.DecisionTable

Adds a rule after the existing ones; only the first rule whose conditions all hold fires.

addRule(SiblingSetRule) - Method in class com.northconcepts.datapipeline.foundations.pipeline.tree.detect.CollapseSiblingPatterns

Adds a rule, consulted after the existing ones.

addRule(String, String) - Method in class com.northconcepts.datapipeline.twitter2.TwitterFilterStreamReader

Adds a filter rule to be used for streaming Tweets.

addRule(Collection<DecisionTableRule>) - Method in class com.northconcepts.datapipeline.foundations.decisiontable.DecisionTable

Adds rules after the existing ones; only the first rule whose conditions all hold fires.

addSchema(JdbcSchema) - Method in class com.northconcepts.datapipeline.foundations.jdbc.JdbcConnection

 

addSegmentRule(NodeNameRule) - Method in class com.northconcepts.datapipeline.foundations.pipeline.tree.detect.AffixSiblingSetRule

Adds a rule for classifying middle segments; all the middle segments of a pattern must satisfy the same rule.

addShutdownListener(EventFilter, ShutdownListener) - Method in class com.northconcepts.datapipeline.eventbus.EventBus

Registers a listener notified when this bus begins shutting down; the filter may be null.

addSingleValueWildcardChildField(TreeNode) - Method in class com.northconcepts.datapipeline.foundations.pipeline.tree.detect.OptimizeTreeStructure

Gives a childless, non-array wildcard node a child field, suffixed _value, that reads the node's text.

addTable(JdbcTable) - Method in class com.northconcepts.datapipeline.foundations.jdbc.JdbcConnection

Adds the table and sets this as its connection.

addToPath(DecisionTreeNode) - Method in class com.northconcepts.datapipeline.foundations.decisiontree.DecisionTreeResult

Appends a node to the path, throwing an exception if it is already in the path (a cycle).

addTransformer(int, TreeTransformer) - Method in class com.northconcepts.datapipeline.foundations.pipeline.tree.detect.TreeDetectionStrategy

Inserts a pass at the given 0-based position in the run order.

addTransformer(TreeTransformer) - Method in class com.northconcepts.datapipeline.foundations.pipeline.tree.detect.TreeDetectionStrategy

Appends a pass to run after the existing ones.

addUntypedEventListener(EventFilter, UntypedEventListener) - Method in class com.northconcepts.datapipeline.eventbus.EventBus

Subscribes a listener to every event on this bus that the filter allows (null allows all).

addUntypedEventListener(EventFilter, UntypedEventListener, Object) - Method in class com.northconcepts.datapipeline.eventbus.EventBus

Subscribes a listener to every event on this bus that the filter allows and, unless topic is null, that carries an equal topic.

addUntypedEventListener(UntypedEventListener) - Method in class com.northconcepts.datapipeline.eventbus.EventBus

Subscribes a listener to every event published on this bus, whatever its listener interface or topic.

addUpdateValue(String) - Method in class com.northconcepts.datapipeline.jdbc.sql.merge.Merge

Adds a column=? assignment with a null parameter value to the UPDATE SET clause.

addUpdateValue(String, Object, boolean) - Method in class com.northconcepts.datapipeline.jdbc.sql.merge.Merge

Adds a column and its parameter value to the UPDATE SET clause, rendered as column=? unless isInsert is true.

addValidation(Filter) - Method in class com.northconcepts.datapipeline.foundations.schema.EntityDef

Adds a filter that records must pass during validation; each rejected record gets an error.

addValidation(String) - Method in class com.northconcepts.datapipeline.foundations.schema.EntityDef

Adds a validation rule from a logical expression (parsed as a FilterExpression) that records must satisfy.

addValue(int, FieldType, Object) - Method in class com.northconcepts.datapipeline.core.ArrayValue

Inserts a value with the specified FieldType at the given index, shifting subsequent elements to the right.

addValue(int, Object) - Method in class com.northconcepts.datapipeline.core.ArrayValue

Inserts a value at the given index, inferring the FieldType from the value's class.

addValue(long, Object) - Method in class com.northconcepts.datapipeline.xml.XmlField

Records a value matched at the node with the given sequence number.

addValue(FieldType, Object) - Method in class com.northconcepts.datapipeline.core.ArrayValue

Adds a value with the specified FieldType to this container.

addValue(FieldType, Object) - Method in class com.northconcepts.datapipeline.core.Field

Adds a value to this field, converting the value to the appropriate type if necessary.

addValue(FieldType, Object) - Method in interface com.northconcepts.datapipeline.core.ValueNodeContainer

Adds a value with the specified FieldType to this container.

addValue(Object) - Method in class com.northconcepts.datapipeline.core.ArrayValue

Adds a value to this container, inferring the FieldType from the value's class.

addValue(Object) - Method in class com.northconcepts.datapipeline.core.Field

Adds a value to this container, inferring the FieldType from the value's class.

addValue(Object) - Method in interface com.northconcepts.datapipeline.core.ValueNodeContainer

Adds a value to this container, inferring the FieldType from the value's class.

addValue(Object) - Method in class com.northconcepts.datapipeline.foundations.pipeline.dataset.Column

Adds the value to the value count and the null, blank, length, sample and unique-value stats without inferring its type.

addValue(Object) - Method in class com.northconcepts.datapipeline.jdbc.sql.merge.Merge

 

addWarning(String, boolean) - Method in class com.northconcepts.datapipeline.core.Messages

Adds a warning, optionally capturing the caller's current stack trace.

addWarning(String, Throwable) - Method in class com.northconcepts.datapipeline.core.Messages

Adds a warning that carries the given exception.

addWhitelistPrefix(String...) - Static method in class com.northconcepts.datapipeline.core.Functions

Prevents methods whose fully-qualified name starts with any of the supplied prefixes from executing.

addXmlNode(XmlNode) - Method in class com.northconcepts.datapipeline.foundations.pipeline.tree.TreeNode

Counts one occurrence of the XML node at this path and records its XPath expression, value and attributes.

adjustInventoryLevel(String, String, int) - Method in interface com.northconcepts.datapipeline.shopify.client.ShopifyClient

Changes the inventory item's available quantity at the location by availableAdjustment.

adjustInventoryLevel(String, String, int) - Method in class com.northconcepts.datapipeline.shopify.client.ShopifyService

Adjust Inventory Level

AffixSiblingSetRule - Class in com.northconcepts.datapipeline.foundations.pipeline.tree.detect

Derives a SiblingSetPattern from siblings sharing a fixed prefix/suffix around a varying dynamic segment — for example item-1, item-2, item-3 collapse to item-*.

AffixSiblingSetRule() - Constructor for class com.northconcepts.datapipeline.foundations.pipeline.tree.detect.AffixSiblingSetRule

Creates a rule that classifies middle segments with a StandardNodeNameRule.

afterColumnStatsLoaded() - Method in class com.northconcepts.datapipeline.foundations.pipeline.dataset.Dataset

Called during the data loading process after all the column stats have been loaded.

afterColumnStatsLoaded() - Method in class com.northconcepts.datapipeline.foundations.pipeline.dataset.JdbcDataset

 

afterColumnStatsLoaded() - Method in class com.northconcepts.datapipeline.foundations.pipeline.dataset.LocalFileDataset

 

afterLoad() - Method in class com.northconcepts.datapipeline.foundations.pipeline.dataset.Dataset

Called at the end of the data loading process after all the records and column stats have been loaded.

afterLoad() - Method in class com.northconcepts.datapipeline.foundations.pipeline.dataset.JdbcDataset

 

afterLoad() - Method in class com.northconcepts.datapipeline.foundations.pipeline.dataset.LocalFileDataset

 

afterLoad() - Method in class com.northconcepts.datapipeline.foundations.pipeline.dataset.MemoryDataset

 

afterLoad() - Method in class com.northconcepts.datapipeline.foundations.pipeline.dataset.MvStoreDataset

 

afterRecordsLoaded() - Method in class com.northconcepts.datapipeline.foundations.pipeline.dataset.Dataset

Called during the data loading process after all the records have been loaded.

afterSequenceCreated() - Method in class com.northconcepts.datapipeline.core.SequenceWriter

Called once a new sequence's writer has been created and opened; does nothing by default.

afterSequenceFinished() - Method in class com.northconcepts.datapipeline.core.SequenceWriter

Called when a sequence ends -- after the next sequence's writer is created, or when this writer is closed; does nothing by default.

AGGREGATE - Enum constant in enum class com.northconcepts.datapipeline.foundations.pipeline.action.ActionGroup

 

AggregateGroupFieldsAction - Class in com.northconcepts.datapipeline.foundations.pipeline.action.aggregate

A PipelineAction that groups records by the fields marked GROUPBY and aggregates the others (count, sum, average, first, last, minimum or maximum) using a GroupByReader.

AggregateGroupFieldsAction() - Constructor for class com.northconcepts.datapipeline.foundations.pipeline.action.aggregate.AggregateGroupFieldsAction

 

AggregateGroupFieldsAction.GroupByField - Class in com.northconcepts.datapipeline.foundations.pipeline.action.aggregate

A source field and the operator applied to it: either a grouping key (GROUPBY) or an aggregate written to the target field.

AggregateGroupFieldsAction.OperatorType - Enum Class in com.northconcepts.datapipeline.foundations.pipeline.action.aggregate

The operator applied to a AggregateGroupFieldsAction.GroupByField: GROUPBY marks a grouping key and the others are aggregates.

AggregateOperation(String, String) - Constructor for class com.northconcepts.datapipeline.group.AggregateReader.AggregateOperation

Deprecated.

Creates an operation; its name (such as sum) and fieldName together identify it in the reader.

AggregateReader - Class in com.northconcepts.datapipeline.group

Deprecated.

use GroupByReader instead. GroupByReader provides the same functionality and can return continuous results

AggregateReader(DataReader) - Constructor for class com.northconcepts.datapipeline.group.AggregateReader

Deprecated.

 

AggregateReader.AggregateOperation - Class in com.northconcepts.datapipeline.group

Deprecated.

Base class for the set functions an AggregateReader applies to each record passing through it.

ALIVE - Enum constant in enum class com.northconcepts.datapipeline.core.Record.State

Record is in normal, unmodified state.

ALIVE - Enum constant in enum class com.northconcepts.datapipeline.eventbus.EventBus.State

 

all() - Static method in interface com.northconcepts.datapipeline.core.FieldLocationPredicate

Returns a predicate that matches all field locations.

ALL - Enum constant in enum class com.northconcepts.datapipeline.jira.JiraSprintReader.SprintState

 

ALL - Enum constant in enum class com.northconcepts.datapipeline.trello.BoardFilter

 

ALL - Enum constant in enum class com.northconcepts.datapipeline.trello.BoardLists

 

ALL - Enum constant in enum class com.northconcepts.datapipeline.trello.CardFilter

 

ALL - Enum constant in enum class com.northconcepts.datapipeline.trello.ListFilter

 

ALL_MAIL - Static variable in interface com.northconcepts.datapipeline.email.GmailFolders

 

allow(Field) - Method in class com.northconcepts.datapipeline.filter.FieldFilterRule

Returns true if the given field satisfies this rule; called by FieldFilter with each field it checks.

allow(Field) - Method in class com.northconcepts.datapipeline.filter.rule.Contains

 

allow(Field) - Method in class com.northconcepts.datapipeline.filter.rule.DateIs

 

allow(Field) - Method in class com.northconcepts.datapipeline.filter.rule.DateIsAfter

 

allow(Field) - Method in class com.northconcepts.datapipeline.filter.rule.DateIsBefore

 

allow(Field) - Method in class com.northconcepts.datapipeline.filter.rule.IsEmpty

 

allow(Field) - Method in class com.northconcepts.datapipeline.filter.rule.IsFieldType

 

allow(Field) - Method in class com.northconcepts.datapipeline.filter.rule.IsInstanceOfJavaType

 

allow(Field) - Method in class com.northconcepts.datapipeline.filter.rule.IsJavaType

 

allow(Field) - Method in class com.northconcepts.datapipeline.filter.rule.IsNotEmpty

 

allow(Field) - Method in class com.northconcepts.datapipeline.filter.rule.IsNotNull

 

allow(Field) - Method in class com.northconcepts.datapipeline.filter.rule.IsNull

 

allow(Field) - Method in class com.northconcepts.datapipeline.filter.rule.NotRule

 

allow(Field) - Method in class com.northconcepts.datapipeline.filter.rule.OrRule

 

allow(Field) - Method in class com.northconcepts.datapipeline.filter.rule.PatternMatch

 

allow(Field) - Method in class com.northconcepts.datapipeline.filter.rule.ValueMatch

 

allow(Record) - Method in class com.northconcepts.datapipeline.filter.FieldCount

 

allow(Record) - Method in class com.northconcepts.datapipeline.filter.FieldExists

 

allow(Record) - Method in class com.northconcepts.datapipeline.filter.FieldFilter

 

allow(Record) - Method in class com.northconcepts.datapipeline.filter.FieldNotExists

 

allow(Record) - Method in class com.northconcepts.datapipeline.filter.Filter

Tests whether a record passes this filter.

allow(Record) - Method in class com.northconcepts.datapipeline.filter.FilterExpression

 

allow(Record) - Method in class com.northconcepts.datapipeline.foundations.schema.SchemaFilter

 

allow(Event<?>, Object) - Method in interface com.northconcepts.datapipeline.eventbus.EventFilter

Returns true to deliver the event to the given listener; called on the bus's delivery thread.

allow(Event<?>, Object) - Method in class com.northconcepts.datapipeline.eventbus.filter.AndFilter

 

allow(Event<?>, Object) - Method in class com.northconcepts.datapipeline.eventbus.filter.EventListenerClassFilter

 

allow(Event<?>, Object) - Method in class com.northconcepts.datapipeline.eventbus.filter.EventSourceFilter

 

allow(Event<?>, Object) - Method in class com.northconcepts.datapipeline.eventbus.filter.NotFilter

 

allow(Event<?>, Object) - Method in class com.northconcepts.datapipeline.eventbus.filter.NullFilter

 

allow(Event<?>, Object) - Method in class com.northconcepts.datapipeline.eventbus.filter.OrFilter

 

allow(Event<?>, Object) - Method in class com.northconcepts.datapipeline.eventbus.filter.TopicFilter

 

AmazonS3File - Class in com.northconcepts.datapipeline.amazons3

Base class for a file in Amazon S3, located by bucket name and path and accessed through an AmazonS3FileSystem that other files may share.

AmazonS3File() - Constructor for class com.northconcepts.datapipeline.amazons3.AmazonS3File

Creates a file with its own new AmazonS3FileSystem.

AmazonS3File(AmazonS3FileSystem) - Constructor for class com.northconcepts.datapipeline.amazons3.AmazonS3File

Creates a file that uses the given file system, or a new one if it is null.

AmazonS3FileSink - Class in com.northconcepts.datapipeline.amazons3

A FileSink that writes an Amazon S3 object with a multipart upload through an AmazonS3FileSystem, connecting on demand if the file system is not open.

AmazonS3FileSink() - Constructor for class com.northconcepts.datapipeline.amazons3.AmazonS3FileSink

 

AmazonS3FileSource - Class in com.northconcepts.datapipeline.amazons3

A FileSource that reads an Amazon S3 object through an AmazonS3FileSystem, connecting on demand if the file system is not open.

AmazonS3FileSource() - Constructor for class com.northconcepts.datapipeline.amazons3.AmazonS3FileSource

 

amazonS3FileSystem - Variable in class com.northconcepts.datapipeline.amazons3.AmazonS3File

 

AmazonS3FileSystem - Class in com.northconcepts.datapipeline.amazons3

Class for accessing an Amazon S3 file system.

AmazonS3FileSystem() - Constructor for class com.northconcepts.datapipeline.amazons3.AmazonS3FileSystem

Constructs an Amazon S3 file system instance.

AmazonS3FileSystem.CredentialsResolverBridge - Class in com.northconcepts.datapipeline.amazons3

Adapts the backend-neutral CredentialsResolver seam to the AWS SDK's

invalid reference

AwsCredentialsProvider

so resolved credentials flow through the native client natively.

AmazonS3Util - Class in com.northconcepts.datapipeline.amazons3

Static helpers that write and read object expiration rules in an S3 bucket's lifecycle configuration through an S3ControlClient.

AmazonS3Util() - Constructor for class com.northconcepts.datapipeline.amazons3.AmazonS3Util

 

ancestor - Variable in class com.northconcepts.datapipeline.jsonata.Parser.Symbol

 

and(boolean, QueryCriteriaPart) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.QueryCriteria

ANDs the part with the existing conditions (first if first is true) and returns the root AndPart.

and(boolean, String, Object...) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.QueryCriteria

ANDs a condition with its parameter values (first if first is true) and returns the root AndPart.

and(BufferStrategy...) - Static method in class com.northconcepts.datapipeline.buffer.BufferStrategy

Closes buffers if all of the supplied strategies request it.

and(ExcelCellStyleDecorator) - Method in interface com.northconcepts.datapipeline.excel.ExcelCellStyleDecorator

Returns a composed decorator that applies this decorator and then the other decorator.

and(CloseWindowStrategy...) - Static method in class com.northconcepts.datapipeline.group.CloseWindowStrategy

Closes windows if all of the supplied strategies request it.

and(CreateWindowStrategy...) - Static method in class com.northconcepts.datapipeline.group.CreateWindowStrategy

Opens a new window if all of the supplied strategies request it.

and(QueryCriteriaPart) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.QueryCriteria

ANDs the part after the existing conditions and returns the root AndPart.

and(String, Object...) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.QueryCriteria

ANDs a condition, such as "id = ?", with its parameter values and returns the root AndPart.

AndFilter - Class in com.northconcepts.datapipeline.eventbus.filter

Matches all filers -- filer A invalid input: '&'invalid input: '&' filer B invalid input: '&'invalid input: '&' filer C.

AndFilter(EventFilter...) - Constructor for class com.northconcepts.datapipeline.eventbus.filter.AndFilter

 

AndPart - Class in com.northconcepts.datapipeline.jdbc.sql.select

A ConjunctivePart that joins its parts with AND.

AndPart() - Constructor for class com.northconcepts.datapipeline.jdbc.sql.select.AndPart

 

ANIMATED_GIFS_ARE_NOT_ALLOWED - Enum constant in enum class com.northconcepts.datapipeline.twitter.TwitterErrorCode

 

ANY - Enum constant in enum class com.northconcepts.datapipeline.shopify.client.FulfillmentStatus

 

ANY - Enum constant in enum class com.northconcepts.datapipeline.shopify.client.OrderStatus

 

ANY - Enum constant in enum class com.northconcepts.datapipeline.shopify.client.PublishedStatus

 

ApiLimitPolicy - Enum Class in com.northconcepts.datapipeline.twitter

Indicates the action to take when the Twitter API call limits are reached.

append(Object, Object) - Static method in class com.northconcepts.datapipeline.jsonata.Functions

Append second argument to first

append(String) - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer

Appends suffix to each value, treating null values as empty strings.

APPEND - Enum constant in enum class com.northconcepts.datapipeline.core.Node.DuplicateNodeAction

Combines the fields into an array if either (or both) are either arrays or single valued fields, otherwise combines the fields into a single record.

appendRow(List<Object>) - Method in class com.northconcepts.datapipeline.google.sheets.GoogleSheetDocument

 

APPLICATION_CANNOT_PERFORM_WRITE_ACTIONS - Enum constant in enum class com.northconcepts.datapipeline.twitter.TwitterErrorCode

 

apply(double) - Method in class com.northconcepts.datapipeline.transform.format.Rounder

Rounds the value in double arithmetic; the UNNECESSARY policy returns it unchanged.

apply(A, B, C) - Method in interface com.northconcepts.datapipeline.jsonata.Jsonata.Fn3

 

apply(A, B, C, D) - Method in interface com.northconcepts.datapipeline.jsonata.Jsonata.Fn4

 

apply(A, B, C, D, E) - Method in interface com.northconcepts.datapipeline.jsonata.Jsonata.Fn5

 

apply(A, B, C, D, E, F) - Method in interface com.northconcepts.datapipeline.jsonata.Jsonata.Fn6

 

apply(A, B, C, D, E, F, G) - Method in interface com.northconcepts.datapipeline.jsonata.Jsonata.Fn7

 

apply(A, B, C, D, E, F, G, H) - Method in interface com.northconcepts.datapipeline.jsonata.Jsonata.Fn8

 

apply(DataReader) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.aggregate.AggregateGroupFieldsAction

 

apply(DataReader) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.CompositePipelineAction

 

apply(DataReader) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.convert.ConvertDateTimeToStringAction

 

apply(DataReader) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.convert.ConvertNullToValueAction

 

apply(DataReader) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.convert.ConvertNumberToStringAction

 

apply(DataReader) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.convert.ConvertStringToBooleanAction

 

apply(DataReader) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.convert.ConvertStringToDateTimeAction

 

apply(DataReader) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.convert.ConvertStringToNumberAction

 

apply(DataReader) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.convert.ConvertValueToStringAction

 

apply(DataReader) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.datamapping.DataMappingAction

 

apply(DataReader) - Method in interface com.northconcepts.datapipeline.foundations.pipeline.action.DataReaderAction

Returns a reader that applies this action to the records of the given reader, usually by wrapping it.

apply(DataReader) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.decision.DecisionTableAction

 

apply(DataReader) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.decision.DecisionTreeAction

 

apply(DataReader) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.filter.FilterFieldExistsAction

 

apply(DataReader) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.filter.FilterFieldMatchesPatternAction

 

apply(DataReader) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.filter.FilterFieldNotNullAction

 

apply(DataReader) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.filter.FilterMatchExpression

 

apply(DataReader) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.transform.AddFieldsAction

 

apply(DataReader) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.transform.CopyFieldsAction

 

apply(DataReader) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.transform.RemoveDuplicatesAction

 

apply(DataReader) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.transform.RenameFieldsAction

 

apply(DataReader) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.transform.SelectArrangeFieldsAction

 

apply(DataReader) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.transform.SortFieldsAction

 

apply(DataReader) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.validate.ValidateFieldsExistsAction

 

apply(DataReader) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.validate.ValidateFieldsMatchPatternAction

 

apply(DataReader) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.validate.ValidateFieldsNotNullAction

 

apply(DataReader) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.validate.ValidateMatchExpression

 

apply(Field) - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer.Operation

Applies this operation to the field, updating its value in place.

apply(Field) - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer.SingleValueOperation

 

apply(Record, Field) - Method in class com.northconcepts.datapipeline.group.GroupOperationField

Adds a record of the group to this result; field is the record's source field or null if the operation has none.

apply(Tree) - Method in class com.northconcepts.datapipeline.foundations.pipeline.tree.detect.TreeDetectionStrategy

Runs every TreeTransformer against the supplied tree, in order.

apply(GroupByReader, AggregateGroupFieldsAction.GroupByField) - Method in enum class com.northconcepts.datapipeline.foundations.pipeline.action.aggregate.AggregateGroupFieldsAction.OperatorType

Adds this operator's aggregate for the field to the reader; does nothing for GROUPBY, whose fields are the reader's grouping keys.

apply(BasicFieldTransformer, String) - Method in enum class com.northconcepts.datapipeline.foundations.pipeline.action.convert.ConvertNullToValueAction.FieldType

Adds the operation that replaces nulls with the value, converted to this type, to the transformer.

apply(TransformingReader, FieldPath, String) - Method in enum class com.northconcepts.datapipeline.foundations.pipeline.action.transform.AddFieldsAction.FieldType

Adds a transformer to the reader that sets the field to the value converted to this type, or to a typed null if the value is blank.

apply(BigDecimal) - Method in class com.northconcepts.datapipeline.transform.format.Rounder

Returns the value with its scale set to the decimal places using this policy, or null for null; HALF_ODD is not supported.

apply(BigInteger) - Method in class com.northconcepts.datapipeline.transform.format.Rounder

Rounds the value as a BigDecimal, so only negative decimal places change it; returns null for null.

applyCode(CodeWriter, String) - Method in enum class com.northconcepts.datapipeline.foundations.pipeline.action.convert.ConvertStringToDateTimeAction.FieldType

Same as ConvertStringToDateTimeAction.FieldType.applyCodeChain(CodeWriter, String), but indented one level.

applyCode(CodeWriter, String) - Method in enum class com.northconcepts.datapipeline.foundations.pipeline.action.convert.ConvertStringToNumberAction.FieldType

Same as ConvertStringToNumberAction.FieldType.applyCodeChain(CodeWriter, String), but indented one level.

applyCodeChain(CodeWriter, String) - Method in enum class com.northconcepts.datapipeline.foundations.pipeline.action.convert.ConvertStringToDateTimeAction.FieldType

Writes this type's BasicFieldTransformer conversion call for the pattern.

applyCodeChain(CodeWriter, String) - Method in enum class com.northconcepts.datapipeline.foundations.pipeline.action.convert.ConvertStringToNumberAction.FieldType

Writes this type's BasicFieldTransformer conversion call for the pattern.

applyDataMapping() - Method in class com.northconcepts.datapipeline.foundations.datamapping.DataMappingEditor

Re-applies an existing DataMapping on the source dataset along with the existing sorting and page number.

applyDataMapping(DataMapping) - Method in class com.northconcepts.datapipeline.foundations.datamapping.DataMappingEditor

Applies a new DataMapping on the source dataset along with the existing sorting and page number.

applyDataProcessing(DataReader) - Method in class com.northconcepts.datapipeline.foundations.pipeline.AbstractPipeline

Wraps the reader with the source entity transformer, this pipeline's own processing and the target entity transformer, in that order.

applyDataProcessingImpl(DataReader) - Method in class com.northconcepts.datapipeline.foundations.pipeline.AbstractPipeline

Wraps the reader with this pipeline's own processing; called between the source and target entity transformers.

applyDataProcessingImpl(DataReader) - Method in class com.northconcepts.datapipeline.foundations.pipeline.DataMappingPipeline

 

applyDataProcessingImpl(DataReader) - Method in class com.northconcepts.datapipeline.foundations.pipeline.NullPipeline

 

applyDataProcessingImpl(DataReader) - Method in class com.northconcepts.datapipeline.foundations.pipeline.Pipeline

 

applyImpl(SingleValue) - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer.SingleValueOperation

Returns the replacement for input; return input itself to leave it unchanged or null to store a null of returnType.

applyImpl(SingleValue) - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer.StringOperation

 

applyImpl(String) - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer.StringOperation

Returns the transformed string or null to store a null; value is null only for operations that apply to nulls.

applyMethod(BasicFieldTransformer, String) - Method in enum class com.northconcepts.datapipeline.foundations.pipeline.action.convert.ConvertStringToDateTimeAction.FieldType

Adds this type's string conversion, using the pattern, to the transformer.

applyMethod(BasicFieldTransformer, String) - Method in enum class com.northconcepts.datapipeline.foundations.pipeline.action.convert.ConvertStringToNumberAction.FieldType

Adds this type's string conversion, using the pattern if not blank, to the transformer.

applyPagination() - Method in class com.northconcepts.datapipeline.foundations.datamapping.DataMappingEditor

Re-applies the existing sorting and page number to the existing mapped data from the source dataset.

applyPagination(int) - Method in class com.northconcepts.datapipeline.foundations.datamapping.DataMappingEditor

Applies a new sorting and page number to the existing mapped data from the source dataset.

applySourceEntityTransformer(DataReader) - Method in class com.northconcepts.datapipeline.foundations.pipeline.AbstractPipeline

Wraps the reader to convert and validate records against the source entity, if one is set, in its own thread when multithreaded.

applyTargetEntityTransformer(DataReader) - Method in class com.northconcepts.datapipeline.foundations.pipeline.AbstractPipeline

Wraps the reader to convert and validate records against the target entity, if one is set, in its own thread when multithreaded.

applyToArrayValue(ArrayValue, int, SingleValue) - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer.SingleValueOperation

Applies applyImpl to the array element at the 0-based index and stores the result in the array.

applyToFieldValue(Field, SingleValue) - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer.SingleValueOperation

Applies applyImpl to a field's single value and stores the result in the field.

applyToNullArray(ArrayValue) - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer.SingleValueOperation

 

applyToNulls - Variable in class com.northconcepts.datapipeline.transform.BasicFieldTransformer.SingleValueOperation

 

AQUA - Enum constant in enum class com.northconcepts.datapipeline.excel.ExcelColorPalette

 

archived - Enum constant in enum class com.northconcepts.datapipeline.mailchimp.list.ListMemberStatus

 

ARCHIVED - Enum constant in enum class com.northconcepts.datapipeline.shopify.client.ProductStatus

 

ARCHIVED_DATE - Enum constant in enum class com.northconcepts.datapipeline.jira.JiraProjectReader.OrderByField

 

array() - Method in class com.northconcepts.datapipeline.json.builder.JsonArray

 

array() - Method in class com.northconcepts.datapipeline.json.builder.JsonConditionalNode

 

array() - Method in class com.northconcepts.datapipeline.json.builder.JsonDetailMarker

 

array() - Method in class com.northconcepts.datapipeline.json.builder.JsonNode

Adds an anonymous array element and returns it; only arrays (and the template root) accept one.

array() - Method in class com.northconcepts.datapipeline.json.builder.JsonTemplate

 

array(String) - Method in class com.northconcepts.datapipeline.json.builder.JsonConditionalNode

 

array(String) - Method in class com.northconcepts.datapipeline.json.builder.JsonDetailMarker

 

array(String) - Method in class com.northconcepts.datapipeline.json.builder.JsonNode

Adds an array-valued field and returns the new array; only valid on object nodes.

array(String) - Method in class com.northconcepts.datapipeline.json.builder.JsonObject

 

ARRAY - Enum constant in enum class com.northconcepts.datapipeline.core.Node.NodeType

 

ARRAY - Enum constant in enum class com.northconcepts.datapipeline.json.builder.JsonNodeType

 

ArrayTemplateModel - Class in com.northconcepts.datapipeline.template

Exposes an ArrayValue to FreeMarker templates as a sequence whose elements are wrapped by the object wrapper.

ArrayTemplateModel() - Constructor for class com.northconcepts.datapipeline.template.ArrayTemplateModel

 

ArrayTemplateModel(ArrayValue, ObjectWrapper) - Constructor for class com.northconcepts.datapipeline.template.ArrayTemplateModel

 

arrayTooLarge(String, Number, Object) - Static method in class com.northconcepts.datapipeline.foundations.i18n.SchemaMessages

 

arrayTooSmall(String, Number, Object) - Static method in class com.northconcepts.datapipeline.foundations.i18n.SchemaMessages

 

ArrayValue - Class in com.northconcepts.datapipeline.core

ArrayValue holds an ordered collection (also known as a sequence) of persistent data.

ArrayValue() - Constructor for class com.northconcepts.datapipeline.core.ArrayValue

Creates a new empty array with an FieldType.UNDEFINED default type.

ArrayValue(FieldType) - Constructor for class com.northconcepts.datapipeline.core.ArrayValue

Creates a new empty array.

ArrayValue(Object...) - Constructor for class com.northconcepts.datapipeline.core.ArrayValue

Creates a new array populated with the given objects.

ARTICLE - Enum constant in enum class com.northconcepts.datapipeline.shopify.client.EventFilter

 

asArray(FieldType, Object) - Static method in class com.northconcepts.datapipeline.core.ValueNode

Wraps the given value as an ArrayValue.

asArrayValue() - Method in class com.northconcepts.datapipeline.core.ValueNode

Casts this value node to an ArrayValue.

asc(String) - Method in class com.northconcepts.datapipeline.core.SortingReader

Adds an ascending sort on the given field name or FieldPath expression, after any fields already added.

ASCENDING - Enum constant in enum class com.northconcepts.datapipeline.jira.JiraProjectReader.SortDirection

 

ASCII - Enum constant in enum class com.northconcepts.datapipeline.filesystem.ftp.FileTransferType

Files to be transferred will be treated as ASCII.

asRecord() - Method in class com.northconcepts.datapipeline.core.ValueNode

Casts this value node to a Record.

assembleLine(Record, StringBuilder) - Method in class com.northconcepts.datapipeline.core.LinedTextWriter

Appends the record's output line, without a line terminator, to the empty buffer; also called for the header row (see AbstractWriter.isHeaderRow()).

assembleLine(Record, StringBuilder) - Method in class com.northconcepts.datapipeline.csv.CSVWriter

 

assembleLine(Record, StringBuilder) - Method in class com.northconcepts.datapipeline.fixedwidth.FixedWidthWriter

 

assembleLine(Record, StringBuilder) - Method in class com.northconcepts.datapipeline.json.JsonLinesWriter

 

assertAlive() - Method in class com.northconcepts.datapipeline.eventbus.EventBus

Asserts that this endpoint has started reading or writing, otherwise an exception is thrown.

assertClosed() - Method in class com.northconcepts.datapipeline.core.Endpoint

Asserts that this endpoint has finished reading or writing, otherwise an exception is thrown.

assertFn(boolean, String) - Static method in class com.northconcepts.datapipeline.jsonata.Functions

 

assertNotAncestorOf(Node) - Method in class com.northconcepts.datapipeline.core.Node

Throws a DataException if the proposed parent is this node or one of its descendants, which would create a cycle.

assertNotOpened() - Method in class com.northconcepts.datapipeline.core.Endpoint

Asserts that this endpoint has not yet started reading or writing, otherwise an exception is thrown.

assertOpened() - Method in class com.northconcepts.datapipeline.core.Endpoint

Asserts that this endpoint has started reading or writing, otherwise an exception is thrown.

assertType(JsonNodeType, String) - Method in class com.northconcepts.datapipeline.json.builder.JsonNode

Throws a DataException with the given message unless this node is of the given type.

assertValid() - Method in class com.northconcepts.datapipeline.amazons3.AmazonS3File

Throws a DataException if this file has no AmazonS3FileSystem.

assertValid() - Method in class com.northconcepts.datapipeline.foundations.core.FoundationObject

Throws a DataException if this object is invalid, otherwise returns it; the base implementation checks nothing.

assertValid() - Method in class com.northconcepts.datapipeline.foundations.decisiontable.DecisionTable

 

assertValid() - Method in class com.northconcepts.datapipeline.foundations.decisiontable.DecisionTableCondition

 

assertValid() - Method in class com.northconcepts.datapipeline.foundations.decisiontable.DecisionTableOutcome

 

assertValid() - Method in class com.northconcepts.datapipeline.foundations.decisiontable.DecisionTableRule

 

assertValid() - Method in class com.northconcepts.datapipeline.foundations.decisiontree.DecisionTree

 

assertValid() - Method in class com.northconcepts.datapipeline.foundations.decisiontree.DecisionTreeOutcome

 

assertValid() - Method in class com.northconcepts.datapipeline.foundations.expression.CalculatedField

 

assertValid() - Method in class com.northconcepts.datapipeline.foundations.schema.FieldDef

 

assertValid() - Method in class com.northconcepts.datapipeline.foundations.schema.IndexFieldDef

 

assertValid(Collection<? extends FoundationObject>) - Method in class com.northconcepts.datapipeline.foundations.core.FoundationObject

Calls FoundationObject.assertValid() on each of the given objects; a null collection is ignored.

assign(String, Object) - Method in class com.northconcepts.datapipeline.jsonata.Jsonata

 

asSingleValue() - Method in class com.northconcepts.datapipeline.core.ValueNode

Casts this value node to a SingleValue.

ASTNode - Interface in com.northconcepts.datapipeline.expression

The public API for a node in the expression language's abstract syntax tree.

AsymmetricDecryptingReader - Class in com.northconcepts.datapipeline.security

A DecryptingReader for fields written by an AsymmetricEncryptingReader; it recovers the symmetric key from the first value it decrypts, using the private key, and uses it for all values.

AsymmetricDecryptingReader(DataReader) - Constructor for class com.northconcepts.datapipeline.security.AsymmetricDecryptingReader

 

AsymmetricDecryptingReader(DataReader, String, PrivateKey) - Constructor for class com.northconcepts.datapipeline.security.AsymmetricDecryptingReader

 

AsymmetricEncryptingReader - Class in com.northconcepts.datapipeline.security

An EncryptingReader that encrypts fields with a symmetric key and appends that key, encrypted with a public key, to every value after a -; read the values back with an AsymmetricDecryptingReader.

AsymmetricEncryptingReader(DataReader) - Constructor for class com.northconcepts.datapipeline.security.AsymmetricEncryptingReader

 

AsymmetricEncryptingReader(DataReader, String, PublicKey) - Constructor for class com.northconcepts.datapipeline.security.AsymmetricEncryptingReader

 

AsyncMultiReader - Class in com.northconcepts.datapipeline.core

AsyncMultiReader reads from one or more source DataReaders asynchronously using a separate thread for each one.

AsyncMultiReader(DataReader...) - Constructor for class com.northconcepts.datapipeline.core.AsyncMultiReader

 

AsyncMultiReader.ReaderThread - Class in com.northconcepts.datapipeline.core

Thread that opens one source reader, copies its records into the AsyncMultiReader's buffer and closes it.

AsyncReader - Class in com.northconcepts.datapipeline.core

A proxy that reads data asynchronously using a separate thread.

AsyncReader(DataReader) - Constructor for class com.northconcepts.datapipeline.core.AsyncReader

 

AsyncTaskReader - Class in com.northconcepts.datapipeline.core

A proxy that uses multiple threads to process incoming data, where the work applied to the incoming data is specified by the a DataReaderDecorator.

AsyncTaskReader(DataReader, DataReaderDecorator, int) - Constructor for class com.northconcepts.datapipeline.core.AsyncTaskReader

Creates a new AsyncTaskReader to process incoming data using multiple threads.

AsyncWriter - Class in com.northconcepts.datapipeline.core

A proxy that writes data asynchronously using a separate thread.

AsyncWriter(DataWriter) - Constructor for class com.northconcepts.datapipeline.core.AsyncWriter

Creates an AsyncWriter object, with the given DataWriter and default capacity of 500 records that can be queued.

AsyncWriter(DataWriter, int) - Constructor for class com.northconcepts.datapipeline.core.AsyncWriter

Creates an AsyncWriter object, with the given DataWriter and maximum number of records that can be queued.

ATTACHMENT_URL_PARAMETER_IS_INVALID - Enum constant in enum class com.northconcepts.datapipeline.twitter.TwitterErrorCode

 

attribute(String, String) - Method in class com.northconcepts.datapipeline.xml.builder.XmlElement

Adds an attribute whose name and value are expressions (quote literal text) and returns this element.

Attributes - Class in com.northconcepts.datapipeline.foundations.core

User-defined name-value pairs that attach arbitrary metadata to schema, entity, relationship and field definitions; kept sorted by name.

Attributes() - Constructor for class com.northconcepts.datapipeline.foundations.core.Attributes

 

AUTHORIZATION_FAILURE - Enum constant in enum class com.northconcepts.datapipeline.shopify.client.EventVerb

 

AUTHORIZATION_PENDING - Enum constant in enum class com.northconcepts.datapipeline.shopify.client.EventVerb

 

AUTHORIZATION_SUCCESS - Enum constant in enum class com.northconcepts.datapipeline.shopify.client.EventVerb

 

AUTHORIZED - Enum constant in enum class com.northconcepts.datapipeline.shopify.client.FinancialStatus

 

AUTO - Enum constant in enum class com.northconcepts.datapipeline.foundations.schema.PrimaryKeyType

 

AUTO - Enum constant in enum class com.northconcepts.datapipeline.jms.JmsAcknowledgeMode

 

AUTOMATIC - Enum constant in enum class com.northconcepts.datapipeline.excel.ExcelColorPalette

 

available() - Method in class com.northconcepts.datapipeline.core.AsyncReader

 

available() - Method in class com.northconcepts.datapipeline.core.AsyncWriter

 

available() - Method in class com.northconcepts.datapipeline.core.DataReader

Returns the number of records that can probably be read without blocking.

available() - Method in class com.northconcepts.datapipeline.core.DataWriter

Returns the number of records that can probably be written without blocking.

available() - Method in class com.northconcepts.datapipeline.core.ParsingReader

 

available() - Method in class com.northconcepts.datapipeline.core.PipedReader

 

available() - Method in class com.northconcepts.datapipeline.core.ProxyReader

 

available() - Method in class com.northconcepts.datapipeline.core.ProxyWriter

 

available() - Method in class com.northconcepts.datapipeline.core.SequenceReader

 

available() - Method in class com.northconcepts.datapipeline.core.TextReader

 

available() - Method in class com.northconcepts.datapipeline.eventbus.EventBusReader

 

available() - Method in class com.northconcepts.datapipeline.foundations.pipeline.dataset.Dataset.ColumnsDataReader

 

available() - Method in class com.northconcepts.datapipeline.google.gmail.GmailMessageReader

 

available() - Method in class com.northconcepts.datapipeline.job.DataReaderIterator

 

available() - Method in class com.northconcepts.datapipeline.memory.MemoryReader

 

AvailableCapacityWriteStrategy() - Constructor for class com.northconcepts.datapipeline.core.MultiWriter.AvailableCapacityWriteStrategy

 

average(String) - Method in class com.northconcepts.datapipeline.group.AggregateReader

Deprecated.

Adds an operation averaging the field's non-null values as a Double (NaN if there are none).

average(List<Number>) - Static method in class com.northconcepts.datapipeline.jsonata.Functions

Average function

AVERAGE - Enum constant in enum class com.northconcepts.datapipeline.foundations.pipeline.action.aggregate.AggregateGroupFieldsAction.OperatorType

 

avg(FieldPath, FieldPath) - Method in class com.northconcepts.datapipeline.group.GroupByReader

Adds the average of the source field as a BigDecimal with 5 decimal places (HALF_UP), written to the target field; null values count as zero.

avg(FieldPath, FieldPath, int, RoundingMode) - Method in class com.northconcepts.datapipeline.group.GroupByReader

Adds the average of the source field rounded to scale decimal places, written to the target field; null values count as zero.

avg(String, String) - Method in class com.northconcepts.datapipeline.group.GroupByReader

Adds the average of the source field as a BigDecimal with 5 decimal places (HALF_UP), written to the target field; null values count as zero.

avg(String, String, int, RoundingMode) - Method in class com.northconcepts.datapipeline.group.GroupByReader

Adds the average of the source field rounded to scale decimal places, written to the target field; null values count as zero.

AVRO - Enum constant in enum class com.northconcepts.datapipeline.foundations.file.FileType

 

AVRO_SCHEMA - Enum constant in enum class com.northconcepts.datapipeline.foundations.file.FileType

 

AvroPipelineInput - Class in com.northconcepts.datapipeline.avro.pipeline.input

A pipeline input that reads Apache Avro data from a FileSource using an AvroReader.

AvroPipelineInput() - Constructor for class com.northconcepts.datapipeline.avro.pipeline.input.AvroPipelineInput

 

AvroPipelineOutput - Class in com.northconcepts.datapipeline.avro.pipeline.output

A pipeline output that writes Apache Avro data to a FileSink using an AvroWriter.

AvroPipelineOutput() - Constructor for class com.northconcepts.datapipeline.avro.pipeline.output.AvroPipelineOutput

 

AvroReader - Class in com.northconcepts.datapipeline.avro

Read an Apache Avro file and convert the contents into Records .

AvroReader(File) - Constructor for class com.northconcepts.datapipeline.avro.AvroReader

Read an Avro file.

AvroReader(InputStream) - Constructor for class com.northconcepts.datapipeline.avro.AvroReader

Read a stream of Avro data.

AvroWriter - Class in com.northconcepts.datapipeline.avro

Write Records to an Apache Avro file.

AvroWriter(File, DataWriter) - Constructor for class com.northconcepts.datapipeline.avro.AvroWriter

Write Avro data to the specified file.

AvroWriter(OutputStream, DataWriter) - Constructor for class com.northconcepts.datapipeline.avro.AvroWriter

Write Avro data to an OutputStream.

B

B4 - Enum constant in enum class com.northconcepts.datapipeline.pdf.PdfWriter.PageSize

 

B5 - Enum constant in enum class com.northconcepts.datapipeline.pdf.PdfWriter.PageSize

 

backgroundColor(ExcelColor) - Static method in interface com.northconcepts.datapipeline.excel.ExcelCellStyleDecorator

Returns a decorator that sets the background color.

backgroundColor(ExcelColorPalette) - Static method in interface com.northconcepts.datapipeline.excel.ExcelCellStyleDecorator

Returns a decorator that sets the background color using a palette color.

BACKWARD - Enum constant in enum class com.northconcepts.datapipeline.email.EmailReadDirection

 

BACKWARD - Enum constant in enum class com.northconcepts.datapipeline.twitter.TwitterPageableReader.Direction

 

BAD_AUTHENTICATION_DATA - Enum constant in enum class com.northconcepts.datapipeline.twitter.TwitterErrorCode

 

base64decode(String) - Static method in class com.northconcepts.datapipeline.jsonata.Functions

Base64 decode a string

base64encode(String) - Static method in class com.northconcepts.datapipeline.jsonata.Functions

Base64 encode a string

BasicFieldTransformer - Class in com.northconcepts.datapipeline.transform

See FieldPath for supported field name expressions.

BasicFieldTransformer(String) - Constructor for class com.northconcepts.datapipeline.transform.BasicFieldTransformer

 

BasicFieldTransformer(String...) - Constructor for class com.northconcepts.datapipeline.transform.BasicFieldTransformer

 

BasicFieldTransformer(Collection<String>) - Constructor for class com.northconcepts.datapipeline.transform.BasicFieldTransformer

 

BasicFieldTransformer.Operation - Class in com.northconcepts.datapipeline.transform

A named step that a BasicFieldTransformer applies to each of its fields.

BasicFieldTransformer.SingleValueOperation - Class in com.northconcepts.datapipeline.transform

An BasicFieldTransformer.Operation applied to each single value in a field, including array elements and values in nested records.

BasicFieldTransformer.StringOperation - Class in com.northconcepts.datapipeline.transform

A BasicFieldTransformer.SingleValueOperation that transforms the string form of each value into a new string.

BasicLookup - Class in com.northconcepts.datapipeline.transform.lookup

An in-memory Lookup filled with add calls, where each key maps to one or more result records.

BasicLookup(FieldList) - Constructor for class com.northconcepts.datapipeline.transform.lookup.BasicLookup

Creates an empty lookup whose result records have the given fields, filled in order from the values passed to add.

batchedInserts - Variable in class com.northconcepts.datapipeline.sql.h2.H2InsertWriter

 

batchedInserts - Variable in class com.northconcepts.datapipeline.sql.mysql.MySqlInsertWriter

 

batchedInserts - Variable in class com.northconcepts.datapipeline.sql.postgresql.PostgreSqlInsertWriter

 

batchSize - Variable in class com.northconcepts.datapipeline.sql.h2.H2InsertWriter

 

batchSize - Variable in class com.northconcepts.datapipeline.sql.mysql.MySqlInsertWriter

 

batchSize - Variable in class com.northconcepts.datapipeline.sql.postgresql.PostgreSqlInsertWriter

 

Bean - Class in com.northconcepts.datapipeline.foundations.core

Base class for Java beans wishing to participate in Java, Record, XML, and JSON serialization; adding their properties to DataException; and having a dynamic toString().

Bean() - Constructor for class com.northconcepts.datapipeline.foundations.core.Bean

 

beforeLoad() - Method in class com.northconcepts.datapipeline.foundations.pipeline.dataset.Dataset

Called at the start of the data loading process, but before any records or column stats have been loaded.

beforeLoad() - Method in class com.northconcepts.datapipeline.foundations.pipeline.dataset.JdbcDataset

 

beforeLoad() - Method in class com.northconcepts.datapipeline.foundations.pipeline.dataset.LocalFileDataset

 

beforeLoad() - Method in class com.northconcepts.datapipeline.foundations.pipeline.dataset.MemoryDataset

 

beforeLoad() - Method in class com.northconcepts.datapipeline.foundations.pipeline.dataset.MvStoreDataset

 

beforeSequenceCreated() - Method in class com.northconcepts.datapipeline.core.SequenceWriter

Called before the factory creates the writer for a new sequence; does nothing by default.

BEST_FIT - Enum constant in enum class com.northconcepts.datapipeline.foundations.tools.GenerateEntityFromDataset.FieldTypeSelectionMode

 

BEST_FIT_INFERRED - Enum constant in enum class com.northconcepts.datapipeline.foundations.tools.GenerateEntityFromDataset.FieldTypeSelectionMode

 

bestRowIdentifiersLoaded(JdbcConnection, DatabaseMetaData, LoadTablesRequest) - Method in interface com.northconcepts.datapipeline.foundations.jdbc.JdbcConnectionListener

 

BIG_DECIMAL - Enum constant in enum class com.northconcepts.datapipeline.core.FieldType

 

BIG_INTEGER - Enum constant in enum class com.northconcepts.datapipeline.core.FieldType

 

BIGDECIMAL - Enum constant in enum class com.northconcepts.datapipeline.foundations.pipeline.action.convert.ConvertNullToValueAction.FieldType

 

BIGDECIMAL - Enum constant in enum class com.northconcepts.datapipeline.foundations.pipeline.action.convert.ConvertStringToNumberAction.FieldType

 

BIGDECIMAL - Enum constant in enum class com.northconcepts.datapipeline.foundations.pipeline.action.transform.AddFieldsAction.FieldType

 

BIGINT - Enum constant in enum class com.northconcepts.datapipeline.sql.h2.TableColumnType

 

BIGINT - Enum constant in enum class com.northconcepts.datapipeline.sql.mysql.TableColumnType

 

BIGINT - Enum constant in enum class com.northconcepts.datapipeline.sql.postgresql.TableColumnType

 

BIGINTEGER - Enum constant in enum class com.northconcepts.datapipeline.foundations.pipeline.action.convert.ConvertNullToValueAction.FieldType

 

BIGINTEGER - Enum constant in enum class com.northconcepts.datapipeline.foundations.pipeline.action.convert.ConvertStringToNumberAction.FieldType

 

BIGINTEGER - Enum constant in enum class com.northconcepts.datapipeline.foundations.pipeline.action.transform.AddFieldsAction.FieldType

 

BIGSERIAL - Enum constant in enum class com.northconcepts.datapipeline.sql.postgresql.TableColumnType

 

BINARY - Enum constant in enum class com.northconcepts.datapipeline.filesystem.ftp.FileTransferType

Files to be transferred will be treated as a binary image, i.e..

BINARY - Enum constant in enum class com.northconcepts.datapipeline.foundations.file.FileType

 

BINARY - Enum constant in enum class com.northconcepts.datapipeline.sql.h2.TableColumnType

 

BINARY - Enum constant in enum class com.northconcepts.datapipeline.sql.mysql.TableColumnType

 

binaryFieldAllowedValuesNotSupported() - Static method in class com.northconcepts.datapipeline.foundations.i18n.SchemaMessages

 

BinaryFieldDef - Class in com.northconcepts.datapipeline.foundations.schema

A FieldDef for binary (byte[]) values with optional minimum and maximum lengths; allowed values are not supported.

BinaryFieldDef() - Constructor for class com.northconcepts.datapipeline.foundations.schema.BinaryFieldDef

 

BinaryFieldDef(String) - Constructor for class com.northconcepts.datapipeline.foundations.schema.BinaryFieldDef

 

BinaryFieldDef(String, FieldType) - Constructor for class com.northconcepts.datapipeline.foundations.schema.BinaryFieldDef

 

BinaryWriter - Class in com.northconcepts.datapipeline.core

Abstract super-class for writing records to a binary stream.

BinaryWriter(File) - Constructor for class com.northconcepts.datapipeline.core.BinaryWriter

Creates a writer to the given file, which is created (or truncated) immediately rather than when the writer is opened.

BinaryWriter(OutputStream) - Constructor for class com.northconcepts.datapipeline.core.BinaryWriter

Creates a writer to the given stream, wrapped in a BufferedOutputStream unless it already is one; the stream is closed when this writer is closed.

bind(String, Jsonata.Fn0<R>) - Method in class com.northconcepts.datapipeline.jsonata.Jsonata.Frame

 

bind(String, Jsonata.Fn1<A, R>) - Method in class com.northconcepts.datapipeline.jsonata.Jsonata.Frame

 

bind(String, Jsonata.Fn2<A, B, R>) - Method in class com.northconcepts.datapipeline.jsonata.Jsonata.Frame

 

bind(String, Jsonata.JFunction) - Method in class com.northconcepts.datapipeline.jsonata.Jsonata.Frame

 

bind(String, Object) - Method in class com.northconcepts.datapipeline.jsonata.Jsonata.Frame

 

BIT - Enum constant in enum class com.northconcepts.datapipeline.sql.h2.TableColumnType

 

BIT - Enum constant in enum class com.northconcepts.datapipeline.sql.mysql.TableColumnType

 

BIT - Enum constant in enum class com.northconcepts.datapipeline.sql.postgresql.TableColumnType

 

BIT_VARYING - Enum constant in enum class com.northconcepts.datapipeline.sql.postgresql.TableColumnType

 

BLACK - Enum constant in enum class com.northconcepts.datapipeline.excel.ExcelColorPalette

 

BLACK1 - Enum constant in enum class com.northconcepts.datapipeline.excel.ExcelColorPalette

 

blankTextIsNotAllowed(String, int) - Static method in class com.northconcepts.datapipeline.foundations.i18n.SchemaMessages

 

BLOB - Enum constant in enum class com.northconcepts.datapipeline.core.FieldType

 

BLOB - Enum constant in enum class com.northconcepts.datapipeline.sql.h2.TableColumnType

 

BLOB - Enum constant in enum class com.northconcepts.datapipeline.sql.mysql.TableColumnType

 

BLOCK - Enum constant in enum class com.northconcepts.datapipeline.filesystem.ftp.FileTransferMode

Transfer files as a series of blocks.

BLOG - Enum constant in enum class com.northconcepts.datapipeline.shopify.client.EventFilter

 

BloombergMessage - Class in com.northconcepts.datapipeline.bloomberg

A Bloomberg message parsed by BloombergMessage.parse(Reader) into its header, field list, data records and footer.

BloombergMessage() - Constructor for class com.northconcepts.datapipeline.bloomberg.BloombergMessage

 

BloombergMessageData - Class in com.northconcepts.datapipeline.bloomberg

The data section of a BloombergMessage, holding one record per data line.

BloombergMessageData() - Constructor for class com.northconcepts.datapipeline.bloomberg.BloombergMessageData

 

BloombergMessageFields - Class in com.northconcepts.datapipeline.bloomberg

The field names listed between START-OF-FIELDS and END-OF-FIELDS in a BloombergMessage.

BloombergMessageFields() - Constructor for class com.northconcepts.datapipeline.bloomberg.BloombergMessageFields

 

BloombergMessageFooter - Class in com.northconcepts.datapipeline.bloomberg

The name=value properties that follow the data section of a BloombergMessage; a name can have several values.

BloombergMessageFooter() - Constructor for class com.northconcepts.datapipeline.bloomberg.BloombergMessageFooter

 

BloombergMessageHeader - Class in com.northconcepts.datapipeline.bloomberg

The name=value properties that precede the data section of a BloombergMessage; a name can have several values.

BloombergMessageHeader() - Constructor for class com.northconcepts.datapipeline.bloomberg.BloombergMessageHeader

 

BloombergMessageReader - Class in com.northconcepts.datapipeline.bloomberg

Reads the data records of a Bloomberg message; the whole message is parsed into memory on open and stays available from BloombergMessageReader.getMessage().

BloombergMessageReader(File) - Constructor for class com.northconcepts.datapipeline.bloomberg.BloombergMessageReader

 

BloombergMessageReader(Reader) - Constructor for class com.northconcepts.datapipeline.bloomberg.BloombergMessageReader

Creates a reader for the message in the given stream; BloombergMessageReader.open() parses and closes the stream, so this reader can be opened only once.

BLUE - Enum constant in enum class com.northconcepts.datapipeline.excel.ExcelColorPalette

 

BLUE_GREY - Enum constant in enum class com.northconcepts.datapipeline.excel.ExcelColorPalette

 

BLUE1 - Enum constant in enum class com.northconcepts.datapipeline.excel.ExcelColorPalette

 

BoardFilter - Enum Class in com.northconcepts.datapipeline.trello

Selects which boards TrelloBoardsReader reads; toString() gives the lowercase value sent to Trello.

BoardLists - Enum Class in com.northconcepts.datapipeline.trello

Selects which of each board's lists TrelloBoardsReader requests; toString() gives the lowercase value sent to Trello.

bold() - Static method in interface com.northconcepts.datapipeline.excel.ExcelCellStyleDecorator

Returns a decorator that makes text bold.

BOOL - Enum constant in enum class com.northconcepts.datapipeline.sql.h2.TableColumnType

 

BOOL - Enum constant in enum class com.northconcepts.datapipeline.sql.mysql.TableColumnType

 

BOOL - Enum constant in enum class com.northconcepts.datapipeline.sql.postgresql.TableColumnType

 

BOOLEAN - Enum constant in enum class com.northconcepts.datapipeline.core.FieldType

 

BOOLEAN - Enum constant in enum class com.northconcepts.datapipeline.foundations.pipeline.action.convert.ConvertNullToValueAction.FieldType

 

BOOLEAN - Enum constant in enum class com.northconcepts.datapipeline.foundations.pipeline.action.transform.AddFieldsAction.FieldType

 

BOOLEAN - Enum constant in enum class com.northconcepts.datapipeline.sql.h2.TableColumnType

 

BOOLEAN - Enum constant in enum class com.northconcepts.datapipeline.sql.mysql.TableColumnType

 

BOOLEAN - Enum constant in enum class com.northconcepts.datapipeline.sql.postgresql.TableColumnType

 

BooleanFieldDef - Class in com.northconcepts.datapipeline.foundations.schema

A FieldDef for boolean values.

BooleanFieldDef() - Constructor for class com.northconcepts.datapipeline.foundations.schema.BooleanFieldDef

 

BooleanFieldDef(String) - Constructor for class com.northconcepts.datapipeline.foundations.schema.BooleanFieldDef

 

BooleanFieldDef(String, FieldType) - Constructor for class com.northconcepts.datapipeline.foundations.schema.BooleanFieldDef

 

boolize(Object) - Static method in class com.northconcepts.datapipeline.jsonata.Jsonata

 

BOX - Enum constant in enum class com.northconcepts.datapipeline.sql.postgresql.TableColumnType

 

BRIGHT_GREEN - Enum constant in enum class com.northconcepts.datapipeline.excel.ExcelColorPalette

 

BRIGHT_GREEN1 - Enum constant in enum class com.northconcepts.datapipeline.excel.ExcelColorPalette

 

BROADCAST - Enum constant in enum class com.northconcepts.datapipeline.multiplex.DeMux.Strategy

Sends a copy of each record to every downstream reader.

BROADCAST - Enum constant in enum class com.northconcepts.datapipeline.multiplex.SplitWriter.Strategy

Sends a copy of each record to every downstream reader.

BROWN - Enum constant in enum class com.northconcepts.datapipeline.excel.ExcelColorPalette

 

bsonDocumentToRecord(BsonDocument) - Static method in class com.northconcepts.datapipeline.mongodb.MongoTypeConverter

Converts a BSON document to a record with one field per key, converting nested documents and arrays recursively.

bsonValueToValueNode(BsonValue) - Static method in class com.northconcepts.datapipeline.mongodb.MongoTypeConverter

Converts a BSON value to a value node (null for a BSON null); documents become records and object IDs become strings.

bucketName - Variable in class com.northconcepts.datapipeline.amazons3.AmazonS3File

 

buffer - Variable in class com.northconcepts.datapipeline.core.AsyncMultiReader

 

buffer - Variable in class com.northconcepts.datapipeline.security.EncryptingReader

 

BUFFER_SIZE - Static variable in class com.northconcepts.datapipeline.core.Endpoint

 

BUFFER_SIZE - Static variable in class com.northconcepts.datapipeline.pdf.PdfWriter

 

BufferedReader - Class in com.northconcepts.datapipeline.buffer

A proxy that organizes incoming data by collecting records of the same type (using values in a subset of fields) to release them downstream together.

BufferedReader(DataReader, int, FieldList) - Constructor for class com.northconcepts.datapipeline.buffer.BufferedReader

Creates a reader that groups records by the values of the given fields; a background thread reads up to queueSize records ahead from the nested reader.

BufferedReader(DataReader, int, String...) - Constructor for class com.northconcepts.datapipeline.buffer.BufferedReader

Creates a reader that groups records by the values of the given fields; a background thread reads up to queueSize records ahead from the nested reader.

BufferStrategy - Class in com.northconcepts.datapipeline.buffer

Determines when BufferedReader closes an open sliding buffer.

BufferStrategy() - Constructor for class com.northconcepts.datapipeline.buffer.BufferStrategy

 

build() - Method in class com.northconcepts.datapipeline.security.Credentials.Builder

Returns new credentials holding copies of the values set so far.

buildDetail(Record, JsonGenerator) - Method in class com.northconcepts.datapipeline.json.builder.JsonTemplate

Writes the detail marker's nodes for the given record; throws a DataException if JsonTemplate.buildHeader(JsonGenerator) found no detail marker.

buildDetail(Record, CodeWriter) - Method in class com.northconcepts.datapipeline.xml.builder.XmlTemplate

Writes the detail marker's nodes for the given record; throws a DataException if XmlTemplate.buildHeader(CodeWriter) found no detail marker.

builder() - Static method in class com.northconcepts.datapipeline.security.Credentials

Creates a builder for assembling credentials one key at a time, with an optional expiry.

buildFooter(JsonGenerator) - Method in class com.northconcepts.datapipeline.json.builder.JsonTemplate

Writes the nodes after the detail marker, closing the objects and arrays the header opened.

buildFooter(CodeWriter) - Method in class com.northconcepts.datapipeline.xml.builder.XmlTemplate

Writes the nodes after the detail marker, closing the elements the header opened.

buildHeader(JsonGenerator) - Method in class com.northconcepts.datapipeline.json.builder.JsonTemplate

Writes the nodes that come before the detail marker; call it once before writing records.

buildHeader(CodeWriter) - Method in class com.northconcepts.datapipeline.xml.builder.XmlTemplate

Writes the declaration and the nodes that come before the detail marker; call it once before writing records.

buildSql(JdbcWriter, Record, int) - Method in class com.northconcepts.datapipeline.jdbc.insert.MultiRowPreparedStatementInsert

Returns the INSERT SQL with rowCount rows of ? placeholders, using the record's field names as columns.

BYTE - Enum constant in enum class com.northconcepts.datapipeline.core.FieldType

 

BYTE - Enum constant in enum class com.northconcepts.datapipeline.foundations.pipeline.action.convert.ConvertNullToValueAction.FieldType

 

BYTE - Enum constant in enum class com.northconcepts.datapipeline.foundations.pipeline.action.convert.ConvertStringToNumberAction.FieldType

 

BYTE - Enum constant in enum class com.northconcepts.datapipeline.foundations.pipeline.action.transform.AddFieldsAction.FieldType

 

BYTEA - Enum constant in enum class com.northconcepts.datapipeline.sql.postgresql.TableColumnType

 

BYTES - Enum constant in enum class com.northconcepts.datapipeline.meter.RecordMeter.MeterUnit

 

bytesToUuid() - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer

Converts 16-byte values (most significant bits first) to UUIDs; other lengths cause an exception.

C

CachedLookup - Class in com.northconcepts.datapipeline.transform.lookup

A Lookup that lazily caches the results of successful lookups performed by another instance.

CachedLookup(Lookup) - Constructor for class com.northconcepts.datapipeline.transform.lookup.CachedLookup

Creates a new CachedLookup that has no limit and never clears itself.

CachedLookup(Lookup, int) - Constructor for class com.northconcepts.datapipeline.transform.lookup.CachedLookup

Creates a new limited CachedLookup that never clears itself.

CachedLookup(Lookup, Integer, Scheduler) - Constructor for class com.northconcepts.datapipeline.transform.lookup.CachedLookup

Creates a new CachedLookup.

cacheFieldIndexes - Variable in class com.northconcepts.datapipeline.core.RecordComparator

 

cacheNextLine() - Method in class com.northconcepts.datapipeline.core.LineParser

 

CachingCredentialsResolver - Class in com.northconcepts.datapipeline.security

A CredentialsResolver decorator that caches its delegate's credentials, re-fetching when: the cached credentials report expiry within CachingCredentialsResolver.getExpirySkewMilliseconds() (see Credentials.isExpired(long)), the optional time-to-live has elapsed, or CachingCredentialsResolver.refresh() is called. Gives rotation with backpressure — remote secret stores are only called when needed.

CachingCredentialsResolver(CredentialsResolver) - Constructor for class com.northconcepts.datapipeline.security.CachingCredentialsResolver

Caches the delegate's credentials until they expire or CachingCredentialsResolver.refresh() is called.

CachingCredentialsResolver(CredentialsResolver, long) - Constructor for class com.northconcepts.datapipeline.security.CachingCredentialsResolver

Caches the delegate's credentials for at most timeToLiveMilliseconds (zero for no time-to-live).

CalculatedField - Class in com.northconcepts.datapipeline.foundations.expression

A variable computed from an expression before a decision table or tree evaluates its rules; the result is stored in the expression context under the variable's name.

CalculatedField() - Constructor for class com.northconcepts.datapipeline.foundations.expression.CalculatedField

 

CalculatedField(String, String) - Constructor for class com.northconcepts.datapipeline.foundations.expression.CalculatedField

Creates a field that is not included in the outcome.

CalculatedField(String, String, boolean) - Constructor for class com.northconcepts.datapipeline.foundations.expression.CalculatedField

 

call(Class, Object, String, List<Object>) - Static method in class com.northconcepts.datapipeline.jsonata.Functions

 

call(Object, Method, List<Object>) - Static method in class com.northconcepts.datapipeline.jsonata.Functions

 

call(Object, List) - Method in class com.northconcepts.datapipeline.jsonata.Jsonata.JFunction

 

call(Object, List) - Method in interface com.northconcepts.datapipeline.jsonata.Jsonata.JFunctionCallable

 

call(Callable<T>) - Method in class com.northconcepts.datapipeline.retry.RetryingOperation

Calls the callable, retrying failures with the strategy's delays for up to RetryingOperation.getMaxRetryCount() attempts in total; rethrows the last exception if none succeeds or the retry predicate declines.

callback(Parser.Symbol, Object, Jsonata.Frame) - Method in interface com.northconcepts.datapipeline.jsonata.Jsonata.EntryCallback

 

callback(Parser.Symbol, Object, Jsonata.Frame, Object) - Method in interface com.northconcepts.datapipeline.jsonata.Jsonata.ExitCallback

 

cancel() - Method in class com.northconcepts.datapipeline.job.AbstractJob

 

cancel() - Method in interface com.northconcepts.datapipeline.job.IJob

Interrupts the run thread and cancels the child job; does nothing unless this job is running and not yet cancelled.

cancel() - Method in class com.northconcepts.datapipeline.job.Job

 

CANCELLED - Enum constant in enum class com.northconcepts.datapipeline.shopify.client.EventVerb

 

CANCELLED - Enum constant in enum class com.northconcepts.datapipeline.shopify.client.OrderStatus

 

cancelLoad() - Method in class com.northconcepts.datapipeline.foundations.pipeline.dataset.Dataset

Gracefully terminate the asynchronous data loading and column stats calculation, waiting up to 10 seconds in total.

CANNOT_MUTE_YOURSELF - Enum constant in enum class com.northconcepts.datapipeline.twitter.TwitterErrorCode

 

CANNOT_REPORT_YOURSELF_FOR_SPAM - Enum constant in enum class com.northconcepts.datapipeline.twitter.TwitterErrorCode

 

canonicalizeNodeName(String) - Method in class com.northconcepts.datapipeline.foundations.pipeline.tree.detect.TreeDetectionStrategy

Returns the node name used to key tree nodes while the tree is being built: the XPath wildcard (*) when optimizeTreeStructure is set and any NodeNameRule classifies the name as dynamic, otherwise the name unchanged.

CAPTURE_FAILURE - Enum constant in enum class com.northconcepts.datapipeline.shopify.client.EventVerb

 

CAPTURE_PENDING - Enum constant in enum class com.northconcepts.datapipeline.shopify.client.EventVerb

 

CAPTURE_SUCCESS - Enum constant in enum class com.northconcepts.datapipeline.shopify.client.EventVerb

 

captureElapsedTime - Static variable in class com.northconcepts.datapipeline.core.Endpoint

 

CardFilter - Enum Class in com.northconcepts.datapipeline.trello

Selects which cards TrelloBoardCardsReader and TrelloBoardListsReader request; toString() gives the lowercase value sent to Trello.

CASCADE - Enum constant in enum class com.northconcepts.datapipeline.foundations.schema.ForeignKeyAction

 

CASCADE - Enum constant in enum class com.northconcepts.datapipeline.sql.h2.ForeignKeyAction

 

CASCADE - Enum constant in enum class com.northconcepts.datapipeline.sql.mysql.ForeignKeyAction

 

CASCADE - Enum constant in enum class com.northconcepts.datapipeline.sql.postgresql.ForeignKeyAction

 

CATEGORY - Enum constant in enum class com.northconcepts.datapipeline.jira.JiraProjectReader.OrderByField

 

ceil(Number) - Static method in class com.northconcepts.datapipeline.jsonata.Functions

Rounds a number up to integer

CEILING - Enum constant in enum class com.northconcepts.datapipeline.transform.format.Rounder.RoundingPolicy

Behaves the same as UP if the value is positive or DOWN if the value is negative.

CHANGED - Enum constant in enum class com.northconcepts.datapipeline.foundations.difference.DiffType

 

CHAR - Enum constant in enum class com.northconcepts.datapipeline.core.FieldType

 

CHAR - Enum constant in enum class com.northconcepts.datapipeline.sql.h2.TableColumnType

 

CHAR - Enum constant in enum class com.northconcepts.datapipeline.sql.mysql.TableColumnType

 

CHAR - Enum constant in enum class com.northconcepts.datapipeline.sql.postgresql.TableColumnType

 

CHARACTER - Enum constant in enum class com.northconcepts.datapipeline.foundations.pipeline.action.convert.ConvertNullToValueAction.FieldType

 

CHARACTER - Enum constant in enum class com.northconcepts.datapipeline.foundations.pipeline.action.transform.AddFieldsAction.FieldType

 

CHARACTER - Enum constant in enum class com.northconcepts.datapipeline.sql.postgresql.TableColumnType

 

CHARACTER_VARYING - Enum constant in enum class com.northconcepts.datapipeline.sql.postgresql.TableColumnType

 

characteristics() - Method in class com.northconcepts.datapipeline.foundations.pipeline.dataset.DatasetSpliterator

 

checkChildren(List<SchemaProblem>, List<T>, boolean) - Static method in class com.northconcepts.datapipeline.foundations.schema.SchemaValidator

Adds each child's problems, including those of its descendants if requested; a null list is ignored.

checkCyclicalFieldDependency(List<SchemaProblem>, RecordFieldDef) - Static method in class com.northconcepts.datapipeline.foundations.schema.SchemaValidator

Adds a problem if the entity referenced by the record field refers back to itself, directly or through other record fields.

checkEntitiesExists(List<SchemaProblem>, SchemaDef, SchemaPart, String, List<String>) - Static method in class com.northconcepts.datapipeline.foundations.schema.SchemaValidator

Adds a problem for each name with no matching entity in the schema; nothing is checked when the schema or the list is null.

checkEntityExists(List<SchemaProblem>, SchemaDef, SchemaPart, String, String) - Static method in class com.northconcepts.datapipeline.foundations.schema.SchemaValidator

Adds a problem if the schema is not null and has no entity with the given name.

checkEntityExistsInRelationship(List<SchemaProblem>, SchemaDef, SchemaPart, String, String) - Static method in class com.northconcepts.datapipeline.foundations.schema.SchemaValidator

Adds a problem if the entity name is empty or the schema, when not null, has no entity with that name.

checkEntityRelationshipCardinality(List<SchemaProblem>, EntityRelationshipDef) - Static method in class com.northconcepts.datapipeline.foundations.schema.SchemaValidator

Adds a problem if the relationship has no cardinality or its foreign key fields contradict it, such as a one-to-one foreign key field that is not part of the foreign entity's primary key.

checkEntityRelationshipKeys(List<SchemaProblem>, EntityRelationshipDef) - Static method in class com.northconcepts.datapipeline.foundations.schema.SchemaValidator

Adds a problem if the primary entity has no primary key or the foreign key fields differ from it in count, existence or type.

checkFieldExists(List<SchemaProblem>, SchemaPart, EntityDef, String, String) - Static method in class com.northconcepts.datapipeline.foundations.schema.SchemaValidator

Adds a problem if the entity is not null and neither it nor its super entities have a field with the given name.

checkFieldsExists(List<SchemaProblem>, SchemaPart, EntityDef, String, List<String>) - Static method in class com.northconcepts.datapipeline.foundations.schema.SchemaValidator

Adds a problem for each name with no matching field in the entity or its super entities; nothing is checked when the entity or the list is null.

checkIndexHasFields(List<SchemaProblem>, SchemaPart, List<T>, boolean, String) - Static method in class com.northconcepts.datapipeline.foundations.schema.SchemaValidator

Adds a problem if the index has no fields (children is null or empty).

checkMinimumAndMaximumValues(List<SchemaProblem>, SchemaPart, Number, Number, String, String) - Static method in class com.northconcepts.datapipeline.foundations.schema.SchemaValidator

Adds the same problems as the overload taking negativeNumberAllowed, with negative numbers disallowed.

checkMinimumAndMaximumValues(List<SchemaProblem>, SchemaPart, Number, Number, String, String, boolean) - Static method in class com.northconcepts.datapipeline.foundations.schema.SchemaValidator

Adds a problem if both values are set and their classes differ, the minimum exceeds the maximum or, unless negativeNumberAllowed is true, either is a negative Integer or Long.

checkMinimumAndMaximumValues(List<SchemaProblem>, SchemaPart, TemporalAccessor, TemporalAccessor, String, String) - Static method in class com.northconcepts.datapipeline.foundations.schema.SchemaValidator

Adds a problem if both values are set but of different classes; the minimum is not compared to the maximum.

checkNameExists(List<DataMappingProblem>, DataMappingPart, String, String) - Static method in class com.northconcepts.datapipeline.foundations.datamapping.DataMappingValidator

Adds a problem, naming the value identifierName, if identifier is null or empty.

checkNegativeValue(List<SchemaProblem>, SchemaPart, Number, String) - Static method in class com.northconcepts.datapipeline.foundations.schema.SchemaValidator

 

checkParentExists(List<SchemaProblem>, SchemaPart, String, SchemaObject) - Static method in class com.northconcepts.datapipeline.foundations.schema.SchemaValidator

 

checkPrecisionAndScale(List<SchemaProblem>, SchemaPart, Integer, Integer, FieldType) - Static method in class com.northconcepts.datapipeline.foundations.schema.SchemaValidator

Adds a problem if the precision is negative, an integer type has a positive scale or the absolute scale exceeds the precision.

checkPrimaryKeyPositions(List<SchemaProblem>, EntityDef) - Static method in class com.northconcepts.datapipeline.foundations.schema.SchemaValidator

Adds a problem if the entity's primary key positions are not the consecutive 0-based sequence 0, 1, 2 and so on.

checkUniqueChildNames(List<DataMappingProblem>, DataMappingPart, String, List<T>, Function<T, String>) - Static method in class com.northconcepts.datapipeline.foundations.datamapping.DataMappingValidator

Adds a problem for each non-empty name that nameExtractor returns for more than one child.

checkUniqueChildNames(List<SchemaProblem>, SchemaPart, String, List<T>, Function<T, String>) - Static method in class com.northconcepts.datapipeline.foundations.schema.SchemaValidator

Adds a problem for each non-empty name shared by more than one child, comparing names case-sensitively.

checkUniqueIndexFieldNames(List<SchemaProblem>, SchemaPart, List<IndexDef>) - Static method in class com.northconcepts.datapipeline.foundations.schema.SchemaValidator

Adds a problem for each list of field names, in the same order, shared by more than one index.

checkUrl(String) - Static method in class com.northconcepts.datapipeline.jsonata.Utils

 

checkValidCondition(List<DataMappingProblem>, DataMappingPart, String, LogicalExpression) - Static method in class com.northconcepts.datapipeline.foundations.datamapping.DataMappingValidator

 

checkValidExpression(List<DataMappingProblem>, DataMappingPart, String, Expression) - Static method in class com.northconcepts.datapipeline.foundations.datamapping.DataMappingValidator

Adds a problem if expression is an unparsable expression kept by lenient parsing, such as when a field mapping is loaded from JSON or XML.

checkValidIdentifier(List<SchemaProblem>, SchemaPart, String, String) - Static method in class com.northconcepts.datapipeline.foundations.schema.SchemaValidator

Adds a problem if the identifier is empty or does not start with a letter, underscore, at sign or dollar sign.

CIDR - Enum constant in enum class com.northconcepts.datapipeline.sql.postgresql.TableColumnType

 

cipher - Variable in class com.northconcepts.datapipeline.security.DecryptingReader

 

cipher - Variable in class com.northconcepts.datapipeline.security.EncryptingReader

 

CIRCLE - Enum constant in enum class com.northconcepts.datapipeline.sql.postgresql.TableColumnType

 

classNameAndSignedParametersLoaded(JdbcConnection, LoadTablesRequest) - Method in interface com.northconcepts.datapipeline.foundations.jdbc.JdbcConnectionListener

Called after the class name, signedness and Java type of every table's columns are resolved.

cleaned - Enum constant in enum class com.northconcepts.datapipeline.mailchimp.list.ListMemberStatus

 

cleanupGarbage() - Method in class com.northconcepts.datapipeline.eventbus.EventBus

Removes the listeners whose soft references were garbage collected; called after each delivery.

clear() - Method in class com.northconcepts.datapipeline.core.FieldList

Removes all the fields from this list.

clear() - Method in class com.northconcepts.datapipeline.core.RecordList

 

clear() - Method in class com.northconcepts.datapipeline.csv.CommaSeparatedValues

 

clear() - Method in class com.northconcepts.datapipeline.foundations.schema.ValidationResult

 

clear() - Method in class com.northconcepts.datapipeline.group.AggregateReader

Deprecated.

 

clear() - Method in class com.northconcepts.datapipeline.jdbc.sql.select.QueryCriteria

 

clear() - Method in class com.northconcepts.datapipeline.jdbc.sql.select.QueryGrouping

 

clear() - Method in class com.northconcepts.datapipeline.jdbc.sql.select.QueryOrder

 

clear() - Method in class com.northconcepts.datapipeline.jdbc.sql.select.Union

 

clear() - Method in class com.northconcepts.datapipeline.security.Credentials

Overwrites all secret values with zeros and empties this bundle.

clear() - Method in class com.northconcepts.datapipeline.transform.lookup.CachedLookup

Removes all cached results; the hit and miss counts are not reset.

clearCurrent() - Static method in class com.northconcepts.datapipeline.core.Messages

Removes the thread-local instance if one exists.

clearFileSize() - Method in class com.northconcepts.datapipeline.amazons3.AmazonS3File

Forgets the kept file size so the next AmazonS3File.getFileSize() looks it up in S3 again.

clearHaving() - Method in class com.northconcepts.datapipeline.jdbc.sql.select.Select

 

clearLimit() - Method in class com.northconcepts.datapipeline.jdbc.sql.select.Select

 

clearNodeNameRules() - Method in class com.northconcepts.datapipeline.foundations.pipeline.tree.detect.TreeDetectionStrategy

Removes all node name rules, including the default StandardNodeNameRule.

clearPatterns() - Method in class com.northconcepts.datapipeline.foundations.time.DateTimePatternDetector

 

clearRules() - Method in class com.northconcepts.datapipeline.foundations.pipeline.tree.detect.CollapseSiblingPatterns

Removes all rules, including the default AffixSiblingSetRule.

clearSegmentRules() - Method in class com.northconcepts.datapipeline.foundations.pipeline.tree.detect.AffixSiblingSetRule

Removes all segment rules, including the default StandardNodeNameRule.

clearTransformers() - Method in class com.northconcepts.datapipeline.foundations.pipeline.tree.detect.TreeDetectionStrategy

Removes all passes, including the standard detection passes.

clearWhere() - Method in class com.northconcepts.datapipeline.jdbc.sql.select.Select

 

client - Variable in class com.northconcepts.datapipeline.twitter2.AbstractTwitterReader

 

CLIENT - Enum constant in enum class com.northconcepts.datapipeline.jms.JmsAcknowledgeMode

 

clone() - Method in class com.northconcepts.datapipeline.core.ArrayValue

Returns a deep copy of this array, cloning every element.

clone() - Method in class com.northconcepts.datapipeline.core.ConcurrentRecordList

 

clone() - Method in class com.northconcepts.datapipeline.core.FieldComparator

 

clone() - Method in class com.northconcepts.datapipeline.core.FieldDeclarations

 

clone() - Method in class com.northconcepts.datapipeline.core.FieldList

Returns a new FieldList that is a copy of this FieldList.

clone() - Method in class com.northconcepts.datapipeline.core.Record

 

clone() - Method in class com.northconcepts.datapipeline.core.RecordComparator

 

clone() - Method in class com.northconcepts.datapipeline.core.RecordList

Returns a new RecordList that is a copy of this RecordList.

clone() - Method in class com.northconcepts.datapipeline.core.SingleValue

Returns a deep copy of this single value.

clone() - Method in class com.northconcepts.datapipeline.core.ValueNode

Returns a deep copy of this value node.

clone() - Method in class com.northconcepts.datapipeline.core.ValueNodeComparator

 

clone() - Method in class com.northconcepts.datapipeline.eventbus.EventBus

 

clone() - Method in class com.northconcepts.datapipeline.excel.ExcelCellStyle

 

clone() - Method in class com.northconcepts.datapipeline.excel.ExcelFont

 

clone() - Method in class com.northconcepts.datapipeline.filter.rule.ValueMatch

 

clone() - Method in class com.northconcepts.datapipeline.foundations.core.Attributes

 

clone() - Method in class com.northconcepts.datapipeline.foundations.core.FoundationObject

 

clone() - Method in class com.northconcepts.datapipeline.foundations.core.Tags

 

clone() - Method in class com.northconcepts.datapipeline.foundations.decisiontable.DecisionTableCondition

 

clone() - Method in class com.northconcepts.datapipeline.foundations.decisiontable.DecisionTableOutcome

 

clone() - Method in class com.northconcepts.datapipeline.foundations.decisiontable.DecisionTableRule

 

clone() - Method in class com.northconcepts.datapipeline.foundations.decisiontree.DecisionTreeNode

 

clone() - Method in class com.northconcepts.datapipeline.foundations.decisiontree.DecisionTreeOutcome

 

clone() - Method in class com.northconcepts.datapipeline.foundations.schema.BinaryFieldDef

 

clone() - Method in class com.northconcepts.datapipeline.foundations.schema.BooleanFieldDef

 

clone() - Method in class com.northconcepts.datapipeline.foundations.schema.EntityDef

 

clone() - Method in class com.northconcepts.datapipeline.foundations.schema.EntityRelationshipDef

 

clone() - Method in class com.northconcepts.datapipeline.foundations.schema.FieldDef

 

clone() - Method in class com.northconcepts.datapipeline.foundations.schema.IndexDef

 

clone() - Method in class com.northconcepts.datapipeline.foundations.schema.IndexFieldDef

 

clone() - Method in class com.northconcepts.datapipeline.foundations.schema.NumericFieldDef

 

clone() - Method in class com.northconcepts.datapipeline.foundations.schema.RecordFieldDef

 

clone() - Method in class com.northconcepts.datapipeline.foundations.schema.SchemaDef

 

clone() - Method in class com.northconcepts.datapipeline.foundations.schema.TemporalFieldDef

 

clone() - Method in class com.northconcepts.datapipeline.foundations.schema.TextFieldDef

 

clone() - Method in class com.northconcepts.datapipeline.foundations.schema.UuidFieldDef

 

clone() - Method in class com.northconcepts.datapipeline.foundations.schema.ValidationResult

 

clone() - Method in interface com.northconcepts.datapipeline.jdbc.insert.IInsert

Returns a new, unprepared copy with the same settings; JdbcMultiWriter uses one for each connection.

clone() - Method in class com.northconcepts.datapipeline.jdbc.insert.MultiRowPreparedStatementInsert

 

clone() - Method in class com.northconcepts.datapipeline.jdbc.insert.MultiRowStatementInsert

 

clone() - Method in class com.northconcepts.datapipeline.jdbc.insert.MySqlPreparedStatementInsert

 

clone() - Method in class com.northconcepts.datapipeline.jdbc.insert.OracleMultiRowInsertAllStatementInsert

 

clone() - Method in class com.northconcepts.datapipeline.jdbc.insert.OracleMultiRowSelectUnionAllStatementInsert

 

clone() - Method in class com.northconcepts.datapipeline.jdbc.insert.PreparedStatementInsert

 

clone() - Method in class com.northconcepts.datapipeline.jdbc.upsert.GenericUpsert

 

clone() - Method in interface com.northconcepts.datapipeline.jdbc.upsert.IUpsert

Returns a new, unprepared copy with the same settings; JdbcMultiUpsertWriter uses one for each connection.

clone() - Method in class com.northconcepts.datapipeline.jdbc.upsert.MergeUpsert

 

clone() - Method in class com.northconcepts.datapipeline.jdbc.upsert.MySqlUpsert

 

clone() - Method in class com.northconcepts.datapipeline.jdbc.upsert.OracleUpsert

 

clone() - Method in class com.northconcepts.datapipeline.jdbc.upsert.PostgreSqlUpsert

 

clone() - Method in class com.northconcepts.datapipeline.jdbc.upsert.SybaseUpsert

 

clone() - Method in class com.northconcepts.datapipeline.jdbc.upsert.VariableFieldsUpsert

 

clone() - Method in class com.northconcepts.datapipeline.job.AbstractJob

 

clone() - Method in class com.northconcepts.datapipeline.job.Job

 

clone(T) - Static method in class com.northconcepts.datapipeline.jsonata.Parser

 

close() - Method in class com.northconcepts.datapipeline.amazons3.AmazonS3FileSystem

Closes the Amazon S3 connection — or, while a source or sink stream or a size lookup is still using it, as soon as the last of them finishes.

close() - Method in class com.northconcepts.datapipeline.avro.AvroReader

 

close() - Method in class com.northconcepts.datapipeline.avro.AvroWriter

 

close() - Method in class com.northconcepts.datapipeline.buffer.BufferedReader

 

close() - Method in class com.northconcepts.datapipeline.buffer.RecordBuffer

 

close() - Method in class com.northconcepts.datapipeline.core.AsyncMultiReader

 

close() - Method in class com.northconcepts.datapipeline.core.AsyncReader

 

close() - Method in class com.northconcepts.datapipeline.core.AsyncTaskReader

 

close() - Method in class com.northconcepts.datapipeline.core.AsyncWriter

 

close() - Method in class com.northconcepts.datapipeline.core.BinaryWriter

 

close() - Method in class com.northconcepts.datapipeline.core.DataEndpoint

Indicates that this endpoint has finished reading or writing.

close() - Method in class com.northconcepts.datapipeline.core.DataEndpointGroup

 

close() - Method in class com.northconcepts.datapipeline.core.DebugReader

 

close() - Method in class com.northconcepts.datapipeline.core.DebugWriter

 

close() - Method in class com.northconcepts.datapipeline.core.Endpoint

Indicates that this endpoint has finished reading or writing.

close() - Method in interface com.northconcepts.datapipeline.core.IParser

 

close() - Method in class com.northconcepts.datapipeline.core.LineParser

 

close() - Method in class com.northconcepts.datapipeline.core.MultiWriter

 

close() - Method in class com.northconcepts.datapipeline.core.Parser

 

close() - Method in class com.northconcepts.datapipeline.core.PipedWriter

 

close() - Method in class com.northconcepts.datapipeline.core.ProxyReader

 

close() - Method in class com.northconcepts.datapipeline.core.ProxyWriter

 

close() - Method in class com.northconcepts.datapipeline.core.RemoveDuplicatesReader

 

close() - Method in class com.northconcepts.datapipeline.core.SequenceReader

 

close() - Method in class com.northconcepts.datapipeline.core.SequenceWriter

 

close() - Method in class com.northconcepts.datapipeline.core.SortingReader

 

close() - Method in class com.northconcepts.datapipeline.core.StreamWriter

 

close() - Method in class com.northconcepts.datapipeline.core.StringParser

 

close() - Method in class com.northconcepts.datapipeline.core.TeeReader

 

close() - Method in class com.northconcepts.datapipeline.core.TextReader

 

close() - Method in class com.northconcepts.datapipeline.core.TextStreamWriter

 

close() - Method in class com.northconcepts.datapipeline.core.TextWriter

 

close() - Method in class com.northconcepts.datapipeline.core.TimedReader

 

close() - Method in class com.northconcepts.datapipeline.email.EmailReader

 

close() - Method in class com.northconcepts.datapipeline.eventbus.EventBusReader

 

close() - Method in class com.northconcepts.datapipeline.eventbus.EventBusWriter

 

close() - Method in class com.northconcepts.datapipeline.excel.ExcelDocument

The method can be called when this document can be discarded, but it will be called automatically in the finalize() method.

close() - Method in class com.northconcepts.datapipeline.excel.ExcelReader

 

close() - Method in class com.northconcepts.datapipeline.excel.ExcelWriter

 

close() - Method in class com.northconcepts.datapipeline.excel.PoiSxssfProvider

 

close() - Method in class com.northconcepts.datapipeline.excel.PoiXssfSaxProvider

 

close() - Method in class com.northconcepts.datapipeline.excel.PoiXssfbProvider

 

close() - Method in class com.northconcepts.datapipeline.file.FileReader

 

close() - Method in class com.northconcepts.datapipeline.file.FileSystemInfoReader

 

close() - Method in class com.northconcepts.datapipeline.file.FileWriter

 

close() - Method in class com.northconcepts.datapipeline.filesystem.dropbox.DropBoxFileSystem

Closes the DropBox connection.

close() - Method in class com.northconcepts.datapipeline.filesystem.ftp.FtpFileSystem

Closes the connection from an FTP server.

close() - Method in class com.northconcepts.datapipeline.filesystem.hdfs.HdfsFileSystem

Closes the HDFS connection.

close() - Method in class com.northconcepts.datapipeline.filesystem.sftp.SftpFileSystem

Closes the connection from an SFTP server.

close() - Method in class com.northconcepts.datapipeline.filesystem.zip.ZipFileSystem

 

close() - Method in class com.northconcepts.datapipeline.filter.Filter

Called by FilteringReader when FilteringReader.close() is called (after reading ends).

close() - Method in class com.northconcepts.datapipeline.filter.FilteringReader

 

close() - Method in class com.northconcepts.datapipeline.foundations.datamapping.DataMappingEditor

Closes the dataset of mapped records; applying a mapping again loads a new one.

close() - Method in class com.northconcepts.datapipeline.foundations.datamapping.DataMappingReader

 

close() - Method in class com.northconcepts.datapipeline.foundations.datamapping.DataMappingWriter

 

close() - Method in class com.northconcepts.datapipeline.foundations.pipeline.dataset.Dataset

 

close() - Method in class com.northconcepts.datapipeline.foundations.pipeline.dataset.JdbcDataset

 

close() - Method in class com.northconcepts.datapipeline.foundations.pipeline.dataset.LocalFileDataset

 

close() - Method in class com.northconcepts.datapipeline.foundations.pipeline.dataset.MemoryDataset

 

close() - Method in class com.northconcepts.datapipeline.foundations.pipeline.dataset.MvStoreDataset

 

close() - Method in class com.northconcepts.datapipeline.google.analytics.GoogleAnalyticsReportReader

 

close() - Method in class com.northconcepts.datapipeline.google.calendar.GoogleCalendarReader

 

close() - Method in class com.northconcepts.datapipeline.google.contacts.GoogleContactsReader

 

close() - Method in class com.northconcepts.datapipeline.google.gmail.GmailMessageReader

 

close() - Method in class com.northconcepts.datapipeline.google.GoogleApiReader

 

close() - Method in class com.northconcepts.datapipeline.google.sheets.GoogleSheetDocument

Forgets the spreadsheet; the transport is shut down only when this document created it.

close() - Method in class com.northconcepts.datapipeline.google.sheets.GoogleSheetReader

 

close() - Method in class com.northconcepts.datapipeline.google.sheets.GoogleSheetWriter

 

close() - Method in class com.northconcepts.datapipeline.googledrive.GoogleDriveFileSystem

Closes the Google Drive connection.

close() - Method in class com.northconcepts.datapipeline.group.GroupByReader

 

close() - Method in class com.northconcepts.datapipeline.group.Window

 

close() - Method in class com.northconcepts.datapipeline.instagram.InstagramLocationMediaReader

 

close() - Method in class com.northconcepts.datapipeline.instagram.InstagramLocationReader

 

close() - Method in class com.northconcepts.datapipeline.instagram.InstagramSelfFollowedByReader

 

close() - Method in class com.northconcepts.datapipeline.instagram.InstagramSelfFollowsReader

 

close() - Method in class com.northconcepts.datapipeline.instagram.InstagramSelfMediaReader

 

close() - Method in class com.northconcepts.datapipeline.instagram.InstagramTagMediaReader

 

close() - Method in class com.northconcepts.datapipeline.instagram.InstagramTagReader

 

close() - Method in class com.northconcepts.datapipeline.instagram.InstagramUserMediaReader

 

close() - Method in class com.northconcepts.datapipeline.internal.lang.FileSystem

Wipes this connection cycle's credentials snapshot, then closes this endpoint.

close() - Method in interface com.northconcepts.datapipeline.jdbc.insert.IInsert

Releases the statement(s); called when the writer is closed.

close() - Method in class com.northconcepts.datapipeline.jdbc.insert.MultiRowPreparedStatementInsert

 

close() - Method in class com.northconcepts.datapipeline.jdbc.insert.MultiRowStatementInsert

 

close() - Method in class com.northconcepts.datapipeline.jdbc.insert.PreparedStatementInsert

 

close() - Method in interface com.northconcepts.datapipeline.jdbc.JdbcConnectionFactory

Releases any resources held by the factory itself (does nothing by default).

close() - Method in class com.northconcepts.datapipeline.jdbc.JdbcReader

 

close() - Method in class com.northconcepts.datapipeline.jdbc.JdbcUpsertWriter

 

close() - Method in class com.northconcepts.datapipeline.jdbc.JdbcWriter

 

close() - Method in class com.northconcepts.datapipeline.jdbc.upsert.GenericUpsert

 

close() - Method in interface com.northconcepts.datapipeline.jdbc.upsert.IUpsert

Releases the statement(s); called when the writer is closed.

close() - Method in class com.northconcepts.datapipeline.jdbc.upsert.MergeUpsert

 

close() - Method in class com.northconcepts.datapipeline.jdbc.upsert.MySqlUpsert

 

close() - Method in class com.northconcepts.datapipeline.jdbc.upsert.OracleUpsert

 

close() - Method in class com.northconcepts.datapipeline.jdbc.upsert.PostgreSqlUpsert

 

close() - Method in class com.northconcepts.datapipeline.jdbc.upsert.SybaseUpsert

 

close() - Method in class com.northconcepts.datapipeline.jdbc.upsert.VariableFieldsUpsert

 

close() - Method in class com.northconcepts.datapipeline.jira.client.JiraClient.JiraStub

 

close() - Method in class com.northconcepts.datapipeline.jira.client.JiraService

 

close() - Method in class com.northconcepts.datapipeline.jira.JiraReader

 

close() - Method in class com.northconcepts.datapipeline.jms.JmsConnection

 

close() - Method in class com.northconcepts.datapipeline.jms.JmsReader

 

close() - Method in class com.northconcepts.datapipeline.jms.JmsWriter

 

close() - Method in class com.northconcepts.datapipeline.job.DataReaderIterator

 

close() - Method in class com.northconcepts.datapipeline.json.JsonRecordReader

 

close() - Method in class com.northconcepts.datapipeline.json.JsonRecordWriter

 

close() - Method in class com.northconcepts.datapipeline.json.JsonWriter

 

close() - Method in class com.northconcepts.datapipeline.json.SimpleJsonReader

 

close() - Method in class com.northconcepts.datapipeline.json.SimpleJsonWriter

 

close() - Method in class com.northconcepts.datapipeline.kafka.KafkaReader

 

close() - Method in class com.northconcepts.datapipeline.kafka.KafkaWriter

 

close() - Method in class com.northconcepts.datapipeline.kafka.RecordDeserializer

 

close() - Method in class com.northconcepts.datapipeline.kafka.RecordSerializer

 

close() - Method in class com.northconcepts.datapipeline.latex.LatexWriter

 

close() - Method in class com.northconcepts.datapipeline.mailchimp.MailChimpListMemberReader

 

close() - Method in class com.northconcepts.datapipeline.meter.MeteredInputStream

 

close() - Method in class com.northconcepts.datapipeline.meter.MeteredOutputStream

 

close() - Method in class com.northconcepts.datapipeline.meter.MeteredReader

 

close() - Method in class com.northconcepts.datapipeline.meter.MeteredWriter

 

close() - Method in class com.northconcepts.datapipeline.microsoft.word.MicrosoftWordWriter

 

close() - Method in class com.northconcepts.datapipeline.mongodb.MongoReader

 

close() - Method in class com.northconcepts.datapipeline.mongodb.MongoWriter

 

close() - Method in class com.northconcepts.datapipeline.multiplex.SplitReader

 

close() - Method in class com.northconcepts.datapipeline.multiplex.SplitWriter

 

close() - Method in class com.northconcepts.datapipeline.openfinancialexchange.OpenFinancialExchangeReader

 

close() - Method in class com.northconcepts.datapipeline.orc.OrcDataReader

 

close() - Method in class com.northconcepts.datapipeline.orc.OrcDataWriter

 

close() - Method in class com.northconcepts.datapipeline.parquet.ParquetDataReader

 

close() - Method in class com.northconcepts.datapipeline.parquet.ParquetDataWriter

 

close() - Method in class com.northconcepts.datapipeline.pdf.PdfDocument

 

close() - Method in class com.northconcepts.datapipeline.pdf.PdfReader

 

close() - Method in class com.northconcepts.datapipeline.pdf.PdfWriter

 

close() - Method in class com.northconcepts.datapipeline.retry.RetryingReader

 

close() - Method in class com.northconcepts.datapipeline.retry.RetryingWriter

 

close() - Method in class com.northconcepts.datapipeline.rtf.RtfWriter

 

close() - Method in class com.northconcepts.datapipeline.shopify.client.ShopifyClient.ShopifyStub

Closes the RESTEasy client behind the proxy.

close() - Method in class com.northconcepts.datapipeline.shopify.client.ShopifyService

Closes the underlying RESTEasy client.

close() - Method in class com.northconcepts.datapipeline.shopify.ShopifyApiReader

 

close() - Method in class com.northconcepts.datapipeline.sourcecode.CodeWriter

Flushes and closes the underlying writer or stream.

close() - Method in class com.northconcepts.datapipeline.sql.h2.H2InsertWriter

 

close() - Method in class com.northconcepts.datapipeline.sql.mysql.MySqlInsertWriter

 

close() - Method in class com.northconcepts.datapipeline.sql.mysql.MySqlUpsertWriter

 

close() - Method in class com.northconcepts.datapipeline.sql.postgresql.PostgreSqlInsertWriter

 

close() - Method in class com.northconcepts.datapipeline.sql.postgresql.PostgreSqlUpsertWriter

 

close() - Method in class com.northconcepts.datapipeline.template.TemplateWriter

 

close() - Method in class com.northconcepts.datapipeline.texttable.TextTableWriter

 

close() - Method in class com.northconcepts.datapipeline.transform.lookup.JdbcLookup

 

close() - Method in class com.northconcepts.datapipeline.transform.lookup.Lookup

Called when the LookupTransformer using this lookup is closed; override to release resources.

close() - Method in class com.northconcepts.datapipeline.transform.lookup.LookupTransformer

 

close() - Method in class com.northconcepts.datapipeline.transform.lookup.ProxyLookup

 

close() - Method in class com.northconcepts.datapipeline.transform.Transformer

Called by TransformingReader or TransformingWriter when their close() method is called (after reading or writing ends).

close() - Method in class com.northconcepts.datapipeline.transform.TransformingReader

 

close() - Method in class com.northconcepts.datapipeline.transform.TransformingWriter

 

close() - Method in class com.northconcepts.datapipeline.trello.TrelloApiReader

 

close() - Method in class com.northconcepts.datapipeline.trello.TrelloApiWriter

 

close() - Method in class com.northconcepts.datapipeline.twitter.TwitterFilterStreamReader

 

close() - Method in class com.northconcepts.datapipeline.twitter.TwitterSampleStreamReader

 

close() - Method in class com.northconcepts.datapipeline.twitter.TwitterSearchReader

 

close() - Method in class com.northconcepts.datapipeline.twitter.TwitterStreamProvider

Shuts down the stream if one was created; a later reader open creates a new one.

close() - Method in class com.northconcepts.datapipeline.twitter.TwitterUserLookupReader

 

close() - Method in class com.northconcepts.datapipeline.twitter2.TwitterFilterStreamReader

 

close() - Method in class com.northconcepts.datapipeline.xml.SimpleXmlReader

 

close() - Method in class com.northconcepts.datapipeline.xml.SimpleXmlWriter

 

close() - Method in class com.northconcepts.datapipeline.xml.XmlReader

 

close() - Method in class com.northconcepts.datapipeline.xml.XmlRecordReader

 

close() - Method in class com.northconcepts.datapipeline.xml.XmlRecordWriter

 

close() - Method in class com.northconcepts.datapipeline.xml.XmlWriter

 

CLOSE_BUFFER_MARGIN_MILLIS - Static variable in class com.northconcepts.datapipeline.buffer.BufferStrategy

 

CLOSE_WINDOW_MARGIN_MILLIS - Static variable in class com.northconcepts.datapipeline.group.CloseWindowStrategy

 

closeConnection(Connection) - Method in interface com.northconcepts.datapipeline.jdbc.JdbcConnectionFactory

Releases a connection obtained from JdbcConnectionFactory.createConnection() (closes it by default).

CLOSED - Enum constant in enum class com.northconcepts.datapipeline.core.DataEndpoint.State

 

CLOSED - Enum constant in enum class com.northconcepts.datapipeline.jira.JiraSprintReader.SprintState

 

CLOSED - Enum constant in enum class com.northconcepts.datapipeline.shopify.client.EventVerb

 

CLOSED - Enum constant in enum class com.northconcepts.datapipeline.shopify.client.OrderStatus

 

CLOSED - Enum constant in enum class com.northconcepts.datapipeline.trello.BoardFilter

 

CLOSED - Enum constant in enum class com.northconcepts.datapipeline.trello.BoardLists

 

CLOSED - Enum constant in enum class com.northconcepts.datapipeline.trello.CardFilter

 

CLOSED - Enum constant in enum class com.northconcepts.datapipeline.trello.ListFilter

 

CloseWindowStrategy - Class in com.northconcepts.datapipeline.group

Determines when GroupByReader closes an open sliding window.

CloseWindowStrategy() - Constructor for class com.northconcepts.datapipeline.group.CloseWindowStrategy

 

CodeWriter - Class in com.northconcepts.datapipeline.sourcecode

A programming-language agnostic class for emitting formatted code using indentation and line breaks.

CodeWriter() - Constructor for class com.northconcepts.datapipeline.sourcecode.CodeWriter

Creates a writer that keeps the code in memory for CodeWriter.getSourceString().

CodeWriter(OutputStream) - Constructor for class com.northconcepts.datapipeline.sourcecode.CodeWriter

Creates a writer for the stream, encoding text with the platform's default charset.

CodeWriter(Writer) - Constructor for class com.northconcepts.datapipeline.sourcecode.CodeWriter

 

collapseChildren(TreeNode) - Method in class com.northconcepts.datapipeline.foundations.pipeline.tree.detect.CollapseSiblingPatterns

Merges the parent's children that match the first pattern a rule derives into one wildcard node; called for every node, children before parents.

CollapseSiblingPatterns - Class in com.northconcepts.datapipeline.foundations.pipeline.tree.detect

Collapses down (merges) sibling tree-node-paths whose names share a derivable naming/wildcard pattern (see SiblingSetRule) into a single wildcard node, mirroring what the build-time NodeNameRules produce for individually dynamic names: the collapsed node is named *, its XPath expression ends in node(), member names become its values, and descendant XPaths collapse the merged segment to *.

CollapseSiblingPatterns() - Constructor for class com.northconcepts.datapipeline.foundations.pipeline.tree.detect.CollapseSiblingPatterns

Creates a pass with a single AffixSiblingSetRule.

collect(FieldPath, boolean, boolean, boolean) - Method in class com.northconcepts.datapipeline.group.GroupByReader

Collects the individual values into an array, using the source field name as the target field name.

collect(FieldPath, FieldPath, boolean, boolean) - Method in class com.northconcepts.datapipeline.group.GroupByReader

Collects the individual values into an array, excluding nulls by default.

collect(FieldPath, FieldPath, boolean, boolean, boolean) - Method in class com.northconcepts.datapipeline.group.GroupByReader

Collects the individual values into an array.

collect(String, boolean, boolean, boolean) - Method in class com.northconcepts.datapipeline.group.GroupByReader

Collects the individual values into an array, using the source field name as the target field name.

collect(String, String, boolean, boolean) - Method in class com.northconcepts.datapipeline.group.GroupByReader

Collects the individual values into an array, excluding nulls by default.

collect(String, String, boolean, boolean, boolean) - Method in class com.northconcepts.datapipeline.group.GroupByReader

Collects the individual values into an array.

collect(String, Collection) - Method in class com.northconcepts.datapipeline.memory.CollectionWriter

 

COLLECTION - Enum constant in enum class com.northconcepts.datapipeline.shopify.client.EventFilter

 

CollectionReader<T> - Class in com.northconcepts.datapipeline.memory

A DataReader that reads records from a Java Collection, Iterator, or Stream.

CollectionReader(Collection<T>, Function<T, Record>) - Constructor for class com.northconcepts.datapipeline.memory.CollectionReader

Creates a CollectionReader from a Collection.

CollectionReader(Iterator<T>, Function<T, Record>) - Constructor for class com.northconcepts.datapipeline.memory.CollectionReader

Creates a CollectionReader from an Iterator.

CollectionReader(Stream<T>, Function<T, Record>) - Constructor for class com.northconcepts.datapipeline.memory.CollectionReader

Creates a CollectionReader from a Stream.

CollectionWriter - Class in com.northconcepts.datapipeline.memory

Copies the values in specific fields to an in-memory Collection.

CollectionWriter() - Constructor for class com.northconcepts.datapipeline.memory.CollectionWriter

 

collectParameterValues(List<Object>) - Method in class com.northconcepts.datapipeline.jdbc.sql.conflict.OnConflict

 

collectParameterValues(List<Object>) - Method in class com.northconcepts.datapipeline.jdbc.sql.delete.Delete

 

collectParameterValues(List<Object>) - Method in class com.northconcepts.datapipeline.jdbc.sql.insert.Insert

 

collectParameterValues(List<Object>) - Method in class com.northconcepts.datapipeline.jdbc.sql.insert.InsertRow

 

collectParameterValues(List<Object>) - Method in class com.northconcepts.datapipeline.jdbc.sql.insert.InsertValue

 

collectParameterValues(List<Object>) - Method in class com.northconcepts.datapipeline.jdbc.sql.merge.Merge

 

collectParameterValues(List<Object>) - Method in class com.northconcepts.datapipeline.jdbc.sql.merge.MergeValue

 

collectParameterValues(List<Object>) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.ConditionPart

 

collectParameterValues(List<Object>) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.NotPart

 

collectParameterValues(List<Object>) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.QueryCriteria

 

collectParameterValues(List<Object>) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.QueryCriteriaPart

 

collectParameterValues(List<Object>) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.QueryOrder

 

collectParameterValues(List<Object>) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.Select

 

collectParameterValues(List<Object>) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.TableQuerySource

 

collectParameterValues(List<Object>) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.Union

 

collectParameterValues(List<Object>) - Method in class com.northconcepts.datapipeline.jdbc.sql.SqlPart

Appends the values for this part's ? parameters to the list in order; adds nothing by default.

collectParameterValues(List<Object>) - Method in class com.northconcepts.datapipeline.jdbc.sql.update.Update

 

collectParameterValues(List<Object>) - Method in class com.northconcepts.datapipeline.jdbc.sql.update.UpdateValue

 

collectQuerySourceSqlFragment(CodeWriter, QuerySource) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.Select

Writes a FROM source, in parentheses if QuerySource.shouldWrapWhenNested() is true, followed by its nested alias if any.

collectSqlFragment(CodeWriter) - Method in class com.northconcepts.datapipeline.jdbc.sql.conflict.OnConflict

 

collectSqlFragment(CodeWriter) - Method in class com.northconcepts.datapipeline.jdbc.sql.delete.Delete

 

collectSqlFragment(CodeWriter) - Method in class com.northconcepts.datapipeline.jdbc.sql.insert.Insert

 

collectSqlFragment(CodeWriter) - Method in class com.northconcepts.datapipeline.jdbc.sql.insert.InsertRow

 

collectSqlFragment(CodeWriter) - Method in class com.northconcepts.datapipeline.jdbc.sql.insert.InsertValue

 

collectSqlFragment(CodeWriter) - Method in class com.northconcepts.datapipeline.jdbc.sql.merge.Merge

 

collectSqlFragment(CodeWriter) - Method in class com.northconcepts.datapipeline.jdbc.sql.merge.MergeValue

 

collectSqlFragment(CodeWriter) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.ConditionPart

 

collectSqlFragment(CodeWriter) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.ConjunctivePart

 

collectSqlFragment(CodeWriter) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.FullJoin

 

collectSqlFragment(CodeWriter) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.InnerJoin

 

collectSqlFragment(CodeWriter) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.LeftJoin

 

collectSqlFragment(CodeWriter) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.NotPart

 

collectSqlFragment(CodeWriter) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.QueryCriteria

 

collectSqlFragment(CodeWriter) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.QueryGrouping

 

collectSqlFragment(CodeWriter) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.QueryOrder

 

collectSqlFragment(CodeWriter) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.QueryOrderPart

 

collectSqlFragment(CodeWriter) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.QuerySelection

 

collectSqlFragment(CodeWriter) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.RightJoin

 

collectSqlFragment(CodeWriter) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.Select

 

collectSqlFragment(CodeWriter) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.TableQuerySource

 

collectSqlFragment(CodeWriter) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.Union

 

collectSqlFragment(CodeWriter) - Method in class com.northconcepts.datapipeline.jdbc.sql.SqlPart

Writes this part's SQL to the writer; used by SqlPart.getSqlFragment() and by enclosing parts.

collectSqlFragment(CodeWriter) - Method in class com.northconcepts.datapipeline.jdbc.sql.update.Update

 

collectSqlFragment(CodeWriter) - Method in class com.northconcepts.datapipeline.jdbc.sql.update.UpdateValue

 

collectSqlFragment(CodeWriter) - Method in class com.northconcepts.datapipeline.sql.h2.CreateForeignKey

 

collectSqlFragment(CodeWriter) - Method in class com.northconcepts.datapipeline.sql.h2.CreateH2DdlFromSchemaDef

Generates DDL from CreateH2DdlFromSchemaDef.schemaDef and writes the output to writer.

collectSqlFragment(CodeWriter) - Method in class com.northconcepts.datapipeline.sql.h2.CreateIndex

 

collectSqlFragment(CodeWriter) - Method in class com.northconcepts.datapipeline.sql.h2.CreateTable

 

collectSqlFragment(CodeWriter) - Method in class com.northconcepts.datapipeline.sql.h2.CreateTableColumn

 

collectSqlFragment(CodeWriter) - Method in class com.northconcepts.datapipeline.sql.h2.DropTable

 

collectSqlFragment(CodeWriter) - Method in class com.northconcepts.datapipeline.sql.h2.DropTableConstraint

 

collectSqlFragment(CodeWriter) - Method in class com.northconcepts.datapipeline.sql.h2.Insert

 

collectSqlFragment(CodeWriter) - Method in class com.northconcepts.datapipeline.sql.h2.InsertRow

 

collectSqlFragment(CodeWriter) - Method in class com.northconcepts.datapipeline.sql.h2.InsertValue

 

collectSqlFragment(CodeWriter) - Method in class com.northconcepts.datapipeline.sql.h2.Upsert

 

collectSqlFragment(CodeWriter) - Method in class com.northconcepts.datapipeline.sql.mysql.CreateForeignKey

 

collectSqlFragment(CodeWriter) - Method in class com.northconcepts.datapipeline.sql.mysql.CreateIndex

 

collectSqlFragment(CodeWriter) - Method in class com.northconcepts.datapipeline.sql.mysql.CreateMySqlDdlFromSchemaDef

Generates DDL from CreateMySqlDdlFromSchemaDef.schemaDef and writes the output to writer.

collectSqlFragment(CodeWriter) - Method in class com.northconcepts.datapipeline.sql.mysql.CreateTable

 

collectSqlFragment(CodeWriter) - Method in class com.northconcepts.datapipeline.sql.mysql.CreateTableColumn

 

collectSqlFragment(CodeWriter) - Method in class com.northconcepts.datapipeline.sql.mysql.DropTable

 

collectSqlFragment(CodeWriter) - Method in class com.northconcepts.datapipeline.sql.mysql.DropTableConstraint

 

collectSqlFragment(CodeWriter) - Method in class com.northconcepts.datapipeline.sql.mysql.Insert

 

collectSqlFragment(CodeWriter) - Method in class com.northconcepts.datapipeline.sql.mysql.InsertRow

 

collectSqlFragment(CodeWriter) - Method in class com.northconcepts.datapipeline.sql.mysql.InsertValue

 

collectSqlFragment(CodeWriter) - Method in class com.northconcepts.datapipeline.sql.mysql.Upsert

 

collectSqlFragment(CodeWriter) - Method in class com.northconcepts.datapipeline.sql.postgresql.CreateForeignKey

 

collectSqlFragment(CodeWriter) - Method in class com.northconcepts.datapipeline.sql.postgresql.CreateIndex

 

collectSqlFragment(CodeWriter) - Method in class com.northconcepts.datapipeline.sql.postgresql.CreatePostgreSqlDdlFromSchemaDef

Generates DDL from CreatePostgreSqlDdlFromSchemaDef.schemaDef and writes the output to writer.

collectSqlFragment(CodeWriter) - Method in class com.northconcepts.datapipeline.sql.postgresql.CreateTable

 

collectSqlFragment(CodeWriter) - Method in class com.northconcepts.datapipeline.sql.postgresql.CreateTableColumn

 

collectSqlFragment(CodeWriter) - Method in class com.northconcepts.datapipeline.sql.postgresql.DropTable

 

collectSqlFragment(CodeWriter) - Method in class com.northconcepts.datapipeline.sql.postgresql.DropTableConstraint

 

collectSqlFragment(CodeWriter) - Method in class com.northconcepts.datapipeline.sql.postgresql.Insert

 

collectSqlFragment(CodeWriter) - Method in class com.northconcepts.datapipeline.sql.postgresql.InsertRow

 

collectSqlFragment(CodeWriter) - Method in class com.northconcepts.datapipeline.sql.postgresql.InsertValue

 

collectSqlFragment(CodeWriter) - Method in class com.northconcepts.datapipeline.sql.postgresql.Upsert

 

column - Variable in class com.northconcepts.datapipeline.jsonata.Location

The column number, starting at 1.

Column - Class in com.northconcepts.datapipeline.foundations.pipeline.dataset

Holds the metadata and statistics for each field in a dataset.

Column() - Constructor for class com.northconcepts.datapipeline.foundations.pipeline.dataset.Column

 

Column(String, int) - Constructor for class com.northconcepts.datapipeline.foundations.pipeline.dataset.Column

 

Column(String, int, Map<Object, LongAdder>) - Constructor for class com.northconcepts.datapipeline.foundations.pipeline.dataset.Column

Creates a column that collects its unique values and their counts in the given map.

COLUMN_STATS_READER_THREADS - Static variable in class com.northconcepts.datapipeline.foundations.datamapping.DataMappingEditor

 

columnCountMismatchInLocalFileDataset(int, int) - Static method in class com.northconcepts.datapipeline.foundations.i18n.FoundationMessages

 

ColumnsDataReader(List<Column>) - Constructor for class com.northconcepts.datapipeline.foundations.pipeline.dataset.Dataset.ColumnsDataReader

 

columnsLoaded(JdbcConnection, DatabaseMetaData, LoadTablesRequest) - Method in interface com.northconcepts.datapipeline.foundations.jdbc.JdbcConnectionListener

 

com.northconcepts.datapipeline.amazons3 - package com.northconcepts.datapipeline.amazons3

Read and write to Amazon-S3.

com.northconcepts.datapipeline.avro - package com.northconcepts.datapipeline.avro

Read and write Apache Avro files.

com.northconcepts.datapipeline.avro.pipeline.input - package com.northconcepts.datapipeline.avro.pipeline.input

 

com.northconcepts.datapipeline.avro.pipeline.output - package com.northconcepts.datapipeline.avro.pipeline.output

 

com.northconcepts.datapipeline.bloomberg - package com.northconcepts.datapipeline.bloomberg

Read Bloomberg Message data.

com.northconcepts.datapipeline.buffer - package com.northconcepts.datapipeline.buffer

Organize incoming data into groups of sequential records without aggregation or transformation.

com.northconcepts.datapipeline.core - package com.northconcepts.datapipeline.core

Core DataPipeline classes for reading, writing, and processing data.

com.northconcepts.datapipeline.csv - package com.northconcepts.datapipeline.csv

Read and write comma separated values (CSV) and other delimited data.

com.northconcepts.datapipeline.diagnostic - package com.northconcepts.datapipeline.diagnostic

Troubleshoot DataPipeline's setup and environment.

com.northconcepts.datapipeline.email - package com.northconcepts.datapipeline.email

Read emails.

com.northconcepts.datapipeline.eventbus - package com.northconcepts.datapipeline.eventbus

In-memory, publish-subscribe hub using simple Java interfaces or loosely-coupled readers and writers.

com.northconcepts.datapipeline.eventbus.filter - package com.northconcepts.datapipeline.eventbus.filter

 

com.northconcepts.datapipeline.excel - package com.northconcepts.datapipeline.excel

Read and write Microsoft Excel documents.

com.northconcepts.datapipeline.expression - package com.northconcepts.datapipeline.expression

Parse and execute DataPipeline's expression language.

com.northconcepts.datapipeline.file - package com.northconcepts.datapipeline.file

Read and write records using DataPipeline's native binary format.

com.northconcepts.datapipeline.filesystem.dropbox - package com.northconcepts.datapipeline.filesystem.dropbox

Read and write to Dropbox.

com.northconcepts.datapipeline.filesystem.ftp - package com.northconcepts.datapipeline.filesystem.ftp

Read and write files to an FTP Server.

com.northconcepts.datapipeline.filesystem.hdfs - package com.northconcepts.datapipeline.filesystem.hdfs

Read and write files to Hadoop Distributed File System.

com.northconcepts.datapipeline.filesystem.sftp - package com.northconcepts.datapipeline.filesystem.sftp

Read and write files to an SFTP Server.

com.northconcepts.datapipeline.filesystem.zip - package com.northconcepts.datapipeline.filesystem.zip

Read and write data by treating Zips as a file system.

com.northconcepts.datapipeline.filter - package com.northconcepts.datapipeline.filter

Filter or exclude data by criteria.

com.northconcepts.datapipeline.filter.rule - package com.northconcepts.datapipeline.filter.rule

 

com.northconcepts.datapipeline.fixedwidth - package com.northconcepts.datapipeline.fixedwidth

Read and write fixed-width / fixed-length records.

com.northconcepts.datapipeline.foundations.core - package com.northconcepts.datapipeline.foundations.core

 

com.northconcepts.datapipeline.foundations.datamapping - package com.northconcepts.datapipeline.foundations.datamapping

Model and execute source-target data mapping using expressions and functions.

com.northconcepts.datapipeline.foundations.decisiontable - package com.northconcepts.datapipeline.foundations.decisiontable

Decision table rule engine.

com.northconcepts.datapipeline.foundations.decisiontree - package com.northconcepts.datapipeline.foundations.decisiontree

Decision tree rule engine.

com.northconcepts.datapipeline.foundations.difference - package com.northconcepts.datapipeline.foundations.difference

Common classes for comparing objects to detect elements that were added, removed, renamed, and changed.

com.northconcepts.datapipeline.foundations.expression - package com.northconcepts.datapipeline.foundations.expression

 

com.northconcepts.datapipeline.foundations.file - package com.northconcepts.datapipeline.foundations.file

 

com.northconcepts.datapipeline.foundations.i18n - package com.northconcepts.datapipeline.foundations.i18n

 

com.northconcepts.datapipeline.foundations.internal - package com.northconcepts.datapipeline.foundations.internal

 

com.northconcepts.datapipeline.foundations.jdbc - package com.northconcepts.datapipeline.foundations.jdbc

Database metadata model and code generation.

com.northconcepts.datapipeline.foundations.number - package com.northconcepts.datapipeline.foundations.number

Detect number patterns in strings.

com.northconcepts.datapipeline.foundations.pipeline - package com.northconcepts.datapipeline.foundations.pipeline

Declarative pipeline modeling and execution.

com.northconcepts.datapipeline.foundations.pipeline.action - package com.northconcepts.datapipeline.foundations.pipeline.action

 

com.northconcepts.datapipeline.foundations.pipeline.action.aggregate - package com.northconcepts.datapipeline.foundations.pipeline.action.aggregate

 

com.northconcepts.datapipeline.foundations.pipeline.action.convert - package com.northconcepts.datapipeline.foundations.pipeline.action.convert

 

com.northconcepts.datapipeline.foundations.pipeline.action.datamapping - package com.northconcepts.datapipeline.foundations.pipeline.action.datamapping

 

com.northconcepts.datapipeline.foundations.pipeline.action.decision - package com.northconcepts.datapipeline.foundations.pipeline.action.decision

 

com.northconcepts.datapipeline.foundations.pipeline.action.filter - package com.northconcepts.datapipeline.foundations.pipeline.action.filter

 

com.northconcepts.datapipeline.foundations.pipeline.action.transform - package com.northconcepts.datapipeline.foundations.pipeline.action.transform

 

com.northconcepts.datapipeline.foundations.pipeline.action.validate - package com.northconcepts.datapipeline.foundations.pipeline.action.validate

 

com.northconcepts.datapipeline.foundations.pipeline.dataset - package com.northconcepts.datapipeline.foundations.pipeline.dataset

 

com.northconcepts.datapipeline.foundations.pipeline.input - package com.northconcepts.datapipeline.foundations.pipeline.input

 

com.northconcepts.datapipeline.foundations.pipeline.output - package com.northconcepts.datapipeline.foundations.pipeline.output

 

com.northconcepts.datapipeline.foundations.pipeline.tree - package com.northconcepts.datapipeline.foundations.pipeline.tree

 

com.northconcepts.datapipeline.foundations.pipeline.tree.detect - package com.northconcepts.datapipeline.foundations.pipeline.tree.detect

Pluggable algorithms to detect record breaks and fields in a Tree, including collapsing down (merging) tree-node-paths where a naming/wildcard pattern can be derived.

com.northconcepts.datapipeline.foundations.schema - package com.northconcepts.datapipeline.foundations.schema

Schema models for validation, mapping, and code generation.

com.northconcepts.datapipeline.foundations.schema.diff - package com.northconcepts.datapipeline.foundations.schema.diff

Compare schema models to detect elements that were added, removed, renamed, and changed.

com.northconcepts.datapipeline.foundations.time - package com.northconcepts.datapipeline.foundations.time

Detect date-time patterns in strings.

com.northconcepts.datapipeline.foundations.tools - package com.northconcepts.datapipeline.foundations.tools

DataPipeline Foundation tools for generating code and models.

com.northconcepts.datapipeline.google - package com.northconcepts.datapipeline.google

 

com.northconcepts.datapipeline.google.analytics - package com.northconcepts.datapipeline.google.analytics

Read Google Analytics Report.

com.northconcepts.datapipeline.google.calendar - package com.northconcepts.datapipeline.google.calendar

Read Google Calendar Events.

com.northconcepts.datapipeline.google.contacts - package com.northconcepts.datapipeline.google.contacts

Read Google Contacts.

com.northconcepts.datapipeline.google.gmail - package com.northconcepts.datapipeline.google.gmail

Read Gmail messages.

com.northconcepts.datapipeline.google.sheets - package com.northconcepts.datapipeline.google.sheets

 

com.northconcepts.datapipeline.googledrive - package com.northconcepts.datapipeline.googledrive

Read and write files to Google Drive.

com.northconcepts.datapipeline.group - package com.northconcepts.datapipeline.group

Summarize batch and streaming data similar to "group by" in SQL.

com.northconcepts.datapipeline.group.operation - package com.northconcepts.datapipeline.group.operation

 

com.northconcepts.datapipeline.instagram - package com.northconcepts.datapipeline.instagram

Search and read Instagram media and user data.

com.northconcepts.datapipeline.internal.lang - package com.northconcepts.datapipeline.internal.lang

 

com.northconcepts.datapipeline.io - package com.northconcepts.datapipeline.io

 

com.northconcepts.datapipeline.javabean - package com.northconcepts.datapipeline.javabean

Read Java Beans as a job's data source.

com.northconcepts.datapipeline.jdbc - package com.northconcepts.datapipeline.jdbc

Database reading and writing via JDBC.

com.northconcepts.datapipeline.jdbc.insert - package com.northconcepts.datapipeline.jdbc.insert

Insert strategies for JdbcWriter and JdbcMultiWriter.

com.northconcepts.datapipeline.jdbc.sql - package com.northconcepts.datapipeline.jdbc.sql

Common SQL generation classes.

com.northconcepts.datapipeline.jdbc.sql.conflict - package com.northconcepts.datapipeline.jdbc.sql.conflict

 

com.northconcepts.datapipeline.jdbc.sql.delete - package com.northconcepts.datapipeline.jdbc.sql.delete

SQL generation classes for DELETE.

com.northconcepts.datapipeline.jdbc.sql.insert - package com.northconcepts.datapipeline.jdbc.sql.insert

SQL generation classes for INSERT.

com.northconcepts.datapipeline.jdbc.sql.merge - package com.northconcepts.datapipeline.jdbc.sql.merge

SQL generation classes for MERGE.

com.northconcepts.datapipeline.jdbc.sql.select - package com.northconcepts.datapipeline.jdbc.sql.select

SQL generation classes for SELECT.

com.northconcepts.datapipeline.jdbc.sql.update - package com.northconcepts.datapipeline.jdbc.sql.update

SQL generation classes for UPDATE.

com.northconcepts.datapipeline.jdbc.upsert - package com.northconcepts.datapipeline.jdbc.upsert

Upsert strategies for JdbcUpsertWriter and JdbcMultiUpsertWriter.

com.northconcepts.datapipeline.jira - package com.northconcepts.datapipeline.jira

Read Jira project, sprint and issue data.

com.northconcepts.datapipeline.jira.client - package com.northconcepts.datapipeline.jira.client

RESTful client and Java wrapper for Jira.

com.northconcepts.datapipeline.jms - package com.northconcepts.datapipeline.jms

Read and write Java Message Service data.

com.northconcepts.datapipeline.job - package com.northconcepts.datapipeline.job

Running, tracking, and managing data transfer pipelines.

com.northconcepts.datapipeline.json - package com.northconcepts.datapipeline.json

JSON reading and writing.

com.northconcepts.datapipeline.json.builder - package com.northconcepts.datapipeline.json.builder

Programmatic JSON creation.

com.northconcepts.datapipeline.jsonata - package com.northconcepts.datapipeline.jsonata

Apply JSONata transformations.

com.northconcepts.datapipeline.jsonata.utils - package com.northconcepts.datapipeline.jsonata.utils

 

com.northconcepts.datapipeline.kafka - package com.northconcepts.datapipeline.kafka

Read and write Apache Kafka distributed messaging system data.

com.northconcepts.datapipeline.latex - package com.northconcepts.datapipeline.latex

 

com.northconcepts.datapipeline.latex.output - package com.northconcepts.datapipeline.latex.output

 

com.northconcepts.datapipeline.lineage - package com.northconcepts.datapipeline.lineage

Extract data lineage from records and fields.

com.northconcepts.datapipeline.mailchimp - package com.northconcepts.datapipeline.mailchimp

Read MailChimp lists.

com.northconcepts.datapipeline.mailchimp.list - package com.northconcepts.datapipeline.mailchimp.list

 

com.northconcepts.datapipeline.memory - package com.northconcepts.datapipeline.memory

Reading and writing data to and from in-memory buffers.

com.northconcepts.datapipeline.meter - package com.northconcepts.datapipeline.meter

Measures the rate (bytes/second or records/second) at which data is read or written.

com.northconcepts.datapipeline.microsoft.word - package com.northconcepts.datapipeline.microsoft.word

Writes records to a Microsoft Word (OOXML .docx) document stream.

com.northconcepts.datapipeline.microsoft.word.output - package com.northconcepts.datapipeline.microsoft.word.output

 

com.northconcepts.datapipeline.mongodb - package com.northconcepts.datapipeline.mongodb

Read and write data in MongoDB.

com.northconcepts.datapipeline.multiplex - package com.northconcepts.datapipeline.multiplex

Strategies to convert a single source DataReader into many downstream readers.

com.northconcepts.datapipeline.openfinancialexchange - package com.northconcepts.datapipeline.openfinancialexchange

Read OFX / QFX (Quicken) / QBO (QuickBooks) files.

com.northconcepts.datapipeline.openfinancialexchange.pipeline.input - package com.northconcepts.datapipeline.openfinancialexchange.pipeline.input

 

com.northconcepts.datapipeline.orc - package com.northconcepts.datapipeline.orc

Read and write Apache ORC columnar files.

com.northconcepts.datapipeline.orc.input - package com.northconcepts.datapipeline.orc.input

 

com.northconcepts.datapipeline.orc.output - package com.northconcepts.datapipeline.orc.output

 

com.northconcepts.datapipeline.parquet - package com.northconcepts.datapipeline.parquet

Read and Write Apache Parquet columnar files.

com.northconcepts.datapipeline.parquet.file - package com.northconcepts.datapipeline.parquet.file

 

com.northconcepts.datapipeline.parquet.input - package com.northconcepts.datapipeline.parquet.input

 

com.northconcepts.datapipeline.parquet.output - package com.northconcepts.datapipeline.parquet.output

 

com.northconcepts.datapipeline.parquet.tools - package com.northconcepts.datapipeline.parquet.tools

 

com.northconcepts.datapipeline.pdf - package com.northconcepts.datapipeline.pdf

Write data to a PDF file.

com.northconcepts.datapipeline.pdf.input - package com.northconcepts.datapipeline.pdf.input

 

com.northconcepts.datapipeline.pdf.output - package com.northconcepts.datapipeline.pdf.output

 

com.northconcepts.datapipeline.retry - package com.northconcepts.datapipeline.retry

Classes to retry and continue reading or writing data on failure.

com.northconcepts.datapipeline.rtf - package com.northconcepts.datapipeline.rtf

Writes records to an RTF document stream.

com.northconcepts.datapipeline.schedule - package com.northconcepts.datapipeline.schedule

Common task scheduling.

com.northconcepts.datapipeline.security - package com.northconcepts.datapipeline.security

Encrypt and decrypt data.

com.northconcepts.datapipeline.shopify - package com.northconcepts.datapipeline.shopify

Read data from Shopify.

com.northconcepts.datapipeline.shopify.client - package com.northconcepts.datapipeline.shopify.client

REST client to read and write Shopify store data.

com.northconcepts.datapipeline.sourcecode - package com.northconcepts.datapipeline.sourcecode

Code generation classes.

com.northconcepts.datapipeline.sql.h2 - package com.northconcepts.datapipeline.sql.h2

Generate SQL code for the H2 database with default mode.

com.northconcepts.datapipeline.sql.mysql - package com.northconcepts.datapipeline.sql.mysql

Generate SQL code for the MySQL database.

com.northconcepts.datapipeline.sql.postgresql - package com.northconcepts.datapipeline.sql.postgresql

Generate SQL code for the PostgreSQL database.

com.northconcepts.datapipeline.template - package com.northconcepts.datapipeline.template

Write data to a text stream using FreeMarker template.

com.northconcepts.datapipeline.texttable - package com.northconcepts.datapipeline.texttable

Write records as an easy-to-read, plain-text table with padded, aligned columns.

com.northconcepts.datapipeline.throttle - package com.northconcepts.datapipeline.throttle

Limits the rate (bytes/second or records/second) at which data is read or written.

com.northconcepts.datapipeline.transform - package com.northconcepts.datapipeline.transform

Restructure data using a variety of built-in and customizable operations.

com.northconcepts.datapipeline.transform.format - package com.northconcepts.datapipeline.transform.format

 

com.northconcepts.datapipeline.transform.lookup - package com.northconcepts.datapipeline.transform.lookup

Enrich data by with data from another source.

com.northconcepts.datapipeline.transform.net - package com.northconcepts.datapipeline.transform.net

 

com.northconcepts.datapipeline.trello - package com.northconcepts.datapipeline.trello

Read and write data to a Trello board and cards.

com.northconcepts.datapipeline.twitter - package com.northconcepts.datapipeline.twitter

Search and read Twitter users and tweets.

com.northconcepts.datapipeline.twitter2 - package com.northconcepts.datapipeline.twitter2

Search and read Twitter users and tweets using Twitter v2 Api.

com.northconcepts.datapipeline.validate - package com.northconcepts.datapipeline.validate

Validate data while reading.

com.northconcepts.datapipeline.weblog - package com.northconcepts.datapipeline.weblog

Read web server logs.

com.northconcepts.datapipeline.xml - package com.northconcepts.datapipeline.xml

XML reading and writing.

com.northconcepts.datapipeline.xml.builder - package com.northconcepts.datapipeline.xml.builder

Programmatic XML creation.

CombinedLogReader - Class in com.northconcepts.datapipeline.weblog

Obtains records from a webserver's access log file using the Combined Log format.

CombinedLogReader(File) - Constructor for class com.northconcepts.datapipeline.weblog.CombinedLogReader

Creates a reader for the log file; each record has the fields remoteHost, clientUsername, authenticatedUsername, date, request, status, bytes, referrer, userAgent and cookies.

CombinedLogReader(Reader) - Constructor for class com.northconcepts.datapipeline.weblog.CombinedLogReader

Creates a reader for the log stream; each record has the fields remoteHost, clientUsername, authenticatedUsername, date, request, status, bytes, referrer, userAgent and cookies.

CommaSeparatedList - Class in com.northconcepts.datapipeline.trello

A list of values parsed from one comma-separated line; toString() joins them back with commas.

CommaSeparatedList(String) - Constructor for class com.northconcepts.datapipeline.trello.CommaSeparatedList

Parses the values of the given comma-separated line as CSV, so values may be enclosed in double quotes.

CommaSeparatedValues - Class in com.northconcepts.datapipeline.csv

A collection of comma delimited values.

CommaSeparatedValues() - Constructor for class com.northconcepts.datapipeline.csv.CommaSeparatedValues

 

CommaSeparatedValues(String) - Constructor for class com.northconcepts.datapipeline.csv.CommaSeparatedValues

Parses the first line of the given comma-separated text; unquoted values are trimmed and become null when empty.

CommaSeparatedValues(Collection<String>) - Constructor for class com.northconcepts.datapipeline.csv.CommaSeparatedValues

Creates an instance backed by the given collection when it is an ArrayList (changes are shared), otherwise by a copy of it.

COMMENT - Enum constant in enum class com.northconcepts.datapipeline.shopify.client.EventFilter

 

compare(Field, Field) - Method in class com.northconcepts.datapipeline.core.FieldComparator

 

compare(Record, Record) - Method in class com.northconcepts.datapipeline.core.RecordComparator

 

compare(ValueNode, ValueNode) - Method in class com.northconcepts.datapipeline.core.ValueNodeComparator

Compares two ValueNode instances for ordering.

compareRecord(Record, Record, boolean) - Method in class com.northconcepts.datapipeline.core.FieldComparator

Compares two records by their field at FieldComparator.getFieldName(), throwing if either lacks it; cacheFieldIndexes is ignored.

compareTo(Field) - Method in class com.northconcepts.datapipeline.core.Field

Compares this field to another by their values using natural ordering.

compareTo(Field, Collator) - Method in class com.northconcepts.datapipeline.core.Field

Compares this field to another by their values, optionally using the specified Collator for string comparisons.

compareTo(Record) - Method in class com.northconcepts.datapipeline.core.Record

Compares this record to another using the default RecordComparator.

compareTo(Record, RecordComparator) - Method in class com.northconcepts.datapipeline.core.Record

Compares this record to another using the specified RecordComparator, or the default if null.

compareTo(ValueNode<ArrayValue>) - Method in class com.northconcepts.datapipeline.core.ArrayValue

Compares this array to another by length first, then element-by-element.

compareTo(ValueNode<Record>) - Method in class com.northconcepts.datapipeline.core.Record

Compares this record to another value node by delegating to Record.compareTo(Record).

compareTo(ValueNode<Object>) - Method in class com.northconcepts.datapipeline.core.SingleValue

Compares this single value to another by their underlying values using natural ordering.

compareTo(ValueNode<Object>, Collator) - Method in class com.northconcepts.datapipeline.core.SingleValue

Compares this single value to another by their underlying values, optionally using the specified Collator for string comparisons.

compareTo(DateTimePattern) - Method in class com.northconcepts.datapipeline.foundations.time.DateTimePattern

 

CompositePipelineAction - Class in com.northconcepts.datapipeline.foundations.pipeline.action

A PipelineAction that applies a list of nested actions in order, as a single step.

CompositePipelineAction() - Constructor for class com.northconcepts.datapipeline.foundations.pipeline.action.CompositePipelineAction

 

CompositeValue - Class in com.northconcepts.datapipeline.core

A fixed-size list of values used as a composite key (for example in lookups, grouping and duplicate removal); a single-value instance hashes like, and equals, that value itself.

CompositeValue(int) - Constructor for class com.northconcepts.datapipeline.core.CompositeValue

Creates an instance with valueCount null values to fill in with CompositeValue.set(int, Object).

CompositeValue(Object...) - Constructor for class com.northconcepts.datapipeline.core.CompositeValue

Creates an instance backed by the given array, which is not copied.

CompositeValue(List<?>) - Constructor for class com.northconcepts.datapipeline.core.CompositeValue

Creates an instance holding a copy of the list's values.

COMPRESSED - Enum constant in enum class com.northconcepts.datapipeline.filesystem.ftp.FileTransferMode

Transfer files as FTP compressed data.

ConcurrentRecordList - Class in com.northconcepts.datapipeline.core

A RecordList that guards many of its methods with a read-write lock; others, such as size() and clear(), are unguarded, as are the iterators, streams and lists it hands out.

ConcurrentRecordList() - Constructor for class com.northconcepts.datapipeline.core.ConcurrentRecordList

 

ConcurrentRecordList(int) - Constructor for class com.northconcepts.datapipeline.core.ConcurrentRecordList

 

ConcurrentRecordList(DataReader) - Constructor for class com.northconcepts.datapipeline.core.ConcurrentRecordList

 

ConcurrentRecordList(Record...) - Constructor for class com.northconcepts.datapipeline.core.ConcurrentRecordList

 

ConditionPart - Class in com.northconcepts.datapipeline.jdbc.sql.select

A single SQL condition, such as "price > ?", with the values for its ? parameters.

ConditionPart(String, Object...) - Constructor for class com.northconcepts.datapipeline.jdbc.sql.select.ConditionPart

 

configure(Map<String, ?>, boolean) - Method in class com.northconcepts.datapipeline.kafka.RecordDeserializer

 

configure(Map<String, ?>, boolean) - Method in class com.northconcepts.datapipeline.kafka.RecordSerializer

 

CONFIRMED - Enum constant in enum class com.northconcepts.datapipeline.shopify.client.EventVerb

 

ConflictAction - Enum Class in com.northconcepts.datapipeline.sql.postgresql

The ON CONFLICT action of an Upsert: update the inserted columns (DO UPDATE SET) or DO NOTHING.

ConjunctivePart - Class in com.northconcepts.datapipeline.jdbc.sql.select

Base class for parts that join their child parts with an operator such as AND or OR, parenthesizing each child when more than one applies.

ConjunctivePart(String) - Constructor for class com.northconcepts.datapipeline.jdbc.sql.select.ConjunctivePart

Creates a part that joins its children with the given SQL operator, such as "AND".

cons - Variable in class com.northconcepts.datapipeline.jsonata.Utils.JList

 

consarray - Variable in class com.northconcepts.datapipeline.jsonata.Parser.Symbol

 

CONSTANT_BACKOFF - Enum constant in enum class com.northconcepts.datapipeline.retry.RetryStrategy

 

Constants - Class in com.northconcepts.datapipeline.jsonata.utils

Constants required by DateTimeUtils

Constants() - Constructor for class com.northconcepts.datapipeline.jsonata.utils.Constants

 

consume() - Method in interface com.northconcepts.datapipeline.core.IParser

 

consume() - Method in class com.northconcepts.datapipeline.core.LineParser

 

consume() - Method in class com.northconcepts.datapipeline.core.Parser

 

consume() - Method in class com.northconcepts.datapipeline.core.StringParser

 

consume(int) - Method in interface com.northconcepts.datapipeline.core.IParser

 

consume(int) - Method in class com.northconcepts.datapipeline.core.LineParser

 

consume(int) - Method in class com.northconcepts.datapipeline.core.Parser

 

consume(int) - Method in class com.northconcepts.datapipeline.core.StringParser

 

consumerKey - Variable in class com.northconcepts.datapipeline.twitter.TwitterProvider

 

consumerKey - Variable in class com.northconcepts.datapipeline.twitter.TwitterStreamProvider

 

consumerSecret - Variable in class com.northconcepts.datapipeline.twitter.TwitterProvider

 

consumerSecret - Variable in class com.northconcepts.datapipeline.twitter.TwitterStreamProvider

 

consumeWhitespace() - Method in interface com.northconcepts.datapipeline.core.IParser

 

consumeWhitespace() - Method in class com.northconcepts.datapipeline.core.LineParser

 

consumeWhitespace() - Method in class com.northconcepts.datapipeline.core.Parser

 

consumeWhitespace() - Method in class com.northconcepts.datapipeline.core.StringParser

 

consumeWhitespace(char[]) - Method in interface com.northconcepts.datapipeline.core.IParser

Skips whitespace at the current position, stopping where the given string (such as a field separator) begins.

consumeWhitespace(char[]) - Method in class com.northconcepts.datapipeline.core.LineParser

 

consumeWhitespace(char[]) - Method in class com.northconcepts.datapipeline.core.Parser

 

consumeWhitespace(char[]) - Method in class com.northconcepts.datapipeline.core.StringParser

 

consumeWhitespace(int) - Method in interface com.northconcepts.datapipeline.core.IParser

Skips spaces and tabs at the current position, stopping early at the given character.

consumeWhitespace(int) - Method in class com.northconcepts.datapipeline.core.LineParser

 

consumeWhitespace(int) - Method in class com.northconcepts.datapipeline.core.Parser

 

consumeWhitespace(int) - Method in class com.northconcepts.datapipeline.core.StringParser

 

consumeWhitespace(CharSequence) - Method in interface com.northconcepts.datapipeline.core.IParser

Skips whitespace at the current position, stopping where the given string (such as a field separator) begins.

consumeWhitespace(CharSequence) - Method in class com.northconcepts.datapipeline.core.LineParser

 

consumeWhitespace(CharSequence) - Method in class com.northconcepts.datapipeline.core.Parser

 

consumeWhitespace(CharSequence) - Method in class com.northconcepts.datapipeline.core.StringParser

 

containedWithin(String...) - Method in class com.northconcepts.datapipeline.core.FieldList

Returns true if the supplied fieldNames contains all the fields names in this list.

containedWithin(List<String>) - Method in class com.northconcepts.datapipeline.core.FieldList

Returns true if the supplied fieldNames contains all the fields names in this list.

contains(FieldPath) - Method in class com.northconcepts.datapipeline.core.Record

Deprecated.

contains(Record) - Method in class com.northconcepts.datapipeline.core.FieldPath

Deprecated.

contains(String) - Method in class com.northconcepts.datapipeline.csv.CommaSeparatedValues

 

contains(String) - Method in class com.northconcepts.datapipeline.foundations.core.Tags

 

contains(String) - Method in class com.northconcepts.datapipeline.security.Credentials

Returns true if a value is present for the given key (false for every key after Credentials.clear()).

contains(String...) - Method in class com.northconcepts.datapipeline.core.FieldList

Returns true if the supplied fieldNames all are existing in this list.

contains(String, boolean) - Method in class com.northconcepts.datapipeline.filter.FieldFilter

Adds a rule requiring the field's value, as a string, to contain the given text; null values fail.

contains(String, Object) - Static method in class com.northconcepts.datapipeline.jsonata.Functions

Tests if the str contains the token

contains(List<String>) - Method in class com.northconcepts.datapipeline.core.FieldList

Returns true if the supplied fieldNames all are existing in this list.

Contains - Class in com.northconcepts.datapipeline.filter.rule

A FieldFilterRule that allows fields whose value, as a string, contains the given text; null values are rejected.

Contains(String) - Constructor for class com.northconcepts.datapipeline.filter.rule.Contains

Creates a case-sensitive rule for the given text.

Contains(String, boolean) - Constructor for class com.northconcepts.datapipeline.filter.rule.Contains

 

containsEntity(String) - Method in class com.northconcepts.datapipeline.foundations.schema.SchemaDef

Returns true if this schema contains an EntityDef with the specified name.

containsEntityRelationship(String) - Method in class com.northconcepts.datapipeline.foundations.schema.SchemaDef

Returns true if this schema contains an EntityRelationshipDef with the specified name.

containsField(FieldList) - Method in class com.northconcepts.datapipeline.core.Record

Returns true if all fields and sub fields in a nested path exists.

containsField(FieldPath) - Method in class com.northconcepts.datapipeline.core.Record

Indicates if this record contains a matching field for the specified path.

containsField(Record) - Method in class com.northconcepts.datapipeline.core.FieldPath

Returns true if this path leads to a field (not an array element) in the record.

containsField(String) - Method in class com.northconcepts.datapipeline.core.Record

Returns true if this record contains a field with the given name.

containsField(String) - Method in class com.northconcepts.datapipeline.foundations.schema.EntityDef

Returns true if this entity contains a FieldDef with the specified name.

containsField(String) - Method in class com.northconcepts.datapipeline.foundations.schema.IndexDef

Returns true if this index contains an IndexFieldDef with the specified name.

containsForeignKeyFieldName(String) - Method in class com.northconcepts.datapipeline.foundations.schema.EntityRelationshipDef

Returns true if the foreign key field names include the given name, ignoring case.

containsIndex(String) - Method in class com.northconcepts.datapipeline.foundations.schema.EntityDef

Returns true if this entity contains an IndexDef with the specified name.

containsInheritedField(String) - Method in class com.northconcepts.datapipeline.foundations.schema.EntityDef

Returns true if this entity or any of its super entities contains a FieldDef with the specified name.

containsInheritedIndex(String) - Method in class com.northconcepts.datapipeline.foundations.schema.EntityDef

Returns true if this entity or any of its super entities contains an IndexDef with the specified name.

containsKey(Object) - Method in class com.northconcepts.datapipeline.jsonata.JsonObject

 

containsKeyImpl(String) - Method in class com.northconcepts.datapipeline.foundations.datamapping.DataMappingExpressionContext

 

containsNonNull(FieldPath) - Method in class com.northconcepts.datapipeline.core.Record

Deprecated.

containsNonNullField(FieldPath) - Method in class com.northconcepts.datapipeline.core.Record

Indicates if this record contains a field at the specified path that is not null.

containsNonNullField(Record) - Method in class com.northconcepts.datapipeline.core.FieldPath

Returns true if this path leads to a field in the record whose value is not null.

containsNonNullField(String) - Method in class com.northconcepts.datapipeline.core.Record

Indicates if this record contains a field at the specified path with a non-null value.

containsNonNullValue(FieldPath) - Method in class com.northconcepts.datapipeline.core.Record

Indicates if this record contains a field or value at the specified path where the value is not null.

containsNonNullValue(Record) - Method in class com.northconcepts.datapipeline.core.FieldPath

Returns true if this path leads to a field or array element in the record whose value is not null.

containsSessionProperty(Class<T>) - Method in class com.northconcepts.datapipeline.core.Node

Returns true if a session property exists for the given type.

containsSessionProperty(Class<T>) - Method in interface com.northconcepts.datapipeline.core.Session

Returns true if a session property exists for the given type.

containsSessionProperty(Class<T>) - Method in class com.northconcepts.datapipeline.core.Session.SessionImpl

 

containsSessionProperty(Class<T>, String) - Method in class com.northconcepts.datapipeline.core.Node

Returns true if a session property exists for the given type and name combination.

containsSessionProperty(Class<T>, String) - Method in interface com.northconcepts.datapipeline.core.Session

Returns true if a session property exists for the given type and name combination.

containsSessionProperty(Class<T>, String) - Method in class com.northconcepts.datapipeline.core.Session.SessionImpl

 

containsSessionProperty(String) - Method in class com.northconcepts.datapipeline.core.Node

Returns true if a session property exists with the given name.

containsSessionProperty(String) - Method in interface com.northconcepts.datapipeline.core.Session

Returns true if a session property exists with the given name.

containsSessionProperty(String) - Method in class com.northconcepts.datapipeline.core.Session.SessionImpl

 

containsTable(String) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.QuerySource

Returns true if this source, a nested source or a join refers to the table (ignoring case).

containsTable(String) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.Select

 

containsTable(String) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.TableQuerySource

 

containsTable(String) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.Union

 

containsValue(FieldPath) - Method in class com.northconcepts.datapipeline.core.Record

Indicates if this record contains a matching field or value for the specified path.

containsValue(Record) - Method in class com.northconcepts.datapipeline.core.FieldPath

Returns true if this path leads to anything in the record (a field or an array element), even if it holds null.

contributeExceptionProperties(DataExceptionContributor...) - Method in exception class com.northconcepts.datapipeline.core.DataException

Adds the properties of each non-null contributor to this exception and returns it.

contributeExceptionProperties(Throwable, DataExceptionContributor...) - Static method in interface com.northconcepts.datapipeline.core.DataExceptionContributor

A utility method to add properties from a list of DataExceptionContributor to the supplied exception.

contributeExceptionProperties(Throwable, String, DataExceptionContributor...) - Static method in interface com.northconcepts.datapipeline.core.DataExceptionContributor

A utility method to add properties from a list of DataExceptionContributor to the supplied exception with the given name prefix.

convert(EntityDef) - Static method in class com.northconcepts.datapipeline.foundations.tools.ConvertSnakeCaseToCamelCase

Converts the entity and super-entity names to UpperCamelCase, along with the entity's fields and indexes, in place.

convert(EntityRelationshipDef) - Static method in class com.northconcepts.datapipeline.foundations.tools.ConvertSnakeCaseToCamelCase

 

convert(FieldDef) - Static method in class com.northconcepts.datapipeline.foundations.tools.ConvertSnakeCaseToCamelCase

Converts the field name to lowerCamelCase, and a record field's referenced entity name to UpperCamelCase, in place.

convert(IndexDef) - Static method in class com.northconcepts.datapipeline.foundations.tools.ConvertSnakeCaseToCamelCase

Converts the index name and its field names to lowerCamelCase, in place.

convert(IndexFieldDef) - Static method in class com.northconcepts.datapipeline.foundations.tools.ConvertSnakeCaseToCamelCase

Converts the indexed field's name to lowerCamelCase, in place.

convert(SchemaDef) - Static method in class com.northconcepts.datapipeline.foundations.tools.ConvertSnakeCaseToCamelCase

Converts the schema name to UpperCamelCase, along with its entities and relationships, in place.

CONVERT - Enum constant in enum class com.northconcepts.datapipeline.foundations.pipeline.action.ActionGroup

 

ConvertDateTimeToStringAction - Class in com.northconcepts.datapipeline.foundations.pipeline.action.convert

A PipelineAction that converts the selected date/time fields to strings, optionally using a SimpleDateFormat pattern.

ConvertDateTimeToStringAction() - Constructor for class com.northconcepts.datapipeline.foundations.pipeline.action.convert.ConvertDateTimeToStringAction

 

convertNulls(Object) - Static method in class com.northconcepts.datapipeline.jsonata.Utils

 

ConvertNullToValueAction - Class in com.northconcepts.datapipeline.foundations.pipeline.action.convert

A PipelineAction that replaces null values in the selected fields with a typed constant or the result of an expression.

ConvertNullToValueAction() - Constructor for class com.northconcepts.datapipeline.foundations.pipeline.action.convert.ConvertNullToValueAction

 

ConvertNullToValueAction.FieldType - Enum Class in com.northconcepts.datapipeline.foundations.pipeline.action.convert

The type a replacement value is converted to, or EXPRESSION to evaluate it; DATETIME, DATE and TIME values use the yyyy-MM-dd HH:mm:ss, yyyy-MM-dd and HH:mm:ss formats.

ConvertNullToValueAction.TypeValue - Class in com.northconcepts.datapipeline.foundations.pipeline.action.convert

A replacement value and the type it is converted to.

convertNumber(Number) - Static method in class com.northconcepts.datapipeline.jsonata.Utils

 

ConvertNumberToStringAction - Class in com.northconcepts.datapipeline.foundations.pipeline.action.convert

A PipelineAction that converts the selected numeric fields to strings, optionally using a DecimalFormat pattern.

ConvertNumberToStringAction() - Constructor for class com.northconcepts.datapipeline.foundations.pipeline.action.convert.ConvertNumberToStringAction

 

ConvertSnakeCaseToCamelCase - Class in com.northconcepts.datapipeline.foundations.tools

Renames schema definitions in place from database-style snake_case names to Java-style camel case.

ConvertSnakeCaseToCamelCase() - Constructor for class com.northconcepts.datapipeline.foundations.tools.ConvertSnakeCaseToCamelCase

 

ConvertStringToBooleanAction - Class in com.northconcepts.datapipeline.foundations.pipeline.action.convert

A PipelineAction that converts the selected string fields to booleans; only "true", ignoring case, becomes true.

ConvertStringToBooleanAction() - Constructor for class com.northconcepts.datapipeline.foundations.pipeline.action.convert.ConvertStringToBooleanAction

 

ConvertStringToDateTimeAction - Class in com.northconcepts.datapipeline.foundations.pipeline.action.convert

A PipelineAction that parses the selected string fields into date-time, date or time values using a SimpleDateFormat pattern.

ConvertStringToDateTimeAction() - Constructor for class com.northconcepts.datapipeline.foundations.pipeline.action.convert.ConvertStringToDateTimeAction

 

ConvertStringToDateTimeAction.FieldType - Enum Class in com.northconcepts.datapipeline.foundations.pipeline.action.convert

The temporal type strings are parsed into: a date-time (java.util.Date), a date (java.sql.Date) or a time (java.sql.Time).

ConvertStringToNumberAction - Class in com.northconcepts.datapipeline.foundations.pipeline.action.convert

A PipelineAction that parses the selected string fields into numbers of the chosen type, optionally using a DecimalFormat pattern.

ConvertStringToNumberAction() - Constructor for class com.northconcepts.datapipeline.foundations.pipeline.action.convert.ConvertStringToNumberAction

 

ConvertStringToNumberAction.FieldType - Enum Class in com.northconcepts.datapipeline.foundations.pipeline.action.convert

The number type strings are parsed into; SHORT, BYTE and FLOAT leave values unconverted when a pattern is set.

ConvertValueToStringAction - Class in com.northconcepts.datapipeline.foundations.pipeline.action.convert

A PipelineAction that converts the values of the selected fields, whatever their type, to strings.

ConvertValueToStringAction() - Constructor for class com.northconcepts.datapipeline.foundations.pipeline.action.convert.ConvertValueToStringAction

 

copy() - Method in class com.northconcepts.datapipeline.security.Credentials

Returns an independent copy of these credentials.

copy(DataReader, DataWriter) - Static method in class com.northconcepts.datapipeline.core.SortingReader

Writes every remaining record from the source to the sink without opening or closing either.

COPY_FIELD - Enum constant in enum class com.northconcepts.datapipeline.xml.XmlReader.DuplicateFieldPolicy

 

COPY_RECORD - Enum constant in enum class com.northconcepts.datapipeline.xml.XmlReader.DuplicateFieldPolicy

 

CopyField - Class in com.northconcepts.datapipeline.transform

Creates a duplicate field with the specified target name.

CopyField(String, String) - Constructor for class com.northconcepts.datapipeline.transform.CopyField

Always overwrites the target field.

CopyField(String, String, boolean) - Constructor for class com.northconcepts.datapipeline.transform.CopyField

Creates a transformer that copies the source field's value into the target field (created if missing) unless the target already exists and overwrite is false.

CopyFieldsAction - Class in com.northconcepts.datapipeline.foundations.pipeline.action.transform

A PipelineAction that copies the values of source fields to target fields.

CopyFieldsAction() - Constructor for class com.northconcepts.datapipeline.foundations.pipeline.action.transform.CopyFieldsAction

 

CopyFieldsAction.FieldMapping - Class in com.northconcepts.datapipeline.foundations.pipeline.action.transform

A copy of one source field to a target field, optionally overwriting an existing target.

copyForm(Property) - Method in class com.northconcepts.datapipeline.foundations.core.Property

Copies the name and value of the given property into this one.

copyFrom(Field) - Method in class com.northconcepts.datapipeline.core.Field

Copies all properties (name, value, and session properties) from the specified field into this one.

copyFrom(FieldComparator) - Method in class com.northconcepts.datapipeline.core.FieldComparator

Copies the field name, sort direction and collator from the given comparator.

copyFrom(Field, boolean) - Method in class com.northconcepts.datapipeline.core.Field

Copies properties from the specified field into this one.

copyFrom(Record) - Method in class com.northconcepts.datapipeline.core.Record

Copy all the fields and child fields from the specified record into this one, creating new unique fields when target fields with the same name already exists (Node.DuplicateNodeAction.APPEND).

copyFrom(Record, boolean) - Method in class com.northconcepts.datapipeline.core.Record

Copy all the fields and child fields from the specified record into this one.

copyFrom(Record, Node.DuplicateNodeAction) - Method in class com.northconcepts.datapipeline.core.Record

Copy all the fields and child fields from the specified record into this one.

copyFrom(Attributes) - Method in class com.northconcepts.datapipeline.foundations.core.Attributes

 

copyFrom(Tags) - Method in class com.northconcepts.datapipeline.foundations.core.Tags

Adds all of the given tags to this set, keeping the existing ones.

copyFrom(RecordLineage) - Method in class com.northconcepts.datapipeline.lineage.FieldLineage

Copies the file, line and column numbers, database URL and query, and record number from the record's lineage, keeping any of these values this field already has.

copySessionPropertiesFrom(Session) - Method in class com.northconcepts.datapipeline.core.Node

Copies all session properties from the given source session into this one.

copySessionPropertiesFrom(Session) - Method in interface com.northconcepts.datapipeline.core.Session

Copies all session properties from the given source session into this one.

copySessionPropertiesFrom(Session) - Method in class com.northconcepts.datapipeline.core.Session.SessionImpl

 

copyToRecord(E, Record, IEntityExpansionPolicy) - Method in class com.northconcepts.datapipeline.twitter.TwitterPageableReader

Populates a new, empty record from one buffered element.

copyToRecord(Long, Record, IEntityExpansionPolicy) - Method in class com.northconcepts.datapipeline.twitter.TwitterFollowerIDsReader

 

copyToRecord(Long, Record, IEntityExpansionPolicy) - Method in class com.northconcepts.datapipeline.twitter.TwitterFollowingIDsReader

 

copyToRecord(UserList, Record, IEntityExpansionPolicy) - Method in class com.northconcepts.datapipeline.twitter.TwitterListOwnershipReader

 

copyToRecord(User, Record, IEntityExpansionPolicy) - Method in class com.northconcepts.datapipeline.twitter.TwitterFollowerListReader

 

copyToRecord(User, Record, IEntityExpansionPolicy) - Method in class com.northconcepts.datapipeline.twitter.TwitterFollowingListReader

 

copyToRecord(User, Record, IEntityExpansionPolicy) - Method in class com.northconcepts.datapipeline.twitter.TwitterListMemberReader

 

CORAL - Enum constant in enum class com.northconcepts.datapipeline.excel.ExcelColorPalette

 

CORNFLOWER_BLUE - Enum constant in enum class com.northconcepts.datapipeline.excel.ExcelColorPalette

 

COULD_NOT_AUTHENTICATE_YOU - Enum constant in enum class com.northconcepts.datapipeline.twitter.TwitterErrorCode

 

COULD_NOT_AUTHENTICATE_YOU_2 - Enum constant in enum class com.northconcepts.datapipeline.twitter.TwitterErrorCode

 

count(FieldPath) - Method in class com.northconcepts.datapipeline.group.GroupByReader

Adds a count of the records in each group, written to the target field.

count(FieldPath, boolean) - Method in class com.northconcepts.datapipeline.group.GroupByReader

 

count(Filter) - Method in class com.northconcepts.datapipeline.core.RecordList

Counts the number of records in this list that pass the specified filter.

count(String) - Method in class com.northconcepts.datapipeline.group.AggregateReader

Deprecated.

Adds an operation counting the records whose field is not null.

count(String) - Method in class com.northconcepts.datapipeline.group.GroupByReader

Adds a count of the records in each group, written to the target field.

count(String, boolean) - Method in class com.northconcepts.datapipeline.group.GroupByReader

 

count(Predicate<ValueNode<?>>) - Method in class com.northconcepts.datapipeline.core.ArrayValue

Returns the number of elements in this array that match the given predicate.

count(List<Object>) - Static method in class com.northconcepts.datapipeline.jsonata.Functions

Count function

COUNT - Enum constant in enum class com.northconcepts.datapipeline.foundations.pipeline.action.aggregate.AggregateGroupFieldsAction.OperatorType

 

create() - Method in class com.northconcepts.datapipeline.jsonata.Parser.Symbol

 

create(long) - Method in class com.northconcepts.datapipeline.parquet.file.ParquetOutputFile

 

CREATE - Enum constant in enum class com.northconcepts.datapipeline.shopify.client.EventVerb

 

CREATE_UNIQUE - Enum constant in enum class com.northconcepts.datapipeline.core.Node.DuplicateNodeAction

Creates a new, unique target field by appending a number to the name.

createColumnsDataReader() - Method in class com.northconcepts.datapipeline.foundations.pipeline.dataset.Dataset

Returns a reader that emits one summary record per column of this dataset (see Dataset.ColumnsDataReader).

createConnection() - Method in class com.northconcepts.datapipeline.foundations.jdbc.JdbcConnection

 

createConnection() - Method in interface com.northconcepts.datapipeline.jdbc.JdbcConnectionFactory

Returns a connection to use; factories from JdbcConnectionFactory.wrap(Connection) return the same connection on every call.

createConsumer(JmsSettings, JmsConnection) - Method in enum class com.northconcepts.datapipeline.jms.JmsDestinationType

Creates the consumer a JmsReader receives messages from; topics use a durable subscriber named by the client ID.

createDataReader() - Method in class com.northconcepts.datapipeline.avro.pipeline.input.AvroPipelineInput

 

createDataReader() - Method in class com.northconcepts.datapipeline.foundations.pipeline.AbstractPipeline

 

createDataReader() - Method in class com.northconcepts.datapipeline.foundations.pipeline.dataset.Dataset

Reads all data cached in this Dataset.

createDataReader() - Method in class com.northconcepts.datapipeline.foundations.pipeline.input.CsvPipelineInput

 

createDataReader() - Method in class com.northconcepts.datapipeline.foundations.pipeline.input.DataReaderPipelineInput

 

createDataReader() - Method in class com.northconcepts.datapipeline.foundations.pipeline.input.DatasetPipelineInput

 

createDataReader() - Method in class com.northconcepts.datapipeline.foundations.pipeline.input.ExcelPipelineInput

 

createDataReader() - Method in class com.northconcepts.datapipeline.foundations.pipeline.input.FixedWidthPipelineInput

 

createDataReader() - Method in class com.northconcepts.datapipeline.foundations.pipeline.input.JdbcPipelineInput

 

createDataReader() - Method in class com.northconcepts.datapipeline.foundations.pipeline.input.JsonRecordPipelineInput

 

createDataReader() - Method in class com.northconcepts.datapipeline.foundations.pipeline.input.XmlPipelineInput

 

createDataReader() - Method in class com.northconcepts.datapipeline.foundations.pipeline.input.XmlRecordPipelineInput

 

createDataReader() - Method in class com.northconcepts.datapipeline.foundations.pipeline.ProxyPipelineInput

 

createDataReader() - Method in interface com.northconcepts.datapipeline.job.DataReaderFactory

 

createDataReader() - Method in class com.northconcepts.datapipeline.openfinancialexchange.pipeline.input.OpenFinancialExchangePipelineInput

 

createDataReader() - Method in class com.northconcepts.datapipeline.orc.input.OrcPipelineInput

 

createDataReader() - Method in class com.northconcepts.datapipeline.parquet.input.ParquetPipelineInput

 

createDataReader() - Method in class com.northconcepts.datapipeline.pdf.input.PdfPipelineInput

 

createDataReader(long, int) - Method in class com.northconcepts.datapipeline.foundations.pipeline.dataset.Dataset

Reads a subset of data cached in this Dataset.

createDataReader(ZipFile, ZipEntry) - Method in interface com.northconcepts.datapipeline.filesystem.zip.ZipDataReaderFactory

 

createDataReaderImpl(InputStream) - Method in class com.northconcepts.datapipeline.foundations.pipeline.input.JsonPipelineInput

 

createDataReaderImpl(InputStream) - Method in class com.northconcepts.datapipeline.foundations.pipeline.input.XmlPipelineInput

Creates the reader for the file's stream; XmlPipelineInput.createDataReader() then applies this input's settings.

createDataset(JdbcDataset.DatabaseProvider, JdbcConnectionFactory, String, AbstractPipeline) - Static method in class com.northconcepts.datapipeline.foundations.pipeline.dataset.JdbcDataset

Creates a persistent dataset stored in a database determined by the provided JdbcDataset.DatabaseProvider.

createDataset(JdbcDataset.DatabaseProvider, JdbcConnectionFactory, String, DataReaderFactory) - Static method in class com.northconcepts.datapipeline.foundations.pipeline.dataset.JdbcDataset

Creates a persistent dataset stored in a database determined by the provided JdbcDataset.DatabaseProvider.

createDataset(File, AbstractPipeline) - Static method in class com.northconcepts.datapipeline.foundations.pipeline.dataset.MvStoreDataset

Creates a persistent dataset on disk in the specified databaseFile.

createDataset(String, String, AbstractPipeline) - Static method in class com.northconcepts.datapipeline.foundations.pipeline.dataset.LocalFileDataset

Creates a persistent dataset on disk in the specified rootFolder directory.

createDataset(String, String, DataReaderFactory) - Static method in class com.northconcepts.datapipeline.foundations.pipeline.dataset.LocalFileDataset

Creates a persistent dataset on disk in the specified rootFolder directory.

createDataWriter() - Method in class com.northconcepts.datapipeline.avro.pipeline.output.AvroPipelineOutput

 

createDataWriter() - Method in class com.northconcepts.datapipeline.foundations.pipeline.AbstractPipeline

 

createDataWriter() - Method in class com.northconcepts.datapipeline.foundations.pipeline.dataset.Dataset

Writes records to this dataset's cache after clearing it.

createDataWriter() - Method in class com.northconcepts.datapipeline.foundations.pipeline.dataset.JdbcDataset

 

createDataWriter() - Method in class com.northconcepts.datapipeline.foundations.pipeline.dataset.LocalFileDataset

 

createDataWriter() - Method in class com.northconcepts.datapipeline.foundations.pipeline.dataset.MemoryDataset

 

createDataWriter() - Method in class com.northconcepts.datapipeline.foundations.pipeline.dataset.MvStoreDataset

 

createDataWriter() - Method in class com.northconcepts.datapipeline.foundations.pipeline.output.CsvPipelineOutput

 

createDataWriter() - Method in class com.northconcepts.datapipeline.foundations.pipeline.output.DataWriterPipelineOutput

 

createDataWriter() - Method in class com.northconcepts.datapipeline.foundations.pipeline.output.ExcelPipelineOutput

 

createDataWriter() - Method in class com.northconcepts.datapipeline.foundations.pipeline.output.FixedWidthPipelineOutput

 

createDataWriter() - Method in class com.northconcepts.datapipeline.foundations.pipeline.output.JdbcPipelineOutput

 

createDataWriter() - Method in class com.northconcepts.datapipeline.foundations.pipeline.output.JsonRecordPipelineOutput

 

createDataWriter() - Method in class com.northconcepts.datapipeline.foundations.pipeline.output.XmlRecordPipelineOutput

 

createDataWriter() - Method in class com.northconcepts.datapipeline.foundations.pipeline.ProxyPipelineOutput

 

createDataWriter() - Method in interface com.northconcepts.datapipeline.job.DataWriterFactory

 

createDataWriter() - Method in class com.northconcepts.datapipeline.latex.output.LatexPipelineOutput

 

createDataWriter() - Method in class com.northconcepts.datapipeline.microsoft.word.output.MicrosoftWordPipelineOutput

 

createDataWriter() - Method in class com.northconcepts.datapipeline.orc.output.OrcPipelineOutput

 

createDataWriter() - Method in class com.northconcepts.datapipeline.parquet.output.ParquetPipelineOutput

 

createDataWriter() - Method in class com.northconcepts.datapipeline.pdf.output.PdfPipelineOutput

 

createDataWriter(SequenceWriter.Sequence, Record) - Method in interface com.northconcepts.datapipeline.core.SequenceWriter.DataWriterFactory

Returns the writer for a new sequence, given the first record it will receive; the SequenceWriter opens and closes it.

createEmptyRecord() - Method in class com.northconcepts.datapipeline.foundations.schema.EntityDef

Creates a record with a typed null (or an empty array for array fields) for each field of this entity and its super entities.

createEntity(Dataset) - Method in class com.northconcepts.datapipeline.foundations.tools.GenerateEntityFromDataset

Returns an entity with a field for each column of the loaded dataset, marking fields required when the column had no null or blank values.

createFactory() - Method in class com.northconcepts.datapipeline.json.JsonRecordReader

Creates the Jackson factory that the File and Reader constructors parse with; the default allows comments, single quotes and unquoted field names.

createField() - Method in class com.northconcepts.datapipeline.group.GroupOperation

Creates the accumulator that computes this operation's result for one group; called once per group in each window.

createField() - Method in class com.northconcepts.datapipeline.group.operation.GroupAverage

 

createField() - Method in class com.northconcepts.datapipeline.group.operation.GroupCollect

 

createField() - Method in class com.northconcepts.datapipeline.group.operation.GroupCount

 

createField() - Method in class com.northconcepts.datapipeline.group.operation.GroupFirst

 

createField() - Method in class com.northconcepts.datapipeline.group.operation.GroupLast

 

createField() - Method in class com.northconcepts.datapipeline.group.operation.GroupMaximum

 

createField() - Method in class com.northconcepts.datapipeline.group.operation.GroupMinimum

 

createField() - Method in class com.northconcepts.datapipeline.group.operation.GroupSum

 

createFieldDef(Column) - Method in class com.northconcepts.datapipeline.foundations.tools.GenerateEntityFromDataset

Returns a field definition typed according to GenerateEntityFromDataset.getFieldTypeSelectionMode(); text fields get a maximum length rounded up to the next multiple of 100.

createFieldName(TreeNode, Set<String>) - Static method in class com.northconcepts.datapipeline.foundations.pipeline.tree.Tree

Builds a normalized field name for the supplied node that is unique within fieldNames (which this method adds it to): wildcard nodes use their name pattern hint or id, collisions gain the parent-name prefix and then a numeric suffix.

CreateForeignKey - Class in com.northconcepts.datapipeline.sql.h2

Generates an ALTER TABLE...ADD CONSTRAINT statement to add a foreign key constraint in H2.

CreateForeignKey - Class in com.northconcepts.datapipeline.sql.mysql

Generates an ALTER TABLE...ADD CONSTRAINT statement to add a foreign key constraint in MySQL.

CreateForeignKey - Class in com.northconcepts.datapipeline.sql.postgresql

Generates an ALTER TABLE...ADD CONSTRAINT statement to add a foreign key constraint in PostgreSQL.

CreateForeignKey() - Constructor for class com.northconcepts.datapipeline.sql.h2.CreateForeignKey

 

CreateForeignKey() - Constructor for class com.northconcepts.datapipeline.sql.mysql.CreateForeignKey

 

CreateForeignKey() - Constructor for class com.northconcepts.datapipeline.sql.postgresql.CreateForeignKey

 

CreateForeignKey(String, String, String) - Constructor for class com.northconcepts.datapipeline.sql.h2.CreateForeignKey

Constructs a CreateForeignKey with the specified constraint, primary table, and foreign table names.

CreateForeignKey(String, String, String) - Constructor for class com.northconcepts.datapipeline.sql.mysql.CreateForeignKey

Creates a foreign key named constraintName on foreignTableName that references primaryTableName.

CreateForeignKey(String, String, String) - Constructor for class com.northconcepts.datapipeline.sql.postgresql.CreateForeignKey

Creates a foreign key named constraintName on foreignTableName that references primaryTableName.

createFrame() - Method in class com.northconcepts.datapipeline.jsonata.Jsonata

Create frame

createFrame(Jsonata.Frame) - Method in class com.northconcepts.datapipeline.jsonata.Jsonata

 

CreateH2DdlFromSchemaDef - Class in com.northconcepts.datapipeline.sql.h2

Generates H2 DDL from SchemaDef

CreateH2DdlFromSchemaDef(SchemaDef) - Constructor for class com.northconcepts.datapipeline.sql.h2.CreateH2DdlFromSchemaDef

 

createHeaderRecord(Record) - Method in class com.northconcepts.datapipeline.core.AbstractWriter

Builds the header row from the first record: a copy whose field values are the field names, without session properties.

CreateIndex - Class in com.northconcepts.datapipeline.sql.h2

Generates a CREATE INDEX statement for H2.

CreateIndex - Class in com.northconcepts.datapipeline.sql.mysql

Generates a CREATE INDEX statement for MySQL.

CreateIndex - Class in com.northconcepts.datapipeline.sql.postgresql

Generates a CREATE INDEX statement for PostgreSQL.

CreateIndex() - Constructor for class com.northconcepts.datapipeline.sql.h2.CreateIndex

 

CreateIndex() - Constructor for class com.northconcepts.datapipeline.sql.mysql.CreateIndex

 

CreateIndex() - Constructor for class com.northconcepts.datapipeline.sql.postgresql.CreateIndex

 

CreateIndex(String, String, String...) - Constructor for class com.northconcepts.datapipeline.sql.h2.CreateIndex

Constructs a CreateIndex with the specified index name, table name, and column names.

CreateIndex(String, String, String...) - Constructor for class com.northconcepts.datapipeline.sql.mysql.CreateIndex

 

CreateIndex(String, String, String...) - Constructor for class com.northconcepts.datapipeline.sql.postgresql.CreateIndex

 

createInputStream() - Method in interface com.northconcepts.datapipeline.io.InputStreamFactory

Returns a newly opened stream; the caller closes it.

createIssue(JiraIssue) - Method in interface com.northconcepts.datapipeline.jira.client.JiraClient

 

createIssue(JiraIssue) - Method in class com.northconcepts.datapipeline.jira.client.JiraService

 

createIssue(String, String, int) - Method in class com.northconcepts.datapipeline.jira.client.JiraService

 

createIssue(String, String, int, Map<String, String>) - Method in class com.northconcepts.datapipeline.jira.client.JiraService

Creates an issue of the given type ID in the project with the given key; a parent entry in optionalFields sets the parent issue's key and the other entries are set as issue fields.

createJdbcUpsertWriter(Connection, String, IUpsert) - Method in class com.northconcepts.datapipeline.jdbc.JdbcMultiUpsertWriter

 

createJdbcWriter(Connection, String, IInsert) - Method in class com.northconcepts.datapipeline.jdbc.JdbcMultiWriter

Creates the writer for a connection obtained in JdbcMultiWriter.open(); the default copies this writer's settings and makes the new writer close the connection.

createJob() - Method in class com.northconcepts.datapipeline.foundations.pipeline.AbstractPipeline

Creates, but does not run, a job that reads the processed input and writes it to the output.

CreateMySqlDdlFromSchemaDef - Class in com.northconcepts.datapipeline.sql.mysql

Generates MySQL DDL from SchemaDef

CreateMySqlDdlFromSchemaDef(SchemaDef) - Constructor for class com.northconcepts.datapipeline.sql.mysql.CreateMySqlDdlFromSchemaDef

 

createOrOverwrite(long) - Method in class com.northconcepts.datapipeline.parquet.file.ParquetOutputFile

 

CreatePostgreSqlDdlFromSchemaDef - Class in com.northconcepts.datapipeline.sql.postgresql

Generates PostgreSQL DDL from SchemaDef

CreatePostgreSqlDdlFromSchemaDef(SchemaDef) - Constructor for class com.northconcepts.datapipeline.sql.postgresql.CreatePostgreSqlDdlFromSchemaDef

 

createProducer(JmsSettings, JmsConnection) - Method in enum class com.northconcepts.datapipeline.jms.JmsDestinationType

Creates the producer a JmsWriter uses to send messages to the connection's destination.

createReader() - Method in class com.northconcepts.datapipeline.multiplex.DeMux

Creates a reader that receives source records according to the strategy; create all readers before running the feeder so none miss records.

createReader() - Method in class com.northconcepts.datapipeline.multiplex.SplitWriter

Creates a reader that receives the written records according to the strategy; create all readers before writing so none miss records.

createRecord() - Method in class com.northconcepts.datapipeline.xml.XmlReader

Starts a new current record with one field per added XmlField, copying the values of cascading fields from the previous record.

createSequence() - Static method in class com.northconcepts.datapipeline.jsonata.Utils

Create an empty sequence to contain query results

createSequence(Object) - Static method in class com.northconcepts.datapipeline.jsonata.Utils

 

createSpreadsheet(String) - Method in class com.northconcepts.datapipeline.google.sheets.GoogleSheetDocument

Creates a new spreadsheet and remembers its id; follow with GoogleSheetDocument.open().

CreateTable - Class in com.northconcepts.datapipeline.sql.h2

Generates a CREATE TABLE statement for H2.

CreateTable - Class in com.northconcepts.datapipeline.sql.mysql

Generates a CREATE TABLE statement for MySQL.

CreateTable - Class in com.northconcepts.datapipeline.sql.postgresql

Generates a CREATE TABLE statement for PostgreSQL.

CreateTable() - Constructor for class com.northconcepts.datapipeline.sql.h2.CreateTable

 

CreateTable() - Constructor for class com.northconcepts.datapipeline.sql.mysql.CreateTable

 

CreateTable() - Constructor for class com.northconcepts.datapipeline.sql.postgresql.CreateTable

 

CreateTable(String) - Constructor for class com.northconcepts.datapipeline.sql.h2.CreateTable

Constructs a CreateTable with the specified table name.

CreateTable(String) - Constructor for class com.northconcepts.datapipeline.sql.mysql.CreateTable

 

CreateTable(String) - Constructor for class com.northconcepts.datapipeline.sql.postgresql.CreateTable

 

CreateTableColumn - Class in com.northconcepts.datapipeline.sql.h2

Generates a column definition for a CREATE TABLE statement for H2.

CreateTableColumn - Class in com.northconcepts.datapipeline.sql.mysql

Generates a column definition for a CREATE TABLE statement for MySQL.

CreateTableColumn - Class in com.northconcepts.datapipeline.sql.postgresql

Generates a column definition for a CREATE TABLE statement for PostgreSQL.

CreateTableColumn() - Constructor for class com.northconcepts.datapipeline.sql.h2.CreateTableColumn

 

CreateTableColumn() - Constructor for class com.northconcepts.datapipeline.sql.mysql.CreateTableColumn

 

CreateTableColumn() - Constructor for class com.northconcepts.datapipeline.sql.postgresql.CreateTableColumn

 

CreateTableColumn(String, TableColumnType) - Constructor for class com.northconcepts.datapipeline.sql.h2.CreateTableColumn

Constructs a CreateTableColumn with the specified column name and type.

CreateTableColumn(String, TableColumnType, Integer) - Constructor for class com.northconcepts.datapipeline.sql.h2.CreateTableColumn

Constructs a CreateTableColumn with the specified column name, type, and length.

CreateTableColumn(String, TableColumnType, Integer, Integer) - Constructor for class com.northconcepts.datapipeline.sql.h2.CreateTableColumn

Constructs a CreateTableColumn with the specified column name, type, length, and scale.

CreateTableColumn(String, TableColumnType) - Constructor for class com.northconcepts.datapipeline.sql.mysql.CreateTableColumn

 

CreateTableColumn(String, TableColumnType, Integer) - Constructor for class com.northconcepts.datapipeline.sql.mysql.CreateTableColumn

 

CreateTableColumn(String, TableColumnType, Integer, Integer) - Constructor for class com.northconcepts.datapipeline.sql.mysql.CreateTableColumn

 

CreateTableColumn(String, TableColumnType) - Constructor for class com.northconcepts.datapipeline.sql.postgresql.CreateTableColumn

 

CreateTableColumn(String, TableColumnType, Integer) - Constructor for class com.northconcepts.datapipeline.sql.postgresql.CreateTableColumn

 

CreateTableColumn(String, TableColumnType, Integer, Integer) - Constructor for class com.northconcepts.datapipeline.sql.postgresql.CreateTableColumn

 

createTableConfig(JdbcTable) - Method in class com.northconcepts.datapipeline.foundations.tools.GenerateTableDaoClasses

Creates the class name, package and file settings used to generate a table's class; override to change them per table.

createTempDataset(AbstractPipeline) - Static method in class com.northconcepts.datapipeline.foundations.pipeline.dataset.MvStoreDataset

Creates a temporary dataset on disk that will be deleted when the dataset is closed or when the JVM exits.

createTempDataset(File, AbstractPipeline) - Static method in class com.northconcepts.datapipeline.foundations.pipeline.dataset.MvStoreDataset

Creates a temporary dataset on disk that will be deleted when the dataset is closed or when the JVM exits.

createTempDataset(String, String, AbstractPipeline) - Static method in class com.northconcepts.datapipeline.foundations.pipeline.dataset.LocalFileDataset

Creates a temporary dataset on disk that will be deleted when the dataset is closed or when the JVM exits.

createTempDataset(String, String, DataReaderFactory) - Static method in class com.northconcepts.datapipeline.foundations.pipeline.dataset.LocalFileDataset

Creates a temporary dataset on disk that will be deleted when the dataset is closed or when the JVM exits.

createUpsert(JdbcUpsertWriter, Record) - Method in interface com.northconcepts.datapipeline.jdbc.upsert.VariableFieldsUpsert.IUpsertFactory

Returns a new strategy for records with the given record's field names (in the same order); the caller prepares it.

createVariable(String) - Method in class com.northconcepts.datapipeline.sourcecode.JavaCodeBuilder

Reserves and returns a unique variable name: the given name if unused, otherwise the name plus the first free suffix from 0 to 99 (throws when all are taken).

CreateWindowStrategy - Class in com.northconcepts.datapipeline.group

Determines when GroupByReader opens a new sliding window.

CreateWindowStrategy() - Constructor for class com.northconcepts.datapipeline.group.CreateWindowStrategy

 

credentials - Variable in class com.northconcepts.datapipeline.google.GoogleApiReader

 

Credentials - Class in com.northconcepts.datapipeline.security

An immutable bundle of resolved secret values keyed by name, with an optional expiry.

CREDENTIALS_EXPIRY_SKEW_MILLISECONDS - Static variable in class com.northconcepts.datapipeline.amazons3.AmazonS3FileSystem

How long before a credentials snapshot's reported expiry the AmazonS3FileSystem.CredentialsResolverBridge re-resolves from the CredentialsResolver.

Credentials.Builder - Class in com.northconcepts.datapipeline.security

Assembles Credentials from key-value pairs and an optional expiry; see Credentials.builder().

CredentialsResolver - Interface in com.northconcepts.datapipeline.security

Resolves Credentials on demand.

CredentialsResolverBridge(AmazonS3FileSystem) - Constructor for class com.northconcepts.datapipeline.amazons3.AmazonS3FileSystem.CredentialsResolverBridge

 

CredentialsResolverRegistry - Class in com.northconcepts.datapipeline.security

A thread-safe mapping of logical ids to CredentialsResolvers, enabling "reference, not secret" late binding: serialized pipelines and sources/sinks carry only a resolver id and are re-wired to the live resolver on load.

CredentialsResolverRegistry() - Constructor for class com.northconcepts.datapipeline.security.CredentialsResolverRegistry

 

credentialValue(Credentials, String, String) - Static method in class com.northconcepts.datapipeline.internal.lang.FileSystem

Returns the value for the given key from the resolved credentials or fallback when the credentials are null or don't contain the key.

CRITICAL - Enum constant in enum class com.northconcepts.datapipeline.core.Message.Level

 

CSV - Enum constant in enum class com.northconcepts.datapipeline.foundations.file.FileType

 

CsvPipelineInput - Class in com.northconcepts.datapipeline.foundations.pipeline.input

Reads a pipeline's source data from a CSV or other delimited FileSource using a CSVReader.

CsvPipelineInput() - Constructor for class com.northconcepts.datapipeline.foundations.pipeline.input.CsvPipelineInput

 

CsvPipelineOutput - Class in com.northconcepts.datapipeline.foundations.pipeline.output

Writes a pipeline's records to a CSV or other delimited FileSink using a CSVWriter.

CsvPipelineOutput() - Constructor for class com.northconcepts.datapipeline.foundations.pipeline.output.CsvPipelineOutput

 

CSVReader - Class in com.northconcepts.datapipeline.csv

Obtains records from a Comma Separated Value (CSV) or delimited stream.

CSVReader(File) - Constructor for class com.northconcepts.datapipeline.csv.CSVReader

 

CSVReader(Reader) - Constructor for class com.northconcepts.datapipeline.csv.CSVReader

 

CSVWriter - Class in com.northconcepts.datapipeline.csv

Writes records to a Comma Separated Value (CSV) stream.

CSVWriter(File) - Constructor for class com.northconcepts.datapipeline.csv.CSVWriter

 

CSVWriter(File, boolean) - Constructor for class com.northconcepts.datapipeline.csv.CSVWriter

 

CSVWriter(Writer) - Constructor for class com.northconcepts.datapipeline.csv.CSVWriter

 

CSVWriter.IValuePolicy - Interface in com.northconcepts.datapipeline.csv

The interface used by null and empty string writers.

CSVWriter.ValuePolicy - Enum Class in com.northconcepts.datapipeline.csv

The default implementation used to write null and empty string.

currentRecord - Variable in class com.northconcepts.datapipeline.core.AbstractReader

 

currentRecord - Variable in class com.northconcepts.datapipeline.core.AbstractWriter

 

currentRecord - Variable in class com.northconcepts.datapipeline.jdbc.JdbcReader

 

currentRecord - Variable in class com.northconcepts.datapipeline.jdbc.JdbcUpsertWriter

 

currentRecord - Variable in class com.northconcepts.datapipeline.jdbc.JdbcWriter

 

currentRecord - Variable in class com.northconcepts.datapipeline.xml.XmlReader

 

cyclicDependency(String, String) - Static method in class com.northconcepts.datapipeline.foundations.i18n.SchemaMessages