Skip navigation links
A B C D E F G H I J K L M N O P Q R S T U V W X 

A

AbstractFieldMapping - Class in com.northconcepts.datapipeline.foundations.datamapping
 
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 extends DataReader,W extends DataWriter> - 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
 
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
 
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.
 
accessToken - Variable in class com.northconcepts.datapipeline.twitter.TwitterProvider
 
accessToken - Variable in class com.northconcepts.datapipeline.twitter.TwitterStreamProvider
 
accessTokenSecret - Variable in class com.northconcepts.datapipeline.twitter.TwitterProvider
 
accessTokenSecret - Variable in class com.northconcepts.datapipeline.twitter.TwitterStreamProvider
 
ActionGroup - Enum in com.northconcepts.datapipeline.foundations.pipeline.action
 
add(Record) - Method in class com.northconcepts.datapipeline.buffer.RecordBuffer
 
add(DataReader...) - Method in class com.northconcepts.datapipeline.core.AsyncMultiReader
 
add(Record...) - Method in class com.northconcepts.datapipeline.core.ConcurrentRecordList
 
add(int, Record) - Method in class com.northconcepts.datapipeline.core.ConcurrentRecordList
 
add(DataEndpoint...) - Method in class com.northconcepts.datapipeline.core.DataEndpointGroup
 
add(String...) - Method in class com.northconcepts.datapipeline.core.FieldList
 
add(Collection<String>) - Method in class com.northconcepts.datapipeline.core.FieldList
 
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, 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(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(DataWriter...) - Method in class com.northconcepts.datapipeline.core.MultiWriter
 
add(String) - Method in class com.northconcepts.datapipeline.core.RecordComparator
 
add(String, boolean) - Method in class com.northconcepts.datapipeline.core.RecordComparator
 
add(String, boolean, Collator) - Method in class com.northconcepts.datapipeline.core.RecordComparator
 
add(Record...) - Method in class com.northconcepts.datapipeline.core.RecordList
 
add(int, Record) - Method in class com.northconcepts.datapipeline.core.RecordList
 
add(DataReader) - Method in class com.northconcepts.datapipeline.core.SequenceReader
 
add(String) - Method in class com.northconcepts.datapipeline.core.SortingReader
 
add(String, boolean) - Method in class com.northconcepts.datapipeline.core.SortingReader
 
add(String, boolean, Collator) - Method in class com.northconcepts.datapipeline.core.SortingReader
 
add(Filter...) - Method in class com.northconcepts.datapipeline.filter.FilteringReader
 
add(FieldFilterRule...) - Method in class com.northconcepts.datapipeline.filter.rule.OrRule
 
add(String...) - Method in class com.northconcepts.datapipeline.filter.rule.PatternMatch
 
add(String, int) - Method in class com.northconcepts.datapipeline.filter.rule.PatternMatch
 
add(T...) - Method in class com.northconcepts.datapipeline.filter.rule.ValueMatch
 
add(DataReader, String) - Method in class com.northconcepts.datapipeline.filter.rule.ValueMatch
 
add(AggregateGroupFieldsAction.GroupByField) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.aggregate.AggregateGroupFieldsAction
 
add(String...) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.convert.ConvertDateTimeToStringAction
 
add(String, ConvertNullToValueAction.FieldType, String) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.convert.ConvertNullToValueAction
 
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, String...) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.filter.FilterFieldMatchesPatternAction
 
add(String...) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.filter.FilterFieldNotNullAction
 
add(String, AddFieldsAction.FieldType, String) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.transform.AddFieldsAction
 
add(String, String) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.transform.CopyFieldsAction
 
add(String, String, boolean) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.transform.CopyFieldsAction
 
add(CopyFieldsAction.FieldMapping) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.transform.CopyFieldsAction
 
add(String, String) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.transform.RenameFieldsAction
 
add(String...) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.transform.SelectArrangeFieldsAction
 
add(String, String) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.transform.SortFieldsAction
 
add(String) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.validate.ValidateFieldsExistsAction
 
add(String, String) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.validate.ValidateFieldsMatchPatternAction
 
add(String) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.validate.ValidateFieldsNotNullAction
 
add(AggregateReader.AggregateOperation...) - Method in class com.northconcepts.datapipeline.group.AggregateReader
Deprecated.
 
add(GroupOperation<?>) - Method in class com.northconcepts.datapipeline.group.GroupByReader
 
add(Record) - Method in class com.northconcepts.datapipeline.group.Window
 
add(String, Object) - Method in class com.northconcepts.datapipeline.jdbc.sql.insert.Insert
 
add(String...) - Method in class com.northconcepts.datapipeline.jdbc.sql.insert.Insert
 
add(String, Object) - Method in class com.northconcepts.datapipeline.jdbc.sql.insert.InsertRow
 
add(String...) - Method in class com.northconcepts.datapipeline.jdbc.sql.insert.InsertRow
 
add(String, Object...) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.AndPart
 
add(QueryCriteriaPart) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.AndPart
 
add(String, Object...) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.ConjunctivePart
 
add(QueryCriteriaPart) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.ConjunctivePart
 
add(String, Object...) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.OrPart
 
add(QueryCriteriaPart) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.OrPart
 
add(String, Object...) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.QueryCriteriaPart
 
add(QueryCriteriaPart) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.QueryCriteriaPart
 
add(String...) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.QueryGrouping
 
add(String...) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.QueryOrder
 
add(String, boolean) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.QueryOrder
 
add(String...) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.QuerySelection
 
add(T) - Method in class com.northconcepts.datapipeline.json.builder.JsonNode
 
add() - Method in class com.northconcepts.datapipeline.meter.Meter
 
add(long) - Method in class com.northconcepts.datapipeline.meter.Meter
 
add(Record) - Method in class com.northconcepts.datapipeline.meter.RecordMeter
 
add(BasicFieldTransformer.Operation...) - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer
 
add(Object, Object) - Method in class com.northconcepts.datapipeline.transform.lookup.BasicLookup
 
add(Object, Object[]) - Method in class com.northconcepts.datapipeline.transform.lookup.BasicLookup
 
add(Object[], Object) - Method in class com.northconcepts.datapipeline.transform.lookup.BasicLookup
 
add(Object[], Object[]) - Method in class com.northconcepts.datapipeline.transform.lookup.BasicLookup
 
add(Collection<String>) - Method in class com.northconcepts.datapipeline.transform.RemoveFields
 
add(String...) - Method in class com.northconcepts.datapipeline.transform.RemoveFields
 
add(Collection<String>) - Method in class com.northconcepts.datapipeline.transform.SelectFields
 
add(String...) - Method in class com.northconcepts.datapipeline.transform.SelectFields
 
add(Transformer...) - Method in class com.northconcepts.datapipeline.transform.TransformingReader
 
add(Transformer...) - Method in class com.northconcepts.datapipeline.transform.TransformingWriter
 
add(T) - Method in class com.northconcepts.datapipeline.xml.builder.XmlNodeContainer
 
addAction(PipelineAction) - Method in enum com.northconcepts.datapipeline.foundations.pipeline.action.ActionGroup
 
addAction(PipelineAction) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.CompositePipelineAction
 
addAction(Integer, PipelineAction) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.CompositePipelineAction
 
addAction(PipelineAction) - Method in class com.northconcepts.datapipeline.foundations.pipeline.Pipeline
 
addAction(Integer, PipelineAction) - Method in class com.northconcepts.datapipeline.foundations.pipeline.Pipeline
 
addAll(ArrayValue) - Method in class com.northconcepts.datapipeline.core.ArrayValue
 
addAll(DataReader) - Method in class com.northconcepts.datapipeline.core.ConcurrentRecordList
 
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(RecordList) - Method in class com.northconcepts.datapipeline.core.RecordList
 
addAll(Collection<Record>) - Method in class com.northconcepts.datapipeline.core.RecordList
 
addAll(DataReader) - Method in class com.northconcepts.datapipeline.core.RecordList
 
addBatch() - Method in interface com.northconcepts.datapipeline.jdbc.insert.IInsert
 
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
 
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(String) - Method in class com.northconcepts.datapipeline.foundations.pipeline.dataset.TreeNode
 
addChild(int, String) - Method in class com.northconcepts.datapipeline.foundations.pipeline.dataset.TreeNode
 
addColumn(JdbcQueryColumn) - Method in class com.northconcepts.datapipeline.foundations.jdbc.JdbcQuery
 
addColumn(JdbcTableColumn) - Method in class com.northconcepts.datapipeline.foundations.jdbc.JdbcTable
 
addCondition(LogicalExpression) - Method in class com.northconcepts.datapipeline.foundations.datamapping.DataMapping
 
addCondition(Collection<LogicalExpression>) - Method in class com.northconcepts.datapipeline.foundations.datamapping.DataMapping
 
addCondition(DecisionTableCondition) - Method in class com.northconcepts.datapipeline.foundations.decisiontable.DecisionTableRule
 
addCondition(Collection<DecisionTableCondition>) - Method in class com.northconcepts.datapipeline.foundations.decisiontable.DecisionTableRule
 
addCondition(String, String) - Method in class com.northconcepts.datapipeline.foundations.decisiontable.DecisionTableRule
 
addDateRange(String, String) - Method in class com.northconcepts.datapipeline.google.analytics.GoogleAnalyticsReportReader
 
addDebug(String, boolean) - Method in class com.northconcepts.datapipeline.core.Messages
 
addDebug(String, Throwable) - Method in class com.northconcepts.datapipeline.core.Messages
 
addDimension(String) - Method in class com.northconcepts.datapipeline.google.analytics.GoogleAnalyticsReportReader
 
addElapsedtime(long) - Method in class com.northconcepts.datapipeline.core.Endpoint
 
addEntity(EntityDef) - Method in class com.northconcepts.datapipeline.foundations.schema.SchemaDef
 
addEventBusLifecycleListener(EventBusLifecycleListener) - Static method in class com.northconcepts.datapipeline.eventbus.EventBus
 
addExceptionListener(ExceptionListener) - Method in class com.northconcepts.datapipeline.eventbus.EventBus
 
addExceptionListener(EventFilter, ExceptionListener) - Method in class com.northconcepts.datapipeline.eventbus.EventBus
 
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.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 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.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.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
 
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.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.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
 
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.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
 
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.mailchimp.MailChimpListMemberReader
 
addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.memory.TailProxyReader
 
addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.meter.Meter
 
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.mongodb.MongoReader
 
addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.mongodb.MongoWriter
 
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.retry.RetryingReader
 
addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.retry.RetryingWriter
 
addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.throttle.Throttle
 
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
 
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
 
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
 
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
 
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
 
addExceptionPropertiesImpl(DataException) - Method in class com.northconcepts.datapipeline.core.AsyncReader
 
addExceptionPropertiesImpl(DataException) - Method in class com.northconcepts.datapipeline.core.AsyncWriter
 
addExportedKey(JdbcExportedKey) - Method in class com.northconcepts.datapipeline.foundations.jdbc.JdbcTable
 
addField(String) - Method in class com.northconcepts.datapipeline.bloomberg.BloombergMessageFields
 
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, Object) - Method in class com.northconcepts.datapipeline.core.Record
Adds a new field with the specified value to this record.
addField() - Method in class com.northconcepts.datapipeline.core.Record
 
addField(String, int) - Method in class com.northconcepts.datapipeline.fixedwidth.FixedWidthReader
 
addField(String, int, FixedWidthAlign, char) - Method in class com.northconcepts.datapipeline.fixedwidth.FixedWidthReader
 
addField(int, FixedWidthAlign, char) - Method in class com.northconcepts.datapipeline.fixedwidth.FixedWidthWriter
 
addField(CalculatedField) - Method in class com.northconcepts.datapipeline.foundations.decisiontable.DecisionTable
 
addField(String, String) - Method in class com.northconcepts.datapipeline.foundations.decisiontable.DecisionTable
 
addField(Collection<CalculatedField>) - Method in class com.northconcepts.datapipeline.foundations.decisiontable.DecisionTable
 
addField(Collection<CalculatedField>) - Method in class com.northconcepts.datapipeline.foundations.decisiontree.DecisionTree
 
addField(String, String) - Method in class com.northconcepts.datapipeline.foundations.decisiontree.DecisionTree
 
addField(CalculatedField) - Method in class com.northconcepts.datapipeline.foundations.decisiontree.DecisionTree
 
addField(Field) - Method in class com.northconcepts.datapipeline.foundations.pipeline.dataset.Column
 
addField(XmlField) - Method in class com.northconcepts.datapipeline.foundations.pipeline.input.JsonPipelineInput
 
addField(String, String) - Method in class com.northconcepts.datapipeline.foundations.pipeline.input.JsonPipelineInput
 
addField(String, String, boolean) - Method in class com.northconcepts.datapipeline.foundations.pipeline.input.JsonPipelineInput
 
addField(String, String, String) - Method in class com.northconcepts.datapipeline.foundations.pipeline.input.JsonPipelineInput
 
addField(XmlField) - Method in class com.northconcepts.datapipeline.foundations.pipeline.input.XmlPipelineInput
 
addField(String, String) - Method in class com.northconcepts.datapipeline.foundations.pipeline.input.XmlPipelineInput
 
addField(String, String, boolean) - Method in class com.northconcepts.datapipeline.foundations.pipeline.input.XmlPipelineInput
 
addField(String, String, String) - Method in class com.northconcepts.datapipeline.foundations.pipeline.input.XmlPipelineInput
 
addField(FieldDef) - Method in class com.northconcepts.datapipeline.foundations.schema.EntityDef
 
addField(XmlField) - Method in class com.northconcepts.datapipeline.xml.XmlReader
 
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.xml.XmlReader
Identifies a new field using XPath in the XML stream.
addField(String, String) - Method in class com.northconcepts.datapipeline.xml.XmlReader
Identifies a new field using XPath in the XML stream.
addFieldMapping(IFieldMapping) - Method in class com.northconcepts.datapipeline.foundations.datamapping.DataMapping
 
addFieldMapping(Collection<IFieldMapping>) - Method in class com.northconcepts.datapipeline.foundations.datamapping.DataMapping
 
addFieldMapping(String, String) - Method in class com.northconcepts.datapipeline.foundations.datamapping.DataMapping
 
addFields(int...) - Method in class com.northconcepts.datapipeline.fixedwidth.FixedWidthReader
 
addFields(int...) - Method in class com.northconcepts.datapipeline.fixedwidth.FixedWidthWriter
 
AddFieldsAction - Class in com.northconcepts.datapipeline.foundations.pipeline.action.transform
 
AddFieldsAction() - Constructor for class com.northconcepts.datapipeline.foundations.pipeline.action.transform.AddFieldsAction
 
AddFieldsAction.FieldType - Enum in com.northconcepts.datapipeline.foundations.pipeline.action.transform
 
AddFieldsAction.TypeValue - Class in com.northconcepts.datapipeline.foundations.pipeline.action.transform
 
addFieldValue(Field, Object) - Method in class com.northconcepts.datapipeline.xml.XmlReader
 
addFirst(String, Object...) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.AndPart
 
addFirst(QueryCriteriaPart) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.AndPart
 
addFirst(String, Object...) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.ConjunctivePart
 
addFirst(QueryCriteriaPart) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.ConjunctivePart
 
addFirst(String, Object...) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.OrPart
 
addFirst(QueryCriteriaPart) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.OrPart
 
addFirst(String, Object...) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.QueryCriteriaPart
 
addFirst(QueryCriteriaPart) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.QueryCriteriaPart
 
addImport(JavaCodeBuilder, AddFieldsAction.TypeValue) - Method in enum com.northconcepts.datapipeline.foundations.pipeline.action.transform.AddFieldsAction.FieldType
 
addImport(String) - Method in class com.northconcepts.datapipeline.foundations.sourcecode.JavaCodeBuilder
 
addImport(Class<?>) - Method in class com.northconcepts.datapipeline.foundations.sourcecode.JavaCodeBuilder
 
addImportedKey(JdbcImportedKey) - Method in class com.northconcepts.datapipeline.foundations.jdbc.JdbcTable
 
addInsertValue(String, Object, boolean) - Method in class com.northconcepts.datapipeline.jdbc.sql.merge.Merge
 
addInsertValues(String...) - Method in class com.northconcepts.datapipeline.jdbc.sql.merge.Merge
 
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
 
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(Class<T>, T) - Method in class com.northconcepts.datapipeline.eventbus.EventBus
 
addListener(Class<T>, EventFilter, T) - Method in class com.northconcepts.datapipeline.eventbus.EventBus
 
addListener(Class<T>, EventFilter, T, Object) - Method in class com.northconcepts.datapipeline.eventbus.EventBus
 
addListener(UntypedEventListener) - Method in class com.northconcepts.datapipeline.eventbus.EventBus
addListener(EventFilter, UntypedEventListener) - Method in class com.northconcepts.datapipeline.eventbus.EventBus
addListener(EventFilter, UntypedEventListener, Object) - Method in class com.northconcepts.datapipeline.eventbus.EventBus
addListMember(String, ListMember) - Method in interface com.northconcepts.datapipeline.mailchimp.MailChimpClient
 
addMessage(Message) - Method in class com.northconcepts.datapipeline.core.Messages
 
addMessageHeader(Message, Record) - Method in class com.northconcepts.datapipeline.jms.JmsReader
 
addMetric(String) - Method in class com.northconcepts.datapipeline.google.analytics.GoogleAnalyticsReportReader
 
addMetric(String, String) - Method in class com.northconcepts.datapipeline.google.analytics.GoogleAnalyticsReportReader
 
addNode(DecisionTreeNode) - Method in class com.northconcepts.datapipeline.foundations.decisiontree.DecisionTreeNode
 
addNode(Collection<DecisionTreeNode>) - Method in class com.northconcepts.datapipeline.foundations.decisiontree.DecisionTreeNode
 
addNotRule(FieldFilterRule) - Method in class com.northconcepts.datapipeline.filter.FieldFilter
 
addNull(FieldType) - Method in class com.northconcepts.datapipeline.core.ArrayValue
 
addNull(int, FieldType) - Method in class com.northconcepts.datapipeline.core.ArrayValue
 
addNull(FieldType) - Method in class com.northconcepts.datapipeline.core.Field
 
addNull(FieldType) - Method in interface com.northconcepts.datapipeline.core.ValueNodeContainer
 
addOrUpdateListMember(String, String, ListMember) - Method in interface com.northconcepts.datapipeline.mailchimp.MailChimpClient
 
addOutcome(DecisionTableOutcome) - Method in class com.northconcepts.datapipeline.foundations.decisiontable.DecisionTableRule
 
addOutcome(Collection<DecisionTableOutcome>) - Method in class com.northconcepts.datapipeline.foundations.decisiontable.DecisionTableRule
 
addOutcome(String, String) - Method in class com.northconcepts.datapipeline.foundations.decisiontable.DecisionTableRule
 
addOutcome(Collection<DecisionTreeOutcome>) - Method in class com.northconcepts.datapipeline.foundations.decisiontree.DecisionTreeNode
 
addOutcome(String, String) - Method in class com.northconcepts.datapipeline.foundations.decisiontree.DecisionTreeNode
 
addOutcome(DecisionTreeOutcome) - Method in class com.northconcepts.datapipeline.foundations.decisiontree.DecisionTreeNode
 
addPageToBuffer(IDs, LinkedList<Long>) - Method in class com.northconcepts.datapipeline.twitter.TwitterFollowerIDsReader
 
addPageToBuffer(<any>, LinkedList<User>) - Method in class com.northconcepts.datapipeline.twitter.TwitterFollowerListReader
 
addPageToBuffer(IDs, LinkedList<Long>) - Method in class com.northconcepts.datapipeline.twitter.TwitterFollowingIDsReader
 
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
 
addProperty(String, String) - Method in class com.northconcepts.datapipeline.bloomberg.BloombergMessageFooter
 
addProperty(String, String) - Method in class com.northconcepts.datapipeline.bloomberg.BloombergMessageHeader
 
addProperty(Property) - Method in class com.northconcepts.datapipeline.foundations.jdbc.JdbcConnection
 
addQuery(JdbcQuery) - Method in class com.northconcepts.datapipeline.foundations.jdbc.JdbcConnection
 
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
 
addRecordBreak(String) - Method in class com.northconcepts.datapipeline.foundations.pipeline.input.XmlPipelineInput
 
addRecordBreak(String) - Method in class com.northconcepts.datapipeline.foundations.pipeline.input.XmlRecordPipelineInput
 
addRecordBreak(String) - Method in class com.northconcepts.datapipeline.json.JsonRecordReader
 
addRecordBreak(String) - Method in class com.northconcepts.datapipeline.xml.XmlReader
 
addRecordBreak(String) - Method in class com.northconcepts.datapipeline.xml.XmlRecordReader
 
addRows(int, boolean) - Method in class com.northconcepts.datapipeline.jdbc.sql.insert.Insert
 
addRule(FieldFilterRule...) - Method in class com.northconcepts.datapipeline.filter.FieldFilter
 
addRule(DecisionTableRule) - Method in class com.northconcepts.datapipeline.foundations.decisiontable.DecisionTable
 
addRule(Collection<DecisionTableRule>) - Method in class com.northconcepts.datapipeline.foundations.decisiontable.DecisionTable
 
addRule(String, String) - Method in class com.northconcepts.datapipeline.twitter2.TwitterFilterStreamReader
Adds a filter rule to be used for streaming Tweets.
addShutdownListener(EventFilter, ShutdownListener) - Method in class com.northconcepts.datapipeline.eventbus.EventBus
 
addTable(JdbcTable) - Method in class com.northconcepts.datapipeline.foundations.jdbc.JdbcConnection
 
addToPath(DecisionTreeNode) - Method in class com.northconcepts.datapipeline.foundations.decisiontree.DecisionTreeResult
 
addUntypedEventListener(UntypedEventListener) - Method in class com.northconcepts.datapipeline.eventbus.EventBus
 
addUntypedEventListener(EventFilter, UntypedEventListener) - Method in class com.northconcepts.datapipeline.eventbus.EventBus
 
addUntypedEventListener(EventFilter, UntypedEventListener, Object) - Method in class com.northconcepts.datapipeline.eventbus.EventBus
 
addUpdateValue(String, Object, boolean) - Method in class com.northconcepts.datapipeline.jdbc.sql.merge.Merge
 
addUpdateValue(String) - Method in class com.northconcepts.datapipeline.jdbc.sql.merge.Merge
 
addValidation(Filter) - Method in class com.northconcepts.datapipeline.foundations.schema.EntityDef
 
addValue(FieldType, Object) - Method in class com.northconcepts.datapipeline.core.ArrayValue
 
addValue(Object) - Method in class com.northconcepts.datapipeline.core.ArrayValue
 
addValue(int, FieldType, Object) - Method in class com.northconcepts.datapipeline.core.ArrayValue
 
addValue(int, Object) - Method in class com.northconcepts.datapipeline.core.ArrayValue
 
addValue(FieldType, Object) - Method in class com.northconcepts.datapipeline.core.Field
 
addValue(Object) - Method in class com.northconcepts.datapipeline.core.Field
 
addValue(FieldType, Object) - Method in interface com.northconcepts.datapipeline.core.ValueNodeContainer
 
addValue(Object) - Method in interface com.northconcepts.datapipeline.core.ValueNodeContainer
 
addValue(Object) - Method in class com.northconcepts.datapipeline.foundations.pipeline.dataset.Column
 
addValue(Object) - Method in class com.northconcepts.datapipeline.jdbc.sql.merge.Merge
 
addValue(long, Object) - Method in class com.northconcepts.datapipeline.xml.XmlField
 
addWarning(String, boolean) - Method in class com.northconcepts.datapipeline.core.Messages
 
addWarning(String, Throwable) - Method in class com.northconcepts.datapipeline.core.Messages
 
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.dataset.TreeNode
 
AggregateGroupFieldsAction - Class in com.northconcepts.datapipeline.foundations.pipeline.action.aggregate
 
AggregateGroupFieldsAction() - Constructor for class com.northconcepts.datapipeline.foundations.pipeline.action.aggregate.AggregateGroupFieldsAction
 
AggregateGroupFieldsAction.GroupByField - Class in com.northconcepts.datapipeline.foundations.pipeline.action.aggregate
 
AggregateGroupFieldsAction.OperatorType - Enum in com.northconcepts.datapipeline.foundations.pipeline.action.aggregate
 
AggregateOperation(String, String) - Constructor for class com.northconcepts.datapipeline.group.AggregateReader.AggregateOperation
Deprecated.
 
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.
 
ALL_MAIL - Static variable in interface com.northconcepts.datapipeline.email.GmailFolders
 
allow(Event<?>, Object) - Method in interface com.northconcepts.datapipeline.eventbus.EventFilter
 
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
 
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(Field) - Method in class com.northconcepts.datapipeline.filter.FieldFilterRule
 
allow(Record) - Method in class com.northconcepts.datapipeline.filter.FieldNotExists
 
allow(Record) - Method in class com.northconcepts.datapipeline.filter.Filter
 
allow(Record) - Method in class com.northconcepts.datapipeline.filter.FilterExpression
 
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.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.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.foundations.schema.SchemaFilter
 
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.
and(BufferStrategy...) - Static method in class com.northconcepts.datapipeline.buffer.BufferStrategy
Closes buffers if all of the supplied strategies request it.
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(boolean, QueryCriteriaPart) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.QueryCriteria
 
and(QueryCriteriaPart) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.QueryCriteria
 
and(String, Object...) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.QueryCriteria
 
and(boolean, String, Object...) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.QueryCriteria
 
AndFilter - Class in com.northconcepts.datapipeline.eventbus.filter
Matches all filers -- filer A && filer B && filer C.
AndFilter(EventFilter...) - Constructor for class com.northconcepts.datapipeline.eventbus.filter.AndFilter
 
AndPart - Class in com.northconcepts.datapipeline.jdbc.sql.select
 
AndPart() - Constructor for class com.northconcepts.datapipeline.jdbc.sql.select.AndPart
 
ApiLimitPolicy - Enum in com.northconcepts.datapipeline.twitter
Indicates the action to take when the Twitter API call limits are reached.
append(String) - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer
 
apply(DataReader) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.aggregate.AggregateGroupFieldsAction
 
apply(GroupByReader, AggregateGroupFieldsAction.GroupByField) - Method in enum com.northconcepts.datapipeline.foundations.pipeline.action.aggregate.AggregateGroupFieldsAction.OperatorType
 
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(BasicFieldTransformer, String) - Method in enum com.northconcepts.datapipeline.foundations.pipeline.action.convert.ConvertNullToValueAction.FieldType
 
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
 
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(TransformingReader, String, String) - Method in enum com.northconcepts.datapipeline.foundations.pipeline.action.transform.AddFieldsAction.FieldType
 
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.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(Record, Field) - Method in class com.northconcepts.datapipeline.group.GroupOperationField
 
apply(Field) - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer.Operation
 
apply(Field) - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer.SingleValueOperation
 
apply(double) - Method in class com.northconcepts.datapipeline.transform.format.Rounder
 
apply(BigDecimal) - Method in class com.northconcepts.datapipeline.transform.format.Rounder
 
apply(BigInteger) - Method in class com.northconcepts.datapipeline.transform.format.Rounder
 
applyCode(CodeWriter, String) - Method in enum com.northconcepts.datapipeline.foundations.pipeline.action.convert.ConvertStringToDateTimeAction.FieldType
 
applyCode(CodeWriter, String) - Method in enum com.northconcepts.datapipeline.foundations.pipeline.action.convert.ConvertStringToNumberAction.FieldType
 
applyCodeChain(CodeWriter, String) - Method in enum com.northconcepts.datapipeline.foundations.pipeline.action.convert.ConvertStringToDateTimeAction.FieldType
 
applyCodeChain(CodeWriter, String) - Method in enum com.northconcepts.datapipeline.foundations.pipeline.action.convert.ConvertStringToNumberAction.FieldType
 
applyDataProcessing(DataReader) - Method in class com.northconcepts.datapipeline.foundations.pipeline.AbstractPipeline
 
applyDataProcessingImpl(DataReader) - Method in class com.northconcepts.datapipeline.foundations.pipeline.AbstractPipeline
 
applyDataProcessingImpl(DataReader) - Method in class com.northconcepts.datapipeline.foundations.pipeline.DataMappingPipeline
 
applyDataProcessingImpl(DataReader) - Method in class com.northconcepts.datapipeline.foundations.pipeline.Pipeline
 
applyImpl(SingleValue) - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer.SingleValueOperation
 
applyImpl(SingleValue) - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer.StringOperation
 
applyImpl(String) - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer.StringOperation
 
applyMethod(BasicFieldTransformer, String) - Method in enum com.northconcepts.datapipeline.foundations.pipeline.action.convert.ConvertStringToDateTimeAction.FieldType
 
applyMethod(BasicFieldTransformer, String) - Method in enum com.northconcepts.datapipeline.foundations.pipeline.action.convert.ConvertStringToNumberAction.FieldType
 
applySourceEntityTransformer(DataReader) - Method in class com.northconcepts.datapipeline.foundations.pipeline.AbstractPipeline
 
applyTargetEntityTransformer(DataReader) - Method in class com.northconcepts.datapipeline.foundations.pipeline.AbstractPipeline
 
applyToArrayValue(ArrayValue, int, SingleValue) - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer.SingleValueOperation
 
applyToFieldValue(Field, SingleValue) - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer.SingleValueOperation
 
applyToNullArray(ArrayValue) - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer.SingleValueOperation
 
applyToNulls - Variable in class com.northconcepts.datapipeline.transform.BasicFieldTransformer.SingleValueOperation
 
array() - Method in class com.northconcepts.datapipeline.json.builder.JsonArray
 
array(String) - Method in class com.northconcepts.datapipeline.json.builder.JsonConditionalNode
 
array() - Method in class com.northconcepts.datapipeline.json.builder.JsonConditionalNode
 
array(String) - Method in class com.northconcepts.datapipeline.json.builder.JsonDetailMarker
 
array() - Method in class com.northconcepts.datapipeline.json.builder.JsonDetailMarker
 
array() - Method in class com.northconcepts.datapipeline.json.builder.JsonNode
 
array(String) - Method in class com.northconcepts.datapipeline.json.builder.JsonNode
 
array(String) - Method in class com.northconcepts.datapipeline.json.builder.JsonObject
 
array() - Method in class com.northconcepts.datapipeline.json.builder.JsonTemplate
 
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
 
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
 
asArray(FieldType, Object) - Static method in class com.northconcepts.datapipeline.core.ValueNode
 
asc(String) - Method in class com.northconcepts.datapipeline.core.SortingReader
 
assembleLine(Record, StringBuilder) - Method in class com.northconcepts.datapipeline.core.LinedTextWriter
 
assembleLine(Record, StringBuilder) - Method in class com.northconcepts.datapipeline.csv.CSVWriter
 
assembleLine(Record, StringBuilder) - Method in class com.northconcepts.datapipeline.fixedwidth.FixedWidthWriter
 
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.
assertNotAncestorOf(Node) - Method in class com.northconcepts.datapipeline.core.Node
 
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
 
assertValid() - Method in class com.northconcepts.datapipeline.foundations.core.FoundationObject
 
assertValid(Collection<? extends FoundationObject>) - Method in class com.northconcepts.datapipeline.foundations.core.FoundationObject
 
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
 
ASTNode - Interface in com.northconcepts.datapipeline.expression
The public API for a node in the expression language's abstract syntax tree.
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
 
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
 
AsyncWriter - Class in com.northconcepts.datapipeline.core
A proxy that writes data asynchronously using a separate thread.
AsyncWriter(DataWriter, int) - Constructor for class com.northconcepts.datapipeline.core.AsyncWriter
 
AsyncWriter(DataWriter) - Constructor for class com.northconcepts.datapipeline.core.AsyncWriter
 
attribute(String, String) - Method in class com.northconcepts.datapipeline.xml.builder.XmlElement
 
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.
 
avg(String, String) - Method in class com.northconcepts.datapipeline.group.GroupByReader
 
avg(String, String, int, RoundingMode) - Method in class com.northconcepts.datapipeline.group.GroupByReader
 
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

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(Collection<String>) - Constructor for class com.northconcepts.datapipeline.transform.BasicFieldTransformer
 
BasicFieldTransformer(String) - Constructor for class com.northconcepts.datapipeline.transform.BasicFieldTransformer
 
BasicFieldTransformer.Operation - Class in com.northconcepts.datapipeline.transform
 
BasicFieldTransformer.SingleValueOperation - Class in com.northconcepts.datapipeline.transform
 
BasicFieldTransformer.StringOperation - Class in com.northconcepts.datapipeline.transform
 
BasicLookup - Class in com.northconcepts.datapipeline.transform.lookup
 
BasicLookup(FieldList) - Constructor for class com.northconcepts.datapipeline.transform.lookup.BasicLookup
 
Bean - Class in com.northconcepts.datapipeline.foundations.core
 
Bean() - Constructor for class com.northconcepts.datapipeline.foundations.core.Bean
 
before(String) - Method in class com.northconcepts.datapipeline.internal.trello.TrelloClient.TrelloStub
 
beforeLoad(Integer) - Method in class com.northconcepts.datapipeline.foundations.pipeline.dataset.Dataset
 
beforeLoad(Integer) - Method in class com.northconcepts.datapipeline.foundations.pipeline.dataset.MemoryDataset
 
beforeLoad(Integer) - Method in class com.northconcepts.datapipeline.foundations.pipeline.dataset.MvStoreDataset
 
binaryFieldAllowedValuesNotSupported() - Static method in class com.northconcepts.datapipeline.foundations.i18n.SchemaMessages
 
BinaryFieldDef - Class in com.northconcepts.datapipeline.foundations.schema
 
BinaryFieldDef() - 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
 
BinaryWriter(OutputStream) - Constructor for class com.northconcepts.datapipeline.core.BinaryWriter
 
blankTextIsNotAllowed(String, int) - Static method in class com.northconcepts.datapipeline.foundations.i18n.SchemaMessages
 
BloombergMessage - Class in com.northconcepts.datapipeline.bloomberg
 
BloombergMessage() - Constructor for class com.northconcepts.datapipeline.bloomberg.BloombergMessage
 
BloombergMessageData - Class in com.northconcepts.datapipeline.bloomberg
 
BloombergMessageData() - Constructor for class com.northconcepts.datapipeline.bloomberg.BloombergMessageData
 
BloombergMessageFields - Class in com.northconcepts.datapipeline.bloomberg
 
BloombergMessageFields() - Constructor for class com.northconcepts.datapipeline.bloomberg.BloombergMessageFields
 
BloombergMessageFooter - Class in com.northconcepts.datapipeline.bloomberg
 
BloombergMessageFooter() - Constructor for class com.northconcepts.datapipeline.bloomberg.BloombergMessageFooter
 
BloombergMessageHeader - Class in com.northconcepts.datapipeline.bloomberg
 
BloombergMessageHeader() - Constructor for class com.northconcepts.datapipeline.bloomberg.BloombergMessageHeader
 
BloombergMessageReader - Class in com.northconcepts.datapipeline.bloomberg
 
BloombergMessageReader(File) - Constructor for class com.northconcepts.datapipeline.bloomberg.BloombergMessageReader
 
BloombergMessageReader(Reader) - Constructor for class com.northconcepts.datapipeline.bloomberg.BloombergMessageReader
 
BoardFilter - Enum in com.northconcepts.datapipeline.trello
 
BoardLists - Enum in com.northconcepts.datapipeline.trello
 
BooleanFieldDef - Class in com.northconcepts.datapipeline.foundations.schema
 
BooleanFieldDef() - Constructor for class com.northconcepts.datapipeline.foundations.schema.BooleanFieldDef
 
BooleanFieldDef(String, FieldType) - Constructor for class com.northconcepts.datapipeline.foundations.schema.BooleanFieldDef
 
bsonDocumentToRecord(BsonDocument) - Static method in class com.northconcepts.datapipeline.mongodb.MongoTypeConverter
 
bsonValueToValueNode(BsonValue) - Static method in class com.northconcepts.datapipeline.mongodb.MongoTypeConverter
 
buffer - Variable in class com.northconcepts.datapipeline.core.AsyncMultiReader
 
BUFFER_SIZE - Static variable in class com.northconcepts.datapipeline.core.Endpoint
 
BufferedReader - Class in com.northconcepts.datapipeline.buffer
A proxy that collects records of the same type (same values and subset of fields) to release them downstream together.
BufferedReader(DataReader, int, String...) - Constructor for class com.northconcepts.datapipeline.buffer.BufferedReader
 
BufferedReader(DataReader, int, FieldList) - Constructor for class com.northconcepts.datapipeline.buffer.BufferedReader
 
BufferStrategy - Class in com.northconcepts.datapipeline.buffer
Determines when BufferedReader closes an open sliding buffer.
BufferStrategy() - Constructor for class com.northconcepts.datapipeline.buffer.BufferStrategy
 
buildDetail(Record, JsonGenerator) - Method in class com.northconcepts.datapipeline.json.builder.JsonTemplate
 
buildDetail(Record, CodeWriter) - Method in class com.northconcepts.datapipeline.xml.builder.XmlTemplate
 
buildFooter(JsonGenerator) - Method in class com.northconcepts.datapipeline.json.builder.JsonTemplate
 
buildFooter(CodeWriter) - Method in class com.northconcepts.datapipeline.xml.builder.XmlTemplate
 
buildHeader(JsonGenerator) - Method in class com.northconcepts.datapipeline.json.builder.JsonTemplate
 
buildHeader(CodeWriter) - Method in class com.northconcepts.datapipeline.xml.builder.XmlTemplate
 
buildSql(JdbcWriter, Record, int) - Method in class com.northconcepts.datapipeline.jdbc.insert.MultiRowPreparedStatementInsert
 

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, Integer, Scheduler) - Constructor for class com.northconcepts.datapipeline.transform.lookup.CachedLookup
Creates a new CachedLookup.
CachedLookup(Lookup, int) - Constructor for class com.northconcepts.datapipeline.transform.lookup.CachedLookup
Creates a new limited CachedLookup that never clears itself.
CachedLookup(Lookup) - Constructor for class com.northconcepts.datapipeline.transform.lookup.CachedLookup
Creates a new CachedLookup that has no limit and never clears itself.
cacheFieldIndexes - Variable in class com.northconcepts.datapipeline.core.RecordComparator
 
cacheNextLine() - Method in class com.northconcepts.datapipeline.core.LineParser
 
CalculatedField - Class in com.northconcepts.datapipeline.foundations.expression
 
CalculatedField() - Constructor for class com.northconcepts.datapipeline.foundations.expression.CalculatedField
 
CalculatedField(String, String) - Constructor for class com.northconcepts.datapipeline.foundations.expression.CalculatedField
 
call(Callable<T>) - Method in class com.northconcepts.datapipeline.retry.RetryingOperation
 
cancel() - Method in class com.northconcepts.datapipeline.job.AbstractJob
 
cancel() - Method in interface com.northconcepts.datapipeline.job.IJob
 
cancel() - Method in class com.northconcepts.datapipeline.job.Job
 
captureElapsedTime - Static variable in class com.northconcepts.datapipeline.core.Endpoint
 
CardFilter - Enum in com.northconcepts.datapipeline.trello
 
cleanupGarbage() - Method in class com.northconcepts.datapipeline.eventbus.EventBus
 
clear() - Method in class com.northconcepts.datapipeline.core.RecordList
 
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.transform.lookup.CachedLookup
 
clearCurrent() - Static method in class com.northconcepts.datapipeline.core.Messages
Removes the thread-local instance if one exists.
client - Variable in class com.northconcepts.datapipeline.twitter2.AbstractTwitterReader
 
clone() - Method in class com.northconcepts.datapipeline.core.ArrayValue
 
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
 
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
 
clone() - Method in class com.northconcepts.datapipeline.core.SingleValue
 
clone() - Method in class com.northconcepts.datapipeline.core.ValueNode
 
clone() - Method in class com.northconcepts.datapipeline.eventbus.EventBus
 
clone() - Method in class com.northconcepts.datapipeline.foundations.core.FoundationObject
 
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.ValidationResult
 
clone() - Method in class com.northconcepts.datapipeline.job.AbstractJob
 
clone() - Method in class com.northconcepts.datapipeline.job.Job
 
close() - Method in class com.northconcepts.datapipeline.amazons3.AmazonS3FileSystem
Closes the Amazon S3 connection.
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.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.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.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.ExcelReader
 
close() - Method in class com.northconcepts.datapipeline.excel.ExcelWriter
 
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.filter.FilteringReader
 
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.MemoryDataset
 
close() - Method in class com.northconcepts.datapipeline.foundations.pipeline.dataset.MvStoreDataset
 
close() - Method in class com.northconcepts.datapipeline.foundations.sourcecode.CodeWriter
 
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.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.trello.TrelloClient.TrelloStub
 
close() - Method in interface com.northconcepts.datapipeline.jdbc.insert.IInsert
 
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 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
 
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.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.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.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.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.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.template.TemplateWriter
 
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
 
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
 
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.foundations.sourcecode
 
CodeWriter(OutputStream) - Constructor for class com.northconcepts.datapipeline.foundations.sourcecode.CodeWriter
 
CodeWriter(Writer) - Constructor for class com.northconcepts.datapipeline.foundations.sourcecode.CodeWriter
 
collect(String, Collection) - Method in class com.northconcepts.datapipeline.memory.CollectionWriter
 
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
 
Column - Class in com.northconcepts.datapipeline.foundations.pipeline.dataset
 
Column(String, int, Map<Object, LongPointer>) - Constructor for class com.northconcepts.datapipeline.foundations.pipeline.dataset.Column
 
ColumnsDataReader(List<Column>) - Constructor for class com.northconcepts.datapipeline.foundations.pipeline.dataset.Dataset.ColumnsDataReader
 
com.northconcepts.datapipeline.amazons3 - package com.northconcepts.datapipeline.amazons3
 
com.northconcepts.datapipeline.avro - package com.northconcepts.datapipeline.avro
 
com.northconcepts.datapipeline.bloomberg - package com.northconcepts.datapipeline.bloomberg
 
com.northconcepts.datapipeline.buffer - package com.northconcepts.datapipeline.buffer
 
com.northconcepts.datapipeline.core - package com.northconcepts.datapipeline.core
 
com.northconcepts.datapipeline.csv - package com.northconcepts.datapipeline.csv
 
com.northconcepts.datapipeline.diagnostic - package com.northconcepts.datapipeline.diagnostic
 
com.northconcepts.datapipeline.email - package com.northconcepts.datapipeline.email
 
com.northconcepts.datapipeline.eventbus - package com.northconcepts.datapipeline.eventbus
 
com.northconcepts.datapipeline.eventbus.filter - package com.northconcepts.datapipeline.eventbus.filter
 
com.northconcepts.datapipeline.excel - package com.northconcepts.datapipeline.excel
 
com.northconcepts.datapipeline.expression - package com.northconcepts.datapipeline.expression
 
com.northconcepts.datapipeline.file - package com.northconcepts.datapipeline.file
 
com.northconcepts.datapipeline.filter - package com.northconcepts.datapipeline.filter
 
com.northconcepts.datapipeline.filter.rule - package com.northconcepts.datapipeline.filter.rule
 
com.northconcepts.datapipeline.fixedwidth - package com.northconcepts.datapipeline.fixedwidth
 
com.northconcepts.datapipeline.foundations.core - package com.northconcepts.datapipeline.foundations.core
 
com.northconcepts.datapipeline.foundations.datamapping - package com.northconcepts.datapipeline.foundations.datamapping
 
com.northconcepts.datapipeline.foundations.decisiontable - package com.northconcepts.datapipeline.foundations.decisiontable
 
com.northconcepts.datapipeline.foundations.decisiontree - package com.northconcepts.datapipeline.foundations.decisiontree
 
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.jdbc - package com.northconcepts.datapipeline.foundations.jdbc
 
com.northconcepts.datapipeline.foundations.pipeline - package com.northconcepts.datapipeline.foundations.pipeline
 
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.schema - package com.northconcepts.datapipeline.foundations.schema
 
com.northconcepts.datapipeline.foundations.sourcecode - package com.northconcepts.datapipeline.foundations.sourcecode
 
com.northconcepts.datapipeline.foundations.tools - package com.northconcepts.datapipeline.foundations.tools
 
com.northconcepts.datapipeline.google - package com.northconcepts.datapipeline.google
 
com.northconcepts.datapipeline.google.analytics - package com.northconcepts.datapipeline.google.analytics
 
com.northconcepts.datapipeline.google.calendar - package com.northconcepts.datapipeline.google.calendar
 
com.northconcepts.datapipeline.google.contacts - package com.northconcepts.datapipeline.google.contacts
 
com.northconcepts.datapipeline.google.gmail - package com.northconcepts.datapipeline.google.gmail
 
com.northconcepts.datapipeline.group - package com.northconcepts.datapipeline.group
 
com.northconcepts.datapipeline.group.operation - package com.northconcepts.datapipeline.group.operation
 
com.northconcepts.datapipeline.instagram - package com.northconcepts.datapipeline.instagram
 
com.northconcepts.datapipeline.internal.lang - package com.northconcepts.datapipeline.internal.lang
 
com.northconcepts.datapipeline.internal.trello - package com.northconcepts.datapipeline.internal.trello
 
com.northconcepts.datapipeline.io - package com.northconcepts.datapipeline.io
 
com.northconcepts.datapipeline.javabean - package com.northconcepts.datapipeline.javabean
 
com.northconcepts.datapipeline.jdbc - package com.northconcepts.datapipeline.jdbc
 
com.northconcepts.datapipeline.jdbc.insert - package com.northconcepts.datapipeline.jdbc.insert
 
com.northconcepts.datapipeline.jdbc.sql - package com.northconcepts.datapipeline.jdbc.sql
 
com.northconcepts.datapipeline.jdbc.sql.conflict - package com.northconcepts.datapipeline.jdbc.sql.conflict
 
com.northconcepts.datapipeline.jdbc.sql.insert - package com.northconcepts.datapipeline.jdbc.sql.insert
 
com.northconcepts.datapipeline.jdbc.sql.merge - package com.northconcepts.datapipeline.jdbc.sql.merge
 
com.northconcepts.datapipeline.jdbc.sql.select - package com.northconcepts.datapipeline.jdbc.sql.select
 
com.northconcepts.datapipeline.jdbc.sql.update - package com.northconcepts.datapipeline.jdbc.sql.update
 
com.northconcepts.datapipeline.jdbc.upsert - package com.northconcepts.datapipeline.jdbc.upsert
 
com.northconcepts.datapipeline.jira - package com.northconcepts.datapipeline.jira
 
com.northconcepts.datapipeline.jira.client - package com.northconcepts.datapipeline.jira.client
 
com.northconcepts.datapipeline.jms - package com.northconcepts.datapipeline.jms
 
com.northconcepts.datapipeline.job - package com.northconcepts.datapipeline.job
 
com.northconcepts.datapipeline.json - package com.northconcepts.datapipeline.json
 
com.northconcepts.datapipeline.json.builder - package com.northconcepts.datapipeline.json.builder
 
com.northconcepts.datapipeline.lineage - package com.northconcepts.datapipeline.lineage
 
com.northconcepts.datapipeline.mailchimp - package com.northconcepts.datapipeline.mailchimp
 
com.northconcepts.datapipeline.mailchimp.list - package com.northconcepts.datapipeline.mailchimp.list
 
com.northconcepts.datapipeline.memory - package com.northconcepts.datapipeline.memory
 
com.northconcepts.datapipeline.meter - package com.northconcepts.datapipeline.meter
 
com.northconcepts.datapipeline.mongodb - package com.northconcepts.datapipeline.mongodb
 
com.northconcepts.datapipeline.multiplex - package com.northconcepts.datapipeline.multiplex
 
com.northconcepts.datapipeline.orc - package com.northconcepts.datapipeline.orc
 
com.northconcepts.datapipeline.parquet - package com.northconcepts.datapipeline.parquet
 
com.northconcepts.datapipeline.pdf - package com.northconcepts.datapipeline.pdf
 
com.northconcepts.datapipeline.retry - package com.northconcepts.datapipeline.retry
 
com.northconcepts.datapipeline.rtf - package com.northconcepts.datapipeline.rtf
 
com.northconcepts.datapipeline.schedule - package com.northconcepts.datapipeline.schedule
 
com.northconcepts.datapipeline.template - package com.northconcepts.datapipeline.template
 
com.northconcepts.datapipeline.throttle - package com.northconcepts.datapipeline.throttle
 
com.northconcepts.datapipeline.transform - package com.northconcepts.datapipeline.transform
 
com.northconcepts.datapipeline.transform.format - package com.northconcepts.datapipeline.transform.format
 
com.northconcepts.datapipeline.transform.lookup - package com.northconcepts.datapipeline.transform.lookup
 
com.northconcepts.datapipeline.transform.net - package com.northconcepts.datapipeline.transform.net
 
com.northconcepts.datapipeline.trello - package com.northconcepts.datapipeline.trello
 
com.northconcepts.datapipeline.twitter - package com.northconcepts.datapipeline.twitter
 
com.northconcepts.datapipeline.twitter2 - package com.northconcepts.datapipeline.twitter2
 
com.northconcepts.datapipeline.validate - package com.northconcepts.datapipeline.validate
 
com.northconcepts.datapipeline.weblog - package com.northconcepts.datapipeline.weblog
 
com.northconcepts.datapipeline.xml - package com.northconcepts.datapipeline.xml
 
com.northconcepts.datapipeline.xml.builder - package com.northconcepts.datapipeline.xml.builder
 
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
 
CombinedLogReader(Reader) - Constructor for class com.northconcepts.datapipeline.weblog.CombinedLogReader
 
CommaSeparatedList - Class in com.northconcepts.datapipeline.trello
 
CommaSeparatedList(String) - Constructor for class com.northconcepts.datapipeline.trello.CommaSeparatedList
 
compare(Field, Field) - Method in class com.northconcepts.datapipeline.core.FieldComparator
 
compare(Record, Record) - Method in class com.northconcepts.datapipeline.core.RecordComparator
 
compareRecord(Record, Record, boolean) - Method in class com.northconcepts.datapipeline.core.FieldComparator
 
compareTo(ValueNode<ArrayValue>) - Method in class com.northconcepts.datapipeline.core.ArrayValue
 
compareTo(Field) - Method in class com.northconcepts.datapipeline.core.Field
 
compareTo(Field, Collator) - Method in class com.northconcepts.datapipeline.core.Field
 
compareTo(ValueNode<Record>) - Method in class com.northconcepts.datapipeline.core.Record
 
compareTo(Record) - Method in class com.northconcepts.datapipeline.core.Record
 
compareTo(Record, RecordComparator) - Method in class com.northconcepts.datapipeline.core.Record
 
compareTo(ValueNode<Object>) - Method in class com.northconcepts.datapipeline.core.SingleValue
 
compareTo(ValueNode<Object>, Collator) - Method in class com.northconcepts.datapipeline.core.SingleValue
 
CompositePipelineAction - Class in com.northconcepts.datapipeline.foundations.pipeline.action
 
CompositePipelineAction() - Constructor for class com.northconcepts.datapipeline.foundations.pipeline.action.CompositePipelineAction
 
CompositeValue - Class in com.northconcepts.datapipeline.core
 
CompositeValue(int) - Constructor for class com.northconcepts.datapipeline.core.CompositeValue
 
CompositeValue(List<?>) - Constructor for class com.northconcepts.datapipeline.core.CompositeValue
 
CompositeValue(Object...) - Constructor for class com.northconcepts.datapipeline.core.CompositeValue
 
ConcurrentRecordList - Class in com.northconcepts.datapipeline.core
 
ConcurrentRecordList() - Constructor for class com.northconcepts.datapipeline.core.ConcurrentRecordList
 
ConcurrentRecordList(int) - Constructor for class com.northconcepts.datapipeline.core.ConcurrentRecordList
 
ConcurrentRecordList(Record...) - Constructor for class com.northconcepts.datapipeline.core.ConcurrentRecordList
 
ConcurrentRecordList(DataReader) - Constructor for class com.northconcepts.datapipeline.core.ConcurrentRecordList
 
ConditionPart - Class in com.northconcepts.datapipeline.jdbc.sql.select
 
ConditionPart(String, Object...) - Constructor for class com.northconcepts.datapipeline.jdbc.sql.select.ConditionPart
 
ConjunctivePart - Class in com.northconcepts.datapipeline.jdbc.sql.select
 
ConjunctivePart(String) - Constructor for class com.northconcepts.datapipeline.jdbc.sql.select.ConjunctivePart
 
consume() - Method in interface com.northconcepts.datapipeline.core.IParser
 
consume(int) - Method in interface com.northconcepts.datapipeline.core.IParser
 
consume() - Method in class com.northconcepts.datapipeline.core.LineParser
 
consume(int) - Method in class com.northconcepts.datapipeline.core.LineParser
 
consume() - Method in class com.northconcepts.datapipeline.core.Parser
 
consume(int) - Method in class com.northconcepts.datapipeline.core.Parser
 
consume() - Method in class com.northconcepts.datapipeline.core.StringParser
 
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(int) - Method in interface com.northconcepts.datapipeline.core.IParser
 
consumeWhitespace(CharSequence) - Method in interface com.northconcepts.datapipeline.core.IParser
 
consumeWhitespace(char[]) - Method in interface com.northconcepts.datapipeline.core.IParser
 
consumeWhitespace() - Method in class com.northconcepts.datapipeline.core.LineParser
 
consumeWhitespace(int) - Method in class com.northconcepts.datapipeline.core.LineParser
 
consumeWhitespace(CharSequence) - Method in class com.northconcepts.datapipeline.core.LineParser
 
consumeWhitespace(char[]) - Method in class com.northconcepts.datapipeline.core.LineParser
 
consumeWhitespace() - Method in class com.northconcepts.datapipeline.core.Parser
 
consumeWhitespace(int) - Method in class com.northconcepts.datapipeline.core.Parser
 
consumeWhitespace(CharSequence) - Method in class com.northconcepts.datapipeline.core.Parser
 
consumeWhitespace(char[]) - Method in class com.northconcepts.datapipeline.core.Parser
 
consumeWhitespace() - Method in class com.northconcepts.datapipeline.core.StringParser
 
consumeWhitespace(int) - Method in class com.northconcepts.datapipeline.core.StringParser
 
consumeWhitespace(CharSequence) - Method in class com.northconcepts.datapipeline.core.StringParser
 
consumeWhitespace(char[]) - Method in class com.northconcepts.datapipeline.core.StringParser
 
contains(String...) - Method in class com.northconcepts.datapipeline.core.FieldList
 
contains(Record) - Method in class com.northconcepts.datapipeline.core.FieldPath
 
contains(FieldPath) - Method in class com.northconcepts.datapipeline.core.Record
Indicates if this record contains a matching field or value for the specified path.
contains(String, boolean) - Method in class com.northconcepts.datapipeline.filter.FieldFilter
 
Contains - Class in com.northconcepts.datapipeline.filter.rule
 
Contains(String) - Constructor for class com.northconcepts.datapipeline.filter.rule.Contains
 
Contains(String, boolean) - Constructor for class com.northconcepts.datapipeline.filter.rule.Contains
 
containsEntity(String) - Method in class com.northconcepts.datapipeline.foundations.schema.SchemaDef
 
containsField(Record) - Method in class com.northconcepts.datapipeline.core.FieldPath
 
containsField(String) - Method in class com.northconcepts.datapipeline.core.Record
 
containsField(FieldPath) - Method in class com.northconcepts.datapipeline.core.Record
Indicates if this record contains a matching field for the specified path.
containsField(FieldList) - Method in class com.northconcepts.datapipeline.core.Record
Returns true if all fields and sub fields in a nested path exists.
containsField(String) - Method in class com.northconcepts.datapipeline.foundations.schema.EntityDef
 
containsKeyImpl(String) - Method in class com.northconcepts.datapipeline.foundations.datamapping.DataMappingExpressionContext
 
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(String) - Method in class com.northconcepts.datapipeline.core.Record
Indicates if this record contains a field at the specified path that is not null.
containsSessionProperty(Class<T>, String) - Method in class com.northconcepts.datapipeline.core.Node
 
containsSessionProperty(Class<T>) - Method in class com.northconcepts.datapipeline.core.Node
 
containsSessionProperty(String) - Method in class com.northconcepts.datapipeline.core.Node
 
containsSessionProperty(Class<T>, String) - Method in interface com.northconcepts.datapipeline.core.Session
 
containsSessionProperty(Class<T>) - Method in interface com.northconcepts.datapipeline.core.Session
 
containsSessionProperty(String) - Method in interface com.northconcepts.datapipeline.core.Session
 
containsSessionProperty(Class<T>, String) - Method in class com.northconcepts.datapipeline.core.Session.SessionImpl
 
containsSessionProperty(Class<T>) - Method in class com.northconcepts.datapipeline.core.Session.SessionImpl
 
containsSessionProperty(String) - Method in class com.northconcepts.datapipeline.core.Session.SessionImpl
 
ConvertDateTimeToStringAction - Class in com.northconcepts.datapipeline.foundations.pipeline.action.convert
 
ConvertDateTimeToStringAction() - Constructor for class com.northconcepts.datapipeline.foundations.pipeline.action.convert.ConvertDateTimeToStringAction
 
ConvertNullToValueAction - Class in com.northconcepts.datapipeline.foundations.pipeline.action.convert
 
ConvertNullToValueAction() - Constructor for class com.northconcepts.datapipeline.foundations.pipeline.action.convert.ConvertNullToValueAction
 
ConvertNullToValueAction.FieldType - Enum in com.northconcepts.datapipeline.foundations.pipeline.action.convert
 
ConvertNullToValueAction.TypeValue - Class in com.northconcepts.datapipeline.foundations.pipeline.action.convert
 
ConvertNumberToStringAction - Class in com.northconcepts.datapipeline.foundations.pipeline.action.convert
 
ConvertNumberToStringAction() - Constructor for class com.northconcepts.datapipeline.foundations.pipeline.action.convert.ConvertNumberToStringAction
 
ConvertStringToBooleanAction - Class in com.northconcepts.datapipeline.foundations.pipeline.action.convert
 
ConvertStringToBooleanAction() - Constructor for class com.northconcepts.datapipeline.foundations.pipeline.action.convert.ConvertStringToBooleanAction
 
ConvertStringToDateTimeAction - Class in com.northconcepts.datapipeline.foundations.pipeline.action.convert
 
ConvertStringToDateTimeAction() - Constructor for class com.northconcepts.datapipeline.foundations.pipeline.action.convert.ConvertStringToDateTimeAction
 
ConvertStringToDateTimeAction.FieldType - Enum in com.northconcepts.datapipeline.foundations.pipeline.action.convert
 
ConvertStringToNumberAction - Class in com.northconcepts.datapipeline.foundations.pipeline.action.convert
 
ConvertStringToNumberAction() - Constructor for class com.northconcepts.datapipeline.foundations.pipeline.action.convert.ConvertStringToNumberAction
 
ConvertStringToNumberAction.FieldType - Enum in com.northconcepts.datapipeline.foundations.pipeline.action.convert
 
ConvertValueToStringAction - Class in com.northconcepts.datapipeline.foundations.pipeline.action.convert
 
ConvertValueToStringAction() - Constructor for class com.northconcepts.datapipeline.foundations.pipeline.action.convert.ConvertValueToStringAction
 
copy(DataReader, DataWriter) - Static method in class com.northconcepts.datapipeline.core.SortingReader
 
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
 
CopyFieldsAction - Class in com.northconcepts.datapipeline.foundations.pipeline.action.transform
 
CopyFieldsAction() - Constructor for class com.northconcepts.datapipeline.foundations.pipeline.action.transform.CopyFieldsAction
 
CopyFieldsAction.FieldMapping - Class in com.northconcepts.datapipeline.foundations.pipeline.action.transform
 
copyForm(Property) - Method in class com.northconcepts.datapipeline.foundations.core.Property
 
copyFrom(Field) - Method in class com.northconcepts.datapipeline.core.Field
 
copyFrom(Field, boolean) - Method in class com.northconcepts.datapipeline.core.Field
 
copyFrom(FieldComparator) - Method in class com.northconcepts.datapipeline.core.FieldComparator
 
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(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) - 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 (DuplicateNodeAction#APPEND).
copyFrom(RecordLineage) - Method in class com.northconcepts.datapipeline.lineage.FieldLineage
 
copySessionPropertiesFrom(Session) - Method in class com.northconcepts.datapipeline.core.Node
 
copySessionPropertiesFrom(Session) - Method in interface com.northconcepts.datapipeline.core.Session
 
copySessionPropertiesFrom(Session) - Method in class com.northconcepts.datapipeline.core.Session.SessionImpl
 
copyToRecord(Long, Record, IEntityExpansionPolicy) - Method in class com.northconcepts.datapipeline.twitter.TwitterFollowerIDsReader
 
copyToRecord(User, Record, IEntityExpansionPolicy) - Method in class com.northconcepts.datapipeline.twitter.TwitterFollowerListReader
 
copyToRecord(Long, Record, IEntityExpansionPolicy) - Method in class com.northconcepts.datapipeline.twitter.TwitterFollowingIDsReader
 
copyToRecord(User, Record, IEntityExpansionPolicy) - Method in class com.northconcepts.datapipeline.twitter.TwitterFollowingListReader
 
copyToRecord(User, Record, IEntityExpansionPolicy) - Method in class com.northconcepts.datapipeline.twitter.TwitterListMemberReader
 
copyToRecord(UserList, Record, IEntityExpansionPolicy) - Method in class com.northconcepts.datapipeline.twitter.TwitterListOwnershipReader
 
copyToRecord(E, Record, IEntityExpansionPolicy) - Method in class com.northconcepts.datapipeline.twitter.TwitterPageableReader
 
count(String) - Method in class com.northconcepts.datapipeline.group.AggregateReader
Deprecated.
 
count(String) - Method in class com.northconcepts.datapipeline.group.GroupByReader
 
count(String, boolean) - Method in class com.northconcepts.datapipeline.group.GroupByReader
 
createColumnsDataReader() - Method in class com.northconcepts.datapipeline.foundations.pipeline.dataset.Dataset
 
createConnection() - Method in class com.northconcepts.datapipeline.foundations.jdbc.JdbcConnection
 
createConnection() - Method in interface com.northconcepts.datapipeline.jdbc.JdbcConnectionFactory
 
createConsumer(JmsSettings, JmsConnection) - Method in enum com.northconcepts.datapipeline.jms.JmsDestinationType
 
createDataReader() - Method in class com.northconcepts.datapipeline.foundations.pipeline.AbstractPipeline
 
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.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 interface com.northconcepts.datapipeline.job.DataReaderFactory
 
createDataReaderImpl(InputStream) - Method in class com.northconcepts.datapipeline.foundations.pipeline.input.JsonPipelineInput
 
createDataReaderImpl(InputStream) - Method in class com.northconcepts.datapipeline.foundations.pipeline.input.XmlPipelineInput
 
createDataWriter(SequenceWriter.Sequence, Record) - Method in interface com.northconcepts.datapipeline.core.SequenceWriter.DataWriterFactory
 
createDataWriter() - Method in class com.northconcepts.datapipeline.foundations.pipeline.AbstractPipeline
 
createDataWriter() - Method in class com.northconcepts.datapipeline.foundations.pipeline.dataset.Dataset
 
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.JdbcPipelineOutput
 
createDataWriter() - Method in interface com.northconcepts.datapipeline.job.DataWriterFactory
 
createFactory() - Method in class com.northconcepts.datapipeline.json.JsonRecordReader
 
createField() - Method in class com.northconcepts.datapipeline.group.GroupOperation
 
createField() - Method in class com.northconcepts.datapipeline.group.operation.GroupAverage
 
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
 
createInputStream() - Method in interface com.northconcepts.datapipeline.io.InputStreamFactory
 
createJob() - Method in class com.northconcepts.datapipeline.foundations.pipeline.AbstractPipeline
 
createProducer(JmsSettings, JmsConnection) - Method in enum com.northconcepts.datapipeline.jms.JmsDestinationType
 
createReader() - Method in class com.northconcepts.datapipeline.multiplex.DeMux
 
createReader() - Method in class com.northconcepts.datapipeline.multiplex.SplitWriter
 
createRecord() - Method in class com.northconcepts.datapipeline.xml.XmlReader
 
createTempDatabaseFile() - Method in class com.northconcepts.datapipeline.foundations.pipeline.dataset.MvStoreDataset
 
createUpsert(JdbcUpsertWriter, Record) - Method in interface com.northconcepts.datapipeline.jdbc.upsert.VariableFieldsUpsert.IUpsertFactory
 
createVariable(String) - Method in class com.northconcepts.datapipeline.foundations.sourcecode.JavaCodeBuilder
 
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
 
CsvPipelineInput - Class in com.northconcepts.datapipeline.foundations.pipeline.input
 
CsvPipelineInput() - Constructor for class com.northconcepts.datapipeline.foundations.pipeline.input.CsvPipelineInput
 
CsvPipelineOutput - Class in com.northconcepts.datapipeline.foundations.pipeline.output
 
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, boolean) - Constructor for class com.northconcepts.datapipeline.csv.CSVWriter
 
CSVWriter(File) - 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 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
 

D

DATABASE_COLUMN_NAME - Static variable in class com.northconcepts.datapipeline.lineage.FieldLineage
 
DATABASE_QUERY - Static variable in class com.northconcepts.datapipeline.lineage.RecordLineage
 
DATABASE_URL - Static variable in class com.northconcepts.datapipeline.lineage.RecordLineage
 
DataEndpoint - Class in com.northconcepts.datapipeline.core
Abstract super-class for reading and writing records.
DataEndpoint() - Constructor for class com.northconcepts.datapipeline.core.DataEndpoint
 
DataEndpoint.State - Enum in com.northconcepts.datapipeline.core
 
DataEndpointGroup - Class in com.northconcepts.datapipeline.core
Helper class--makes it easy to work with multiple readers and writers as a single unit.
DataEndpointGroup() - Constructor for class com.northconcepts.datapipeline.core.DataEndpointGroup
 
DataException - Exception in com.northconcepts.datapipeline.core
Indicates an error has occurred during the course of execution.
DataException() - Constructor for exception com.northconcepts.datapipeline.core.DataException
Constructs a new exception.
DataException(String) - Constructor for exception com.northconcepts.datapipeline.core.DataException
Constructs a new exception with the specified detail message.
DataException(Throwable) - Constructor for exception com.northconcepts.datapipeline.core.DataException
Constructs a new exception with the specified cause.
DataException(String, Throwable) - Constructor for exception com.northconcepts.datapipeline.core.DataException
Constructs a new exception with the specified detail message and cause.
DataMapping - Class in com.northconcepts.datapipeline.foundations.datamapping
 
DataMapping() - Constructor for class com.northconcepts.datapipeline.foundations.datamapping.DataMapping
 
DataMappingAction - Class in com.northconcepts.datapipeline.foundations.pipeline.action.datamapping
 
DataMappingAction() - Constructor for class com.northconcepts.datapipeline.foundations.pipeline.action.datamapping.DataMappingAction
 
DataMappingExpressionContext - Class in com.northconcepts.datapipeline.foundations.datamapping
 
DataMappingExpressionContext(ExpressionContext, ExpressionContext, ExpressionContext, ExpressionContext) - Constructor for class com.northconcepts.datapipeline.foundations.datamapping.DataMappingExpressionContext
 
DataMappingExpressionContext(ExpressionContext, ExpressionContext) - Constructor for class com.northconcepts.datapipeline.foundations.datamapping.DataMappingExpressionContext
 
DataMappingObject - Class in com.northconcepts.datapipeline.foundations.datamapping
 
DataMappingObject() - Constructor for class com.northconcepts.datapipeline.foundations.datamapping.DataMappingObject
 
DataMappingPipeline - Class in com.northconcepts.datapipeline.foundations.pipeline
 
DataMappingPipeline() - Constructor for class com.northconcepts.datapipeline.foundations.pipeline.DataMappingPipeline
 
DataMappingReader - Class in com.northconcepts.datapipeline.foundations.datamapping
 
DataMappingReader(DataReader, DataMapping, DataWriter, String) - Constructor for class com.northconcepts.datapipeline.foundations.datamapping.DataMappingReader
 
DataMappingReader(DataReader, DataMapping) - Constructor for class com.northconcepts.datapipeline.foundations.datamapping.DataMappingReader
 
DataMappingResult - Class in com.northconcepts.datapipeline.foundations.datamapping
 
DataMappingResult() - Constructor for class com.northconcepts.datapipeline.foundations.datamapping.DataMappingResult
 
DataMappingWriter - Class in com.northconcepts.datapipeline.foundations.datamapping
 
DataMappingWriter(DataWriter, DataMapping) - Constructor for class com.northconcepts.datapipeline.foundations.datamapping.DataMappingWriter
 
DataMappingWriter(DataWriter, DataMapping, DataWriter, String) - Constructor for class com.northconcepts.datapipeline.foundations.datamapping.DataMappingWriter
 
DataObject - Class in com.northconcepts.datapipeline.core
Abstract super-class for classes that work with data and require a consistent error handling mechanism.
DataObject() - Constructor for class com.northconcepts.datapipeline.core.DataObject
 
DataReader - Class in com.northconcepts.datapipeline.core
Abstract super-class for reading records.
DataReader() - Constructor for class com.northconcepts.datapipeline.core.DataReader
 
DataReaderAction - Interface in com.northconcepts.datapipeline.foundations.pipeline.action
 
DataReaderDecorator - Interface in com.northconcepts.datapipeline.job
A Decorator that allows a DataReader to be wrapped in new behavior.
DataReaderFactory - Interface in com.northconcepts.datapipeline.job
A factory to create new DataReaders.
DataReaderIterator - Class in com.northconcepts.datapipeline.job
A DataReader that sequentially reads from an Iterator of other DataReaders.
DataReaderIterator(Iterator<DataReader>) - Constructor for class com.northconcepts.datapipeline.job.DataReaderIterator
 
DataReaderLookup - Class in com.northconcepts.datapipeline.transform.lookup
 
DataReaderLookup(DataReader, FieldList) - Constructor for class com.northconcepts.datapipeline.transform.lookup.DataReaderLookup
Add all result fields.
DataReaderLookup(DataReader, FieldList, FieldList) - Constructor for class com.northconcepts.datapipeline.transform.lookup.DataReaderLookup
Adds selected result fields.
DataReaderPipelineInput - Class in com.northconcepts.datapipeline.foundations.pipeline.input
 
DataReaderPipelineInput() - Constructor for class com.northconcepts.datapipeline.foundations.pipeline.input.DataReaderPipelineInput
 
DataReaderPipelineInput(DataReaderFactory) - Constructor for class com.northconcepts.datapipeline.foundations.pipeline.input.DataReaderPipelineInput
 
Dataset - Class in com.northconcepts.datapipeline.foundations.pipeline.dataset
 
Dataset(AbstractPipeline) - Constructor for class com.northconcepts.datapipeline.foundations.pipeline.dataset.Dataset
 
Dataset.ColumnsDataReader - Class in com.northconcepts.datapipeline.foundations.pipeline.dataset
 
DatasetPipelineInput - Class in com.northconcepts.datapipeline.foundations.pipeline.input
 
DatasetPipelineInput(Dataset) - Constructor for class com.northconcepts.datapipeline.foundations.pipeline.input.DatasetPipelineInput
 
DatasetReader - Class in com.northconcepts.datapipeline.foundations.pipeline.dataset
 
DatasetReader(Dataset) - Constructor for class com.northconcepts.datapipeline.foundations.pipeline.dataset.DatasetReader
 
DataWriter - Class in com.northconcepts.datapipeline.core
Abstract super-class for writing records.
DataWriter() - Constructor for class com.northconcepts.datapipeline.core.DataWriter
 
DataWriterDecorator - Interface in com.northconcepts.datapipeline.job
A Decorator that allows a DataWriter to be wrapped in new behavior.
DataWriterFactory - Interface in com.northconcepts.datapipeline.job
A factory to create new DataWriters.
DataWriterPipelineOutput - Class in com.northconcepts.datapipeline.foundations.pipeline.output
 
DataWriterPipelineOutput() - Constructor for class com.northconcepts.datapipeline.foundations.pipeline.output.DataWriterPipelineOutput
 
DataWriterPipelineOutput(DataWriterFactory) - Constructor for class com.northconcepts.datapipeline.foundations.pipeline.output.DataWriterPipelineOutput
 
DATE_14_DAYS_AGO - Static variable in class com.northconcepts.datapipeline.google.analytics.GoogleAnalyticsReportReader
 
DATE_30_DAYS_AGO - Static variable in class com.northconcepts.datapipeline.google.analytics.GoogleAnalyticsReportReader
 
DATE_60_DAYS_AGO - Static variable in class com.northconcepts.datapipeline.google.analytics.GoogleAnalyticsReportReader
 
DATE_7_DAYS_AGO - Static variable in class com.northconcepts.datapipeline.google.analytics.GoogleAnalyticsReportReader
 
DATE_90_DAYS_AGO - Static variable in class com.northconcepts.datapipeline.google.analytics.GoogleAnalyticsReportReader
 
DATE_FORMAT - Variable in class com.northconcepts.datapipeline.jdbc.insert.MultiRowStatementInsert
 
DATE_TIME_FORMAT - Variable in class com.northconcepts.datapipeline.jdbc.insert.MultiRowStatementInsert
 
DATE_TIME_FORMATTER - Static variable in class com.northconcepts.datapipeline.twitter2.TwitterV2Client
 
DATE_TODAY - Static variable in class com.northconcepts.datapipeline.google.analytics.GoogleAnalyticsReportReader
 
DATE_YESTERDAY - Static variable in class com.northconcepts.datapipeline.google.analytics.GoogleAnalyticsReportReader
 
dateIs(Date) - Method in class com.northconcepts.datapipeline.filter.FieldFilter
 
dateIs(String) - Method in class com.northconcepts.datapipeline.filter.FieldFilter
 
DateIs - Class in com.northconcepts.datapipeline.filter.rule
 
DateIs(Date) - Constructor for class com.northconcepts.datapipeline.filter.rule.DateIs
 
DateIs(String) - Constructor for class com.northconcepts.datapipeline.filter.rule.DateIs
 
DateIs(LocalDateTime) - Constructor for class com.northconcepts.datapipeline.filter.rule.DateIs
 
dateIsAfter(Date) - Method in class com.northconcepts.datapipeline.filter.FieldFilter
 
dateIsAfter(String) - Method in class com.northconcepts.datapipeline.filter.FieldFilter
 
DateIsAfter - Class in com.northconcepts.datapipeline.filter.rule
 
DateIsAfter(Date) - Constructor for class com.northconcepts.datapipeline.filter.rule.DateIsAfter
 
DateIsAfter(String) - Constructor for class com.northconcepts.datapipeline.filter.rule.DateIsAfter
 
DateIsAfter(LocalDateTime) - Constructor for class com.northconcepts.datapipeline.filter.rule.DateIsAfter
 
dateIsBefore(Date) - Method in class com.northconcepts.datapipeline.filter.FieldFilter
 
dateIsBefore(String) - Method in class com.northconcepts.datapipeline.filter.FieldFilter
 
DateIsBefore - Class in com.northconcepts.datapipeline.filter.rule
 
DateIsBefore(Date) - Constructor for class com.northconcepts.datapipeline.filter.rule.DateIsBefore
 
DateIsBefore(String) - Constructor for class com.northconcepts.datapipeline.filter.rule.DateIsBefore
 
DateIsBefore(LocalDateTime) - Constructor for class com.northconcepts.datapipeline.filter.rule.DateIsBefore
 
DateParam - Class in com.northconcepts.datapipeline.trello
 
DateParam(String) - Constructor for class com.northconcepts.datapipeline.trello.DateParam
 
DateParam(Date) - Constructor for class com.northconcepts.datapipeline.trello.DateParam
 
dateTimeToDate() - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer
 
datetimeToString(Date) - Static method in class com.northconcepts.datapipeline.internal.trello.TrelloClient.Proxy
 
dateTimeToString(DateFormat) - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer
 
dateTimeToString(String) - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer
 
dateTimeToString(String, String) - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer
 
dateTimeToTime() - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer
 
dateToString(DateFormat) - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer
 
dateToString(String) - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer
 
dateToString(String, String) - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer
 
daysToDate() - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer
 
daysToDateTime() - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer
 
DebugReader - Class in com.northconcepts.datapipeline.core
A proxy that prints records passing through to a stream in a human-readable format
DebugReader(DataReader, String, Writer) - Constructor for class com.northconcepts.datapipeline.core.DebugReader
 
DebugReader(DataReader, String, OutputStream) - Constructor for class com.northconcepts.datapipeline.core.DebugReader
 
DebugReader(DataReader, String) - Constructor for class com.northconcepts.datapipeline.core.DebugReader
 
DebugReader(DataReader) - Constructor for class com.northconcepts.datapipeline.core.DebugReader
 
DecisionTable - Class in com.northconcepts.datapipeline.foundations.decisiontable
 
DecisionTable() - Constructor for class com.northconcepts.datapipeline.foundations.decisiontable.DecisionTable
 
DecisionTableAction - Class in com.northconcepts.datapipeline.foundations.pipeline.action.decision
 
DecisionTableAction() - Constructor for class com.northconcepts.datapipeline.foundations.pipeline.action.decision.DecisionTableAction
 
DecisionTableCondition - Class in com.northconcepts.datapipeline.foundations.decisiontable
 
DecisionTableCondition() - Constructor for class com.northconcepts.datapipeline.foundations.decisiontable.DecisionTableCondition
 
DecisionTableCondition(String, String) - Constructor for class com.northconcepts.datapipeline.foundations.decisiontable.DecisionTableCondition
 
DecisionTableObject - Class in com.northconcepts.datapipeline.foundations.decisiontable
 
DecisionTableObject() - Constructor for class com.northconcepts.datapipeline.foundations.decisiontable.DecisionTableObject
 
DecisionTableOutcome - Class in com.northconcepts.datapipeline.foundations.decisiontable
 
DecisionTableOutcome() - Constructor for class com.northconcepts.datapipeline.foundations.decisiontable.DecisionTableOutcome
 
DecisionTableOutcome(String, String) - Constructor for class com.northconcepts.datapipeline.foundations.decisiontable.DecisionTableOutcome
 
DecisionTableReader - Class in com.northconcepts.datapipeline.foundations.decisiontable
 
DecisionTableReader(DataReader, DecisionTable) - Constructor for class com.northconcepts.datapipeline.foundations.decisiontable.DecisionTableReader
 
DecisionTableResult - Class in com.northconcepts.datapipeline.foundations.decisiontable
 
DecisionTableResult() - Constructor for class com.northconcepts.datapipeline.foundations.decisiontable.DecisionTableResult
 
DecisionTableRule - Class in com.northconcepts.datapipeline.foundations.decisiontable
 
DecisionTableRule() - Constructor for class com.northconcepts.datapipeline.foundations.decisiontable.DecisionTableRule
 
DecisionTableWriter - Class in com.northconcepts.datapipeline.foundations.decisiontable
 
DecisionTableWriter(DataWriter, DecisionTable) - Constructor for class com.northconcepts.datapipeline.foundations.decisiontable.DecisionTableWriter
 
DecisionTree - Class in com.northconcepts.datapipeline.foundations.decisiontree
 
DecisionTree() - Constructor for class com.northconcepts.datapipeline.foundations.decisiontree.DecisionTree
 
DecisionTreeAction - Class in com.northconcepts.datapipeline.foundations.pipeline.action.decision
 
DecisionTreeAction() - Constructor for class com.northconcepts.datapipeline.foundations.pipeline.action.decision.DecisionTreeAction
 
DecisionTreeNode - Class in com.northconcepts.datapipeline.foundations.decisiontree
 
DecisionTreeNode() - Constructor for class com.northconcepts.datapipeline.foundations.decisiontree.DecisionTreeNode
 
DecisionTreeNode(String) - Constructor for class com.northconcepts.datapipeline.foundations.decisiontree.DecisionTreeNode
 
DecisionTreeNode(String, String) - Constructor for class com.northconcepts.datapipeline.foundations.decisiontree.DecisionTreeNode
 
DecisionTreeObject - Class in com.northconcepts.datapipeline.foundations.decisiontree
 
DecisionTreeObject() - Constructor for class com.northconcepts.datapipeline.foundations.decisiontree.DecisionTreeObject
 
DecisionTreeOutcome - Class in com.northconcepts.datapipeline.foundations.decisiontree
 
DecisionTreeOutcome() - Constructor for class com.northconcepts.datapipeline.foundations.decisiontree.DecisionTreeOutcome
 
DecisionTreeOutcome(String, String) - Constructor for class com.northconcepts.datapipeline.foundations.decisiontree.DecisionTreeOutcome
 
DecisionTreeReader - Class in com.northconcepts.datapipeline.foundations.decisiontree
 
DecisionTreeReader(DataReader, DecisionTree) - Constructor for class com.northconcepts.datapipeline.foundations.decisiontree.DecisionTreeReader
 
DecisionTreeResult - Class in com.northconcepts.datapipeline.foundations.decisiontree
 
DecisionTreeResult() - Constructor for class com.northconcepts.datapipeline.foundations.decisiontree.DecisionTreeResult
 
DecisionTreeVisitor - Interface in com.northconcepts.datapipeline.foundations.decisiontree
 
DecisionTreeWriter - Class in com.northconcepts.datapipeline.foundations.decisiontree
 
DecisionTreeWriter(DataWriter, DecisionTree) - Constructor for class com.northconcepts.datapipeline.foundations.decisiontree.DecisionTreeWriter
 
decode(T) - Method in interface com.northconcepts.datapipeline.foundations.core.Encoder
 
decode(String) - Method in class com.northconcepts.datapipeline.foundations.core.Encoder.HexEncoder
 
decode(Object) - Method in class com.northconcepts.datapipeline.foundations.core.Encoder.NullEncoder
 
decorate(DataReader) - Method in interface com.northconcepts.datapipeline.job.DataReaderDecorator
 
decorate(DataWriter) - Method in interface com.northconcepts.datapipeline.job.DataWriterDecorator
 
decrementRecordCount() - Method in class com.northconcepts.datapipeline.core.DataEndpoint
Reduces this endpoint's record-count by 1.
DEFAULT - Static variable in interface com.northconcepts.datapipeline.jdbc.JdbcValueReader
 
DEFAULT - Static variable in interface com.northconcepts.datapipeline.job.JobTemplate
 
DEFAULT - Static variable in interface com.northconcepts.datapipeline.twitter.ITwitterConverter
 
DEFAULT - Static variable in class com.northconcepts.datapipeline.twitter.TwitterConverter
 
DEFAULT_QUEUE_SIZE - Static variable in class com.northconcepts.datapipeline.amazons3.AmazonS3FileSystem
 
DEFAULT_QUEUE_SIZE - Static variable in class com.northconcepts.datapipeline.multiplex.SplitWriter
 
DEFAULT_READ_BUFFER_SIZE - Static variable in class com.northconcepts.datapipeline.core.Endpoint
 
DEFAULT_RETRY_AFTER_SECONDS - Static variable in class com.northconcepts.datapipeline.twitter2.AbstractTwitterReader
 
DefaultJobCallback - Class in com.northconcepts.datapipeline.job
A default implementation of JobCallback.
DefaultJobCallback() - Constructor for class com.northconcepts.datapipeline.job.DefaultJobCallback
 
delete() - Method in class com.northconcepts.datapipeline.core.Record
 
delete(int, int) - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer
 
deliverEvent(Event<T>) - Method in class com.northconcepts.datapipeline.eventbus.EventBus
 
DeMux - Class in com.northconcepts.datapipeline.multiplex
Converts a single source DataReader into many using one of the provided strategies.
DeMux(DataReader, DeMux.IStrategy) - Constructor for class com.northconcepts.datapipeline.multiplex.DeMux
 
DeMux.IStrategy - Interface in com.northconcepts.datapipeline.multiplex
 
DeMux.Strategy - Enum in com.northconcepts.datapipeline.multiplex
 
desc(String) - Method in class com.northconcepts.datapipeline.core.SortingReader
 
deserialize(JsonParser, DeserializationContext) - Method in class com.northconcepts.datapipeline.json.RecordJsonDeserializer
 
detail() - Method in class com.northconcepts.datapipeline.json.builder.JsonFragment
 
detail() - Method in class com.northconcepts.datapipeline.json.builder.JsonNode
 
detail() - Method in class com.northconcepts.datapipeline.json.builder.JsonValue
 
detail() - Method in class com.northconcepts.datapipeline.xml.builder.XmlNodeContainer
 
detectFileType() - Method in class com.northconcepts.datapipeline.foundations.file.LocalFile
 
detectFileType() - Method in class com.northconcepts.datapipeline.foundations.file.LocalFileSink
 
detectFileType() - Method in class com.northconcepts.datapipeline.foundations.file.LocalFileSource
 
Diagnostic - Class in com.northconcepts.datapipeline.diagnostic
Helps diagnose environmental issues by collecting properties and logging them to the console.
Diagnostic() - Constructor for class com.northconcepts.datapipeline.diagnostic.Diagnostic
 
discard(Record, Filter) - Method in class com.northconcepts.datapipeline.filter.FilteringReader
 
discard(Record, Filter) - Method in class com.northconcepts.datapipeline.validate.ValidatingReader
 
displayText - Variable in enum com.northconcepts.datapipeline.foundations.pipeline.action.transform.AddFieldsAction.FieldType
 
DRAFTS - Static variable in interface com.northconcepts.datapipeline.email.GmailFolders
 

E

E - Static variable in class com.northconcepts.datapipeline.meter.Meter
 
ElapsedTimeSequenceStrategy(long) - Constructor for class com.northconcepts.datapipeline.core.SequenceWriter.ElapsedTimeSequenceStrategy
 
element(String) - Method in class com.northconcepts.datapipeline.xml.builder.XmlNodeContainer
 
EmailReadDirection - Enum in com.northconcepts.datapipeline.email
 
EmailReader - Class in com.northconcepts.datapipeline.email
Reads emails (and their attachments) from IMAP mailboxes.
EmailReader(MailStore, String, String, String) - Constructor for class com.northconcepts.datapipeline.email.EmailReader
 
EmailReader(MailStore, String, int, String, String) - Constructor for class com.northconcepts.datapipeline.email.EmailReader
 
EmailType - Enum in com.northconcepts.datapipeline.mailchimp.list
 
emptyToNull() - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer
Converts empty string to null, otherwise the original value is returned.
enableJmx() - Static method in class com.northconcepts.datapipeline.core.DataEndpoint
Turns JMX (Java Management Extensions) monitoring & management on and exposes running Jobs and EventBuses as managed beans.
encode(S) - Method in interface com.northconcepts.datapipeline.foundations.core.Encoder
 
encode(String) - Method in class com.northconcepts.datapipeline.foundations.core.Encoder.HexEncoder
 
encode(Object) - Method in class com.northconcepts.datapipeline.foundations.core.Encoder.NullEncoder
 
Encoder<S,T> - Interface in com.northconcepts.datapipeline.foundations.core
 
Encoder.HexEncoder - Class in com.northconcepts.datapipeline.foundations.core
 
Encoder.NullEncoder - Class in com.northconcepts.datapipeline.foundations.core
 
endArray(ArrayValue) - Method in interface com.northconcepts.datapipeline.core.INodeVisitor
 
endArray(ArrayValue) - Method in class com.northconcepts.datapipeline.core.NodeVisitor
 
endArray(ArrayValue) - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer.SingleValueOperation
 
endArrayValue(ArrayValue, int, ValueNode<?>) - Method in interface com.northconcepts.datapipeline.core.INodeVisitor
 
endArrayValue(ArrayValue, int, ValueNode<?>) - Method in class com.northconcepts.datapipeline.core.NodeVisitor
 
endArrayValue(ArrayValue, int, ValueNode<?>) - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer.SingleValueOperation
 
endField(Field) - Method in interface com.northconcepts.datapipeline.core.INodeVisitor
 
endField(Field) - Method in class com.northconcepts.datapipeline.core.NodeVisitor
 
endField(Field) - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer.SingleValueOperation
 
endFieldValue(Field, ValueNode<?>) - Method in interface com.northconcepts.datapipeline.core.INodeVisitor
 
endFieldValue(Field, ValueNode<?>) - Method in class com.northconcepts.datapipeline.core.NodeVisitor
 
endFieldValue(Field, ValueNode<?>) - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer.SingleValueOperation
 
Endpoint - Class in com.northconcepts.datapipeline.core
 
Endpoint() - Constructor for class com.northconcepts.datapipeline.core.Endpoint
 
endRecord(Record) - Method in interface com.northconcepts.datapipeline.core.INodeVisitor
 
endRecord(Record) - Method in class com.northconcepts.datapipeline.core.NodeVisitor
 
endRecord(Record) - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer.SingleValueOperation
 
endSequence(SequenceWriter.Sequence, Record) - Method in class com.northconcepts.datapipeline.core.SequenceWriter.ElapsedTimeSequenceStrategy
 
endSequence(SequenceWriter.Sequence, Record) - Method in interface com.northconcepts.datapipeline.core.SequenceWriter.ISequenceStrategy
 
endSequence(SequenceWriter.Sequence, Record) - Method in class com.northconcepts.datapipeline.core.SequenceWriter.OrSequenceStrategy
 
endSequence(SequenceWriter.Sequence, Record) - Method in class com.northconcepts.datapipeline.core.SequenceWriter.RecordCountSequenceStrategy
 
endSequence(SequenceWriter.Sequence, Record) - Method in class com.northconcepts.datapipeline.core.SequenceWriter.SchedulerSequenceStrategy
 
ensureCapacity(int) - Method in class com.northconcepts.datapipeline.core.ArrayValue
 
ensureFields(String...) - Method in class com.northconcepts.datapipeline.core.Record
 
ensureFields(Collection<String>) - Method in class com.northconcepts.datapipeline.core.Record
 
entitiesToArray(TweetEntity[], String) - Method in interface com.northconcepts.datapipeline.twitter.ITwitterConverter
 
entitiesToArray(TweetEntity[], String) - Method in class com.northconcepts.datapipeline.twitter.TwitterConverter
 
entitiesToString(TweetEntity[], String, String) - Method in interface com.northconcepts.datapipeline.twitter.ITwitterConverter
 
entitiesToString(TweetEntity[], String, String) - Method in class com.northconcepts.datapipeline.twitter.TwitterConverter
 
EntityDef - Class in com.northconcepts.datapipeline.foundations.schema
 
EntityDef() - Constructor for class com.northconcepts.datapipeline.foundations.schema.EntityDef
 
EntityDef(String) - Constructor for class com.northconcepts.datapipeline.foundations.schema.EntityDef
 
EntityExpansionPolicy - Enum in com.northconcepts.datapipeline.twitter
Indicates how multi-valued values should be returned.
entityToString(TweetEntity) - Method in interface com.northconcepts.datapipeline.twitter.ITwitterConverter
 
entityToString(TweetEntity) - Method in class com.northconcepts.datapipeline.twitter.TwitterConverter
 
EOF - Static variable in interface com.northconcepts.datapipeline.core.IParser
 
EOF - Static variable in class com.northconcepts.datapipeline.core.PipedWriter
 
EOF - Static variable in class com.northconcepts.datapipeline.core.TextReader
 
EOF - Static variable in class com.northconcepts.datapipeline.multiplex.DeMux
 
EOF - Static variable in class com.northconcepts.datapipeline.multiplex.SplitWriter
 
EOF - Static variable in class com.northconcepts.datapipeline.twitter.TwitterProxyReader
 
EOF - Static variable in class com.northconcepts.datapipeline.twitter.TwitterReader
 
EOF - Static variable in class com.northconcepts.datapipeline.twitter.TwitterWriter
 
EOF - Static variable in class com.northconcepts.datapipeline.twitter2.TwitterFilterStreamReader
 
equals(Object) - Method in class com.northconcepts.datapipeline.core.ArrayValue
 
equals(Object) - Method in class com.northconcepts.datapipeline.core.CompositeValue
 
equals(Object) - Method in class com.northconcepts.datapipeline.core.Field
 
equals(Object, Collator) - Method in class com.northconcepts.datapipeline.core.Field
 
equals(Object) - Method in class com.northconcepts.datapipeline.core.FieldDeclarations
 
equals(Object) - Method in class com.northconcepts.datapipeline.core.FieldList
 
equals(Object) - Method in class com.northconcepts.datapipeline.core.FieldPath
 
equals(Object) - Method in class com.northconcepts.datapipeline.core.Record
 
equals(Record, RecordComparator) - Method in class com.northconcepts.datapipeline.core.Record
 
equals(Object) - Method in class com.northconcepts.datapipeline.core.SingleValue
 
escapeJavaString(String) - Static method in class com.northconcepts.datapipeline.foundations.pipeline.action.PipelineAction
 
evaluate(String) - Method in class com.northconcepts.datapipeline.core.Record
 
evaluate(ExpressionContext) - Method in class com.northconcepts.datapipeline.foundations.decisiontable.DecisionTable
 
evaluate(ExpressionContext) - Method in class com.northconcepts.datapipeline.foundations.decisiontable.DecisionTableCondition
 
evaluate(ExpressionContext, Record) - Method in class com.northconcepts.datapipeline.foundations.decisiontable.DecisionTableOutcome
 
evaluate(ExpressionContext) - Method in class com.northconcepts.datapipeline.foundations.decisiontable.DecisionTableRule
 
evaluate(ExpressionContext) - Method in class com.northconcepts.datapipeline.foundations.decisiontree.DecisionTree
 
evaluate(ExpressionContext, Record) - Method in class com.northconcepts.datapipeline.foundations.decisiontree.DecisionTreeOutcome
 
evaluate(DefaultExpressionContext) - Method in class com.northconcepts.datapipeline.foundations.expression.CalculatedField
 
evaluate() - Method in class com.northconcepts.datapipeline.group.AggregateReader.AggregateOperation
Deprecated.
 
evaluate(ExpressionContext) - Method in class com.northconcepts.datapipeline.json.builder.JsonExpression
 
evaluateOutcome(ExpressionContext, Record) - Method in class com.northconcepts.datapipeline.foundations.decisiontable.DecisionTableRule
 
Event<T> - Class in com.northconcepts.datapipeline.eventbus
 
Event(Object, Object, Class<T>, Object, Method, Object[]) - Constructor for class com.northconcepts.datapipeline.eventbus.Event
 
EventBus - Class in com.northconcepts.datapipeline.eventbus
An asynchronous, in-memory, event delivery service.
EventBus(ExecutorService) - Constructor for class com.northconcepts.datapipeline.eventbus.EventBus
Creates a bus using the specified ExecutorService to deliver events to listeners.
EventBus() - Constructor for class com.northconcepts.datapipeline.eventbus.EventBus
Creates a bus using a single thread to deliver events.
EventBus.State - Enum in com.northconcepts.datapipeline.eventbus
 
EventBusLifecycleListener - Interface in com.northconcepts.datapipeline.eventbus
 
EventBusReader - Class in com.northconcepts.datapipeline.eventbus
 
EventBusReader(EventBus, Object...) - Constructor for class com.northconcepts.datapipeline.eventbus.EventBusReader
 
EventBusReader(EventBus, int, Object...) - Constructor for class com.northconcepts.datapipeline.eventbus.EventBusReader
 
EventBusWriter - Class in com.northconcepts.datapipeline.eventbus
Writes records to an event bus under a specific topic.
EventBusWriter(EventBus, Object) - Constructor for class com.northconcepts.datapipeline.eventbus.EventBusWriter
Creates a new EventBusWriter.
EventFilter - Interface in com.northconcepts.datapipeline.eventbus
 
EventListenerClassFilter - Class in com.northconcepts.datapipeline.eventbus.filter
 
EventListenerClassFilter(Class<?>...) - Constructor for class com.northconcepts.datapipeline.eventbus.filter.EventListenerClassFilter
 
EventSourceFilter - Class in com.northconcepts.datapipeline.eventbus.filter
 
EventSourceFilter(Object...) - Constructor for class com.northconcepts.datapipeline.eventbus.filter.EventSourceFilter
 
EventSourceInvocationHandler<T> - Class in com.northconcepts.datapipeline.eventbus
 
EventSourceInvocationHandler(EventBus, Object, Class<T>, Object) - Constructor for class com.northconcepts.datapipeline.eventbus.EventSourceInvocationHandler
 
ExcelDocument - Class in com.northconcepts.datapipeline.excel
The in-memory abstraction for an Excel workbook.
ExcelDocument() - Constructor for class com.northconcepts.datapipeline.excel.ExcelDocument
 
ExcelDocument(ExcelDocument.ProviderType) - Constructor for class com.northconcepts.datapipeline.excel.ExcelDocument
 
ExcelDocument.ProviderType - Enum in com.northconcepts.datapipeline.excel
 
ExcelPipelineInput - Class in com.northconcepts.datapipeline.foundations.pipeline.input
 
ExcelPipelineInput() - Constructor for class com.northconcepts.datapipeline.foundations.pipeline.input.ExcelPipelineInput
 
ExcelPipelineOutput - Class in com.northconcepts.datapipeline.foundations.pipeline.output
 
ExcelPipelineOutput() - Constructor for class com.northconcepts.datapipeline.foundations.pipeline.output.ExcelPipelineOutput
 
ExcelReader - Class in com.northconcepts.datapipeline.excel
Obtains records from a Microsoft Excel document.
ExcelReader(ExcelDocument) - Constructor for class com.northconcepts.datapipeline.excel.ExcelReader
 
ExcelWriter - Class in com.northconcepts.datapipeline.excel
Writes records to a Microsoft Excel document.
ExcelWriter(ExcelDocument) - Constructor for class com.northconcepts.datapipeline.excel.ExcelWriter
 
exception(String, Throwable) - Method in class com.northconcepts.datapipeline.core.AsyncReader
 
exception(Throwable) - Method in class com.northconcepts.datapipeline.core.AsyncReader
 
exception(String) - Method in class com.northconcepts.datapipeline.core.AsyncReader
 
exception(String, Throwable) - Method in class com.northconcepts.datapipeline.core.AsyncWriter
 
exception(Throwable) - Method in class com.northconcepts.datapipeline.core.AsyncWriter
 
exception(String) - Method in class com.northconcepts.datapipeline.core.AsyncWriter
 
exception(String, Throwable) - Method in class com.northconcepts.datapipeline.core.DataObject
Converts an exception to a DataException, prefixing the original message with the specified text and adding this endpoint's properties (name-value pairs).
exception(Throwable) - Method in class com.northconcepts.datapipeline.core.DataObject
Converts an exception to a DataException and adds this endpoint's properties (name-value pairs).
exception(String) - Method in class com.northconcepts.datapipeline.core.DataObject
Creates an exception with the specified message and containing this endpoint's properties (name-value pairs).
exception(Throwable) - Method in interface com.northconcepts.datapipeline.core.IParser
 
exception(Throwable) - Method in class com.northconcepts.datapipeline.core.LineParser
 
exception(Throwable) - Method in class com.northconcepts.datapipeline.core.Parser
 
exception(Throwable) - Method in class com.northconcepts.datapipeline.core.StringParser
 
exception(String, Throwable) - Method in class com.northconcepts.datapipeline.foundations.core.FoundationObject
Converts an exception to a DataException, prefixing the original message with the specified text and adding this endpoint's properties (name-value pairs).
exception(Throwable) - Method in class com.northconcepts.datapipeline.foundations.core.FoundationObject
Converts an exception to a DataException and adds this endpoint's properties (name-value pairs).
exception(String) - Method in class com.northconcepts.datapipeline.foundations.core.FoundationObject
Creates an exception with the specified message and containing this endpoint's properties (name-value pairs).
exception(Throwable) - Method in class com.northconcepts.datapipeline.json.builder.JsonConditionalNode
 
exception(Throwable) - Method in class com.northconcepts.datapipeline.json.builder.JsonField
 
exception(Throwable) - Method in class com.northconcepts.datapipeline.json.builder.JsonFragment
 
exception(Throwable) - Method in class com.northconcepts.datapipeline.json.builder.JsonNode
 
exception(Throwable) - Method in class com.northconcepts.datapipeline.json.builder.JsonPrimitive
 
ExceptionListener - Interface in com.northconcepts.datapipeline.eventbus
 
exceptionMappingValue(String, String, Object, FieldType) - Static method in class com.northconcepts.datapipeline.foundations.i18n.SchemaMessages
 
excludeFields(FieldList) - Method in class com.northconcepts.datapipeline.core.Record
 
excludeFields(Set<String>) - Method in class com.northconcepts.datapipeline.core.Record
 
excludeFields(Iterable<FieldPath>) - Method in class com.northconcepts.datapipeline.core.Record
 
ExcludeFields - Class in com.northconcepts.datapipeline.transform
Deprecated.
ExcludeFields(Collection<String>) - Constructor for class com.northconcepts.datapipeline.transform.ExcludeFields
Deprecated.
 
ExcludeFields(String...) - Constructor for class com.northconcepts.datapipeline.transform.ExcludeFields
Deprecated.
 
executeBatch() - Method in interface com.northconcepts.datapipeline.jdbc.insert.IInsert
 
executeBatch() - Method in class com.northconcepts.datapipeline.jdbc.insert.MultiRowPreparedStatementInsert
 
executeBatch() - Method in class com.northconcepts.datapipeline.jdbc.insert.MultiRowStatementInsert
 
executeBatch() - Method in class com.northconcepts.datapipeline.jdbc.insert.PreparedStatementInsert
 
executeBatch() - Method in class com.northconcepts.datapipeline.jdbc.upsert.GenericUpsert
 
executeBatch() - Method in interface com.northconcepts.datapipeline.jdbc.upsert.IUpsert
 
executeBatch() - Method in class com.northconcepts.datapipeline.jdbc.upsert.MergeUpsert
 
executeBatch() - Method in class com.northconcepts.datapipeline.jdbc.upsert.MySqlUpsert
 
executeBatch() - Method in class com.northconcepts.datapipeline.jdbc.upsert.OracleUpsert
 
executeBatch() - Method in class com.northconcepts.datapipeline.jdbc.upsert.PostgreSqlUpsert
 
executeBatch() - Method in class com.northconcepts.datapipeline.jdbc.upsert.SybaseUpsert
 
executeBatch() - Method in class com.northconcepts.datapipeline.jdbc.upsert.VariableFieldsUpsert
 
executeUpdate() - Method in interface com.northconcepts.datapipeline.jdbc.insert.IInsert
 
executeUpdate() - Method in class com.northconcepts.datapipeline.jdbc.insert.MultiRowPreparedStatementInsert
 
executeUpdate() - Method in class com.northconcepts.datapipeline.jdbc.insert.MultiRowStatementInsert
 
executeUpdate() - Method in class com.northconcepts.datapipeline.jdbc.insert.PreparedStatementInsert
 
executeUpdate() - Method in class com.northconcepts.datapipeline.jdbc.upsert.GenericUpsert
 
executeUpdate() - Method in interface com.northconcepts.datapipeline.jdbc.upsert.IUpsert
 
executeUpdate() - Method in class com.northconcepts.datapipeline.jdbc.upsert.MergeUpsert
 
executeUpdate() - Method in class com.northconcepts.datapipeline.jdbc.upsert.MySqlUpsert
 
executeUpdate() - Method in class com.northconcepts.datapipeline.jdbc.upsert.OracleUpsert
 
executeUpdate() - Method in class com.northconcepts.datapipeline.jdbc.upsert.PostgreSqlUpsert
 
executeUpdate() - Method in class com.northconcepts.datapipeline.jdbc.upsert.SybaseUpsert
 
executeUpdate() - Method in class com.northconcepts.datapipeline.jdbc.upsert.VariableFieldsUpsert
 
expandAndPushRecords(Record) - Method in class com.northconcepts.datapipeline.xml.XmlReader
 
expandEntities(TweetEntity[], String, ITwitterConverter) - Method in interface com.northconcepts.datapipeline.twitter.IEntityExpansionPolicy
 
expandListFieldsAsFields(Record) - Method in class com.northconcepts.datapipeline.xml.XmlReader
 
ExpressionHelper - Class in com.northconcepts.datapipeline.expression
 

F

Field - Class in com.northconcepts.datapipeline.core
Field holds persistent key-value data as part of a record.
Field(Record) - Constructor for class com.northconcepts.datapipeline.core.Field
 
field(String, String) - Method in class com.northconcepts.datapipeline.json.builder.JsonConditionalNode
 
field(String, String) - Method in class com.northconcepts.datapipeline.json.builder.JsonDetailMarker
 
field(String, String) - Method in class com.northconcepts.datapipeline.json.builder.JsonNode
 
field(String, String) - Method in class com.northconcepts.datapipeline.json.builder.JsonObject
 
FIELD_SCHEMA - Static variable in class com.northconcepts.datapipeline.lineage.FieldLineage
 
FieldComparator - Class in com.northconcepts.datapipeline.core
See FieldPath for supported field name expressions.
FieldComparator() - Constructor for class com.northconcepts.datapipeline.core.FieldComparator
 
FieldCount - Class in com.northconcepts.datapipeline.filter
A filter that checks for the total number of fields
FieldCount(int) - Constructor for class com.northconcepts.datapipeline.filter.FieldCount
 
FieldDeclarations - Class in com.northconcepts.datapipeline.core
 
FieldDeclarations() - Constructor for class com.northconcepts.datapipeline.core.FieldDeclarations
 
FieldDef - Class in com.northconcepts.datapipeline.foundations.schema
 
FieldDef() - Constructor for class com.northconcepts.datapipeline.foundations.schema.FieldDef
 
FieldDef(String, FieldType) - Constructor for class com.northconcepts.datapipeline.foundations.schema.FieldDef
 
FieldExists - Class in com.northconcepts.datapipeline.filter
A filter that checks if all the specified field exists.
FieldExists(String...) - Constructor for class com.northconcepts.datapipeline.filter.FieldExists
 
FieldExists(String) - Constructor for class com.northconcepts.datapipeline.filter.FieldExists
 
FieldFilter - Class in com.northconcepts.datapipeline.filter
See FieldPath for supported field name expressions.
FieldFilter(String...) - Constructor for class com.northconcepts.datapipeline.filter.FieldFilter
 
FieldFilter(String) - Constructor for class com.northconcepts.datapipeline.filter.FieldFilter
 
FieldFilter(String, FieldFilterRule...) - Constructor for class com.northconcepts.datapipeline.filter.FieldFilter
 
FieldFilterRule - Class in com.northconcepts.datapipeline.filter
 
FieldFilterRule() - Constructor for class com.northconcepts.datapipeline.filter.FieldFilterRule
 
fieldIsWrongType(String, FieldType, FieldType) - Static method in class com.northconcepts.datapipeline.foundations.i18n.SchemaMessages
 
FieldKeyValuePair - Class in com.northconcepts.datapipeline.template
 
FieldKeyValuePair() - Constructor for class com.northconcepts.datapipeline.template.FieldKeyValuePair
 
FieldKeyValuePair(Field, ObjectWrapper) - Constructor for class com.northconcepts.datapipeline.template.FieldKeyValuePair
 
FieldKeyValuePairIterator - Class in com.northconcepts.datapipeline.template
 
FieldKeyValuePairIterator() - Constructor for class com.northconcepts.datapipeline.template.FieldKeyValuePairIterator
 
FieldKeyValuePairIterator(Record, ObjectWrapper) - Constructor for class com.northconcepts.datapipeline.template.FieldKeyValuePairIterator
 
fieldLineage - Variable in class com.northconcepts.datapipeline.core.DataReader
 
FieldLineage - Class in com.northconcepts.datapipeline.lineage
 
FieldLineage() - Constructor for class com.northconcepts.datapipeline.lineage.FieldLineage
 
FieldLineage(Field) - Constructor for class com.northconcepts.datapipeline.lineage.FieldLineage
 
FieldList - Class in com.northconcepts.datapipeline.core
See FieldPath for supported field name expressions.
FieldList(String...) - Constructor for class com.northconcepts.datapipeline.core.FieldList
 
FieldMapping - Class in com.northconcepts.datapipeline.foundations.datamapping
 
FieldMapping() - Constructor for class com.northconcepts.datapipeline.foundations.datamapping.FieldMapping
 
FieldMapping(String, String) - Constructor for class com.northconcepts.datapipeline.foundations.datamapping.FieldMapping
 
FieldMapping(String, String) - Constructor for class com.northconcepts.datapipeline.foundations.pipeline.action.transform.CopyFieldsAction.FieldMapping
 
FieldMapping(String, String, boolean) - Constructor for class com.northconcepts.datapipeline.foundations.pipeline.action.transform.CopyFieldsAction.FieldMapping
 
FieldMapping() - Constructor for class com.northconcepts.datapipeline.foundations.pipeline.action.transform.RenameFieldsAction.FieldMapping
 
FieldMapping(String, String) - Constructor for class com.northconcepts.datapipeline.foundations.pipeline.action.transform.RenameFieldsAction.FieldMapping
 
fieldName - Variable in class com.northconcepts.datapipeline.group.AggregateReader.AggregateOperation
Deprecated.
 
fieldNames - Variable in class com.northconcepts.datapipeline.core.AbstractReader
 
FieldNotExists - Class in com.northconcepts.datapipeline.filter
A filter that checks if all the specified field does not exist.
FieldNotExists(String...) - Constructor for class com.northconcepts.datapipeline.filter.FieldNotExists
 
FieldNotExists(String) - Constructor for class com.northconcepts.datapipeline.filter.FieldNotExists
 
FieldPath - Class in com.northconcepts.datapipeline.core
An abstract representation for the location of a field within a record.
FieldPath() - Constructor for class com.northconcepts.datapipeline.core.FieldPath
 
fields - Variable in class com.northconcepts.datapipeline.xml.XmlReader
 
FieldTransformer - Class in com.northconcepts.datapipeline.transform
See FieldPath for supported field name expressions.
FieldTransformer(String...) - Constructor for class com.northconcepts.datapipeline.transform.FieldTransformer
 
FieldTransformer(String) - Constructor for class com.northconcepts.datapipeline.transform.FieldTransformer
 
FieldTransformer(Collection<String>) - Constructor for class com.northconcepts.datapipeline.transform.FieldTransformer
 
FieldType - Enum in com.northconcepts.datapipeline.core
FieldType lists of all field data types used in records.
fieldTypeIsNotBinary(String, FieldType) - Static method in class com.northconcepts.datapipeline.foundations.i18n.SchemaMessages
 
fieldTypeIsNotBooelan(String, FieldType) - Static method in class com.northconcepts.datapipeline.foundations.i18n.SchemaMessages
 
fieldTypeIsNotNumeric(String, FieldType) - Static method in class com.northconcepts.datapipeline.foundations.i18n.SchemaMessages
 
fieldTypeIsNotTemporal(String, FieldType) - Static method in class com.northconcepts.datapipeline.foundations.i18n.SchemaMessages
 
fieldTypeIsNotText(String, FieldType) - Static method in class com.northconcepts.datapipeline.foundations.i18n.SchemaMessages
 
FILE - Static variable in class com.northconcepts.datapipeline.lineage.RecordLineage
 
file - Variable in class com.northconcepts.datapipeline.xml.XmlReader
 
FILE_COLUMN_NUMBER - Static variable in class com.northconcepts.datapipeline.lineage.RecordLineage
 
FILE_LINE_NUMBER - Static variable in class com.northconcepts.datapipeline.lineage.RecordLineage
 
FileDetector - Class in com.northconcepts.datapipeline.foundations.file
 
FileDetector(File) - Constructor for class com.northconcepts.datapipeline.foundations.file.FileDetector
 
FileDetector(InputStream) - Constructor for class com.northconcepts.datapipeline.foundations.file.FileDetector
 
FileDetector(InputStream, String) - Constructor for class com.northconcepts.datapipeline.foundations.file.FileDetector
 
FileReader - Class in com.northconcepts.datapipeline.file
Obtains records from a binary stream previously written using a FileWriter.
FileReader(File, boolean) - Constructor for class com.northconcepts.datapipeline.file.FileReader
 
FileReader(InputStream, boolean) - Constructor for class com.northconcepts.datapipeline.file.FileReader
 
FileReader(File) - Constructor for class com.northconcepts.datapipeline.file.FileReader
 
FileReader(DataInput) - Constructor for class com.northconcepts.datapipeline.file.FileReader
 
FileSink - Interface in com.northconcepts.datapipeline.foundations.file
 
FileSinkPipelineOutput - Class in com.northconcepts.datapipeline.foundations.pipeline.output
 
FileSinkPipelineOutput() - Constructor for class com.northconcepts.datapipeline.foundations.pipeline.output.FileSinkPipelineOutput
 
FileSource - Interface in com.northconcepts.datapipeline.foundations.file
 
FileSourcePipelineInput - Class in com.northconcepts.datapipeline.foundations.pipeline.input
 
FileSourcePipelineInput() - Constructor for class com.northconcepts.datapipeline.foundations.pipeline.input.FileSourcePipelineInput
 
FileSystem - Class in com.northconcepts.datapipeline.internal.lang
Abstract class for reading and writing to virtual file systems.
FileSystem() - Constructor for class com.northconcepts.datapipeline.internal.lang.FileSystem
 
FileSystemInfoReader - Class in com.northconcepts.datapipeline.file
Creates records from the metadata of files within a directory.
FileSystemInfoReader(File) - Constructor for class com.northconcepts.datapipeline.file.FileSystemInfoReader
 
FileType - Enum in com.northconcepts.datapipeline.foundations.file
 
FileWriter - Class in com.northconcepts.datapipeline.file
Writes records to a binary stream that can be later read using a FileReader.
FileWriter(File, boolean, boolean) - Constructor for class com.northconcepts.datapipeline.file.FileWriter
 
FileWriter(OutputStream, boolean) - Constructor for class com.northconcepts.datapipeline.file.FileWriter
 
FileWriter(File, boolean) - Constructor for class com.northconcepts.datapipeline.file.FileWriter
 
FileWriter(File) - Constructor for class com.northconcepts.datapipeline.file.FileWriter
 
FileWriter(DataOutput) - Constructor for class com.northconcepts.datapipeline.file.FileWriter
 
fillCache() - Method in class com.northconcepts.datapipeline.core.AsyncReader
 
fillRecord(Record) - Method in class com.northconcepts.datapipeline.core.AbstractReader
 
fillRecord(Record) - Method in class com.northconcepts.datapipeline.core.ParsingReader
 
fillRecord(Record) - Method in class com.northconcepts.datapipeline.csv.CSVReader
 
fillRecord(Record) - Method in class com.northconcepts.datapipeline.excel.ExcelReader
 
fillRecord(Record) - Method in class com.northconcepts.datapipeline.fixedwidth.FixedWidthReader
 
fillRecord(Record) - Method in class com.northconcepts.datapipeline.weblog.CombinedLogReader
 
Filter - Class in com.northconcepts.datapipeline.filter
 
Filter() - Constructor for class com.northconcepts.datapipeline.filter.Filter
 
FilterExpression - Class in com.northconcepts.datapipeline.filter
 
FilterExpression(String, FieldDeclarations) - Constructor for class com.northconcepts.datapipeline.filter.FilterExpression
 
FilterExpression(String) - Constructor for class com.northconcepts.datapipeline.filter.FilterExpression
 
FilterFieldExistsAction - Class in com.northconcepts.datapipeline.foundations.pipeline.action.filter
 
FilterFieldExistsAction() - Constructor for class com.northconcepts.datapipeline.foundations.pipeline.action.filter.FilterFieldExistsAction
 
FilterFieldMatchesPatternAction - Class in com.northconcepts.datapipeline.foundations.pipeline.action.filter
 
FilterFieldMatchesPatternAction() - Constructor for class com.northconcepts.datapipeline.foundations.pipeline.action.filter.FilterFieldMatchesPatternAction
 
FilterFieldNotNullAction - Class in com.northconcepts.datapipeline.foundations.pipeline.action.filter
 
FilterFieldNotNullAction() - Constructor for class com.northconcepts.datapipeline.foundations.pipeline.action.filter.FilterFieldNotNullAction
 
FilteringReader - Class in com.northconcepts.datapipeline.filter
A proxy that chooses records using a filter criteria.
FilteringReader(DataReader, DataWriter, String) - Constructor for class com.northconcepts.datapipeline.filter.FilteringReader
Accepts the DataReader to filter and the DataWriter to send discarded records to.
FilteringReader(DataReader, DataWriter) - Constructor for class com.northconcepts.datapipeline.filter.FilteringReader
Accepts the DataReader to filter and the DataWriter to send discarded records to.
FilteringReader(DataReader) - Constructor for class com.northconcepts.datapipeline.filter.FilteringReader
Accepts the DataReader to filter.
FilterMatchExpression - Class in com.northconcepts.datapipeline.foundations.pipeline.action.filter
 
FilterMatchExpression() - Constructor for class com.northconcepts.datapipeline.foundations.pipeline.action.filter.FilterMatchExpression
 
finalize() - Method in class com.northconcepts.datapipeline.core.Endpoint
Closes this endpoint if it's still open.
finalize() - Method in class com.northconcepts.datapipeline.eventbus.EventBus
 
finalize() - Method in class com.northconcepts.datapipeline.foundations.pipeline.dataset.Dataset
 
findAll(Filter) - Method in class com.northconcepts.datapipeline.core.ConcurrentRecordList
 
findAll(Filter) - Method in class com.northconcepts.datapipeline.core.RecordList
 
findFirst(Filter, int) - Method in class com.northconcepts.datapipeline.core.ConcurrentRecordList
 
findFirst(Filter, int) - Method in class com.northconcepts.datapipeline.core.RecordList
 
findLast(Filter, int) - Method in class com.northconcepts.datapipeline.core.ConcurrentRecordList
 
findLast(Filter, int) - Method in class com.northconcepts.datapipeline.core.RecordList
 
first(String, String, boolean) - Method in class com.northconcepts.datapipeline.group.GroupByReader
 
first(String, String) - Method in class com.northconcepts.datapipeline.group.GroupByReader
 
first(String, boolean) - Method in class com.northconcepts.datapipeline.group.GroupByReader
 
FIRST_PAGE - Static variable in class com.northconcepts.datapipeline.twitter.TwitterPageableReader
 
FixedWidthAlign - Enum in com.northconcepts.datapipeline.fixedwidth
 
FixedWidthReader - Class in com.northconcepts.datapipeline.fixedwidth
Obtains records from a fixed width stream.
FixedWidthReader(File) - Constructor for class com.northconcepts.datapipeline.fixedwidth.FixedWidthReader
 
FixedWidthReader(Reader) - Constructor for class com.northconcepts.datapipeline.fixedwidth.FixedWidthReader
 
FixedWidthWriter - Class in com.northconcepts.datapipeline.fixedwidth
Writes records to a fixed width stream.
FixedWidthWriter(File, boolean) - Constructor for class com.northconcepts.datapipeline.fixedwidth.FixedWidthWriter
 
FixedWidthWriter(File) - Constructor for class com.northconcepts.datapipeline.fixedwidth.FixedWidthWriter
 
FixedWidthWriter(Writer) - Constructor for class com.northconcepts.datapipeline.fixedwidth.FixedWidthWriter
 
FlattenRecord - Class in com.northconcepts.datapipeline.transform
Flattens an array field by creating one record for each value.
FlattenRecord() - Constructor for class com.northconcepts.datapipeline.transform.FlattenRecord
 
flattenToString(String) - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer
 
forceValueAsArray() - Method in class com.northconcepts.datapipeline.core.Field
Converts this field's value to an array if it's not already one, otherwise no change is made.
FoundationMessages - Class in com.northconcepts.datapipeline.foundations.i18n
 
FoundationMessages() - Constructor for class com.northconcepts.datapipeline.foundations.i18n.FoundationMessages
 
FoundationObject - Class in com.northconcepts.datapipeline.foundations.core
Abstract super-class for DP Foundation classes that require a consistent error handling mechanism.
FoundationObject() - Constructor for class com.northconcepts.datapipeline.foundations.core.FoundationObject
 
from(FieldType, Object) - Static method in class com.northconcepts.datapipeline.core.ValueNode
 
fromArray(Object) - Static method in class com.northconcepts.datapipeline.core.ArrayValue
 
fromBinary(byte[]) - Static method in class com.northconcepts.datapipeline.core.Record
 
fromBinary(InputStream) - Static method in class com.northconcepts.datapipeline.core.Record
 
fromBinary(DataInput) - Static method in class com.northconcepts.datapipeline.core.Record
 
fromJson(String) - Method in interface com.northconcepts.datapipeline.core.JsonSerializable
 
fromJson(InputStream) - Method in interface com.northconcepts.datapipeline.core.JsonSerializable
 
fromJson(String) - Static method in class com.northconcepts.datapipeline.core.Record
 
fromJson(Reader) - Static method in class com.northconcepts.datapipeline.core.Record
 
fromJson(String) - Method in interface com.northconcepts.datapipeline.core.RecordSerializable
 
fromJson(InputStream) - Method in interface com.northconcepts.datapipeline.core.RecordSerializable
 
fromJson(String) - Method in class com.northconcepts.datapipeline.foundations.datamapping.DataMapping
 
fromJson(InputStream) - Method in class com.northconcepts.datapipeline.foundations.datamapping.DataMapping
 
fromJson(String) - Method in class com.northconcepts.datapipeline.foundations.decisiontable.DecisionTable
 
fromJson(String) - Method in class com.northconcepts.datapipeline.foundations.decisiontree.DecisionTree
 
fromJson(String) - Method in class com.northconcepts.datapipeline.foundations.pipeline.AbstractPipeline
 
fromJson(String) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.CompositePipelineAction
 
fromJson(String) - Method in class com.northconcepts.datapipeline.foundations.pipeline.DataMappingPipeline
 
fromJson(InputStream) - Method in class com.northconcepts.datapipeline.foundations.pipeline.DataMappingPipeline
 
fromJson(File) - Static method in class com.northconcepts.datapipeline.foundations.pipeline.dataset.Tree
 
fromJson(String) - Method in class com.northconcepts.datapipeline.foundations.pipeline.Pipeline
 
fromJson(String) - Method in class com.northconcepts.datapipeline.foundations.schema.EntityDef
 
fromJson(String) - Method in class com.northconcepts.datapipeline.foundations.schema.FieldDef
 
fromJson(String) - Method in class com.northconcepts.datapipeline.foundations.schema.SchemaDef
 
fromJson(InputStream) - Method in class com.northconcepts.datapipeline.foundations.schema.SchemaDef
 
fromMinutes(int...) - Static method in class com.northconcepts.datapipeline.schedule.HourlyScheduler
 
fromMinutesPeriod(int, int) - Static method in class com.northconcepts.datapipeline.schedule.HourlyScheduler
 
fromName(String) - Static method in class com.northconcepts.datapipeline.core.FieldPath
Converts a single field name into a FieldPath.
fromRecord(Record) - Method in interface com.northconcepts.datapipeline.core.RecordSerializable
Loads this instance's state from a record and returns this (for fluid API call chaining).
fromRecord(Record) - Method in class com.northconcepts.datapipeline.foundations.core.Bean
 
fromRecord(Record) - Method in class com.northconcepts.datapipeline.foundations.core.Encoder.HexEncoder
 
fromRecord(Record) - Method in class com.northconcepts.datapipeline.foundations.core.Encoder.NullEncoder
 
fromRecord(Record) - Method in class com.northconcepts.datapipeline.foundations.core.Property
 
fromRecord(Record) - Method in class com.northconcepts.datapipeline.foundations.datamapping.AbstractFieldMapping
 
fromRecord(Record) - Method in class com.northconcepts.datapipeline.foundations.datamapping.DataMapping
 
fromRecord(Record) - Method in class com.northconcepts.datapipeline.foundations.datamapping.FieldMapping
 
fromRecord(Record) - Method in class com.northconcepts.datapipeline.foundations.decisiontable.DecisionTable
 
fromRecord(Record) - Method in class com.northconcepts.datapipeline.foundations.decisiontable.DecisionTableCondition
 
fromRecord(Record) - Method in class com.northconcepts.datapipeline.foundations.decisiontable.DecisionTableOutcome
 
fromRecord(Record) - Method in class com.northconcepts.datapipeline.foundations.decisiontable.DecisionTableRule
 
fromRecord(Record) - Method in class com.northconcepts.datapipeline.foundations.decisiontree.DecisionTree
 
fromRecord(Record) - Method in class com.northconcepts.datapipeline.foundations.decisiontree.DecisionTreeNode
 
fromRecord(Record) - Method in class com.northconcepts.datapipeline.foundations.decisiontree.DecisionTreeOutcome
 
fromRecord(Record) - Method in class com.northconcepts.datapipeline.foundations.expression.CalculatedField
 
fromRecord(Record) - Method in interface com.northconcepts.datapipeline.foundations.file.FileSink
 
fromRecord(Record) - Method in interface com.northconcepts.datapipeline.foundations.file.FileSource
 
fromRecord(Record) - Method in class com.northconcepts.datapipeline.foundations.file.LocalFile
 
fromRecord(Record) - Method in class com.northconcepts.datapipeline.foundations.file.LocalFileSink
 
fromRecord(Record) - Method in class com.northconcepts.datapipeline.foundations.file.LocalFileSource
 
fromRecord(Record) - Method in class com.northconcepts.datapipeline.foundations.jdbc.JdbcConnection
 
fromRecord(Record) - Method in class com.northconcepts.datapipeline.foundations.jdbc.JdbcExportedKey
 
fromRecord(Record) - Method in class com.northconcepts.datapipeline.foundations.jdbc.JdbcImportedKey
 
fromRecord(Record) - Method in class com.northconcepts.datapipeline.foundations.jdbc.JdbcQuery
 
fromRecord(Record) - Method in class com.northconcepts.datapipeline.foundations.jdbc.JdbcQueryColumn
 
fromRecord(Record) - Method in class com.northconcepts.datapipeline.foundations.jdbc.JdbcTable
 
fromRecord(Record) - Method in class com.northconcepts.datapipeline.foundations.jdbc.JdbcTableColumn
 
fromRecord(Record) - Method in class com.northconcepts.datapipeline.foundations.pipeline.AbstractPipeline
 
fromRecord(Record) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.aggregate.AggregateGroupFieldsAction
 
fromRecord(Record) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.CompositePipelineAction
 
fromRecord(Record) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.convert.ConvertDateTimeToStringAction
 
fromRecord(Record) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.convert.ConvertNullToValueAction
 
fromRecord(Record) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.convert.ConvertNumberToStringAction
 
fromRecord(Record) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.convert.ConvertStringToBooleanAction
 
fromRecord(Record) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.convert.ConvertStringToDateTimeAction
 
fromRecord(Record) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.convert.ConvertStringToNumberAction
 
fromRecord(Record) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.convert.ConvertValueToStringAction
 
fromRecord(Record) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.datamapping.DataMappingAction
 
fromRecord(Record) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.decision.DecisionTableAction
 
fromRecord(Record) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.decision.DecisionTreeAction
 
fromRecord(Record) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.filter.FilterFieldExistsAction
 
fromRecord(Record) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.filter.FilterFieldMatchesPatternAction
 
fromRecord(Record) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.filter.FilterFieldNotNullAction
 
fromRecord(Record) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.filter.FilterMatchExpression
 
fromRecord(Record) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.PipelineAction
 
fromRecord(Record) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.transform.AddFieldsAction
 
fromRecord(Record) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.transform.CopyFieldsAction
 
fromRecord(Record) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.transform.RenameFieldsAction
 
fromRecord(Record) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.transform.SelectArrangeFieldsAction
 
fromRecord(Record) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.transform.SortFieldsAction
 
fromRecord(Record) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.validate.ValidateFieldsExistsAction
 
fromRecord(Record) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.validate.ValidateFieldsMatchPatternAction
 
fromRecord(Record) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.validate.ValidateFieldsNotNullAction
 
fromRecord(Record) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.validate.ValidateMatchExpression
 
fromRecord(Record) - Method in class com.northconcepts.datapipeline.foundations.pipeline.DataMappingPipeline
 
fromRecord(Record) - Method in class com.northconcepts.datapipeline.foundations.pipeline.dataset.Dataset
 
fromRecord(Record) - Method in class com.northconcepts.datapipeline.foundations.pipeline.input.CsvPipelineInput
 
fromRecord(Record) - Method in class com.northconcepts.datapipeline.foundations.pipeline.input.DataReaderPipelineInput
 
fromRecord(Record) - Method in class com.northconcepts.datapipeline.foundations.pipeline.input.DatasetPipelineInput
 
fromRecord(Record) - Method in class com.northconcepts.datapipeline.foundations.pipeline.input.ExcelPipelineInput
 
fromRecord(Record) - Method in class com.northconcepts.datapipeline.foundations.pipeline.input.JdbcPipelineInput
 
fromRecord(Record) - Method in class com.northconcepts.datapipeline.foundations.pipeline.input.JsonPipelineInput
 
fromRecord(Record) - Method in class com.northconcepts.datapipeline.foundations.pipeline.input.JsonRecordPipelineInput
 
fromRecord(Record) - Method in class com.northconcepts.datapipeline.foundations.pipeline.input.XmlPipelineInput
 
fromRecord(Record) - Method in class com.northconcepts.datapipeline.foundations.pipeline.input.XmlRecordPipelineInput
 
fromRecord(Record) - Method in class com.northconcepts.datapipeline.foundations.pipeline.output.CsvPipelineOutput
 
fromRecord(Record) - Method in class com.northconcepts.datapipeline.foundations.pipeline.output.DataWriterPipelineOutput
 
fromRecord(Record) - Method in class com.northconcepts.datapipeline.foundations.pipeline.output.ExcelPipelineOutput
 
fromRecord(Record) - Method in class com.northconcepts.datapipeline.foundations.pipeline.output.JdbcPipelineOutput
 
fromRecord(Record) - Method in class com.northconcepts.datapipeline.foundations.pipeline.Pipeline
 
fromRecord(Record) - Method in class com.northconcepts.datapipeline.foundations.pipeline.PipelineInput
 
fromRecord(Record) - Method in class com.northconcepts.datapipeline.foundations.pipeline.PipelineOutput
 
fromRecord(Record) - Method in class com.northconcepts.datapipeline.foundations.schema.BinaryFieldDef
 
fromRecord(Record) - Method in class com.northconcepts.datapipeline.foundations.schema.BooleanFieldDef
 
fromRecord(Record) - Method in class com.northconcepts.datapipeline.foundations.schema.EntityDef
 
fromRecord(Record) - Method in class com.northconcepts.datapipeline.foundations.schema.FieldDef
 
fromRecord(Record) - Method in class com.northconcepts.datapipeline.foundations.schema.NumericFieldDef
 
fromRecord(Record) - Method in class com.northconcepts.datapipeline.foundations.schema.SchemaDef
 
fromRecord(Record) - Method in class com.northconcepts.datapipeline.foundations.schema.TemporalFieldDef
 
fromRecord(Record) - Method in class com.northconcepts.datapipeline.foundations.schema.TextFieldDef
 
fromRecord(Record) - Method in class com.northconcepts.datapipeline.foundations.schema.ValidationMessage
 
fromRecord(Record) - Method in class com.northconcepts.datapipeline.xml.XmlField
 
fromXml(String) - Static method in class com.northconcepts.datapipeline.core.Record
 
fromXml(Reader) - Static method in class com.northconcepts.datapipeline.core.Record
 
fromXml(String) - Method in interface com.northconcepts.datapipeline.core.XmlSerializable
 
fromXml(InputStream) - Method in interface com.northconcepts.datapipeline.core.XmlSerializable
 
fromXml(InputStream) - Method in class com.northconcepts.datapipeline.foundations.datamapping.DataMapping
 
fromXml(String) - Method in class com.northconcepts.datapipeline.foundations.datamapping.DataMapping
 
fromXml(InputStream) - Method in class com.northconcepts.datapipeline.foundations.decisiontable.DecisionTable
 
fromXml(InputStream) - Method in class com.northconcepts.datapipeline.foundations.decisiontree.DecisionTree
 
fromXml(InputStream) - Method in class com.northconcepts.datapipeline.foundations.pipeline.DataMappingPipeline
 
fromXml(String) - Method in class com.northconcepts.datapipeline.foundations.pipeline.DataMappingPipeline
 
fromXml(File) - Static method in class com.northconcepts.datapipeline.foundations.pipeline.dataset.Tree
 
fromXml(InputStream) - Method in class com.northconcepts.datapipeline.foundations.schema.SchemaDef
 
fromXml(String) - Method in class com.northconcepts.datapipeline.foundations.schema.SchemaDef
 
fromXmlElement(Element) - Method in interface com.northconcepts.datapipeline.core.XmlSerializable
 
fromXmlElement(Element) - Method in class com.northconcepts.datapipeline.foundations.datamapping.AbstractFieldMapping
 
fromXmlElement(Element) - Method in class com.northconcepts.datapipeline.foundations.datamapping.DataMapping
 
fromXmlElement(Element) - Method in class com.northconcepts.datapipeline.foundations.datamapping.FieldMapping
 
fromXmlElement(Element) - Method in class com.northconcepts.datapipeline.foundations.file.LocalFile
 
fromXmlElement(Element) - Method in class com.northconcepts.datapipeline.foundations.file.LocalFileSink
 
fromXmlElement(Element) - Method in class com.northconcepts.datapipeline.foundations.file.LocalFileSource
 
fromXmlElement(Element) - Method in class com.northconcepts.datapipeline.foundations.pipeline.AbstractPipeline
 
fromXmlElement(Element) - Method in class com.northconcepts.datapipeline.foundations.pipeline.DataMappingPipeline
 
fromXmlElement(Element) - Method in class com.northconcepts.datapipeline.foundations.pipeline.input.CsvPipelineInput
 
fromXmlElement(Element) - Method in class com.northconcepts.datapipeline.foundations.pipeline.input.ExcelPipelineInput
 
fromXmlElement(Element) - Method in class com.northconcepts.datapipeline.foundations.pipeline.input.JdbcPipelineInput
 
fromXmlElement(Element) - Method in class com.northconcepts.datapipeline.foundations.pipeline.input.JsonPipelineInput
 
fromXmlElement(Element) - Method in class com.northconcepts.datapipeline.foundations.pipeline.input.JsonRecordPipelineInput
 
fromXmlElement(Element) - Method in class com.northconcepts.datapipeline.foundations.pipeline.input.XmlPipelineInput
 
fromXmlElement(Element) - Method in class com.northconcepts.datapipeline.foundations.pipeline.input.XmlRecordPipelineInput
 
fromXmlElement(Element) - Method in class com.northconcepts.datapipeline.foundations.pipeline.output.CsvPipelineOutput
 
fromXmlElement(Element) - Method in class com.northconcepts.datapipeline.foundations.pipeline.output.ExcelPipelineOutput
 
fromXmlElement(Element) - Method in class com.northconcepts.datapipeline.foundations.pipeline.output.JdbcPipelineOutput
 
fromXmlElement(Element) - Method in class com.northconcepts.datapipeline.foundations.pipeline.Pipeline
 
fromXmlElement(Element) - Method in class com.northconcepts.datapipeline.foundations.schema.BinaryFieldDef
 
fromXmlElement(Element) - Method in class com.northconcepts.datapipeline.foundations.schema.EntityDef
 
fromXmlElement(Element) - Method in class com.northconcepts.datapipeline.foundations.schema.FieldDef
 
fromXmlElement(Element) - Method in class com.northconcepts.datapipeline.foundations.schema.NumericFieldDef
 
fromXmlElement(Element) - Method in class com.northconcepts.datapipeline.foundations.schema.SchemaDef
 
fromXmlElement(Element) - Method in class com.northconcepts.datapipeline.foundations.schema.TemporalFieldDef
 
fromXmlElement(Element) - Method in class com.northconcepts.datapipeline.foundations.schema.TextFieldDef
 
fromXmlElement(Element) - Method in class com.northconcepts.datapipeline.xml.XmlField
 
Functions - Class in com.northconcepts.datapipeline.core
Functions is the entry point for adding new method aliases to the dynamic expression language.

G

G - Static variable in class com.northconcepts.datapipeline.meter.Meter
 
geEndpoint() - Method in class com.northconcepts.datapipeline.transform.Transformer
 
generate(Set<String>) - Method in class com.northconcepts.datapipeline.foundations.tools.GenerateRecordSerializers
 
generateCode(CodeWriter, AggregateGroupFieldsAction.GroupByField) - Method in enum com.northconcepts.datapipeline.foundations.pipeline.action.aggregate.AggregateGroupFieldsAction.OperatorType
 
generateCode(JavaCodeBuilder, CodeWriter, String) - Method in enum com.northconcepts.datapipeline.foundations.pipeline.action.convert.ConvertNullToValueAction.FieldType
 
generateCode(CodeWriter, String, String) - Method in enum com.northconcepts.datapipeline.foundations.pipeline.action.transform.AddFieldsAction.FieldType
 
generateCodeByFunction(CodeWriter, AggregateGroupFieldsAction.GroupByField, String) - Method in enum com.northconcepts.datapipeline.foundations.pipeline.action.aggregate.AggregateGroupFieldsAction.OperatorType
 
generateCodeForNonNull(CodeWriter, String, String) - Method in enum com.northconcepts.datapipeline.foundations.pipeline.action.transform.AddFieldsAction.FieldType
 
generateJavaCode(JavaCodeBuilder) - Method in class com.northconcepts.datapipeline.foundations.pipeline.AbstractPipeline
 
generateJavaCode(JavaCodeBuilder) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.aggregate.AggregateGroupFieldsAction
 
generateJavaCode(JavaCodeBuilder) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.CompositePipelineAction
 
generateJavaCode(JavaCodeBuilder) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.convert.ConvertDateTimeToStringAction
 
generateJavaCode(JavaCodeBuilder) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.convert.ConvertNullToValueAction
 
generateJavaCode(JavaCodeBuilder) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.convert.ConvertNumberToStringAction
 
generateJavaCode(JavaCodeBuilder) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.convert.ConvertStringToBooleanAction
 
generateJavaCode(JavaCodeBuilder) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.convert.ConvertStringToDateTimeAction
 
generateJavaCode(JavaCodeBuilder) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.convert.ConvertStringToNumberAction
 
generateJavaCode(JavaCodeBuilder) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.convert.ConvertValueToStringAction
 
generateJavaCode(JavaCodeBuilder) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.datamapping.DataMappingAction
 
generateJavaCode(JavaCodeBuilder) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.decision.DecisionTableAction
 
generateJavaCode(JavaCodeBuilder) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.decision.DecisionTreeAction
 
generateJavaCode(JavaCodeBuilder) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.filter.FilterFieldExistsAction
 
generateJavaCode(JavaCodeBuilder) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.filter.FilterFieldMatchesPatternAction
 
generateJavaCode(JavaCodeBuilder) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.filter.FilterFieldNotNullAction
 
generateJavaCode(JavaCodeBuilder) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.filter.FilterMatchExpression
 
generateJavaCode(JavaCodeBuilder) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.PipelineAction
 
generateJavaCode(JavaCodeBuilder) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.transform.AddFieldsAction
 
generateJavaCode(JavaCodeBuilder) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.transform.CopyFieldsAction
 
generateJavaCode(JavaCodeBuilder) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.transform.RenameFieldsAction
 
generateJavaCode(JavaCodeBuilder) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.transform.SelectArrangeFieldsAction
 
generateJavaCode(JavaCodeBuilder) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.transform.SortFieldsAction
 
generateJavaCode(JavaCodeBuilder) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.validate.ValidateFieldsExistsAction
 
generateJavaCode(JavaCodeBuilder) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.validate.ValidateFieldsMatchPatternAction
 
generateJavaCode(JavaCodeBuilder) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.validate.ValidateFieldsNotNullAction
 
generateJavaCode(JavaCodeBuilder) - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.validate.ValidateMatchExpression
 
generateJavaCode(JavaCodeBuilder) - Method in class com.northconcepts.datapipeline.foundations.pipeline.input.CsvPipelineInput
 
generateJavaCode(JavaCodeBuilder) - Method in class com.northconcepts.datapipeline.foundations.pipeline.input.DataReaderPipelineInput
 
generateJavaCode(JavaCodeBuilder) - Method in class com.northconcepts.datapipeline.foundations.pipeline.input.DatasetPipelineInput
 
generateJavaCode(JavaCodeBuilder) - Method in class com.northconcepts.datapipeline.foundations.pipeline.input.ExcelPipelineInput
 
generateJavaCode(JavaCodeBuilder) - Method in class com.northconcepts.datapipeline.foundations.pipeline.input.JdbcPipelineInput
 
generateJavaCode(JavaCodeBuilder) - Method in class com.northconcepts.datapipeline.foundations.pipeline.input.JsonRecordPipelineInput
 
generateJavaCode(JavaCodeBuilder) - Method in class com.northconcepts.datapipeline.foundations.pipeline.input.XmlPipelineInput
 
generateJavaCode(JavaCodeBuilder) - Method in class com.northconcepts.datapipeline.foundations.pipeline.input.XmlRecordPipelineInput
 
generateJavaCode(JavaCodeBuilder) - Method in class com.northconcepts.datapipeline.foundations.pipeline.output.CsvPipelineOutput
 
generateJavaCode(JavaCodeBuilder) - Method in class com.northconcepts.datapipeline.foundations.pipeline.output.DataWriterPipelineOutput
 
generateJavaCode(JavaCodeBuilder) - Method in class com.northconcepts.datapipeline.foundations.pipeline.output.ExcelPipelineOutput
 
generateJavaCode(JavaCodeBuilder) - Method in class com.northconcepts.datapipeline.foundations.pipeline.output.JdbcPipelineOutput
 
generateJavaCode(JavaCodeBuilder) - Method in class com.northconcepts.datapipeline.foundations.pipeline.Pipeline
 
generateJavaCode(JavaCodeBuilder) - Method in interface com.northconcepts.datapipeline.foundations.sourcecode.JavaCodeGenerator
 
generateJavaCodeImpl(JavaCodeBuilder, CodeWriter) - Method in class com.northconcepts.datapipeline.foundations.pipeline.input.JsonPipelineInput
 
generateJavaCodeImpl(JavaCodeBuilder, CodeWriter) - Method in class com.northconcepts.datapipeline.foundations.pipeline.input.XmlPipelineInput
 
GenerateRecordSerializers - Class in com.northconcepts.datapipeline.foundations.tools
 
GenerateRecordSerializers() - Constructor for class com.northconcepts.datapipeline.foundations.tools.GenerateRecordSerializers
 
generateSaveCode(JavaCodeBuilder) - Method in class com.northconcepts.datapipeline.foundations.pipeline.output.CsvPipelineOutput
 
generateSaveCode(JavaCodeBuilder) - Method in class com.northconcepts.datapipeline.foundations.pipeline.output.ExcelPipelineOutput
 
generateSaveCode(JavaCodeBuilder) - Method in class com.northconcepts.datapipeline.foundations.pipeline.output.FileSinkPipelineOutput
 
GenericUpsert - Class in com.northconcepts.datapipeline.jdbc.upsert
An upsert strategy that attempts to either:
GenericUpsert() - Constructor for class com.northconcepts.datapipeline.jdbc.upsert.GenericUpsert
 
geoLocationToString(GeoLocation[][]) - Method in interface com.northconcepts.datapipeline.twitter.ITwitterConverter
 
geoLocationToString(GeoLocation[][]) - Method in class com.northconcepts.datapipeline.twitter.TwitterConverter
 
get(int) - Method in class com.northconcepts.datapipeline.core.CompositeValue
 
get(int) - Method in class com.northconcepts.datapipeline.core.ConcurrentRecordList
 
get(int) - Method in class com.northconcepts.datapipeline.core.DataEndpointGroup
 
get(String) - Method in exception com.northconcepts.datapipeline.core.DataException
Returns the value mapped to the specified key or null.
get(String) - Method in class com.northconcepts.datapipeline.core.FieldDeclarations
 
get(int) - Method in class com.northconcepts.datapipeline.core.FieldList
 
get(String) - Static method in class com.northconcepts.datapipeline.core.Functions
Returns the fully-qualified method name for a function alias or null.
get(int) - Method in class com.northconcepts.datapipeline.core.MultiWriter
 
get(int) - Method in class com.northconcepts.datapipeline.core.RecordComparator
 
get(int) - Method in class com.northconcepts.datapipeline.core.RecordList
 
get(int) - Method in class com.northconcepts.datapipeline.core.SequenceReader
 
get(int) - Method in class com.northconcepts.datapipeline.filter.FilteringReader
 
get(int) - Method in class com.northconcepts.datapipeline.filter.rule.OrRule
 
get(int) - Method in class com.northconcepts.datapipeline.filter.rule.PatternMatch
 
get(int) - Method in class com.northconcepts.datapipeline.filter.rule.ValueMatch
 
get(String, String) - Static method in class com.northconcepts.datapipeline.internal.trello.TrelloClient.Proxy
 
get(String, String, Integer, String, String) - Static method in class com.northconcepts.datapipeline.internal.trello.TrelloClient.Proxy
 
get(String, String, String) - Static method in class com.northconcepts.datapipeline.jira.client.JiraClient.Proxy
 
get(String) - Static method in class com.northconcepts.datapipeline.mailchimp.MailChimpClient.Proxy
 
get(String) - Method in class com.northconcepts.datapipeline.template.RecordTemplateModel
 
get(Object...) - Method in class com.northconcepts.datapipeline.transform.lookup.BasicLookup
 
get(Object...) - Method in class com.northconcepts.datapipeline.transform.lookup.CachedLookup
 
get(Object...) - Method in class com.northconcepts.datapipeline.transform.lookup.DataReaderLookup
 
get(Object...) - Method in class com.northconcepts.datapipeline.transform.lookup.JdbcLookup
 
get(Object...) - Method in class com.northconcepts.datapipeline.transform.lookup.Lookup
 
get(List<?>) - Method in class com.northconcepts.datapipeline.transform.lookup.Lookup
 
get(Object...) - Method in class com.northconcepts.datapipeline.transform.lookup.ProxyLookup
 
get(int) - Method in class com.northconcepts.datapipeline.transform.TransformingReader
 
get(int) - Method in class com.northconcepts.datapipeline.transform.TransformingWriter
 
getAbsolutePaths() - Method in class com.northconcepts.datapipeline.file.FileSystemInfoReader
 
getAcknowledgeMode() - Method in class com.northconcepts.datapipeline.jms.JmsSettings
Indicates how received messages should be acknowledged (default to JmsAcknowledgeMode.AUTO).
getActionCount() - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.CompositePipelineAction
 
getActionCount() - Method in class com.northconcepts.datapipeline.foundations.pipeline.Pipeline
 
getActions() - Method in enum com.northconcepts.datapipeline.foundations.pipeline.action.ActionGroup
 
getActions() - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.CompositePipelineAction
 
getActions() - Method in class com.northconcepts.datapipeline.foundations.pipeline.Pipeline
 
getAdditionalProperties() - Method in class com.northconcepts.datapipeline.mailchimp.list.Link
 
getAdditionalProperties() - Method in class com.northconcepts.datapipeline.mailchimp.list.ListMember
 
getAdditionalProperties() - Method in class com.northconcepts.datapipeline.mailchimp.list.ListMembers
 
getAdditionalProperties() - Method in class com.northconcepts.datapipeline.mailchimp.list.Location
 
getAdditionalProperties() - Method in class com.northconcepts.datapipeline.mailchimp.list.Tag
 
getAfterFieldName() - Method in class com.northconcepts.datapipeline.transform.MoveFieldAfter
 
getAliases() - Static method in class com.northconcepts.datapipeline.core.Functions
Returns all the aliases.
getAll() - Method in class com.northconcepts.datapipeline.core.CompositeValue
 
getAll() - Static method in class com.northconcepts.datapipeline.eventbus.EventBus
 
getAll() - Static method in class com.northconcepts.datapipeline.job.AbstractJob
 
getAll() - Static method in class com.northconcepts.datapipeline.job.Job
Returns all the live jobs in the JVM/classloader.
getAllNodes() - Method in class com.northconcepts.datapipeline.foundations.pipeline.dataset.Tree
 
getAllowedValues() - Method in class com.northconcepts.datapipeline.foundations.schema.FieldDef
 
getAllTweets(String, LocalDateTime, LocalDateTime, int, String) - Method in class com.northconcepts.datapipeline.twitter2.TwitterV2Client
Currently only available via the Academic Research product track https://developer.twitter.com/en/docs/twitter-api/tweets/search/api-reference
getApiKey() - Method in class com.northconcepts.datapipeline.twitter2.TwitterCredentials
 
getApiLimitPolicy() - Method in class com.northconcepts.datapipeline.twitter.TwitterProxyReader
 
getApiLimitPolicy() - Method in class com.northconcepts.datapipeline.twitter.TwitterReader
 
getApiLimitPolicy() - Method in class com.northconcepts.datapipeline.twitter.TwitterWriter
 
getApiSecret() - Method in class com.northconcepts.datapipeline.twitter2.TwitterCredentials
 
getApplicationName() - Method in class com.northconcepts.datapipeline.google.GoogleApiReader
 
getArguments() - Method in class com.northconcepts.datapipeline.eventbus.Event
 
getAsBoolean(String) - Method in exception com.northconcepts.datapipeline.core.DataException
Returns the value mapped to the specified key as a boolean or throws NullPointeException.
getAsDatetime(String) - Method in exception com.northconcepts.datapipeline.core.DataException
Returns the value mapped to the specified key as a Date or null.
getAsDouble(String) - Method in exception com.northconcepts.datapipeline.core.DataException
Returns the value mapped to the specified key as a double or throws NullPointeException.
getAsInteger(String) - Method in exception com.northconcepts.datapipeline.core.DataException
Returns the value mapped to the specified key as an int or throws NullPointeException.
getAsLong(String) - Method in exception com.northconcepts.datapipeline.core.DataException
Returns the value mapped to the specified key as a long or throws NullPointeException.
getAsString(String) - Method in exception com.northconcepts.datapipeline.core.DataException
Returns the value mapped to the specified key as a String or null.
getAsyncWriter(int) - Method in class com.northconcepts.datapipeline.jdbc.JdbcMultiWriter
 
getAttribute(Element, String) - Static method in interface com.northconcepts.datapipeline.core.XmlSerializable
 
getAttribute(Element, String, String) - Static method in interface com.northconcepts.datapipeline.core.XmlSerializable
 
getAttribute(Element, String, Boolean) - Static method in interface com.northconcepts.datapipeline.core.XmlSerializable
 
getAttribute(Element, String, Integer) - Static method in interface com.northconcepts.datapipeline.core.XmlSerializable
 
getAttributes() - Method in class com.northconcepts.datapipeline.xml.builder.XmlElement
 
getAutoCloseConnection() - Method in class com.northconcepts.datapipeline.jdbc.JdbcReader
 
getAutoCloseConnection() - Method in class com.northconcepts.datapipeline.jdbc.JdbcUpsertWriter
 
getAutoCloseConnection() - Method in class com.northconcepts.datapipeline.jdbc.JdbcWriter
 
getAverage(String) - Method in class com.northconcepts.datapipeline.group.AggregateReader
Deprecated.
 
getAverageLength() - Method in class com.northconcepts.datapipeline.foundations.pipeline.dataset.Column
 
getBatchSize() - Method in class com.northconcepts.datapipeline.foundations.pipeline.output.JdbcPipelineOutput
 
getBatchSize() - Method in class com.northconcepts.datapipeline.google.calendar.GoogleCalendarReader
 
getBatchSize() - Method in class com.northconcepts.datapipeline.google.contacts.GoogleContactsReader
 
getBatchSize() - Method in class com.northconcepts.datapipeline.google.gmail.GmailMessageReader
 
getBatchSize() - Method in class com.northconcepts.datapipeline.jdbc.JdbcMultiWriter
 
getBatchSize() - Method in class com.northconcepts.datapipeline.jdbc.JdbcUpsertWriter
 
getBatchSize() - Method in class com.northconcepts.datapipeline.jdbc.JdbcWriter
 
getBatchSize() - Method in class com.northconcepts.datapipeline.jira.JiraReader
Indicates the number of items to retrieve per batch.
getBatchSize() - Method in class com.northconcepts.datapipeline.mongodb.MongoWriter
 
getBatchSize() - Method in class com.northconcepts.datapipeline.orc.OrcDataReader
Indicates the maximum number of records to buffer when reading ORC data (default 1024).
getBatchSize() - Method in class com.northconcepts.datapipeline.orc.OrcDataWriter
Indicates the maximum number of records to buffer when writing ORC data (default 1024).
getBatchSize() - Method in class com.northconcepts.datapipeline.trello.TrelloApiReader
 
getBatchSize() - Method in class com.northconcepts.datapipeline.twitter.TwitterUserLookupReader
 
getBefore() - Method in class com.northconcepts.datapipeline.trello.TrelloApiReader
 
getBeforeFieldName() - Method in class com.northconcepts.datapipeline.transform.MoveFieldBefore
 
getBigDecimalLiteral(BigDecimal) - Method in class com.northconcepts.datapipeline.jdbc.insert.MultiRowStatementInsert
 
getBigDecimalPrecision() - Method in class com.northconcepts.datapipeline.orc.OrcDataWriter
Returns default precision value for BigDecimal type of values.
getBigDecimalScale() - Method in class com.northconcepts.datapipeline.orc.OrcDataWriter
Indicates the scale used when writing BigDecimal values (default 10).
getBigIntegerLiteral(BigInteger) - Method in class com.northconcepts.datapipeline.jdbc.insert.MultiRowStatementInsert
 
getBlankCount() - Method in class com.northconcepts.datapipeline.foundations.pipeline.dataset.Column
 
getBoardCards(String, String) - Method in interface com.northconcepts.datapipeline.internal.trello.TrelloClient
 
getBoardId() - Method in class com.northconcepts.datapipeline.trello.TrelloBoardCardsReader
 
getBoardId() - Method in class com.northconcepts.datapipeline.trello.TrelloBoardListsReader
 
getBoardLists(String, String, String, String, String) - Method in interface com.northconcepts.datapipeline.internal.trello.TrelloClient
 
getBoolean() - Method in class com.northconcepts.datapipeline.foundations.pipeline.dataset.Column
 
getBooleanLiteral(boolean) - Method in class com.northconcepts.datapipeline.jdbc.insert.MultiRowStatementInsert
 
getBuffer() - Method in class com.northconcepts.datapipeline.foundations.file.FileDetector
 
getBufferByFields() - Method in class com.northconcepts.datapipeline.buffer.BufferedReader
 
getBuffersClosed() - Method in class com.northconcepts.datapipeline.buffer.BufferedReader
 
getBuffersCreated() - Method in class com.northconcepts.datapipeline.buffer.BufferedReader
 
getBufferSize() - Method in class com.northconcepts.datapipeline.core.DataReader
Returns the number of records in this DataReaders buffer.
getBufferSize() - Method in class com.northconcepts.datapipeline.foundations.file.FileDetector
 
getBufferSizeInBytes() - Method in class com.northconcepts.datapipeline.core.AsyncReader
 
getBufferSizeInBytes() - Method in class com.northconcepts.datapipeline.core.AsyncWriter
 
getBufferStrategy() - Method in class com.northconcepts.datapipeline.buffer.BufferedReader
 
getByteCount() - Method in class com.northconcepts.datapipeline.foundations.jdbc.JdbcTableColumn
 
getByteLiteral(byte) - Method in class com.northconcepts.datapipeline.jdbc.insert.MultiRowStatementInsert
 
getBytesLiteral(byte[]) - Method in class com.northconcepts.datapipeline.jdbc.insert.MultiRowStatementInsert
 
getCalendarId() - Method in class com.northconcepts.datapipeline.google.calendar.GoogleCalendarReader
 
getCallback() - Method in class com.northconcepts.datapipeline.job.Job
 
getCancelledOn() - Method in class com.northconcepts.datapipeline.job.AbstractJob
Returns the time this job instance was cancelled.
getCancelledOn() - Method in interface com.northconcepts.datapipeline.job.IJob
Returns the time this job instance was cancelled.
getCancelledOn() - Method in class com.northconcepts.datapipeline.job.Job
Returns the time this job instance was cancelled.
getCardFilter() - Method in class com.northconcepts.datapipeline.trello.TrelloBoardCardsReader
 
getCardFilter() - Method in class com.northconcepts.datapipeline.trello.TrelloBoardListsReader
 
getCascadeResetLocationPath() - Method in class com.northconcepts.datapipeline.xml.XmlField
 
getCatalogName() - Method in class com.northconcepts.datapipeline.foundations.jdbc.JdbcQueryColumn
 
getCatalogName() - Method in class com.northconcepts.datapipeline.foundations.jdbc.JdbcTable
 
getCharset() - Method in class com.northconcepts.datapipeline.foundations.pipeline.input.CsvPipelineInput
 
getCharset() - Method in class com.northconcepts.datapipeline.foundations.pipeline.output.CsvPipelineOutput
 
getChild() - Method in class com.northconcepts.datapipeline.job.AbstractJob
Returns the thread-local child job of this one while this job is running.
getChild() - Method in interface com.northconcepts.datapipeline.job.IJob
Returns the thread-local child job of this one while this job is running.
getChild() - Method in class com.northconcepts.datapipeline.job.Job
Returns the thread-local child job of this one while this job is running.
getChildElement(Element, String) - Static method in interface com.northconcepts.datapipeline.core.XmlSerializable
 
getChildElements(Element, String) - Static method in interface com.northconcepts.datapipeline.core.XmlSerializable
 
getChildNode(String, boolean) - Method in class com.northconcepts.datapipeline.foundations.pipeline.dataset.TreeNode
 
getChildNode(XmlNode, boolean) - Method in class com.northconcepts.datapipeline.foundations.pipeline.dataset.TreeNode
 
getChildNodes(ExpressionContext) - Method in class com.northconcepts.datapipeline.xml.builder.XmlConditionalNode
 
getChildNodes(ExpressionContext) - Method in class com.northconcepts.datapipeline.xml.builder.XmlDetailMarker
 
getChildNodes(ExpressionContext) - Method in class com.northconcepts.datapipeline.xml.builder.XmlNode
 
getChildNodes(ExpressionContext) - Method in class com.northconcepts.datapipeline.xml.builder.XmlNodeContainer
 
getChildren() - Method in class com.northconcepts.datapipeline.foundations.pipeline.dataset.TreeNode
 
getChildrenValueCount() - Method in class com.northconcepts.datapipeline.foundations.pipeline.dataset.TreeNode
 
getClient() - Method in class com.northconcepts.datapipeline.amazons3.AmazonS3FileSystem
 
getClient() - Method in class com.northconcepts.datapipeline.jira.JiraReader
 
getClientId() - Method in class com.northconcepts.datapipeline.jms.JmsSettings
 
getClosedOn() - Method in class com.northconcepts.datapipeline.core.Endpoint
Returns the time in milliseconds when this endpoint was closed or zero (0) if it hasn't yet been closed.
getClosedWindows() - Method in class com.northconcepts.datapipeline.group.GroupByReader
 
getCloseStream() - Method in class com.northconcepts.datapipeline.core.StreamWriter
 
getCloseWindowStrategy() - Method in class com.northconcepts.datapipeline.group.GroupByReader
 
getCloseWriterOnClose() - Method in class com.northconcepts.datapipeline.core.DebugReader
 
getCode() - Method in enum com.northconcepts.datapipeline.foundations.pipeline.action.ActionGroup
 
getCode() - Method in interface com.northconcepts.datapipeline.foundations.pipeline.action.DataReaderAction
 
getCode() - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.PipelineAction
 
getCode() - Method in enum com.northconcepts.datapipeline.twitter.TwitterErrorCode
 
getCollator() - Method in class com.northconcepts.datapipeline.core.FieldComparator
 
getCollection(String) - Method in class com.northconcepts.datapipeline.memory.CollectionWriter
 
getColumn() - Method in interface com.northconcepts.datapipeline.core.IParser
 
getColumn() - Method in class com.northconcepts.datapipeline.core.LineParser
 
getColumn() - Method in class com.northconcepts.datapipeline.core.Parser
 
getColumn() - Method in class com.northconcepts.datapipeline.core.StringParser
 
getColumn(String) - Method in class com.northconcepts.datapipeline.foundations.jdbc.JdbcTable
 
getColumn(int) - Method in class com.northconcepts.datapipeline.foundations.pipeline.dataset.Dataset
 
getColumn(String) - Method in class com.northconcepts.datapipeline.foundations.pipeline.dataset.Dataset
 
getColumn(int) - Method in class com.northconcepts.datapipeline.foundations.pipeline.dataset.MemoryDataset
 
getColumn(String) - Method in class com.northconcepts.datapipeline.foundations.pipeline.dataset.MemoryDataset
 
getColumn(int) - Method in class com.northconcepts.datapipeline.foundations.pipeline.dataset.MvStoreDataset
 
getColumn(String) - Method in class com.northconcepts.datapipeline.foundations.pipeline.dataset.MvStoreDataset
 
getColumnCount() - Method in class com.northconcepts.datapipeline.foundations.pipeline.dataset.Dataset
 
getColumnCount() - Method in class com.northconcepts.datapipeline.foundations.pipeline.dataset.MemoryDataset
 
getColumnCount() - Method in class com.northconcepts.datapipeline.foundations.pipeline.dataset.MvStoreDataset
 
getColumnName() - Method in class com.northconcepts.datapipeline.jdbc.sql.insert.InsertValue
 
getColumnName() - Method in class com.northconcepts.datapipeline.jdbc.sql.merge.MergeValue
 
getColumnName() - Method in class com.northconcepts.datapipeline.jdbc.sql.update.UpdateValue
 
getColumnNames() - Method in class com.northconcepts.datapipeline.foundations.pipeline.dataset.Dataset
 
getColumnNames() - Method in class com.northconcepts.datapipeline.foundations.pipeline.dataset.MemoryDataset
 
getColumnNames() - Method in class com.northconcepts.datapipeline.foundations.pipeline.dataset.MvStoreDataset
 
getColumnNumber() - Method in class com.northconcepts.datapipeline.csv.CSVReader
 
getColumns() - Method in class com.northconcepts.datapipeline.foundations.jdbc.JdbcQuery
 
getColumns() - Method in class com.northconcepts.datapipeline.foundations.jdbc.JdbcTable
 
getColumns(String...) - Method in class com.northconcepts.datapipeline.foundations.jdbc.JdbcTable
 
getColumns(Collection<String>) - Method in class com.northconcepts.datapipeline.foundations.jdbc.JdbcTable
 
getColumns() - Method in class com.northconcepts.datapipeline.foundations.pipeline.dataset.Dataset
 
getColumns() - Method in class com.northconcepts.datapipeline.foundations.pipeline.dataset.MemoryDataset
 
getColumns() - Method in class com.northconcepts.datapipeline.foundations.pipeline.dataset.MvStoreDataset
 
getColumns() - Method in class com.northconcepts.datapipeline.orc.OrcDataReader
Indicates the columns to read from ORC file.
getCompletedTaskCount() - Method in class com.northconcepts.datapipeline.eventbus.EventBus
Returns the approximate total number of tasks that have completed execution by this bus' executorService or -1 if unknown.
getCompressionCodecName() - Method in class com.northconcepts.datapipeline.parquet.ParquetDataWriter
Indicates the compression used for writing (default UNCOMPRESSED).
getCompressionKind() - Method in class com.northconcepts.datapipeline.orc.OrcDataWriter
Indicates the compression used for writing (default NONE).
getCondition() - Method in class com.northconcepts.datapipeline.foundations.datamapping.AbstractFieldMapping
 
getCondition() - Method in class com.northconcepts.datapipeline.foundations.decisiontree.DecisionTreeNode
 
getCondition() - Method in class com.northconcepts.datapipeline.jdbc.sql.merge.Merge
 
getCondition() - Method in class com.northconcepts.datapipeline.jdbc.sql.select.InnerJoin
 
getCondition() - Method in class com.northconcepts.datapipeline.json.builder.JsonConditionalNode
 
getCondition() - Method in class com.northconcepts.datapipeline.transform.TransformingReader
Returns the condition under which this transformation applies or null if it always applies.
getCondition() - Method in class com.northconcepts.datapipeline.transform.TransformingWriter
Returns the condition under which this transformation applies or null if it always applies.
getCondition() - Method in class com.northconcepts.datapipeline.xml.builder.XmlAttribute
 
getCondition() - Method in class com.northconcepts.datapipeline.xml.builder.XmlConditionalNode
 
getConditionAsSource() - Method in class com.northconcepts.datapipeline.foundations.decisiontree.DecisionTreeNode
 
getConditionAsString() - Method in class com.northconcepts.datapipeline.foundations.datamapping.AbstractFieldMapping
 
getConditionCount() - Method in class com.northconcepts.datapipeline.jdbc.sql.select.ConditionPart
 
getConditionCount() - Method in class com.northconcepts.datapipeline.jdbc.sql.select.QueryCriteriaPart
 
getConditionFailedSource() - Method in class com.northconcepts.datapipeline.foundations.datamapping.DataMappingResult
 
getConditions() - Method in class com.northconcepts.datapipeline.foundations.datamapping.DataMapping
 
getConditions() - Method in class com.northconcepts.datapipeline.foundations.decisiontable.DecisionTableRule
 
getConditionsSource() - Method in class com.northconcepts.datapipeline.foundations.datamapping.DataMapping
 
getConfig() - Method in class com.northconcepts.datapipeline.orc.OrcDataReader
Returns the Orc configuration parameters.
getConfig() - Method in class com.northconcepts.datapipeline.orc.OrcDataWriter
Returns the Orc configuration parameters.
getConfig() - Method in class com.northconcepts.datapipeline.twitter.TwitterProvider
 
getConfig() - Method in class com.northconcepts.datapipeline.twitter.TwitterStreamProvider
 
getConfiguration() - Method in class com.northconcepts.datapipeline.parquet.ParquetDataReader
Returns the Parquet configuration parameters.
getConfiguration() - Method in class com.northconcepts.datapipeline.template.TemplateWriter
 
getConflictAction() - Method in class com.northconcepts.datapipeline.jdbc.upsert.PostgreSqlUpsert
Returns the action to perform on conflict (default ConflictAction.UPDATE).
getConnection() - Method in class com.northconcepts.datapipeline.foundations.jdbc.JdbcQuery
 
getConnection() - Method in class com.northconcepts.datapipeline.foundations.jdbc.JdbcTable
 
getConnection() - Method in class com.northconcepts.datapipeline.jdbc.JdbcUpsertWriter
 
getConnection() - Method in class com.northconcepts.datapipeline.jdbc.JdbcWriter
 
getConnection() - Method in class com.northconcepts.datapipeline.jms.JmsConnection
 
getConnection() - Method in class com.northconcepts.datapipeline.jms.JmsReader
 
getConnection() - Method in class com.northconcepts.datapipeline.jms.JmsWriter
 
getConnections() - Method in class com.northconcepts.datapipeline.jdbc.JdbcMultiWriter
 
getContentType() - Method in interface com.northconcepts.datapipeline.foundations.file.FileSink
 
getContentType() - Method in interface com.northconcepts.datapipeline.foundations.file.FileSource
 
getContentType() - Method in class com.northconcepts.datapipeline.foundations.file.LocalFile
 
getConverter() - Method in class com.northconcepts.datapipeline.twitter.TwitterProxyReader
 
getConverter() - Method in class com.northconcepts.datapipeline.twitter.TwitterReader
 
getConverter() - Method in class com.northconcepts.datapipeline.twitter.TwitterWriter
 
getCorePoolSize() - Method in class com.northconcepts.datapipeline.eventbus.EventBus
Returns the core number of threads in this bus' executorService or -1 if unknown.
getCount() - Method in class com.northconcepts.datapipeline.core.DataEndpointGroup
 
getCount() - Method in class com.northconcepts.datapipeline.core.FieldDeclarations
 
getCount() - Static method in class com.northconcepts.datapipeline.core.Functions
Returns the number of aliased functions.
getCount() - Method in class com.northconcepts.datapipeline.core.MultiWriter
 
getCount() - Method in class com.northconcepts.datapipeline.core.RecordComparator
 
getCount() - Method in class com.northconcepts.datapipeline.core.SequenceReader
 
getCount() - Method in class com.northconcepts.datapipeline.filter.FilteringReader
 
getCount() - Method in class com.northconcepts.datapipeline.filter.rule.OrRule
 
getCount() - Method in class com.northconcepts.datapipeline.filter.rule.PatternMatch
 
getCount() - Method in class com.northconcepts.datapipeline.filter.rule.ValueMatch
 
getCount(String) - Method in class com.northconcepts.datapipeline.group.AggregateReader
Deprecated.
 
getCount() - Method in class com.northconcepts.datapipeline.jdbc.sql.select.Select
 
getCount() - Method in class com.northconcepts.datapipeline.meter.Meter
 
getCount() - Method in class com.northconcepts.datapipeline.transform.TransformingReader
 
getCount() - Method in class com.northconcepts.datapipeline.transform.TransformingWriter
 
getCountryCode() - Method in class com.northconcepts.datapipeline.mailchimp.list.Location
 
getCreatedOn() - Method in class com.northconcepts.datapipeline.core.Record
Returns the time in milliseconds when this record was created.
getCreatedOn() - Method in class com.northconcepts.datapipeline.eventbus.EventBus
The time this job instance was created.
getCreatedOn() - Method in class com.northconcepts.datapipeline.job.AbstractJob
Returns the time this job instance was created.
getCreatedOn() - Method in interface com.northconcepts.datapipeline.job.IJob
Returns the time this job instance was created.
getCreatedOn() - Method in class com.northconcepts.datapipeline.job.Job
Returns the time this job instance was created.
getCreateWindowStrategy() - Method in class com.northconcepts.datapipeline.group.GroupByReader
 
getCredentials() - Method in class com.northconcepts.datapipeline.amazons3.AmazonS3FileSystem
 
getCredentialsProvider() - Method in class com.northconcepts.datapipeline.amazons3.AmazonS3FileSystem
 
getCriteria() - Method in class com.northconcepts.datapipeline.jdbc.sql.select.Select
 
getCriteria() - Method in class com.northconcepts.datapipeline.jdbc.sql.update.Update
 
getCsvFieldSeparator() - Method in class com.northconcepts.datapipeline.foundations.file.FileDetector
 
getCurrent(boolean) - Static method in class com.northconcepts.datapipeline.core.Messages
 
getCurrent() - Static method in class com.northconcepts.datapipeline.core.Messages
 
getCurrent() - Static method in class com.northconcepts.datapipeline.job.AbstractJob
 
getCurrent() - Static method in class com.northconcepts.datapipeline.job.Job
Returns the job currently running in this thread.
getCurrentEvent() - Static method in class com.northconcepts.datapipeline.eventbus.EventBus
Returns the event currently being delivered on this thread.
getCurrentField() - Method in class com.northconcepts.datapipeline.filter.FieldFilter
 
getCurrentField() - Method in class com.northconcepts.datapipeline.transform.FieldTransformer
 
getCurrentFilter() - Method in class com.northconcepts.datapipeline.filter.FilteringReader
 
getCurrentRecord() - Method in class com.northconcepts.datapipeline.transform.FieldTransformer
 
getCurrentRule() - Method in class com.northconcepts.datapipeline.filter.FieldFilter
 
getData() - Method in class com.northconcepts.datapipeline.bloomberg.BloombergMessage
 
getData() - Method in class com.northconcepts.datapipeline.template.TemplateWriter
 
getDatabaseColumnName() - Method in class com.northconcepts.datapipeline.lineage.FieldLineage
 
getDatabaseQuery() - Method in class com.northconcepts.datapipeline.lineage.FieldLineage
 
getDatabaseQuery() - Method in class com.northconcepts.datapipeline.lineage.RecordLineage
 
getDatabaseTypeName() - Method in class com.northconcepts.datapipeline.foundations.jdbc.JdbcQueryColumn
 
getDatabaseTypeName() - Method in class com.northconcepts.datapipeline.foundations.jdbc.JdbcTableColumn
 
getDatabaseUrl() - Method in class com.northconcepts.datapipeline.lineage.FieldLineage
 
getDatabaseUrl() - Method in class com.northconcepts.datapipeline.lineage.RecordLineage
 
getDataMapping() - Method in class com.northconcepts.datapipeline.foundations.datamapping.DataMappingReader
 
getDataMapping() - Method in class com.northconcepts.datapipeline.foundations.datamapping.DataMappingWriter
 
getDataMapping() - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.datamapping.DataMappingAction
 
getDataMapping() - Method in class com.northconcepts.datapipeline.foundations.pipeline.DataMappingPipeline
 
getDataset() - Method in class com.northconcepts.datapipeline.foundations.pipeline.dataset.DatasetReader
 
getDate() - Method in class com.northconcepts.datapipeline.filter.rule.DateIs
 
getDate() - Method in class com.northconcepts.datapipeline.filter.rule.DateIsAfter
 
getDate() - Method in class com.northconcepts.datapipeline.filter.rule.DateIsBefore
 
getDate() - Method in class com.northconcepts.datapipeline.trello.DateParam
 
getDateLiteral(Date) - Method in class com.northconcepts.datapipeline.jdbc.insert.MultiRowStatementInsert
 
getDateTimeLiteral(Date) - Method in class com.northconcepts.datapipeline.jdbc.insert.MultiRowStatementInsert
 
getDecimalPlaces() - Method in class com.northconcepts.datapipeline.transform.format.Rounder
 
getDecimals() - Method in class com.northconcepts.datapipeline.foundations.jdbc.JdbcTableColumn
 
getDecisionTable() - Method in class com.northconcepts.datapipeline.foundations.decisiontable.DecisionTableReader
 
getDecisionTable() - Method in class com.northconcepts.datapipeline.foundations.decisiontable.DecisionTableWriter
 
getDecisionTable() - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.decision.DecisionTableAction
 
getDecisionTree() - Method in class com.northconcepts.datapipeline.foundations.decisiontree.DecisionTreeReader
 
getDecisionTree() - Method in class com.northconcepts.datapipeline.foundations.decisiontree.DecisionTreeWriter
 
getDecisionTree() - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.decision.DecisionTreeAction
 
getDeclaration() - Method in class com.northconcepts.datapipeline.xml.builder.XmlTemplate
 
getDefaultBigDecimalScale() - Method in class com.northconcepts.datapipeline.parquet.ParquetDataWriter
Returns the default scale used when writing BigDecimal values (default 5).
getDefaultNode() - Method in class com.northconcepts.datapipeline.foundations.decisiontree.DecisionTreeNode
 
getDefaultPort() - Method in enum com.northconcepts.datapipeline.email.MailStore
 
getDefaultType() - Method in class com.northconcepts.datapipeline.core.ArrayValue
 
getDefaultValue() - Method in class com.northconcepts.datapipeline.foundations.jdbc.JdbcTableColumn
 
getDefaultValueExpression() - Method in class com.northconcepts.datapipeline.foundations.datamapping.AbstractFieldMapping
 
getDefaultValueExpression() - Method in class com.northconcepts.datapipeline.foundations.schema.FieldDef
 
getDefaultValueExpressionAsString() - Method in class com.northconcepts.datapipeline.foundations.datamapping.AbstractFieldMapping
 
getDefaultValueExpressionAsString() - Method in class com.northconcepts.datapipeline.foundations.schema.FieldDef
 
getDeferrability() - Method in class com.northconcepts.datapipeline.foundations.jdbc.JdbcImportedKey
 
getDeleteRule() - Method in class com.northconcepts.datapipeline.foundations.jdbc.JdbcImportedKey
 
getDepth() - Method in class com.northconcepts.datapipeline.foundations.pipeline.dataset.TreeNode
 
getDescendantValueCount() - Method in class com.northconcepts.datapipeline.foundations.pipeline.dataset.TreeNode
 
getDescription() - Method in class com.northconcepts.datapipeline.core.Endpoint
 
getDescription() - Method in class com.northconcepts.datapipeline.foundations.datamapping.DataMapping
 
getDescription() - Method in class com.northconcepts.datapipeline.foundations.decisiontable.DecisionTable
 
getDescription() - Method in class com.northconcepts.datapipeline.foundations.decisiontable.DecisionTableRule
 
getDescription() - Method in class com.northconcepts.datapipeline.foundations.decisiontree.DecisionTree
 
getDescription() - Method in class com.northconcepts.datapipeline.foundations.decisiontree.DecisionTreeNode
 
getDescription() - Method in class com.northconcepts.datapipeline.foundations.pipeline.AbstractPipeline
 
getDescription() - Method in enum com.northconcepts.datapipeline.foundations.pipeline.action.ActionGroup
 
getDescription() - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.PipelineAction
 
getDescription() - Method in class com.northconcepts.datapipeline.foundations.schema.EntityDef
 
getDescription() - Method in class com.northconcepts.datapipeline.foundations.schema.FieldDef
 
getDescription() - Method in class com.northconcepts.datapipeline.foundations.schema.SchemaDef
 
getDescription() - Method in enum com.northconcepts.datapipeline.twitter.TwitterErrorCode
 
getDescriptionField() - Method in class com.northconcepts.datapipeline.trello.TrelloCardWriter
 
getDestination() - Method in class com.northconcepts.datapipeline.jms.JmsConnection
 
getDetailTemplate() - Method in class com.northconcepts.datapipeline.template.TemplateWriter
 
getDirection() - Method in class com.northconcepts.datapipeline.email.EmailReader
 
getDirection() - Method in class com.northconcepts.datapipeline.twitter.TwitterPageableReader
 
getDiscardedRecordCount() - Method in class com.northconcepts.datapipeline.avro.AvroWriter
Returns the number of discarded Records
getDiscardReasonFieldName() - Method in class com.northconcepts.datapipeline.filter.FilteringReader
Returns the field in the record to place the description of the filter that disallowed it or null if one should not be added.
getDiscardReasonFieldName() - Method in class com.northconcepts.datapipeline.foundations.pipeline.AbstractPipeline
 
getDiscardReasonFieldName() - Method in class com.northconcepts.datapipeline.retry.RetryingReader
Returns the field in the record to place the description of the exception that was thrown by the failing read or null if one should not be added.
getDiscardReasonFieldName() - Method in class com.northconcepts.datapipeline.retry.RetryingWriter
Returns the field in the record to place the description of the exception that was thrown by the failing write or null if one should not be added.
getDiscardReasonFieldName() - Method in class com.northconcepts.datapipeline.transform.TransformingReader
Returns the the field in the record to place the description of the transformation that failed along with the exception message.
getDiscardReasonFieldName() - Method in class com.northconcepts.datapipeline.transform.TransformingWriter
Returns the the field in the record to place the description of the transformation that failed along with the exception message.
getDiscardWriter() - Method in class com.northconcepts.datapipeline.core.RemoveDuplicatesReader
Returns the discard sink for discarded records or null if one was not assigned.
getDiscardWriter() - Method in class com.northconcepts.datapipeline.filter.FilteringReader
Returns the discard sink for disallowed records or null if one was not assigned.
getDiscardWriter() - Method in class com.northconcepts.datapipeline.foundations.pipeline.AbstractPipeline
 
getDiscardWriter() - Method in class com.northconcepts.datapipeline.retry.RetryingReader
Returns the discard sink for failing records or null if one was not assigned.
getDiscardWriter() - Method in class com.northconcepts.datapipeline.retry.RetryingWriter
Returns the discard sink for failing records or null if one was not assigned.
getDiscardWriter() - Method in class com.northconcepts.datapipeline.transform.TransformingReader
Returns the discard sink for bad records or null if one was not assigned.
getDiscardWriter() - Method in class com.northconcepts.datapipeline.transform.TransformingWriter
Returns the discard sink for bad records or null if one was not assigned.
getDiscardWriter() - Method in class com.northconcepts.datapipeline.twitter.TwitterUserLookupReader
Returns the discard sink for records where the lookup failed or null if one was not assigned.
getDisplayName() - Method in enum com.northconcepts.datapipeline.foundations.file.FileType
 
getDisplayName() - Method in class com.northconcepts.datapipeline.foundations.schema.FieldDef
 
getDisplayText() - Method in enum com.northconcepts.datapipeline.foundations.pipeline.action.ActionGroup
 
getDisplayText() - Method in interface com.northconcepts.datapipeline.foundations.pipeline.action.DataReaderAction
 
getDisplayText() - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.PipelineAction
 
getDisplayText() - Method in enum com.northconcepts.datapipeline.foundations.pipeline.action.transform.AddFieldsAction.FieldType
 
getDocument() - Method in class com.northconcepts.datapipeline.excel.ExcelReader
 
getDocument() - Method in class com.northconcepts.datapipeline.excel.ExcelWriter
 
getDoneFilter() - Method in class com.northconcepts.datapipeline.jira.JiraEpicReader
Indicates which epics to return: true=done, false=not done, null=all (default is all).
getDoubleLiteral(double) - Method in class com.northconcepts.datapipeline.jdbc.insert.MultiRowStatementInsert
 
getDriverClassName() - Method in class com.northconcepts.datapipeline.foundations.jdbc.JdbcConnection
 
getDstoff() - Method in class com.northconcepts.datapipeline.mailchimp.list.Location
 
getDuplicateFieldAction() - Method in class com.northconcepts.datapipeline.transform.lookup.LookupTransformer
 
getDuplicateFieldPolicy() - Method in class com.northconcepts.datapipeline.foundations.pipeline.input.XmlPipelineInput
 
getDuplicateFieldPolicy() - Method in class com.northconcepts.datapipeline.xml.XmlReader
 
getElapsedTime() - Method in class com.northconcepts.datapipeline.core.Endpoint
Returns the total time in milliseconds this endpoint spent reading (inside DataReader.read()) or writing (inside DataWriter.write(Record)) if the captureElapsedTime flag is set (Endpoint.setCaptureElapsedTime(boolean) was called with true).
getElapsedTime() - Method in class com.northconcepts.datapipeline.core.SequenceWriter.Sequence
The number of records written in this sequence.
getElapsedTime() - Method in class com.northconcepts.datapipeline.meter.Meter
 
getElapsedTimeAsString() - Method in class com.northconcepts.datapipeline.core.Endpoint
Returns the total time (as a human readable string) this endpoint spent reading (inside DataReader.read()) or writing (inside DataWriter.write(Record)) if the captureElapsedTime flag is set (Endpoint.setCaptureElapsedTime(boolean) was called with true).
getElementDepth() - Method in class com.northconcepts.datapipeline.xml.builder.XmlElement
 
getElementDepth() - Method in class com.northconcepts.datapipeline.xml.builder.XmlNode
 
getEmailAddress() - Method in class com.northconcepts.datapipeline.mailchimp.list.ListMember
 
getEmailClient() - Method in class com.northconcepts.datapipeline.mailchimp.list.ListMember
 
getEmailType() - Method in class com.northconcepts.datapipeline.mailchimp.list.ListMember
 
getEmptyStringValuePolicy() - Method in class com.northconcepts.datapipeline.csv.CSVWriter
Returns the object responsible for writing empty string values (defaults to ValuePolicy.QUOTED_EMPTY_STRING).
getEmptyStringValuePolicy() - Method in class com.northconcepts.datapipeline.foundations.pipeline.output.CsvPipelineOutput
 
getEncodedPassword() - Method in class com.northconcepts.datapipeline.foundations.jdbc.JdbcConnection
 
getEndDate() - Method in class com.northconcepts.datapipeline.twitter2.TwitterSearchReader
Indicates the newest UTC timestamp search criteria.
getEndDate() - Method in class com.northconcepts.datapipeline.twitter2.TwitterTimelineReader
Indicates the newest UTC timestamp search criteria.
getEndingQuote() - Method in class com.northconcepts.datapipeline.csv.CSVReader
Returns the string used to mark the ending of text values that may contain commas and other special characters (defaults to double quote - ").
getEndingQuote() - Method in class com.northconcepts.datapipeline.csv.CSVWriter
Returns the string used to mark the ending of text values that may contain commas and other special characters (defaults to double quote - ").
getEndingQuote() - Method in class com.northconcepts.datapipeline.foundations.pipeline.input.CsvPipelineInput
 
getEndingQuote() - Method in class com.northconcepts.datapipeline.foundations.pipeline.output.CsvPipelineOutput
 
getEntities(boolean) - Method in class com.northconcepts.datapipeline.foundations.schema.SchemaDef
 
getEntities() - Method in class com.northconcepts.datapipeline.foundations.schema.SchemaDef
 
getEntity(String) - Method in class com.northconcepts.datapipeline.foundations.schema.SchemaDef
 
getEntity() - Method in class com.northconcepts.datapipeline.foundations.schema.SchemaFilter
 
getEntity() - Method in class com.northconcepts.datapipeline.foundations.schema.ValidationMessage
 
getEntityDef() - Method in class com.northconcepts.datapipeline.foundations.schema.FieldDef
 
getEntityDef() - Method in class com.northconcepts.datapipeline.foundations.schema.SchemaTransformer
 
getEntityExpansionPolicy() - Method in class com.northconcepts.datapipeline.twitter.TwitterProxyReader
 
getEntityExpansionPolicy() - Method in class com.northconcepts.datapipeline.twitter.TwitterReader
 
getEntityExpansionPolicy() - Method in class com.northconcepts.datapipeline.twitter.TwitterWriter
 
getEntries() - Method in class com.northconcepts.datapipeline.transform.lookup.CachedLookup
Returns the number of cached elements.
getEpics(int, int, int, Boolean) - Method in interface com.northconcepts.datapipeline.jira.client.JiraClient
 
getErrorCount() - Method in class com.northconcepts.datapipeline.eventbus.EventBus
Returns the number of exceptions this bus has experienced.
getErrors() - Method in class com.northconcepts.datapipeline.foundations.datamapping.DataMappingResult
 
getErrors() - Method in class com.northconcepts.datapipeline.foundations.schema.ValidationResult
 
getErrors(boolean) - Method in class com.northconcepts.datapipeline.foundations.schema.ValidationResult
 
getEventBus() - Method in class com.northconcepts.datapipeline.eventbus.EventBusReader
 
getEventBus() - Method in class com.northconcepts.datapipeline.eventbus.EventBusWriter
 
getEventFilter() - Method in class com.northconcepts.datapipeline.eventbus.EventBusReader
 
getEventListenerClass() - Method in class com.northconcepts.datapipeline.eventbus.Event
 
getEventPublisher() - Method in class com.northconcepts.datapipeline.eventbus.Event
 
getEventsActive() - Method in class com.northconcepts.datapipeline.eventbus.EventBus
Returns the approximate number of threads that are actively delivering events using this bus' executorService or -1 if unknown.
getEventsDelivered() - Method in class com.northconcepts.datapipeline.eventbus.EventBus
Returns the combined number of events each listener on this event bus has received (typically EventBus.getEventsPublished() * EventBus.getListenerCount()).
getEventSource() - Method in class com.northconcepts.datapipeline.eventbus.Event
 
getEventSource() - Method in class com.northconcepts.datapipeline.eventbus.EventBusWriter
 
getEventsPublished() - Method in class com.northconcepts.datapipeline.eventbus.EventBus
Returns the number of events sent to this event bus for delivery to listeners.
getEventsQueued() - Method in class com.northconcepts.datapipeline.eventbus.EventBus
Returns the number of events waiting to be executed by this bus' executorService or -1 if unknown.
getException() - Method in class com.northconcepts.datapipeline.core.AsyncMultiReader
 
getException() - Method in class com.northconcepts.datapipeline.core.AsyncMultiReader.ReaderThread
 
getException() - Method in class com.northconcepts.datapipeline.core.AsyncReader
 
getException() - Method in class com.northconcepts.datapipeline.core.AsyncWriter
 
getException() - Method in class com.northconcepts.datapipeline.core.Message
 
getException() - Method in class com.northconcepts.datapipeline.google.calendar.GoogleCalendarReader
 
getException() - Method in class com.northconcepts.datapipeline.google.contacts.GoogleContactsReader
 
getException() - Method in class com.northconcepts.datapipeline.jdbc.JdbcMultiWriter
Returns an exception thrown by one of the internal AsyncWriters if any.
getException() - Method in class com.northconcepts.datapipeline.job.AbstractJob
Returns the last exception thrown while running.
getException() - Method in interface com.northconcepts.datapipeline.job.IJob
Returns the last exception thrown while running.
getException() - Method in class com.northconcepts.datapipeline.job.Job
Returns the last exception thrown while running.
getException() - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer
 
getException() - Method in class com.northconcepts.datapipeline.twitter2.TwitterFilterStreamReader
 
getExceptionCount() - Method in class com.northconcepts.datapipeline.retry.RetryingOperation
Returns the total number of exceptions/failures seen by this reader.
getExceptionCount() - Method in class com.northconcepts.datapipeline.retry.RetryingReader
Returns the total number of exceptions/failures seen by this reader.
getExceptionCount() - Method in class com.northconcepts.datapipeline.retry.RetryingWriter
Returns the total number of exceptions/failures seen by this writer.
getExceptions(boolean) - Method in class com.northconcepts.datapipeline.foundations.datamapping.DataMappingResult
 
getExceptions() - Method in class com.northconcepts.datapipeline.foundations.datamapping.DataMappingResult
 
getExceptions() - Method in class com.northconcepts.datapipeline.jdbc.JdbcMultiWriter
Returns all exceptions thrown by the internal AsyncWriters (the list will not be null, but may contain no elements).
getExcludedWords() - Method in class com.northconcepts.datapipeline.transform.SplitWords
 
getExcludeNulls() - Method in class com.northconcepts.datapipeline.group.GroupOperation
 
getExportedKey(String) - Method in class com.northconcepts.datapipeline.foundations.jdbc.JdbcTable
 
getExportedKeyColumns(String) - Method in class com.northconcepts.datapipeline.foundations.jdbc.JdbcTable
 
getExportedKeys() - Method in class com.northconcepts.datapipeline.foundations.jdbc.JdbcTable
 
getExpression() - Method in class com.northconcepts.datapipeline.filter.FilterExpression
 
getExpression() - Method in class com.northconcepts.datapipeline.foundations.decisiontable.DecisionTableCondition
 
getExpression() - Method in class com.northconcepts.datapipeline.foundations.decisiontable.DecisionTableOutcome
 
getExpression() - Method in class com.northconcepts.datapipeline.foundations.decisiontree.DecisionTreeOutcome
 
getExpression() - Method in class com.northconcepts.datapipeline.foundations.expression.CalculatedField
 
getExpression() - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.filter.FilterMatchExpression
 
getExpression() - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.validate.ValidateMatchExpression
 
getExpression() - Method in class com.northconcepts.datapipeline.json.builder.JsonExpression
 
getExpression() - Method in class com.northconcepts.datapipeline.json.builder.JsonLogicalExpression
 
getExpression() - Method in class com.northconcepts.datapipeline.transform.SetCalculatedField
 
getExpression() - Method in class com.northconcepts.datapipeline.xml.builder.XmlExpression
 
getExpression() - Method in class com.northconcepts.datapipeline.xml.builder.XmlLogicalExpression
 
getExpressionAsString() - Method in exception com.northconcepts.datapipeline.expression.ParseException
 
getExpressionAsString() - Method in class com.northconcepts.datapipeline.filter.FilterExpression
 
getExpressionContext() - Method in class com.northconcepts.datapipeline.foundations.datamapping.DataMappingReader
 
getExpressionContext() - Method in class com.northconcepts.datapipeline.foundations.datamapping.DataMappingWriter
 
getExpressionContext() - Method in class com.northconcepts.datapipeline.foundations.decisiontable.DecisionTableReader
 
getExpressionContext() - Method in class com.northconcepts.datapipeline.foundations.decisiontable.DecisionTableWriter
 
getExpressionContext() - Method in class com.northconcepts.datapipeline.foundations.decisiontree.DecisionTreeReader
 
getExpressionContext() - Method in class com.northconcepts.datapipeline.foundations.decisiontree.DecisionTreeWriter
 
getExpressionSource() - Method in class com.northconcepts.datapipeline.foundations.decisiontable.DecisionTableCondition
 
getExpressionSource() - Method in class com.northconcepts.datapipeline.foundations.decisiontable.DecisionTableOutcome
 
getExpressionSource() - Method in class com.northconcepts.datapipeline.foundations.decisiontree.DecisionTreeOutcome
 
getExpressionSource() - Method in class com.northconcepts.datapipeline.foundations.expression.CalculatedField
 
getFactory() - Method in class com.northconcepts.datapipeline.foundations.pipeline.input.DataReaderPipelineInput
 
getFactory() - Method in class com.northconcepts.datapipeline.foundations.pipeline.output.DataWriterPipelineOutput
 
getFailedCondition() - Method in class com.northconcepts.datapipeline.foundations.datamapping.DataMappingResult
 
getField(Record, boolean, boolean) - Method in class com.northconcepts.datapipeline.core.FieldPath
 
getField(int) - Method in class com.northconcepts.datapipeline.core.Record
Returns the field at the specified index (for zero or positive indexes) or from the end of the list (for negative indexes by adding index to the size of the list).
getField(int, boolean) - Method in class com.northconcepts.datapipeline.core.Record
 
getField(String) - Method in class com.northconcepts.datapipeline.core.Record
 
getField(String, boolean) - Method in class com.northconcepts.datapipeline.core.Record
 
getField(FieldPath) - Method in class com.northconcepts.datapipeline.core.Record
 
getField(FieldPath, boolean) - Method in class com.northconcepts.datapipeline.core.Record
 
getField(FieldPath, boolean, boolean) - Method in class com.northconcepts.datapipeline.core.Record
 
getField(FieldList, boolean) - Method in class com.northconcepts.datapipeline.core.Record
Retrieves a nested child field.
getField(String) - Method in class com.northconcepts.datapipeline.foundations.schema.EntityDef
 
getField() - Method in class com.northconcepts.datapipeline.foundations.schema.ValidationMessage
 
getField() - Method in class com.northconcepts.datapipeline.jdbc.sql.select.QueryOrderPart
 
getField() - Method in class com.northconcepts.datapipeline.lineage.FieldLineage
 
getField() - Method in class com.northconcepts.datapipeline.template.FieldKeyValuePair
 
getFieldCount() - Method in class com.northconcepts.datapipeline.core.Record
 
getFieldFilter() - Method in class com.northconcepts.datapipeline.filter.FieldFilterRule
 
getFieldMappings() - Method in class com.northconcepts.datapipeline.foundations.datamapping.DataMapping
 
getFieldName() - Method in exception com.northconcepts.datapipeline.core.DataException
Returns the field name associated with this exception.
getFieldName() - Method in class com.northconcepts.datapipeline.core.FieldComparator
 
getFieldName() - Method in class com.northconcepts.datapipeline.foundations.pipeline.dataset.TreeNode
 
getFieldName() - Method in class com.northconcepts.datapipeline.transform.MoveFieldAfter
 
getFieldName() - Method in class com.northconcepts.datapipeline.transform.MoveFieldBefore
 
getFieldName() - Method in class com.northconcepts.datapipeline.transform.MoveFieldToIndex
 
getFieldNameList() - Method in class com.northconcepts.datapipeline.core.Record
 
getFieldNames() - Method in class com.northconcepts.datapipeline.core.AbstractReader
 
getFieldNames() - Method in class com.northconcepts.datapipeline.core.Record
 
getFieldNames() - Method in class com.northconcepts.datapipeline.foundations.schema.ValidationResult
 
getFieldPath(int) - Method in class com.northconcepts.datapipeline.core.FieldList
 
getFields() - Method in class com.northconcepts.datapipeline.bloomberg.BloombergMessage
 
getFields() - Method in class com.northconcepts.datapipeline.bloomberg.BloombergMessageFields
 
getFields() - Method in class com.northconcepts.datapipeline.core.FieldDeclarations
 
getFields() - Method in class com.northconcepts.datapipeline.core.Record
Returns a new collection of the fields in this record.
getFields() - Method in class com.northconcepts.datapipeline.foundations.decisiontable.DecisionTable
 
getFields() - Method in class com.northconcepts.datapipeline.foundations.decisiontree.DecisionTree
 
getFields() - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.aggregate.AggregateGroupFieldsAction
 
getFields() - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.convert.ConvertDateTimeToStringAction
 
getFields() - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.convert.ConvertNumberToStringAction
 
getFields() - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.convert.ConvertStringToBooleanAction
 
getFields() - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.convert.ConvertStringToDateTimeAction
 
getFields() - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.convert.ConvertStringToNumberAction
 
getFields() - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.convert.ConvertValueToStringAction
 
getFields() - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.filter.FilterFieldExistsAction
 
getFields() - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.filter.FilterFieldNotNullAction
 
getFields() - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.transform.SelectArrangeFieldsAction
 
getFields() - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.validate.ValidateFieldsExistsAction
 
getFields() - Method in class com.northconcepts.datapipeline.foundations.pipeline.action.validate.ValidateFieldsNotNullAction
 
getFields() - Method in class com.northconcepts.datapipeline.foundations.pipeline.input.XmlPipelineInput
 
getFields(boolean) - Method in class com.northconcepts.datapipeline.foundations.pipeline.input.XmlPipelineInput
 
getFields(boolean) - Method in class com.northconcepts.datapipeline.foundations.schema.EntityDef
 
getFields() - Method in class com.northconcepts.datapipeline.foundations.schema.EntityDef
 
getFields() - Method in class com.northconcepts.datapipeline.foundations.schema.ValidationResult
 
getFields() - Method in class com.northconcepts.datapipeline.jdbc.sql.select.QueryGrouping
 
getFields() - Method in class com.northconcepts.datapipeline.jdbc.sql.select.QuerySelection
 
getFields() - Method in class com.northconcepts.datapipeline.jira.JiraSearch
 
getFields() - Method in class com.northconcepts.datapipeline.transform.lookup.LookupTransformer
 
getFields() - Method in class com.northconcepts.datapipeline.transform.RemoveDuplicateFields
 
getFields() - Method in class com.northconcepts.datapipeline.transform.SelectFields
 
getFieldSchema() - Method in class com.northconcepts.datapipeline.lineage.FieldLineage
 
getFieldSeparator() - Method in class com.northconcepts.datapipeline.csv.CSVReader
 
getFieldSeparator() - Method in class com.northconcepts.datapipeline.csv.CSVWriter
Returns the string used between each field value (defaults to comma).
getFieldSeparator() - Method in class com.northconcepts.datapipeline.foundations.pipeline.input.CsvPipelineInput
 
getFieldSeparator() - Method in class com.northconcepts.datapipeline.foundations.pipeline.output.CsvPipelineOutput
 
getFieldSeparator() - Method in class com.northconcepts.datapipeline.transform.FlattenRecord
 
getFieldType() - Method in class com.northconcepts.datapipeline.foundations.pipeline.dataset.Column
 
getFieldType() - Method in class com.northconcepts.datapipeline.transform.SetField
 
getFieldTypeCount() - Method in class com.northconcepts.datapipeline.foundations.pipeline.dataset.Column
 
getFieldTypes(FieldList) - Method in class com.northconcepts.datapipeline.core.Record
 
getFieldTypes() - Method in class com.northconcepts.datapipeline.core.Record
 
getFieldTypes() - Method in class com.northconcepts.datapipeline.foundations.pipeline.dataset.Column
 
getFieldValue(String, T) - Method in class com.northconcepts.datapipeline.core.Record
 
getFieldValueAsArray(String, ArrayValue) - Method in class com.northconcepts.datapipeline.core.Record
Returns the field's value as array if the field exists and its value is not null, otherwise, it returns the default value.
getFieldValueAsBigDecimal(String, BigDecimal) - Method in class com.northconcepts.datapipeline.core.Record
Returns the field's value if the field exists and its value is not null, otherwise, it returns the default value.
getFieldValueAsBigInteger(String, BigInteger) - Method in class com.northconcepts.datapipeline.core.Record
Returns the field's value if the field exists and its value is not null, otherwise, it returns the default value.
getFieldValueAsBoolean(String, Boolean) - Method in class com.northconcepts.datapipeline.core.Record
Returns the field's value if the field exists and its value is not null, otherwise, it returns the default value.
getFieldValueAsByte(String, Byte) - Method in class com.northconcepts.datapipeline.core.Record
Returns the field's value if the field exists and its value is not null, otherwise, it returns the default value.
getFieldValueAsChar(String, Character) - Method in class com.northconcepts.datapipeline.core.Record
Returns the field's value if the field exists and its value is not null, otherwise, it returns the default value.
getFieldValueAsDate(String, Date) - Method in class com.northconcepts.datapipeline.core.Record
Returns the field's value if the field exists and its value is not null, otherwise, it returns the default value.
getFieldValueAsDatetime(String, Date) - Method in class com.northconcepts.datapipeline.core.Record
Returns the field's value if the field exists and its value is not null, otherwise, it returns the default value.
getFieldValueAsDouble(String, Double) - Method in class com.northconcepts.datapipeline.core.Record
Returns the field's value if the field exists and its value is not null, otherwise, it returns the default value.
getFieldValueAsFloat(String, Float) - Method in class com.northconcepts.datapipeline.core.Record
Returns the field's value if the field exists and its value is not null, otherwise, it returns the default value.
getFieldValueAsInteger(String, Integer) - Method in class com.northconcepts.datapipeline.core.Record
Returns the field's value if the field exists and its value is not null, otherwise, it returns the default value.
getFieldValueAsLocalDate(String, LocalDate) - Method in class com.northconcepts.datapipeline.core.Record
Returns the field's value if the field exists and its value is not null, otherwise, it returns the default value.
getFieldValueAsLocalDatetime(String, LocalDateTime) - Method in class com.northconcepts.datapipeline.core.Record
Returns the field's value if the field exists and its value is not null, otherwise, it returns the default value.
getFieldValueAsLocalTime(String, LocalTime) - Method in class com.northconcepts.datapipeline.core.Record
Returns the field's value if the field exists and its value is not null, otherwise, it returns the default value.
getFieldValueAsLong(String, Long) - Method in class com.northconcepts.datapipeline.core.Record
Returns the field's value if the field exists and its value is not null, otherwise, it returns the default value.
getFieldValueAsRecord(String, Record) - Method in class com.northconcepts.datapipeline.core.Record
Returns the field's value if the field exists and its value is not null, otherwise, it returns the default value.
getFieldValueAsShort(String, Short) - Method in class com.northconcepts.datapipeline.core.Record
Returns the field's value if the field exists and its value is not null, otherwise, it returns the default value.
getFieldValueAsString(String, String) - Method in class com.northconcepts.datapipeline.core.Record
Returns the field's value if the field exists and its value is not null, otherwise, it returns the default value.
getFieldValueAsTime(String, Time) - Method in class com.northconcepts.datapipeline.core.Record
Returns the field's value if the field exists and its value is not null, otherwise, it returns the default value.
getFieldValues(long) - Method in class com.northconcepts.datapipeline.xml.XmlReader
 
getFile() - Method in class com.northconcepts.datapipeline.core.TextReader
 
getFile() - Method in class com.northconcepts.datapipeline.core.TextStreamWriter
 
getFile() - Method in class com.northconcepts.datapipeline.core.TextWriter
 
getFile() - Method in class com.northconcepts.datapipeline.excel.ExcelDocument
 
getFile() - Method in class com.northconcepts.datapipeline.foundations.file.FileDetector
 
getFile() - Method in class com.northconcepts.datapipeline.foundations.file.LocalFile
 
getFile() - Method in class com.northconcepts.datapipeline.lineage.FieldLineage
 
getFile() - Method in class com.northconcepts.datapipeline.lineage.RecordLineage
 
getFileColumnNumber() - Method in class com.northconcepts.datapipeline.lineage.FieldLineage
 
getFileColumnNumber() - Method in class com.northconcepts.datapipeline.lineage.RecordLineage
 
getFileExtension() - Method in enum com.northconcepts.datapipeline.foundations.file.FileType
 
getFileLineNumber() - Method in class com.northconcepts.datapipeline.lineage.FieldLineage
 
getFileLineNumber() - Method in class com.northconcepts.datapipeline.lineage.RecordLineage
 
getFileSink() - Method in class com.northconcepts.datapipeline.foundations.pipeline.output.CsvPipelineOutput
 
getFileSink() - Method in class com.northconcepts.datapipeline.foundations.pipeline.output.ExcelPipelineOutput
 
getFileSink() - Method in class com.northconcepts.datapipeline.foundations.pipeline.output.FileSinkPipelineOutput
 
getFileSize() - Method in interface com.northconcepts.datapipeline.foundations.file.FileSink
 
getFileSize() - Method in interface com.northconcepts.datapipeline.foundations.file.FileSource
 
getFileSize() - Method in class com.northconcepts.datapipeline.foundations.file.LocalFile
 
getFileSource() - Method in class com.northconcepts.datapipeline.foundations.pipeline.input.CsvPipelineInput
 
getFileSource() - Method in class com.northconcepts.datapipeline.foundations.pipeline.input.ExcelPipelineInput
 
getFileSource() - Method in class com.northconcepts.datapipeline.foundations.pipeline.input.FileSourcePipelineInput
 
getFileSource() - Method in class com.northconcepts.datapipeline.foundations.pipeline.input.JsonRecordPipelineInput
 
getFileSource() - Method in class com.northconcepts.datapipeline.foundations.pipeline.input.XmlPipelineInput
 
getFileSource() - Method in class com.northconcepts.datapipeline.foundations.pipeline.input.XmlRecordPipelineInput
 
getFileType() - Method in class com.northconcepts.datapipeline.foundations.file.FileDetector
 
getFileType() - Method in interface com.northconcepts.datapipeline.foundations.file.FileSink
 
getFileType() - Method in interface com.northconcepts.datapipeline.foundations.file.FileSource
 
getFileType() - Method in class com.northconcepts.datapipeline.foundations.file.LocalFile
 
getFillChar() - Method in class com.northconcepts.datapipeline.fixedwidth.FixedWidthReader
 
getFillChar() - Method in class com.northconcepts.datapipeline.fixedwidth.FixedWidthWriter
 
getFilter() - Method in class com.northconcepts.datapipeline.file.FileSystemInfoReader
 
getFilter() - Method in class com.northconcepts.datapipeline.group.GroupOperation
 
getFilter() - Method in class com.northconcepts.datapipeline.parquet.ParquetDataReader
Returns the filter settings.
getFilter() - Method in class com.northconcepts.datapipeline.transform.TransformingReader
Deprecated.
getFilter() - Method in class com.northconcepts.datapipeline.trello.TrelloBoardsReader
 
getFilteredStreamRules() - Method in class com.northconcepts.datapipeline.twitter2.TwitterV2Client
Returns the active rules on the streaming endpoint.
getFinishedOn() - Method in class com.northconcepts.datapipeline.job.AbstractJob
Returns the time this job finished running.
getFinishedOn() - Method in interface com.northconcepts.datapipeline.job.IJob
Returns the time this job finished running.
getFinishedOn() - Method in class com.northconcepts.datapipeline.job.Job
Returns the time this job finished running.
getFirstColumnIndex() - Method in class com.northconcepts.datapipeline.excel.ExcelWriter
 
getFirstColumnIndex() - Method in class com.northconcepts.datapipeline.foundations.pipeline.output.ExcelPipelineOutput
 
getFirstException() - Method in class com.northconcepts.datapipeline.retry.RetryingOperation
Returns the first exception thrown for any individual read attempt.
getFirstException() - Method in class com.northconcepts.datapipeline.retry.RetryingReader
Returns the first exception thrown for any individual read attempt.
getFirstException() - Method in class com.northconcepts.datapipeline.retry.RetryingWriter
Returns the first exception thrown for any individual write attempt.
getFirstMessage(Message[]) - Method in enum com.northconcepts.datapipeline.email.EmailReadDirection
 
getFirstProperty(String, String) - Method in class com.northconcepts.datapipeline.bloomberg.BloombergMessageFooter
 
getFirstProperty(String, String) - Method in class com.northconcepts.datapipeline.bloomberg.BloombergMessageHeader