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

AbstractJob - Class in com.northconcepts.datapipeline.job
Used to run, pause, and cancel Runnables.
AbstractJob() - Constructor for class com.northconcepts.datapipeline.job.AbstractJob
 
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
 
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
 
add(Record) - Method in class com.northconcepts.datapipeline.buffer.RecordBuffer
 
add(DataReader...) - Method in class com.northconcepts.datapipeline.core.AsyncMultiReader
 
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(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.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
 
addAll(ArrayValue) - Method in class com.northconcepts.datapipeline.core.ArrayValue
 
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(DataReader) - Method in class com.northconcepts.datapipeline.core.RecordList
 
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.MySqlUpsert
 
addDebug(String, boolean) - Method in class com.northconcepts.datapipeline.core.Messages
 
addDebug(String, Throwable) - Method in class com.northconcepts.datapipeline.core.Messages
 
addElapsedtime(long) - Method in class com.northconcepts.datapipeline.core.DataEndpoint
 
addEventBusLifecycleListener(EventBusLifecycleListener) - Static 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.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
Adds this endpoint's current state to a DataException.
addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.core.DataObject
Adds this object's current state to a DataException.
addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.core.DataReader
 
addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.core.DataWriter
 
addExceptionProperties(DataException) - Method in class com.northconcepts.datapipeline.core.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.TextWriter
 
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.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.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 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.MySqlUpsert
 
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.json.JsonRecordReader
 
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.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.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.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
 
addExceptionPropertiesImpl(DataException) - Method in class com.northconcepts.datapipeline.core.AsyncReader
 
addExceptionPropertiesImpl(DataException) - Method in class com.northconcepts.datapipeline.core.AsyncWriter
 
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(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.
addFields(int...) - Method in class com.northconcepts.datapipeline.fixedwidth.FixedWidthReader
 
addFields(int...) - Method in class com.northconcepts.datapipeline.fixedwidth.FixedWidthWriter
 
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
 
addJobLifecycleListener(JobLifecycleListener) - Static method in class com.northconcepts.datapipeline.job.Job
 
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(EventFilter, UntypedEventListener) - Method in class com.northconcepts.datapipeline.eventbus.EventBus
 
addListener(EventFilter, UntypedEventListener, Object) - Method in class com.northconcepts.datapipeline.eventbus.EventBus
 
addMessage(Message) - Method in class com.northconcepts.datapipeline.core.Messages
 
addMessageHeader(Message, Record) - Method in class com.northconcepts.datapipeline.jms.JmsReader
 
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
 
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
 
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
 
addRule(FieldFilterRule...) - Method in class com.northconcepts.datapipeline.filter.FieldFilter
 
addShutdownListener(EventFilter, ShutdownListener) - Method in class com.northconcepts.datapipeline.eventbus.EventBus
 
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(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
 
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.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
 
AmazonS3FileSystem - Class in com.northconcepts.datapipeline.filesystem.amazons3
Class for accessing an Amazon S3 file system.
AmazonS3FileSystem() - Constructor for class com.northconcepts.datapipeline.filesystem.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(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
 
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
 
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.DataEndpoint
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.DataEndpoint
Asserts that this endpoint has not yet started reading or writing, otherwise an exception is thrown.
assertOpened() - Method in class com.northconcepts.datapipeline.core.DataEndpoint
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
 
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.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(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
 
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
 
buffer - Variable in class com.northconcepts.datapipeline.core.AsyncMultiReader
 
BUFFER_SIZE - Static variable in class com.northconcepts.datapipeline.core.DataEndpoint
 
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
 

C

CachedLookup - Class in com.northconcepts.datapipeline.transform.lookup
A Lookup that 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 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
 
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.DataEndpoint
 
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.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.
clone() - Method in class com.northconcepts.datapipeline.core.ArrayValue
 
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.job.AbstractJob
 
clone() - Method in class com.northconcepts.datapipeline.job.Job
 
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 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.TextWriter
 
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.filesystem.amazons3.AmazonS3FileSystem
Closes the Amazon S3 connection.
close() - Method in class com.northconcepts.datapipeline.filter.FilteringReader
 
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.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.MySqlUpsert
 
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.json.JsonRecordReader
 
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.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.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.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.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
 
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
 
com.northconcepts.datapipeline.avro - package com.northconcepts.datapipeline.avro
 
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.filesystem.amazons3 - package com.northconcepts.datapipeline.filesystem.amazons3
 
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.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.javabean - package com.northconcepts.datapipeline.javabean
 
com.northconcepts.datapipeline.jdbc - package com.northconcepts.datapipeline.jdbc
 
com.northconcepts.datapipeline.jdbc.sql - package com.northconcepts.datapipeline.jdbc.sql
 
com.northconcepts.datapipeline.jdbc.sql.insert - package com.northconcepts.datapipeline.jdbc.sql.insert
 
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.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.mailchimp - package com.northconcepts.datapipeline.mailchimp
 
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.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.twitter - package com.northconcepts.datapipeline.twitter
 
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
 
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
 
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
 
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
 
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.
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
 
copy(DataReader, DataWriter) - Static method in class com.northconcepts.datapipeline.core.SortingReader
 
CopyField - Class in com.northconcepts.datapipeline.transform
See FieldPath for supported field name expressions.
CopyField(String, String) - Constructor for class com.northconcepts.datapipeline.transform.CopyField
 
CopyField(String, String, boolean) - Constructor for class com.northconcepts.datapipeline.transform.CopyField
 
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).
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
 
createConsumer(JmsSettings, JmsConnection) - Method in enum com.northconcepts.datapipeline.jms.JmsDestinationType
 
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
 
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
 
CreateWindowStrategy - Class in com.northconcepts.datapipeline.group
Determines when GroupByReader opens a new sliding window.
CreateWindowStrategy() - Constructor for class com.northconcepts.datapipeline.group.CreateWindowStrategy
 
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

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.
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
 
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.
DataWriter - Class in com.northconcepts.datapipeline.core
Abstract super-class for writing records.
DataWriter() - Constructor for class com.northconcepts.datapipeline.core.DataWriter
 
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
 
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
 
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
 
dateTimeToDate() - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer
 
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
 
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.filesystem.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.DataEndpoint
 
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
 
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
 
Diagnostic - Class in com.northconcepts.datapipeline.diagnostic
Helps diagnose environmental issues by collecting properties and sending them to https://northconcepts.com/contact.
Diagnostic() - Constructor for class com.northconcepts.datapipeline.diagnostic.Diagnostic
 
Diagnostic(String, String, String) - 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
 
DRAFTS - Static variable in interface com.northconcepts.datapipeline.email.GmailFolders
 

E

E - Static variable in class com.northconcepts.datapipeline.meter.Meter
 
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
 
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.
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
 
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
 
ensureCapacity(int) - Method in class com.northconcepts.datapipeline.core.ArrayValue
 
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
 
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
 
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
 
evaluate(String) - Method in class com.northconcepts.datapipeline.core.Record
 
evaluate() - Method in class com.northconcepts.datapipeline.group.AggregateReader.AggregateOperation
Deprecated.
 
evaluate(ExpressionContext) - Method in class com.northconcepts.datapipeline.json.builder.JsonExpression
 
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
 
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(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
 
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 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.MySqlUpsert
 
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.MySqlUpsert
 
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
 
FieldComparator - Class in com.northconcepts.datapipeline.core
See FieldPath for supported field name expressions.
FieldComparator() - Constructor for class com.northconcepts.datapipeline.core.FieldComparator
 
FieldDeclarations - Class in com.northconcepts.datapipeline.core
 
FieldDeclarations() - Constructor for class com.northconcepts.datapipeline.core.FieldDeclarations
 
FieldExists - Class in com.northconcepts.datapipeline.filter
A filter that checks if 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
 
FieldList - Class in com.northconcepts.datapipeline.core
See FieldPath for supported field name expressions.
FieldList(String...) - Constructor for class com.northconcepts.datapipeline.core.FieldList
 
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 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
 
FieldType - Enum in com.northconcepts.datapipeline.core
FieldType lists of all field data types used in records.
file - Variable in class com.northconcepts.datapipeline.xml.XmlReader
 
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
 
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
 
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
 
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.
finalize() - Method in class com.northconcepts.datapipeline.core.DataEndpoint
Closes this endpoint if it's still open.
finalize() - Method in class com.northconcepts.datapipeline.eventbus.EventBus
 
findAll(Filter) - Method in class com.northconcepts.datapipeline.core.RecordList
 
findFirst(Filter, int) - Method in class com.northconcepts.datapipeline.core.RecordList
 
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.
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) - Static method in class com.northconcepts.datapipeline.core.Record
 
fromJson(Reader) - Static method in class com.northconcepts.datapipeline.core.Record
 
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.
fromXml(String) - Static method in class com.northconcepts.datapipeline.core.Record
 
fromXml(Reader) - Static method in class com.northconcepts.datapipeline.core.Record
 
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
 
GenericUpsert - Class in com.northconcepts.datapipeline.jdbc.upsert
 
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.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) - Static method in class com.northconcepts.datapipeline.mailchimp.MailChimpClient.Proxy
 
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).
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.
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
 
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
 
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.
 
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.mongodb.MongoWriter
 
getBatchSize() - Method in class com.northconcepts.datapipeline.twitter.TwitterUserLookupReader
 
getBeforeFieldName() - Method in class com.northconcepts.datapipeline.transform.MoveFieldBefore
 
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.
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
 
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.
getCascadeResetLocationPath() - Method in class com.northconcepts.datapipeline.xml.XmlField
 
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.
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
 
getClient() - Method in class com.northconcepts.datapipeline.filesystem.amazons3.AmazonS3FileSystem
 
getClientId() - Method in class com.northconcepts.datapipeline.jms.JmsSettings
 
getClosedOn() - Method in class com.northconcepts.datapipeline.core.DataEndpoint
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.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
 
getColumnName() - Method in class com.northconcepts.datapipeline.jdbc.sql.insert.InsertValue
 
getColumnName() - Method in class com.northconcepts.datapipeline.jdbc.sql.update.UpdateValue
 
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.
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
 
getConditionCount() - Method in class com.northconcepts.datapipeline.jdbc.sql.select.ConditionPart
 
getConditionCount() - Method in class com.northconcepts.datapipeline.jdbc.sql.select.QueryCriteriaPart
 
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.template.TemplateWriter
 
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
 
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
 
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.filesystem.amazons3.AmazonS3FileSystem
 
getCredentialsProvider() - Method in class com.northconcepts.datapipeline.filesystem.amazons3.AmazonS3FileSystem
 
getCriteria() - Method in class com.northconcepts.datapipeline.jdbc.sql.select.Select
 
getCriteria() - Method in class com.northconcepts.datapipeline.jdbc.sql.update.Update
 
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.template.TemplateWriter
 
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
 
getDecimalPlaces() - Method in class com.northconcepts.datapipeline.transform.format.Rounder
 
getDeclaration() - Method in class com.northconcepts.datapipeline.xml.builder.XmlTemplate
 
getDefaultPort() - Method in enum com.northconcepts.datapipeline.email.MailStore
 
getDefaultType() - Method in class com.northconcepts.datapipeline.core.ArrayValue
 
getDescription() - Method in class com.northconcepts.datapipeline.core.DataEndpoint
 
getDescription() - Method in enum com.northconcepts.datapipeline.twitter.TwitterErrorCode
 
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.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.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.
getDuplicateFieldAction() - Method in class com.northconcepts.datapipeline.transform.lookup.LookupTransformer
 
getDuplicateFieldPolicy() - Method in class com.northconcepts.datapipeline.xml.XmlReader
 
getElapsedTime() - Method in class com.northconcepts.datapipeline.core.DataEndpoint
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 (DataEndpoint.setCaptureElapsedTime(boolean) was called with true).
getElapsedTime() - Method in class com.northconcepts.datapipeline.meter.Meter
 
getElapsedTimeAsString() - Method in class com.northconcepts.datapipeline.core.DataEndpoint
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 (DataEndpoint.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
 
getEmptyStringValuePolicy() - Method in class com.northconcepts.datapipeline.csv.CSVWriter
Returns the object responsible for writing empty string values (defaults to ValuePolicy.QUOTED_EMPTY_STRING).
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 - ").
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.
getErrorCount() - Method in class com.northconcepts.datapipeline.eventbus.EventBus
Returns the number of exceptions this bus has experienced.
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.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
 
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() - 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
 
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
 
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() - Method in class com.northconcepts.datapipeline.jdbc.sql.select.QueryOrderPart
 
getFieldCount() - Method in class com.northconcepts.datapipeline.core.Record
 
getFieldFilter() - Method in class com.northconcepts.datapipeline.filter.FieldFilterRule
 
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.transform.MoveFieldAfter
 
getFieldName() - Method in class com.northconcepts.datapipeline.transform.MoveFieldBefore
 
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
 
getFieldPath(int) - Method in class com.northconcepts.datapipeline.core.FieldList
 
getFields() - Method in class com.northconcepts.datapipeline.core.FieldDeclarations
 
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.transform.lookup.LookupTransformer
 
getFields() - Method in class com.northconcepts.datapipeline.transform.SelectFields
 
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.transform.FlattenRecord
 
getFieldType() - Method in class com.northconcepts.datapipeline.transform.SetField
 
getFieldTypes(FieldList) - Method in class com.northconcepts.datapipeline.core.Record
 
getFieldTypes() - Method in class com.northconcepts.datapipeline.core.Record
 
getFieldValues(long) - Method in class com.northconcepts.datapipeline.xml.XmlReader
 
getFile() - Method in class com.northconcepts.datapipeline.core.TextWriter
 
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.transform.TransformingReader
Deprecated.
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
 
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
 
getFirstRowIndex() - Method in class com.northconcepts.datapipeline.excel.ExcelWriter
 
getFolderName() - Method in class com.northconcepts.datapipeline.email.EmailReader
 
getFollow() - Method in class com.northconcepts.datapipeline.twitter.TwitterFilterStreamReader
 
getFooterTemplate() - Method in class com.northconcepts.datapipeline.template.TemplateWriter
 
getFormat() - Method in class com.northconcepts.datapipeline.core.StreamWriter
 
getGroupByFields() - Method in class com.northconcepts.datapipeline.group.GroupByReader
 
getGrouping() - Method in class com.northconcepts.datapipeline.jdbc.sql.select.Select
 
getHasValue() - Method in class com.northconcepts.datapipeline.jdbc.sql.select.ConditionPart
 
getHeaderTemplate() - Method in class com.northconcepts.datapipeline.template.TemplateWriter
 
getHits() - Method in class com.northconcepts.datapipeline.transform.lookup.CachedLookup
Returns the number of lookup requests where the results were already cached.
getHost() - Method in class com.northconcepts.datapipeline.email.EmailReader
 
getHttpProxyHost() - Method in class com.northconcepts.datapipeline.twitter.TwitterProvider
 
getHttpProxyHost() - Method in class com.northconcepts.datapipeline.twitter.TwitterStreamProvider
 
getHttpProxyPort() - Method in class com.northconcepts.datapipeline.twitter.TwitterProvider
 
getHttpProxyPort() - Method in class com.northconcepts.datapipeline.twitter.TwitterStreamProvider
 
getId() - Method in class com.northconcepts.datapipeline.core.DataObject
The auto numbered ID of this instance.
getId() - Method in class com.northconcepts.datapipeline.eventbus.EventBus
Returns the unique (sequential) ID of this event bus (within this JVM/classloader).
getId() - Method in enum com.northconcepts.datapipeline.jms.JmsAcknowledgeMode
 
getId() - Method in class com.northconcepts.datapipeline.job.Job
Returns the unique (sequential) ID of this job (within this JVM/classloader).
getIncludeDirectories() - Method in class com.northconcepts.datapipeline.file.FileSystemInfoReader
 
getIncludeElapsedTime() - Method in class com.northconcepts.datapipeline.core.DebugReader
 
getIndex() - Method in class com.northconcepts.datapipeline.core.Field
Returns the position of this field within its record.
getInitialRetryDelay() - Method in class com.northconcepts.datapipeline.retry.RetryingOperation
Returns the amount of time to wait (in milliseconds) after the first error, before retrying (default 1 second).
getInitialRetryDelay() - Method in class com.northconcepts.datapipeline.retry.RetryingReader
Returns the amount of time to wait (in milliseconds) after the first error, before retrying (default 1 second).
getInitialRetryDelay() - Method in class com.northconcepts.datapipeline.retry.RetryingWriter
Returns the amount of time to wait (in milliseconds) after the first error, before retrying (default 1 second).
getInstanceName() - Method in class com.northconcepts.datapipeline.jms.JmsSettings
 
getJdbcType(String) - Method in class com.northconcepts.datapipeline.jdbc.JdbcUpsertWriter
 
getJdbcType(String) - Method in class com.northconcepts.datapipeline.jdbc.JdbcWriter
 
getJdbcWriter(int) - Method in class com.northconcepts.datapipeline.jdbc.JdbcMultiWriter
 
getJndiFactoryName() - Method in class com.northconcepts.datapipeline.jms.JmsSettings
Indicates the JNDI name to use when looking up the ConnectionFactory (defaults to "ConnectionFactory").
getJobCount() - Static method in class com.northconcepts.datapipeline.job.Job
Returns the current number of live jobs in the JVM/classloader.
getKey() - Method in class com.northconcepts.datapipeline.buffer.RecordBuffer
 
getKeyFields() - Method in class com.northconcepts.datapipeline.jdbc.JdbcUpsertWriter
 
getLanguage() - Method in class com.northconcepts.datapipeline.twitter.TwitterFilterStreamReader
 
getLargestPoolSize() - Method in class com.northconcepts.datapipeline.eventbus.EventBus
Returns the largest number of threads that have ever simultaneously been in the pool in this bus' executorService or -1 if unknown.
getLastChildNodeElementDepth() - Method in class com.northconcepts.datapipeline.xml.builder.XmlNode
 
getLastChildNodeElementDepth() - Method in class com.northconcepts.datapipeline.xml.builder.XmlNodeContainer
 
getLastException() - Method in class com.northconcepts.datapipeline.retry.RetryingOperation
Returns the last exception thrown for any individual read attempt.
getLastException() - Method in class com.northconcepts.datapipeline.retry.RetryingReader
Returns the last exception thrown for any individual read attempt.
getLastException() - Method in class com.northconcepts.datapipeline.retry.RetryingWriter
Returns the last exception thrown for any individual write attempt.
getLastLineSeparator() - Method in class com.northconcepts.datapipeline.core.LineParser
 
getLastRecord() - Method in class com.northconcepts.datapipeline.core.DataEndpoint
Returns the most recent record seen by this endpoint while it is open or null.
getLastRecord() - Method in class com.northconcepts.datapipeline.job.Job
Returns the most recent record seen by this job while it is running or null.
getLastRow() - Method in class com.northconcepts.datapipeline.core.AbstractReader
 
getLatitude() - Method in class com.northconcepts.datapipeline.instagram.InstagramLocationMediaReader
 
getLatitude() - Method in class com.northconcepts.datapipeline.instagram.InstagramLocationReader
 
getLevel() - Method in class com.northconcepts.datapipeline.core.Message
 
getLimit() - Method in class com.northconcepts.datapipeline.core.LimitReader
 
getLimit() - Method in class com.northconcepts.datapipeline.twitter.TwitterRateLimit
 
getLimitRemaining() - Method in class com.northconcepts.datapipeline.twitter.TwitterRateLimit
 
getLimitResetTime() - Method in class com.northconcepts.datapipeline.twitter.TwitterRateLimit
 
getLimitResetTimeRemaining() - Method in class com.northconcepts.datapipeline.twitter.TwitterRateLimit
 
getLineSeparators() - Method in class com.northconcepts.datapipeline.csv.CSVReader
Returns the strings used to separate records or null if none were explicitly assigned.
getList() - Method in class com.northconcepts.datapipeline.core.FieldList
 
getList() - Method in class com.northconcepts.datapipeline.eventbus.TypedListenerList
 
getListenerCount() - Method in class com.northconcepts.datapipeline.eventbus.EventBus
Returns the total number of listeners subscribed to this bus.
getListId() - Method in class com.northconcepts.datapipeline.mailchimp.MailChimpListMemberReader
 
getListMembers(String, long, long) - Method in interface com.northconcepts.datapipeline.mailchimp.MailChimpClient
 
getLocationPath() - Method in class com.northconcepts.datapipeline.xml.XmlField
 
getLocationPath() - Method in class com.northconcepts.datapipeline.xml.XmlRecordBreak
 
getLocations() - Method in class com.northconcepts.datapipeline.twitter.TwitterFilterStreamReader
 
getLogWriter() - Method in class com.northconcepts.datapipeline.job.AbstractJob
 
getLogWriter() - Method in class com.northconcepts.datapipeline.job.Job
 
getLongitude() - Method in class com.northconcepts.datapipeline.instagram.InstagramLocationMediaReader
 
getLongitude() - Method in class com.northconcepts.datapipeline.instagram.InstagramLocationReader
 
getLookup() - Method in class com.northconcepts.datapipeline.transform.lookup.LookupTransformer
 
getMailStore() - Method in class com.northconcepts.datapipeline.email.EmailReader
 
getMaxBufferSizeInBytes() - Method in class com.northconcepts.datapipeline.core.AsyncReader
 
getMaxEntries() - Method in class com.northconcepts.datapipeline.transform.lookup.CachedLookup
 
getMaxErrorCount() - Method in class com.northconcepts.datapipeline.retry.RetryingOperation
Returns the number of retries allowed across all read attempts (default max long - 1).
getMaxErrorCount() - Method in class com.northconcepts.datapipeline.retry.RetryingReader
Returns the number of retries allowed across all read attempts (default max long - 1).
getMaxErrorCount() - Method in class com.northconcepts.datapipeline.retry.RetryingWriter
Returns the number of retries allowed across all write attempts (default max long - 1).
getMaxId() - Method in class com.northconcepts.datapipeline.twitter.TwitterSearchReader
Searches for tweets with IDs less than the specified ID (i.e.
getMaximum(String) - Method in class com.northconcepts.datapipeline.group.AggregateReader
Deprecated.
 
getMaximumPoolSize() - Method in class com.northconcepts.datapipeline.eventbus.EventBus
Returns the maximum allowed number of threads in this bus' executorService or -1 if unknown.
getMaxRecords() - Method in class com.northconcepts.datapipeline.memory.TailProxyReader
 
getMaxRecords() - Method in class com.northconcepts.datapipeline.memory.TailWriter
 
getMaxResults() - Method in class com.northconcepts.datapipeline.instagram.InstagramMediaReader
 
getMaxResults() - Method in class com.northconcepts.datapipeline.instagram.InstagramSelfReader
 
getMaxRetryCount() - Method in class com.northconcepts.datapipeline.retry.RetryingOperation
Returns the number of retries allowed for any individual read attempt (default 5).
getMaxRetryCount() - Method in class com.northconcepts.datapipeline.retry.RetryingReader
Returns the number of retries allowed for any individual read attempt (default 5).
getMaxRetryCount() - Method in class com.northconcepts.datapipeline.retry.RetryingWriter
Returns the number of retries allowed for any individual write attempt (default 5).
getMeasure() - Method in class com.northconcepts.datapipeline.meter.RecordMeter
 
getMessage() - Method in exception com.northconcepts.datapipeline.core.DataException
Returns the detail message string of this exception along with any prefixed text.
getMessage() - Method in class com.northconcepts.datapipeline.core.Message
 
getMessage(int) - Method in class com.northconcepts.datapipeline.core.Messages
 
getMessageCount() - Method in class com.northconcepts.datapipeline.core.Messages
 
getMessageWithProperties() - Method in exception com.northconcepts.datapipeline.core.DataException
Returns the detail message string of this exception along with any prefixed text and properties (name-value pairs).
getMeter() - Method in interface com.northconcepts.datapipeline.meter.Metered
 
getMeter() - Method in class com.northconcepts.datapipeline.meter.MeteredInputStream
 
getMeter() - Method in class com.northconcepts.datapipeline.meter.MeteredOutputStream
 
getMeter() - Method in class com.northconcepts.datapipeline.meter.MeteredReader
 
getMeter() - Method in class com.northconcepts.datapipeline.meter.MeteredWriter
 
getMeter() - Method in class com.northconcepts.datapipeline.throttle.Throttle
 
getMethod() - Method in class com.northconcepts.datapipeline.eventbus.Event
 
getMillisecondsPastHour() - Method in class com.northconcepts.datapipeline.schedule.HourlyScheduler
 
getMinimum(String) - Method in class com.northconcepts.datapipeline.group.AggregateReader
Deprecated.
 
getMissedTweets() - Method in class com.northconcepts.datapipeline.twitter.TwitterFilterStreamReader
 
getMisses() - Method in class com.northconcepts.datapipeline.transform.lookup.CachedLookup
Returns the number of lookup requests where the results were not already cached and the underlying lookup was used.
getName() - Method in class com.northconcepts.datapipeline.core.DataObject
The name of this instance (-).
getName() - Method in class com.northconcepts.datapipeline.core.Field
 
getName(boolean) - Method in class com.northconcepts.datapipeline.core.Field
 
getName() - Method in class com.northconcepts.datapipeline.eventbus.EventBus
Returns the name assigned to this bus or its default name if one was not assigned.
getName() - Method in class com.northconcepts.datapipeline.filter.FieldExists
 
getName() - Method in class com.northconcepts.datapipeline.filter.FieldFilter
 
getName() - Method in class com.northconcepts.datapipeline.filter.FieldNotExists
 
getName() - Method in class com.northconcepts.datapipeline.job.AbstractJob
Returns the name assigned to this job or its default name if one was not assigned.
getName() - Method in interface com.northconcepts.datapipeline.job.IJob
Returns the name assigned to this job or its default name if one was not assigned.
getName() - Method in class com.northconcepts.datapipeline.job.Job
Returns the name assigned to this job or its default name if one was not assigned.
getName() - Method in class com.northconcepts.datapipeline.transform.FieldTransformer
Returns the name of the field this transformer applies to if only one field was specified, otherwise null if multiple fields.
getName() - Method in class com.northconcepts.datapipeline.transform.SetCalculatedField
 
getName() - Method in class com.northconcepts.datapipeline.transform.SetField
 
getName() - Method in class com.northconcepts.datapipeline.transform.SplitArrayField
 
getName() - Method in class com.northconcepts.datapipeline.xml.builder.XmlAttribute
 
getName() - Method in class com.northconcepts.datapipeline.xml.builder.XmlElement
 
getName() - Method in class com.northconcepts.datapipeline.xml.XmlField
 
getNames() - Method in class com.northconcepts.datapipeline.filter.FieldExists
 
getNames() - Method in class com.northconcepts.datapipeline.filter.FieldFilter
 
getNames() - Method in class com.northconcepts.datapipeline.transform.FieldTransformer
 
getNamesAsStrings() - Method in class com.northconcepts.datapipeline.transform.FieldTransformer
 
getNestedLookup() - Method in class com.northconcepts.datapipeline.transform.lookup.ProxyLookup
 
getNestedReader() - Method in class com.northconcepts.datapipeline.core.DataReader
Returns the DataReader held inside this one or null if there isn't one.
getNestedReader() - Method in class com.northconcepts.datapipeline.core.ProxyReader
 
getNestedReader() - Method in class com.northconcepts.datapipeline.core.SortingReader
 
getNestedReader0() - Method in class com.northconcepts.datapipeline.core.SortingReader
 
getNestedWriter() - Method in class com.northconcepts.datapipeline.core.DataWriter
Returns the DataWriter held inside this one or null if there isn't one.
getNestedWriter() - Method in class com.northconcepts.datapipeline.core.ProxyWriter
 
getNewLine() - Method in class com.northconcepts.datapipeline.core.LinedTextWriter
 
getNewName() - Method in class com.northconcepts.datapipeline.transform.RenameField
 
getNextTime(long) - Method in class com.northconcepts.datapipeline.schedule.HourlyScheduler
 
getNextTime(long) - Method in class com.northconcepts.datapipeline.schedule.PeriodicScheduler
 
getNextTime(long) - Method in interface com.northconcepts.datapipeline.schedule.Scheduler
Returns the next time in this schedule after the specified time.
getNodeDepth() - Method in class com.northconcepts.datapipeline.core.ArrayValue
 
getNodeDepth() - Method in class com.northconcepts.datapipeline.core.Node
Returns this node's distance from its root node.
getNodes(ExpressionContext) - Method in class com.northconcepts.datapipeline.json.builder.JsonConditionalNode
 
getNodes(ExpressionContext) - Method in class com.northconcepts.datapipeline.json.builder.JsonNode
 
getNodes() - Method in class com.northconcepts.datapipeline.xml.builder.XmlNodeContainer
 
getNodeType() - Method in class com.northconcepts.datapipeline.core.ArrayValue
 
getNodeType() - Method in class com.northconcepts.datapipeline.core.Field
 
getNodeType() - Method in class com.northconcepts.datapipeline.core.Node
 
getNodeType() - Method in class com.northconcepts.datapipeline.core.Record
 
getNodeType() - Method in class com.northconcepts.datapipeline.core.SingleValue
 
getNonUpdateFields() - Method in class com.northconcepts.datapipeline.jdbc.JdbcUpsertWriter
Returns the list of fields that must not be updated if the recored already exists (default null).
getNullValuePolicy() - Method in class com.northconcepts.datapipeline.csv.CSVWriter
Returns the object responsible for writing null values (defaults to ValuePolicy.EMPTY_STRING).
getOffset() - Method in class com.northconcepts.datapipeline.core.LimitReader
 
getOffset() - Method in class com.northconcepts.datapipeline.jdbc.sql.select.Select
 
getOffsetConsumed() - Method in class com.northconcepts.datapipeline.core.LimitReader
 
getOldName() - Method in class com.northconcepts.datapipeline.transform.RenameField
 
getOpenedOn() - Method in class com.northconcepts.datapipeline.core.DataEndpoint
Returns the time in milliseconds when this endpoint was opened or zero (0) if it hasn't yet been opened.
getOpenedWindows() - Method in class com.northconcepts.datapipeline.group.GroupByReader
 
getOpenElapsedTime() - Method in class com.northconcepts.datapipeline.core.DataEndpoint
Returns the number of milliseconds this endpoint was (or has been) opened for or zero (0) if it hasn't yet been opened.
getOpenElapsedTimeAsString() - Method in class com.northconcepts.datapipeline.core.DataEndpoint
Returns the total time (as a human readable string) this endpoint was (or has been) opened for or "0 seconds" if it hasn't yet been opened.
getOperation() - Method in class com.northconcepts.datapipeline.group.GroupOperationField
 
getOperations() - Method in class com.northconcepts.datapipeline.group.GroupByReader
 
getOrder() - Method in class com.northconcepts.datapipeline.core.SortingReader
 
getOrder() - Method in class com.northconcepts.datapipeline.jdbc.sql.select.Select
 
getOutputStream() - Method in class com.northconcepts.datapipeline.core.BinaryWriter
 
getOverwrite() - Method in class com.northconcepts.datapipeline.transform.CopyField
 
getOverwrite() - Method in class com.northconcepts.datapipeline.transform.SetCalculatedField
 
getOverwrite() - Method in class com.northconcepts.datapipeline.transform.SetField
 
getPage() - Method in class com.northconcepts.datapipeline.twitter.TwitterPageableReader
 
getPageImpl(long, int) - Method in class com.northconcepts.datapipeline.twitter.TwitterFollowerIDsReader
 
getPageImpl(long, int) - Method in class com.northconcepts.datapipeline.twitter.TwitterFollowerListReader
 
getPageImpl(long, int) - Method in class com.northconcepts.datapipeline.twitter.TwitterFollowingIDsReader
 
getPageImpl(long, int) - Method in class com.northconcepts.datapipeline.twitter.TwitterFollowingListReader
 
getPageImpl(long, int) - Method in class com.northconcepts.datapipeline.twitter.TwitterListMemberReader
 
getPageImpl(long, int) - Method in class com.northconcepts.datapipeline.twitter.TwitterListOwnershipReader
 
getPageImpl(long, int) - Method in class com.northconcepts.datapipeline.twitter.TwitterPageableReader
 
getPageOffset() - Method in class com.northconcepts.datapipeline.mailchimp.MailChimpListMemberReader
 
getPageSize() - Method in class com.northconcepts.datapipeline.mailchimp.MailChimpListMemberReader
 
getPageSize() - Method in class com.northconcepts.datapipeline.twitter.TwitterPageableReader
 
getParameterValues() - Method in class com.northconcepts.datapipeline.jdbc.sql.select.QueryCriteria
 
getParameterValues(List<Object>) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.QueryCriteriaPart
 
getParameterValues() - Method in class com.northconcepts.datapipeline.jdbc.sql.select.QueryCriteriaPart
 
getParameterValues() - Method in class com.northconcepts.datapipeline.jdbc.sql.select.Select
 
getParent() - Method in class com.northconcepts.datapipeline.job.AbstractJob
Returns the thread-local job that ran this one while this job is running.
getParent() - Method in interface com.northconcepts.datapipeline.job.IJob
Returns the thread-local job that ran this one while this job is running.
getParent() - Method in class com.northconcepts.datapipeline.job.Job
Returns the thread-local job that ran this one while this job is running.
getParentField() - Method in class com.northconcepts.datapipeline.core.Node
Returns the closest parent record's field that this node is the child of, otherwise null if one does not exist.
getParentNode() - Method in class com.northconcepts.datapipeline.core.Field
 
getParentNode() - Method in class com.northconcepts.datapipeline.core.Node
 
getParentNode() - Method in class com.northconcepts.datapipeline.core.ValueNode
 
getParentNode() - Method in class com.northconcepts.datapipeline.json.builder.JsonFragment
 
getParentRecord() - Method in class com.northconcepts.datapipeline.core.Field
 
getParentRecord() - Method in class com.northconcepts.datapipeline.core.Node
Returns the closest parent record that this node is the child of, otherwise null if one does not exist.
getParser() - Method in class com.northconcepts.datapipeline.csv.CSVReader
 
getPartParameterValues(List<Object>) - Method in class com.northconcepts.datapipeline.jdbc.sql.insert.InsertValue
 
getPartParameterValues(List<Object>) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.ConditionPart
 
getPartParameterValues(List<Object>) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.ConjunctivePart
 
getPartParameterValues(List<Object>) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.NotPart
 
getPartParameterValues(List<Object>) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.QueryCriteriaPart
 
getPartParameterValues(List<Object>) - Method in interface com.northconcepts.datapipeline.jdbc.sql.SqlValueContainer
 
getPartParameterValues(List<Object>) - Method in class com.northconcepts.datapipeline.jdbc.sql.update.UpdateValue
 
getParts() - Method in class com.northconcepts.datapipeline.jdbc.sql.select.ConjunctivePart
 
getParts() - Method in class com.northconcepts.datapipeline.jdbc.sql.select.QueryCriteriaPart
 
getParts() - Method in class com.northconcepts.datapipeline.jdbc.sql.select.QueryOrder
 
getPausedOn() - Method in class com.northconcepts.datapipeline.job.AbstractJob
Returns the time this job was paused or null if this job is not currently paused.
getPausedOn() - Method in interface com.northconcepts.datapipeline.job.IJob
Returns the time this job was paused or null if this job is not currently paused.
getPausedOn() - Method in class com.northconcepts.datapipeline.job.Job
Returns the time this job was paused or null if this job is not currently paused.
getPeakBufferSizeInBytes() - Method in class com.northconcepts.datapipeline.core.AsyncReader
 
getPeakBufferSizeInBytes() - Method in class com.northconcepts.datapipeline.core.AsyncWriter
 
getPeekUnitsPerSecond() - Method in class com.northconcepts.datapipeline.throttle.Throttle
 
getPercentage() - Method in class com.northconcepts.datapipeline.twitter.TwitterRateLimit
 
getPeriod() - Method in class com.northconcepts.datapipeline.schedule.PeriodicScheduler
 
getPolicy() - Method in enum com.northconcepts.datapipeline.transform.format.Rounder.RoundingPolicy
 
getPoolSize() - Method in class com.northconcepts.datapipeline.eventbus.EventBus
Returns the current number of threads in this bus' executorService pool or -1 if unknown.
getPort() - Method in class com.northconcepts.datapipeline.email.EmailReader
 
getPriority() - Method in class com.northconcepts.datapipeline.core.AsyncReader
 
getPriority() - Method in class com.northconcepts.datapipeline.core.AsyncWriter
 
getProperties() - Method in exception com.northconcepts.datapipeline.core.DataException
Returns the values associated with this exception as a Map.
getProperties() - Method in class com.northconcepts.datapipeline.email.EmailReader
 
getProperties() - Method in class com.northconcepts.datapipeline.jms.JmsSettings
 
getPropertiesAsString() - Method in exception com.northconcepts.datapipeline.core.DataException
 
getProperty(String) - Method in class com.northconcepts.datapipeline.jms.JmsSettings
 
getProtocol() - Method in enum com.northconcepts.datapipeline.email.MailStore
 
getProvider() - Method in class com.northconcepts.datapipeline.twitter.TwitterProxyReader
 
getProvider() - Method in class com.northconcepts.datapipeline.twitter.TwitterReader
 
getProvider() - Method in class com.northconcepts.datapipeline.twitter.TwitterWriter
 
getProviderType() - Method in class com.northconcepts.datapipeline.excel.ExcelDocument
 
getPublisher(Object, Class<T>) - Method in class com.northconcepts.datapipeline.eventbus.EventBus
 
getPublisher(Object, Class<T>, Object) - Method in class com.northconcepts.datapipeline.eventbus.EventBus
 
getPublishersCreated() - Method in class com.northconcepts.datapipeline.eventbus.EventBus
Returns the number of event publishers created by this bus.
getQuery() - Method in class com.northconcepts.datapipeline.mongodb.MongoReader
Gets the JSON style query string.
Output format:
(e.g.
getQueue() - Method in class com.northconcepts.datapipeline.core.PipedReader
 
getQueue() - Method in class com.northconcepts.datapipeline.core.PipedWriter
 
getQueue() - Method in class com.northconcepts.datapipeline.multiplex.SplitReader
 
getQueueSize() - Method in class com.northconcepts.datapipeline.multiplex.SplitWriter
 
getQuoteChar() - Method in class com.northconcepts.datapipeline.csv.CSVReader
Returns the starting quote - same as calling getStartingQuote() (defaults to double quote - ").
getQuoteChar() - Method in class com.northconcepts.datapipeline.csv.CSVWriter
Returns the starting quote - same as calling getStartingQuote() (defaults to double quote - ").
getRateLimit(String, String) - Method in class com.northconcepts.datapipeline.twitter.TwitterProvider
 
getRateLimit() - Method in class com.northconcepts.datapipeline.twitter.TwitterProxyReader
 
getRateLimit(boolean) - Method in class com.northconcepts.datapipeline.twitter.TwitterProxyReader
 
getRateLimit() - Method in class com.northconcepts.datapipeline.twitter.TwitterReader
 
getRateLimit(boolean) - Method in class com.northconcepts.datapipeline.twitter.TwitterReader
 
getReader() - Method in class com.northconcepts.datapipeline.core.AsyncMultiReader.ReaderThread
 
getReader() - Method in class com.northconcepts.datapipeline.job.Job
Returns the reader supplied to this job.
getReader() - Method in class com.northconcepts.datapipeline.transform.Transformer
 
getReaders() - Method in class com.northconcepts.datapipeline.job.Job
Returns the read pipeline — the chain of readers records pass through, starting with the root instance and ending with the reader passed to this job (and returned by Job.getReader()).
getReceiveTimeout() - Method in class com.northconcepts.datapipeline.jms.JmsReader
Returns the timeout interval for receiving messages or null if reads should not timeout (default to null).
getRecord() - Method in exception com.northconcepts.datapipeline.core.DataException
Returns the record associated with this exception.
getRecord() - Method in class com.northconcepts.datapipeline.core.Field
Returns the record this field belongs to.
getRecordCount() - Method in class com.northconcepts.datapipeline.core.DataEndpoint
Returns this endpoint's record-count as a long.
getRecordCount() - Method in class com.northconcepts.datapipeline.core.RecordList
 
getRecordCountAsBigInteger() - Method in class com.northconcepts.datapipeline.core.DataEndpoint
Returns this endpoint's record-count as a BigInteger.
getRecordCountAsString() - Method in class com.northconcepts.datapipeline.core.DataEndpoint
Returns this endpoint's record-count as a String.
getRecordList() - Method in class com.northconcepts.datapipeline.memory.MemoryReader
 
getRecordList() - Method in class com.northconcepts.datapipeline.memory.MemoryWriter
 
getRecords() - Method in class com.northconcepts.datapipeline.buffer.RecordBuffer
 
getRecords() - Method in class com.northconcepts.datapipeline.core.RecordList
 
getRecordsTransferred() - Method in class com.northconcepts.datapipeline.job.Job
Returns the number of records sent from the supplied reader to the supplied writer.
getRecurseDirectories() - Method in class com.northconcepts.datapipeline.file.FileSystemInfoReader
 
getRemainingCallString() - Method in class com.northconcepts.datapipeline.twitter.TwitterRateLimit
 
getRequests() - Method in class com.northconcepts.datapipeline.transform.lookup.CachedLookup
Returns the number of lookup requests made on this cache (sum of CachedLookup.getHits() and CachedLookup.getMisses()).
getResetInterval() - Method in class com.northconcepts.datapipeline.twitter.TwitterRateLimit
 
getResetSchedule() - Method in class com.northconcepts.datapipeline.transform.lookup.CachedLookup
 
getResetTimeString() - Method in class com.northconcepts.datapipeline.twitter.TwitterRateLimit
 
getRetryDelay(int, long) - Method in interface com.northconcepts.datapipeline.retry.IRetryStrategy
Returns the amount of time to wait (in milliseconds) before retrying the operation.
getRetryDelay(int, long) - Method in enum com.northconcepts.datapipeline.retry.RetryStrategy
 
getRetryDelayImpl(int, long) - Method in enum com.northconcepts.datapipeline.retry.RetryStrategy
 
getRootCause() - Method in exception com.northconcepts.datapipeline.core.DataException
Returns the root cause of this throwable or this if the cause is nonexistent or unknown.
getRootPart() - Method in class com.northconcepts.datapipeline.jdbc.sql.select.QueryCriteria
 
getRootReader() - Method in class com.northconcepts.datapipeline.core.DataReader
Returns the deepest, nested DataReader held inside this one, otherwise this instance is returned if there aren't any nested DataReaders.
getRootWriter() - Method in class com.northconcepts.datapipeline.core.DataWriter
Returns the deepest, nested DataWriter held inside this one, otherwise this instance is returned if there aren't any nested DataWriters.
getRoundingMode() - Method in class com.northconcepts.datapipeline.group.operation.GroupAverage
 
getRoundPolicy() - Method in class com.northconcepts.datapipeline.transform.format.Rounder
 
getRule(int) - Method in class com.northconcepts.datapipeline.filter.FieldFilter
 
getRuleCount() - Method in class com.northconcepts.datapipeline.filter.FieldFilter
 
getRunnable() - Method in class com.northconcepts.datapipeline.job.RunnableJobAdapter
 
getRunningTime() - Method in class com.northconcepts.datapipeline.job.AbstractJob
Returns the number of milliseconds this job was (or has been) running for or zero (0) if it hasn't yet started running.
getRunningTime() - Method in interface com.northconcepts.datapipeline.job.IJob
Returns the number of milliseconds this job was (or has been) running for or zero (0) if it hasn't yet started running.
getRunningTime() - Method in class com.northconcepts.datapipeline.job.Job
Returns the number of milliseconds this job was (or has been) running for or zero (0) if it hasn't yet started running.
getRunningTimeAsString() - Method in class com.northconcepts.datapipeline.job.AbstractJob
Returns the time this job was (or has been) running in long form as a human readable string (2 Years, 1 Second, 12 Millisecond) or null if it hasn't yet started running.
getRunningTimeAsString(boolean) - Method in class com.northconcepts.datapipeline.job.AbstractJob
Returns the time this job was (or has been) running as a human readable string in long form (2 Years, 1 Second, 12 Millisecond) or short form (2y 1s 12ms) or null if it hasn't yet started running.
getRunningTimeAsString() - Method in interface com.northconcepts.datapipeline.job.IJob
Returns the time this job was (or has been) running in long form as a human readable string (2 Years, 1 Second, 12 Millisecond) or null if it hasn't yet started running.
getRunningTimeAsString(boolean) - Method in interface com.northconcepts.datapipeline.job.IJob
Returns the time this job was (or has been) running as a human readable string in long form (2 Years, 1 Second, 12 Millisecond) or short form (2y 1s 12ms) or null if it hasn't yet started running.
getRunningTimeAsString() - Method in class com.northconcepts.datapipeline.job.Job
Returns the time this job was (or has been) running in long form as a human readable string (2 Years, 1 Second, 12 Millisecond) or null if it hasn't yet started running.
getRunningTimeAsString(boolean) - Method in class com.northconcepts.datapipeline.job.Job
Returns the time this job was (or has been) running as a human readable string in long form (2 Years, 1 Second, 12 Millisecond) or short form (2y 1s 12ms) or null if it hasn't yet started running.
getRunThread() - Method in class com.northconcepts.datapipeline.job.AbstractJob
Returns the thread currently executing this job or null if the job is not running.
getRunThread() - Method in interface com.northconcepts.datapipeline.job.IJob
Returns the thread currently executing this job or null if the job is not running.
getRunThread() - Method in class com.northconcepts.datapipeline.job.Job
Returns the thread currently executing this job or null if the job is not running.
getScale() - Method in class com.northconcepts.datapipeline.group.operation.GroupAverage
 
getSearchTerm() - Method in class com.northconcepts.datapipeline.email.EmailReader
 
getSelection() - Method in class com.northconcepts.datapipeline.jdbc.sql.select.Select
 
getSequence() - Method in class com.northconcepts.datapipeline.eventbus.Event
 
getSession() - Method in class com.northconcepts.datapipeline.jms.JmsConnection
 
getSessionProperty(Class<T>, String) - Method in class com.northconcepts.datapipeline.core.Node
 
getSessionProperty(Class<T>) - Method in class com.northconcepts.datapipeline.core.Node
 
getSessionProperty(String) - Method in class com.northconcepts.datapipeline.core.Node
 
getSessionProperty(Class<T>) - Method in interface com.northconcepts.datapipeline.core.Session
 
getSessionProperty(Class<T>, String) - Method in interface com.northconcepts.datapipeline.core.Session
 
getSessionProperty(String) - Method in interface com.northconcepts.datapipeline.core.Session
 
getSessionProperty(Class<T>, String) - Method in class com.northconcepts.datapipeline.core.Session.SessionImpl
 
getSessionProperty(Class<T>) - Method in class com.northconcepts.datapipeline.core.Session.SessionImpl
 
getSessionProperty(String) - Method in class com.northconcepts.datapipeline.core.Session.SessionImpl
 
getSettings() - Method in class com.northconcepts.datapipeline.jms.JmsReader
 
getSettings() - Method in class com.northconcepts.datapipeline.jms.JmsWriter
 
getSheet() - Method in class com.northconcepts.datapipeline.excel.PoiSxssfProvider
 
getSheetIndex() - Method in class com.northconcepts.datapipeline.excel.ExcelReader
 
getSheetIndex() - Method in class com.northconcepts.datapipeline.excel.ExcelWriter
 
getSheetName() - Method in class com.northconcepts.datapipeline.excel.ExcelReader
 
getSheetName() - Method in class com.northconcepts.datapipeline.excel.ExcelWriter
 
getSheetNames() - Method in class com.northconcepts.datapipeline.excel.ExcelDocument
 
getShutdownTimeout() - Method in class com.northconcepts.datapipeline.eventbus.EventBus
Returns the time in milliseconds this bus will wait for events to complete before forcibly shutting down (defaults to 30 seconds).
getShutdownTimeoutAsString() - Method in class com.northconcepts.datapipeline.eventbus.EventBus
Returns time as human readable string this bus will wait for events to complete before forcibly shutting down (defaults to 30 seconds).
getSimpleName() - Method in class com.northconcepts.datapipeline.core.FieldPath
Returns the name (or number/index) of the last segment in this path as a string.
getSinceId() - Method in class com.northconcepts.datapipeline.twitter.TwitterSearchReader
Searches for tweets with IDs greater than the specified ID (i.e.
getSink() - Method in class com.northconcepts.datapipeline.multiplex.DeMux
 
getSizeInBytes() - Method in class com.northconcepts.datapipeline.core.ArrayValue
 
getSizeInBytes() - Method in class com.northconcepts.datapipeline.core.Field
 
getSizeInBytes(ValueNode<?>) - Method in enum com.northconcepts.datapipeline.core.FieldType
 
getSizeInBytes() - Method in class com.northconcepts.datapipeline.core.Record
 
getSizeInBytes() - Method in class com.northconcepts.datapipeline.core.RecordList
 
getSizeInBytes() - Method in class com.northconcepts.datapipeline.core.SingleValue
 
getSizeInBytes() - Method in class com.northconcepts.datapipeline.core.ValueNode
 
getSizeInBytesImpl(Object) - Method in enum com.northconcepts.datapipeline.core.FieldType
 
getSizeInBytesOfFieldNames() - Method in class com.northconcepts.datapipeline.core.Record
 
getSizeOfNameInBytes() - Method in class com.northconcepts.datapipeline.core.Field
 
getSnapshot() - Method in class com.northconcepts.datapipeline.memory.TailProxyReader
 
getSnapshot() - Method in class com.northconcepts.datapipeline.memory.TailWriter
 
getSource() - Method in class com.northconcepts.datapipeline.json.builder.JsonExpression
 
getSource() - Method in class com.northconcepts.datapipeline.json.builder.JsonLogicalExpression
 
getSource() - Method in class com.northconcepts.datapipeline.multiplex.DeMux
 
getSource() - Method in class com.northconcepts.datapipeline.xml.builder.XmlExpression
 
getSource() - Method in class com.northconcepts.datapipeline.xml.builder.XmlLogicalExpression
 
getSourceFieldName() - Method in class com.northconcepts.datapipeline.group.GroupOperation
 
getSourceFieldName() - Method in class com.northconcepts.datapipeline.transform.CopyField
 
getSourceFieldPath() - Method in class com.northconcepts.datapipeline.group.GroupOperation
 
getSourceString() - Method in interface com.northconcepts.datapipeline.expression.ASTNode
Returns the source code for this node and its descendants in the syntax tree.
getSqlFragment() - Method in class com.northconcepts.datapipeline.jdbc.sql.insert.Insert
 
getSqlFragment() - Method in class com.northconcepts.datapipeline.jdbc.sql.insert.InsertValue
 
getSqlFragment() - Method in class com.northconcepts.datapipeline.jdbc.sql.select.ConditionPart
 
getSqlFragment() - Method in class com.northconcepts.datapipeline.jdbc.sql.select.ConjunctivePart
 
getSqlFragment() - Method in class com.northconcepts.datapipeline.jdbc.sql.select.InnerJoin
 
getSqlFragment() - Method in class com.northconcepts.datapipeline.jdbc.sql.select.NotPart
 
getSqlFragment() - Method in class com.northconcepts.datapipeline.jdbc.sql.select.QueryCriteria
 
getSqlFragment() - Method in class com.northconcepts.datapipeline.jdbc.sql.select.QueryGrouping
 
getSqlFragment() - Method in class com.northconcepts.datapipeline.jdbc.sql.select.QueryOrder
 
getSqlFragment() - Method in class com.northconcepts.datapipeline.jdbc.sql.select.QueryOrderPart
 
getSqlFragment() - Method in class com.northconcepts.datapipeline.jdbc.sql.select.QueryPart
 
getSqlFragment() - Method in class com.northconcepts.datapipeline.jdbc.sql.select.QuerySelection
 
getSqlFragment() - Method in class com.northconcepts.datapipeline.jdbc.sql.select.Select
 
getSqlFragment() - Method in class com.northconcepts.datapipeline.jdbc.sql.SqlPart
 
getSqlFragment() - Method in class com.northconcepts.datapipeline.jdbc.sql.update.Update
 
getSqlFragment() - Method in class com.northconcepts.datapipeline.jdbc.sql.update.UpdateValue
 
getStackTrace() - Method in class com.northconcepts.datapipeline.core.Message
 
getStarted() - Method in class com.northconcepts.datapipeline.meter.Meter
 
getStartedOn() - Method in class com.northconcepts.datapipeline.job.AbstractJob
Returns the time this job instance started running.
getStartedOn() - Method in interface com.northconcepts.datapipeline.job.IJob
Returns the time this job instance started running.
getStartedOn() - Method in class com.northconcepts.datapipeline.job.Job
Returns the time this job instance started running.
getStartingColumn() - Method in class com.northconcepts.datapipeline.excel.ExcelReader
 
getStartingOffset() - Method in class com.northconcepts.datapipeline.twitter.TwitterPageableReader
 
getStartingQuote() - Method in class com.northconcepts.datapipeline.csv.CSVReader
Returns the string used to mark the beginning of text values that may contain commas and other special characters (defaults to double quote - ").
getStartingQuote() - Method in class com.northconcepts.datapipeline.csv.CSVWriter
Returns the string used to mark the beginning of text values that may contain commas and other special characters (defaults to double quote - ").
getStartingRow() - Method in class com.northconcepts.datapipeline.core.AbstractReader
 
getState() - Method in class com.northconcepts.datapipeline.core.DataEndpoint
 
getState() - Method in class com.northconcepts.datapipeline.core.Record
 
getState() - Method in class com.northconcepts.datapipeline.eventbus.EventBus
Returns the current state of this bus.
getStatement() - Method in class com.northconcepts.datapipeline.jdbc.sql.select.ConditionPart
 
getStrategy() - Method in class com.northconcepts.datapipeline.multiplex.DeMux
 
getStrategy() - Method in class com.northconcepts.datapipeline.multiplex.SplitWriter
 
getStrategy() - Method in class com.northconcepts.datapipeline.retry.RetryingOperation
Returns the retry strategy (default RetryStrategy.EXPONENTIAL_BACKOFF).
getStrategy() - Method in class com.northconcepts.datapipeline.retry.RetryingReader
Returns the retry strategy (default RetryStrategy.EXPONENTIAL_BACKOFF).
getStrategy() - Method in class com.northconcepts.datapipeline.retry.RetryingWriter
Returns the retry strategy (default RetryStrategy.EXPONENTIAL_BACKOFF).
getString(CSVWriter, Record, int, Field, String) - Method in interface com.northconcepts.datapipeline.csv.CSVWriter.IValuePolicy
 
getSum(String) - Method in class com.northconcepts.datapipeline.group.AggregateReader
Deprecated.
 
getSystemEventBus() - Static method in class com.northconcepts.datapipeline.eventbus.EventBus
 
getTable() - Method in class com.northconcepts.datapipeline.jdbc.sql.insert.Insert
 
getTable() - Method in class com.northconcepts.datapipeline.jdbc.sql.select.InnerJoin
 
getTable() - Method in class com.northconcepts.datapipeline.jdbc.sql.select.Select
 
getTable() - Method in class com.northconcepts.datapipeline.jdbc.sql.update.Update
 
getTableName() - Method in class com.northconcepts.datapipeline.jdbc.JdbcUpsertWriter
 
getTableName() - Method in class com.northconcepts.datapipeline.jdbc.JdbcWriter
 
getTagName() - Method in class com.northconcepts.datapipeline.instagram.InstagramTagMediaReader
 
getTagName() - Method in class com.northconcepts.datapipeline.instagram.InstagramTagReader
 
getTargetFieldName() - Method in class com.northconcepts.datapipeline.group.GroupOperation
 
getTargetFieldName() - Method in class com.northconcepts.datapipeline.transform.CopyField
 
getTargetFieldPath() - Method in class com.northconcepts.datapipeline.group.GroupOperation
 
getTargets() - Method in class com.northconcepts.datapipeline.multiplex.SplitWriter
 
getTaskCount() - Method in class com.northconcepts.datapipeline.eventbus.EventBus
Returns the approximate total number of tasks that have ever been scheduled for execution by this bus' executorService or -1 if unknown.
getText() - Method in class com.northconcepts.datapipeline.xml.builder.XmlText
 
getThread() - Method in class com.northconcepts.datapipeline.core.Message
 
getThread() - Method in class com.northconcepts.datapipeline.multiplex.DeMux
 
getThrottle() - Method in interface com.northconcepts.datapipeline.throttle.Throttled
 
getThrottle() - Method in class com.northconcepts.datapipeline.throttle.ThrottledInputStream
 
getThrottle() - Method in class com.northconcepts.datapipeline.throttle.ThrottledOutputStream
 
getThrottle() - Method in class com.northconcepts.datapipeline.throttle.ThrottledReader
 
getThrottle() - Method in class com.northconcepts.datapipeline.throttle.ThrottledWriter
 
getTimestamp() - Method in class com.northconcepts.datapipeline.core.Message
 
getToken() - Method in class com.northconcepts.datapipeline.instagram.InstagramMediaReader
 
getToken() - Method in class com.northconcepts.datapipeline.instagram.InstagramSelfReader
 
getTopic() - Method in class com.northconcepts.datapipeline.eventbus.Event
 
getTopic() - Method in class com.northconcepts.datapipeline.eventbus.EventBusWriter
 
getTopicFieldName() - Method in class com.northconcepts.datapipeline.eventbus.EventBusReader
Returns the field name used to add the delivery topic to each record or null if the topic should not be added to records (defaults to null).
getTopics() - Method in class com.northconcepts.datapipeline.eventbus.EventBusReader
 
getTrack() - Method in class com.northconcepts.datapipeline.twitter.TwitterFilterStreamReader
 
getTwitter() - Method in class com.northconcepts.datapipeline.twitter.TwitterProvider
 
getTwitterStream() - Method in class com.northconcepts.datapipeline.twitter.TwitterStreamProvider
 
getType() - Method in class com.northconcepts.datapipeline.core.ArrayValue
Returns ArrayValue.defaultType if there are no elements, the FieldType matching all elements if they are the same or FieldType.UNDEFINED if elements contain multiple types.
getType() - Method in class com.northconcepts.datapipeline.core.Field
 
getType() - Method in class com.northconcepts.datapipeline.core.Record
 
getType() - Method in class com.northconcepts.datapipeline.core.SingleValue
 
getType() - Method in class com.northconcepts.datapipeline.core.ValueNode
 
getType() - Method in class com.northconcepts.datapipeline.eventbus.TypedListenerList
 
getType() - Method in class com.northconcepts.datapipeline.jms.JmsSettings
 
getType() - Method in class com.northconcepts.datapipeline.json.builder.JsonArray
 
getType() - Method in class com.northconcepts.datapipeline.json.builder.JsonField
 
getType() - Method in class com.northconcepts.datapipeline.json.builder.JsonFragment
 
getType() - Method in class com.northconcepts.datapipeline.json.builder.JsonNode
 
getType() - Method in class com.northconcepts.datapipeline.json.builder.JsonObject
 
getType() - Method in class com.northconcepts.datapipeline.json.builder.JsonPrimitive
 
getTypedListenerCount() - Method in class com.northconcepts.datapipeline.eventbus.EventBus
Returns the number of type-specific listeners subscribed to this bus.
getTypedListenerList(Class<T>) - Method in class com.northconcepts.datapipeline.eventbus.EventBus
 
getUnitsPerSecond() - Method in class com.northconcepts.datapipeline.meter.Meter
Returns units per second.
getUnitsPerSecond() - Method in class com.northconcepts.datapipeline.throttle.Throttle
 
getUnitsPerSecondAsString() - Method in class com.northconcepts.datapipeline.meter.Meter
 
getUnitsPerSecondAsString(String) - Method in class com.northconcepts.datapipeline.meter.Meter
 
getUnitsPerSecondAsString() - Method in class com.northconcepts.datapipeline.meter.RecordMeter
 
getUntypedListenerCount() - Method in class com.northconcepts.datapipeline.eventbus.EventBus
Returns the number of non-type-specific listeners subscribed to this bus.
getUpdatedOn() - Method in class com.northconcepts.datapipeline.buffer.RecordBuffer
 
getUpsert() - Method in class com.northconcepts.datapipeline.jdbc.JdbcUpsertWriter
 
GetUrlQueryParam - Class in com.northconcepts.datapipeline.transform.net
Retrieves all query parameter values in a URL for the given name and stores them in the target field.
GetUrlQueryParam(String, String, String) - Constructor for class com.northconcepts.datapipeline.transform.net.GetUrlQueryParam
 
getUseColumnLabel() - Method in class com.northconcepts.datapipeline.jdbc.JdbcReader
 
getUser() - Method in class com.northconcepts.datapipeline.email.EmailReader
 
getUserMessage() - Method in enum com.northconcepts.datapipeline.twitter.TwitterErrorCode
 
getUserName() - Method in class com.northconcepts.datapipeline.instagram.InstagramUserMediaReader
 
getUserScreenNameField() - Method in class com.northconcepts.datapipeline.twitter.TwitterFollowWriter
 
getUserScreenNameField() - Method in class com.northconcepts.datapipeline.twitter.TwitterUnfollowWriter
 
getUuid() - Method in class com.northconcepts.datapipeline.eventbus.EventBus
Returns the universally unique identifier (UUID) for this job.
getUuid() - Method in class com.northconcepts.datapipeline.job.AbstractJob
Returns the universally unique identifier (UUID) for this job.
getUuid() - Method in interface com.northconcepts.datapipeline.job.IJob
Returns the universally unique identifier (UUID) for this job.
getUuid() - Method in class com.northconcepts.datapipeline.job.Job
Returns the universally unique identifier (UUID) for this job.
getValue(int) - Method in class com.northconcepts.datapipeline.core.ArrayValue
Returns the value 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).
getValue() - Method in class com.northconcepts.datapipeline.core.ArrayValue
 
getValue() - Method in class com.northconcepts.datapipeline.core.Field
 
getValue(Record, boolean, boolean) - Method in class com.northconcepts.datapipeline.core.FieldPath
 
getValue() - Method in class com.northconcepts.datapipeline.core.Record
 
getValue(FieldPath) - Method in class com.northconcepts.datapipeline.core.Record
 
getValue(FieldPath, boolean) - Method in class com.northconcepts.datapipeline.core.Record
 
getValue(FieldPath, boolean, boolean) - Method in class com.northconcepts.datapipeline.core.Record
 
getValue() - Method in class com.northconcepts.datapipeline.core.SingleValue
 
getValue() - Method in class com.northconcepts.datapipeline.core.ValueNode
 
getValue() - Method in class com.northconcepts.datapipeline.filter.rule.Contains
 
getValue() - Method in class com.northconcepts.datapipeline.group.GroupOperationField
 
getValue() - Method in class com.northconcepts.datapipeline.jdbc.sql.insert.InsertValue
 
getValue() - Method in class com.northconcepts.datapipeline.jdbc.sql.update.UpdateValue
 
getValue() - Method in class com.northconcepts.datapipeline.transform.SetField
 
getValue() - Method in class com.northconcepts.datapipeline.xml.builder.XmlAttribute
 
getValueAsArray(int) - Method in class com.northconcepts.datapipeline.core.ArrayValue
 
getValueAsArray() - Method in class com.northconcepts.datapipeline.core.Field
 
getValueAsArray(boolean) - Method in class com.northconcepts.datapipeline.core.Field
 
getValueAsBigDecimal(int) - Method in class com.northconcepts.datapipeline.core.ArrayValue
 
getValueAsBigDecimal() - Method in class com.northconcepts.datapipeline.core.Field
 
getValueAsBigDecimal() - Method in class com.northconcepts.datapipeline.core.SingleValue
 
getValueAsBigInteger(int) - Method in class com.northconcepts.datapipeline.core.ArrayValue
 
getValueAsBigInteger() - Method in class com.northconcepts.datapipeline.core.Field
 
getValueAsBigInteger() - Method in class com.northconcepts.datapipeline.core.SingleValue
 
getValueAsBoolean(int) - Method in class com.northconcepts.datapipeline.core.ArrayValue
 
getValueAsBoolean() - Method in class com.northconcepts.datapipeline.core.Field
 
getValueAsBoolean() - Method in class com.northconcepts.datapipeline.core.SingleValue
 
getValueAsByte(int) - Method in class com.northconcepts.datapipeline.core.ArrayValue
 
getValueAsByte() - Method in class com.northconcepts.datapipeline.core.Field
 
getValueAsByte() - Method in class com.northconcepts.datapipeline.core.SingleValue
 
getValueAsBytes(int) - Method in class com.northconcepts.datapipeline.core.ArrayValue
 
getValueAsBytes() - Method in class com.northconcepts.datapipeline.core.Field
 
getValueAsBytes() - Method in class com.northconcepts.datapipeline.core.SingleValue
 
getValueAsChar(int) - Method in class com.northconcepts.datapipeline.core.ArrayValue
 
getValueAsChar() - Method in class com.northconcepts.datapipeline.core.Field
 
getValueAsChar() - Method in class com.northconcepts.datapipeline.core.SingleValue
 
getValueAsDate(int) - Method in class com.northconcepts.datapipeline.core.ArrayValue
 
getValueAsDate() - Method in class com.northconcepts.datapipeline.core.Field
 
getValueAsDate() - Method in class com.northconcepts.datapipeline.core.SingleValue
 
getValueAsDatetime(int) - Method in class com.northconcepts.datapipeline.core.ArrayValue
 
getValueAsDatetime() - Method in class com.northconcepts.datapipeline.core.Field
 
getValueAsDatetime() - Method in class com.northconcepts.datapipeline.core.SingleValue
 
getValueAsDouble(int) - Method in class com.northconcepts.datapipeline.core.ArrayValue
 
getValueAsDouble() - Method in class com.northconcepts.datapipeline.core.Field
 
getValueAsDouble() - Method in class com.northconcepts.datapipeline.core.SingleValue
 
getValueAsFloat(int) - Method in class com.northconcepts.datapipeline.core.ArrayValue
 
getValueAsFloat() - Method in class com.northconcepts.datapipeline.core.Field
 
getValueAsFloat() - Method in class com.northconcepts.datapipeline.core.SingleValue
 
getValueAsInteger(int) - Method in class com.northconcepts.datapipeline.core.ArrayValue
 
getValueAsInteger() - Method in class com.northconcepts.datapipeline.core.Field
 
getValueAsInteger() - Method in class com.northconcepts.datapipeline.core.SingleValue
 
getValueAsLong(int) - Method in class com.northconcepts.datapipeline.core.ArrayValue
 
getValueAsLong() - Method in class com.northconcepts.datapipeline.core.Field
 
getValueAsLong() - Method in class com.northconcepts.datapipeline.core.SingleValue
 
getValueAsRecord(int) - Method in class com.northconcepts.datapipeline.core.ArrayValue
 
getValueAsRecord() - Method in class com.northconcepts.datapipeline.core.Field
 
getValueAsShort(int) - Method in class com.northconcepts.datapipeline.core.ArrayValue
 
getValueAsShort() - Method in class com.northconcepts.datapipeline.core.Field
 
getValueAsShort() - Method in class com.northconcepts.datapipeline.core.SingleValue
 
getValueAsSingleValue(int) - Method in class com.northconcepts.datapipeline.core.ArrayValue
 
getValueAsSingleValue() - Method in class com.northconcepts.datapipeline.core.Field
 
getValueAsString(int) - Method in class com.northconcepts.datapipeline.core.ArrayValue
 
getValueAsString() - Method in class com.northconcepts.datapipeline.core.ArrayValue
 
getValueAsString() - Method in class com.northconcepts.datapipeline.core.Field
 
getValueAsString() - Method in class com.northconcepts.datapipeline.core.Record
 
getValueAsString() - Method in class com.northconcepts.datapipeline.core.SingleValue
 
getValueAsString() - Method in class com.northconcepts.datapipeline.core.ValueNode
 
getValueAsTime(int) - Method in class com.northconcepts.datapipeline.core.ArrayValue
 
getValueAsTime() - Method in class com.northconcepts.datapipeline.core.Field
 
getValueAsTime() - Method in class com.northconcepts.datapipeline.core.SingleValue
 
getValueNode(int) - Method in class com.northconcepts.datapipeline.core.ArrayValue
Returns the value node 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).
getValueNode() - Method in class com.northconcepts.datapipeline.core.Field
 
getValueNode(Record, boolean, boolean) - Method in class com.northconcepts.datapipeline.core.FieldPath
 
getValueOnException() - Method in class com.northconcepts.datapipeline.transform.FieldTransformer
 
getValueReader() - Method in class com.northconcepts.datapipeline.jdbc.JdbcReader
 
getValues(FieldList) - Method in class com.northconcepts.datapipeline.core.Record
 
getValues() - Method in class com.northconcepts.datapipeline.core.Record
 
getValues() - Method in class com.northconcepts.datapipeline.jdbc.sql.select.ConditionPart
 
getValues() - Method in class com.northconcepts.datapipeline.xml.XmlField
 
getValuesAsString() - Method in class com.northconcepts.datapipeline.core.CompositeValue
 
getWindowsClosed() - Method in class com.northconcepts.datapipeline.group.GroupByReader
 
getWindowsCreated() - Method in class com.northconcepts.datapipeline.group.GroupByReader
 
getWorkbook() - Method in class com.northconcepts.datapipeline.excel.PoiSxssfProvider
 
getWriter() - Method in class com.northconcepts.datapipeline.core.TextWriter
 
getWriter() - Method in class com.northconcepts.datapipeline.job.Job
Returns the writer supplied to this job.
getWriter() - Method in class com.northconcepts.datapipeline.transform.Transformer
 
getWriters() - Method in class com.northconcepts.datapipeline.job.Job
Returns the write pipeline — the chain of writers records pass through, starting with the writer passed to this job and returned by Job.getWriter() and ending with the root instance.
getWriteStrategy() - Method in class com.northconcepts.datapipeline.core.MultiWriter
 
GmailFolders - Interface in com.northconcepts.datapipeline.email
 
GroupAverage - Class in com.northconcepts.datapipeline.group.operation
 
GroupAverage(String) - Constructor for class com.northconcepts.datapipeline.group.operation.GroupAverage
 
GroupAverage(String, String) - Constructor for class com.northconcepts.datapipeline.group.operation.GroupAverage
 
GroupAverage(String, String, boolean) - Constructor for class com.northconcepts.datapipeline.group.operation.GroupAverage
 
groupBy(String...) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.Select
 
GroupByReader - Class in com.northconcepts.datapipeline.group
A proxy that divides records into groups and applies summary operations to each group; similar to "group by" in SQL, but applied to streaming data.
GroupByReader(DataReader, String...) - Constructor for class com.northconcepts.datapipeline.group.GroupByReader
 
GroupByReader(DataReader, int, String...) - Constructor for class com.northconcepts.datapipeline.group.GroupByReader
 
GroupByReader(DataReader, FieldList) - Constructor for class com.northconcepts.datapipeline.group.GroupByReader
 
GroupByReader(DataReader, int, FieldList) - Constructor for class com.northconcepts.datapipeline.group.GroupByReader
 
GroupCount - Class in com.northconcepts.datapipeline.group.operation
 
GroupCount(String) - Constructor for class com.northconcepts.datapipeline.group.operation.GroupCount
 
GroupFirst - Class in com.northconcepts.datapipeline.group.operation
 
GroupFirst(String) - Constructor for class com.northconcepts.datapipeline.group.operation.GroupFirst
 
GroupFirst(String, String) - Constructor for class com.northconcepts.datapipeline.group.operation.GroupFirst
 
GroupFirst(String, String, boolean) - Constructor for class com.northconcepts.datapipeline.group.operation.GroupFirst
 
GroupLast - Class in com.northconcepts.datapipeline.group.operation
 
GroupLast(String) - Constructor for class com.northconcepts.datapipeline.group.operation.GroupLast
 
GroupLast(String, String) - Constructor for class com.northconcepts.datapipeline.group.operation.GroupLast
 
GroupLast(String, String, boolean) - Constructor for class com.northconcepts.datapipeline.group.operation.GroupLast
 
GroupMaximum - Class in com.northconcepts.datapipeline.group.operation
 
GroupMaximum(String) - Constructor for class com.northconcepts.datapipeline.group.operation.GroupMaximum
 
GroupMaximum(String, String) - Constructor for class com.northconcepts.datapipeline.group.operation.GroupMaximum
 
GroupMaximum(String, String, boolean) - Constructor for class com.northconcepts.datapipeline.group.operation.GroupMaximum
 
GroupMinimum - Class in com.northconcepts.datapipeline.group.operation
 
GroupMinimum(String) - Constructor for class com.northconcepts.datapipeline.group.operation.GroupMinimum
 
GroupMinimum(String, String) - Constructor for class com.northconcepts.datapipeline.group.operation.GroupMinimum
 
GroupMinimum(String, String, boolean) - Constructor for class com.northconcepts.datapipeline.group.operation.GroupMinimum
 
GroupOperation<T> - Class in com.northconcepts.datapipeline.group
See FieldPath for supported field name expressions.
GroupOperation(String) - Constructor for class com.northconcepts.datapipeline.group.GroupOperation
 
GroupOperation(String, String) - Constructor for class com.northconcepts.datapipeline.group.GroupOperation
 
GroupOperation(String, String, boolean) - Constructor for class com.northconcepts.datapipeline.group.GroupOperation
 
GroupOperationField<T> - Class in com.northconcepts.datapipeline.group
 
GroupOperationField(GroupOperation<T>) - Constructor for class com.northconcepts.datapipeline.group.GroupOperationField
 
GroupSum - Class in com.northconcepts.datapipeline.group.operation
 
GroupSum(String) - Constructor for class com.northconcepts.datapipeline.group.operation.GroupSum
 
GroupSum(String, String) - Constructor for class com.northconcepts.datapipeline.group.operation.GroupSum
 
GroupSum(String, String, boolean) - Constructor for class com.northconcepts.datapipeline.group.operation.GroupSum
 

H

handleCancel() - Method in class com.northconcepts.datapipeline.job.AbstractJob
 
handleException(Event<?>, Object, Throwable) - Method in class com.northconcepts.datapipeline.eventbus.EventBus
 
handlePause() - Method in class com.northconcepts.datapipeline.job.AbstractJob
 
hasArrayFields() - Method in class com.northconcepts.datapipeline.core.Record
 
hasCallback() - Method in class com.northconcepts.datapipeline.job.Job
 
hasCascadingFields - Variable in class com.northconcepts.datapipeline.xml.XmlReader
 
hasChildNodes() - Method in class com.northconcepts.datapipeline.core.ArrayValue
 
hasChildNodes() - Method in class com.northconcepts.datapipeline.core.Field
 
hasChildNodes() - Method in class com.northconcepts.datapipeline.core.Node
Returns true if this node contains any sub nodes.
hasChildNodes() - Method in class com.northconcepts.datapipeline.core.Record
 
hasChildNodes() - Method in class com.northconcepts.datapipeline.core.SingleValue
 
hasChildNodes(ExpressionContext) - Method in class com.northconcepts.datapipeline.xml.builder.XmlConditionalNode
 
hasChildNodes(ExpressionContext) - Method in class com.northconcepts.datapipeline.xml.builder.XmlDetailMarker
 
hasChildNodes(ExpressionContext) - Method in class com.northconcepts.datapipeline.xml.builder.XmlNode
 
hasChildNodes(ExpressionContext) - Method in class com.northconcepts.datapipeline.xml.builder.XmlNodeContainer
 
hasChildRecords() - Method in class com.northconcepts.datapipeline.core.ArrayValue
 
hasChildRecords() - Method in class com.northconcepts.datapipeline.core.Field
 
hasChildRecords() - Method in class com.northconcepts.datapipeline.core.Node
Returns true if this node contains any descendant, record nodes.
hasChildRecords() - Method in class com.northconcepts.datapipeline.core.Record
 
hasChildRecords() - Method in class com.northconcepts.datapipeline.core.SingleValue
 
hashCode() - Method in class com.northconcepts.datapipeline.core.ArrayValue
 
hashCode() - Method in class com.northconcepts.datapipeline.core.CompositeValue
 
hashCode() - Method in class com.northconcepts.datapipeline.core.Field
 
hashCode() - Method in class com.northconcepts.datapipeline.core.FieldDeclarations
 
hashCode() - Method in class com.northconcepts.datapipeline.core.FieldList
 
hashCode() - Method in class com.northconcepts.datapipeline.core.FieldPath
 
hashCode() - Method in class com.northconcepts.datapipeline.core.Record
 
hashCode(FieldList) - Method in class com.northconcepts.datapipeline.core.Record
 
hashCode() - Method in class com.northconcepts.datapipeline.core.SingleValue
 
hasMoreMessages(int, Message[]) - Method in enum com.northconcepts.datapipeline.email.EmailReadDirection
 
hasNodes(ExpressionContext) - Method in class com.northconcepts.datapipeline.json.builder.JsonConditionalNode
 
hasNodes(ExpressionContext) - Method in class com.northconcepts.datapipeline.json.builder.JsonNode
 
hasValueOnException() - Method in class com.northconcepts.datapipeline.transform.FieldTransformer
 
Helper() - Constructor for class com.northconcepts.datapipeline.job.JobCallback.Helper
 
HOUR - Static variable in class com.northconcepts.datapipeline.schedule.HourlyScheduler
 
hourlyScheduleInMinutes(int...) - Static method in class com.northconcepts.datapipeline.buffer.BufferStrategy
Closes buffers at fixed minutes past each hour (for example: 0, 15, 30, and 45 minutes past each hour).
hourlyScheduleInMinutes(String, int...) - Static method in class com.northconcepts.datapipeline.buffer.BufferStrategy
Closes buffers at fixed minutes past each hour for the specified datetime field (for example: 0, 15, 30, and 45 minutes past each hour).
hourlyScheduleInMinutes(int...) - Static method in class com.northconcepts.datapipeline.group.CloseWindowStrategy
Closes windows at fixed minutes past each hour (for example: 0, 15, 30, and 45 minutes past each hour).
hourlyScheduleInMinutes(String, int...) - Static method in class com.northconcepts.datapipeline.group.CloseWindowStrategy
Closes windows at fixed minutes past each hour for the specified datetime field (for example: 0, 15, 30, and 45 minutes past each hour).
HourlyScheduler - Class in com.northconcepts.datapipeline.schedule
Represents a schedule of fixed minutes past each hour (for example: 0, 15, 30, and 45 minutes past each hour).
HourlyScheduler(long...) - Constructor for class com.northconcepts.datapipeline.schedule.HourlyScheduler
 
hoursToDate() - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer
 
hoursToDateTime() - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer
 

I

IApiLimitPolicy - Interface in com.northconcepts.datapipeline.twitter
Indicates the action to take when the Twitter API call limits are reached.
id - Variable in class com.northconcepts.datapipeline.core.DataObject
 
IEntityExpansionPolicy - Interface in com.northconcepts.datapipeline.twitter
Indicates how multi-valued values should be returned.
IJob - Interface in com.northconcepts.datapipeline.job
 
INBOX - Static variable in interface com.northconcepts.datapipeline.email.GmailFolders
 
incEventsDelivered() - Method in class com.northconcepts.datapipeline.eventbus.EventBus
 
IncludeFields - Class in com.northconcepts.datapipeline.transform
Deprecated.
IncludeFields(Collection<String>) - Constructor for class com.northconcepts.datapipeline.transform.IncludeFields
Deprecated.
 
IncludeFields(String...) - Constructor for class com.northconcepts.datapipeline.transform.IncludeFields
Deprecated.
 
incrementRecordCount() - Method in class com.northconcepts.datapipeline.core.DataEndpoint
Increases this endpoint's record-count by 1.
index(int) - Method in class com.northconcepts.datapipeline.core.FieldPath
 
indexOfField(Field) - Method in class com.northconcepts.datapipeline.core.Record
 
indexOfField(String, boolean) - Method in class com.northconcepts.datapipeline.core.Record
 
indexOfNode(Node) - Method in class com.northconcepts.datapipeline.core.ArrayValue
 
indexOfValue(Object) - Method in class com.northconcepts.datapipeline.core.ArrayValue
 
InnerJoin - Class in com.northconcepts.datapipeline.jdbc.sql.select
 
InnerJoin(String, String) - Constructor for class com.northconcepts.datapipeline.jdbc.sql.select.InnerJoin
 
innerJoin(String, String) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.Select
 
INodeVisitor - Interface in com.northconcepts.datapipeline.core
 
Insert - Class in com.northconcepts.datapipeline.jdbc.sql.insert
 
Insert(String) - Constructor for class com.northconcepts.datapipeline.jdbc.sql.insert.Insert
 
insert(int, String) - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer
 
InsertValue - Class in com.northconcepts.datapipeline.jdbc.sql.insert
 
InsertValue(String, Object) - Constructor for class com.northconcepts.datapipeline.jdbc.sql.insert.InsertValue
 
InsertValue(String) - Constructor for class com.northconcepts.datapipeline.jdbc.sql.insert.InsertValue
 
InstagramLocationMediaReader - Class in com.northconcepts.datapipeline.instagram
Search Instagram for media given a specific location (latitude, longitude).
InstagramLocationMediaReader(String, String, double, double, int) - Constructor for class com.northconcepts.datapipeline.instagram.InstagramLocationMediaReader
Get at most maximum number(maxResults) of recently searched media by location (latitude, longitude).
InstagramLocationReader - Class in com.northconcepts.datapipeline.instagram
Search for a location by geographic coordinate in Instagram.
InstagramLocationReader(String, String, double, double) - Constructor for class com.northconcepts.datapipeline.instagram.InstagramLocationReader
Search Instagram for a location by geographic coordinate.
InstagramMediaReader - Class in com.northconcepts.datapipeline.instagram
Base class for all InstagramXXXMediaReader.
InstagramMediaReader(String, String, int) - Constructor for class com.northconcepts.datapipeline.instagram.InstagramMediaReader
 
InstagramSelfFollowedByReader - Class in com.northconcepts.datapipeline.instagram
Get the list of users this user is followed by.
InstagramSelfFollowedByReader(String, String, int) - Constructor for class com.northconcepts.datapipeline.instagram.InstagramSelfFollowedByReader
Get at most maximum number(maxResults) of users this user is followed by.
InstagramSelfFollowsReader - Class in com.northconcepts.datapipeline.instagram
Get the list of users this user follows.
InstagramSelfFollowsReader(String, String, int) - Constructor for class com.northconcepts.datapipeline.instagram.InstagramSelfFollowsReader
Get at most maximum number(maxResults) of users this user follows.
InstagramSelfMediaReader - Class in com.northconcepts.datapipeline.instagram
Get your most recent media published.
InstagramSelfMediaReader(String, String, int) - Constructor for class com.northconcepts.datapipeline.instagram.InstagramSelfMediaReader
Get at most maximum number(maxResults) of your recent media.
InstagramSelfReader - Class in com.northconcepts.datapipeline.instagram
Base class for all InstagramSelfXXXReader.
InstagramSelfReader(String, String, int) - Constructor for class com.northconcepts.datapipeline.instagram.InstagramSelfReader
 
InstagramTagMediaReader - Class in com.northconcepts.datapipeline.instagram
Search Instagram for media given a specific tag.
InstagramTagMediaReader(String, String, String, int) - Constructor for class com.northconcepts.datapipeline.instagram.InstagramTagMediaReader
Get at most maximum number(maxResults) of recently tagged media.
InstagramTagReader - Class in com.northconcepts.datapipeline.instagram
Search for matching tags in Instagram by name - results are ordered first as an exact match, then by popularity.
InstagramTagReader(String, String, String) - Constructor for class com.northconcepts.datapipeline.instagram.InstagramTagReader
 
InstagramUserMediaReader - Class in com.northconcepts.datapipeline.instagram
Get the most recent media published by a user.
InstagramUserMediaReader(String, String, String, int) - Constructor for class com.northconcepts.datapipeline.instagram.InstagramUserMediaReader
 
interceptRecord(Record) - Method in class com.northconcepts.datapipeline.core.DebugReader
 
interceptRecord(Record) - Method in class com.northconcepts.datapipeline.core.ProxyReader
 
interceptRecord(Record) - Method in class com.northconcepts.datapipeline.core.ProxyWriter
 
interceptRecord(Record) - Method in class com.northconcepts.datapipeline.core.RemoveDuplicatesReader
 
interceptRecord(Record) - Method in class com.northconcepts.datapipeline.core.TeeReader
 
interceptRecord(Record) - Method in class com.northconcepts.datapipeline.filter.FilteringReader
 
interceptRecord(Record) - Method in class com.northconcepts.datapipeline.group.AggregateReader
Deprecated.
 
interceptRecord(Record) - Method in class com.northconcepts.datapipeline.memory.TailProxyReader
 
interceptRecord(Record) - Method in class com.northconcepts.datapipeline.meter.MeteredWriter
 
interceptRecord(Record) - Method in class com.northconcepts.datapipeline.throttle.ThrottledWriter
 
interceptRecord(Record) - Method in class com.northconcepts.datapipeline.transform.TransformingReader
 
interceptRecord(Record) - Method in class com.northconcepts.datapipeline.transform.TransformingWriter
 
intervalToMilliseconds() - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer
 
intervalToMonths() - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer
 
intervalToSeconds() - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer
 
intervalToYears() - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer
 
invoke(Object, Method, Object[]) - Method in class com.northconcepts.datapipeline.eventbus.EventSourceInvocationHandler
 
IParser - Interface in com.northconcepts.datapipeline.core
 
IRetryStrategy - Interface in com.northconcepts.datapipeline.retry
 
isAddTextToParent() - Method in class com.northconcepts.datapipeline.xml.XmlReader
Return true if each child node's text should be concatenated to its parent during parsing (defaults to false).
isAddTextToParent() - Method in class com.northconcepts.datapipeline.xml.XmlRecordReader
Return true if each child node's text should be concatenated to its parent during parsing (defaults to false).
isAddUserToRecord() - Method in class com.northconcepts.datapipeline.twitter.TwitterFollowWriter
 
isAddUserToRecord() - Method in class com.northconcepts.datapipeline.twitter.TwitterUnfollowWriter
 
isAlive() - Method in class com.northconcepts.datapipeline.eventbus.EventBus
Returns true if this bus has not been shutdown.
isAllowMultiLineText() - Method in class com.northconcepts.datapipeline.csv.CSVReader
Indicates if line separators are allowed inside quoted fields.
isAllowNoResults() - Method in class com.northconcepts.datapipeline.transform.lookup.LookupTransformer
 
isAllowQuoteInField() - Method in class com.northconcepts.datapipeline.csv.CSVReader
 
isAlwaysShowFooter() - Method in class com.northconcepts.datapipeline.template.TemplateWriter
 
isAlwaysShowHeader() - Method in class com.northconcepts.datapipeline.template.TemplateWriter
 
isAncestorOf(Node) - Method in class com.northconcepts.datapipeline.core.Node
Returns true if the supplied node is a descendant of this one.
isAppend() - Method in class com.northconcepts.datapipeline.core.TextWriter
Indicates if writing should start at the end of the file (if it exists).
isAppend() - Method in class com.northconcepts.datapipeline.file.FileWriter
Indicates if writing should start at the end of the file (if it exists).
isApplicable() - Method in class com.northconcepts.datapipeline.jdbc.sql.select.ConditionPart
 
isApplicable() - Method in class com.northconcepts.datapipeline.jdbc.sql.select.ConjunctivePart
 
isApplicable() - Method in class com.northconcepts.datapipeline.jdbc.sql.select.NotPart
 
isApplicable() - Method in class com.northconcepts.datapipeline.jdbc.sql.select.QueryCriteriaPart
 
isArray() - Method in class com.northconcepts.datapipeline.core.ArrayValue
 
isArray() - Method in class com.northconcepts.datapipeline.core.Field
 
isArray() - Method in class com.northconcepts.datapipeline.core.Record
 
isArray() - Method in class com.northconcepts.datapipeline.core.SingleValue
 
isArray() - Method in class com.northconcepts.datapipeline.core.ValueNode
 
isAscending() - Method in class com.northconcepts.datapipeline.core.FieldComparator
 
isAscending() - Method in class com.northconcepts.datapipeline.jdbc.sql.select.QueryOrderPart
 
isAutoCloseConnection() - Method in class com.northconcepts.datapipeline.mongodb.MongoReader
Indicates if the MongoDB client should be closed when this reader closes (defaults to false).
isAutoCloseConnection() - Method in class com.northconcepts.datapipeline.mongodb.MongoWriter
Indicates if the MongoDB client should be closed when this writer closes (defaults to false).
isAutoCloseLogWriter() - Method in class com.northconcepts.datapipeline.job.AbstractJob
 
isAutoCloseLogWriter() - Method in class com.northconcepts.datapipeline.job.Job
 
isAutoCloseWriter() - Method in class com.northconcepts.datapipeline.core.TextWriter
Indicates if the underlying java.io.BufferedWriter should be closed when this stream closes (defaults to true).
isAutoCloseWriter() - Method in class com.northconcepts.datapipeline.file.FileReader
Indicates if the underlying input stream should be closed when this stream closes (defaults to true).
isAutoCloseWriter() - Method in class com.northconcepts.datapipeline.file.FileWriter
Indicates if the underlying output stream should be closed when this stream closes (defaults to true).
isAutofilterColumns() - Method in class com.northconcepts.datapipeline.excel.ExcelWriter
 
isAutofitColumns() - Method in class com.northconcepts.datapipeline.excel.ExcelWriter
 
isBatchMode() - Method in class com.northconcepts.datapipeline.jdbc.JdbcUpsertWriter
 
isBatchMode() - Method in class com.northconcepts.datapipeline.jdbc.JdbcWriter
 
isBatchMode() - Method in class com.northconcepts.datapipeline.mongodb.MongoWriter
 
isBatchSupported() - Method in class com.northconcepts.datapipeline.jdbc.upsert.GenericUpsert
 
isBatchSupported() - Method in interface com.northconcepts.datapipeline.jdbc.upsert.IUpsert
 
isBatchSupported() - Method in class com.northconcepts.datapipeline.jdbc.upsert.MySqlUpsert
 
isCacheFieldIndexes() - Method in class com.northconcepts.datapipeline.core.SortingReader
 
isCancelled() - Method in class com.northconcepts.datapipeline.job.AbstractJob
Returns true if this job was cancelled.
isCancelled(Throwable) - Method in class com.northconcepts.datapipeline.job.AbstractJob
Returns true if this exception is due to this job being cancelled.
isCancelled() - Method in interface com.northconcepts.datapipeline.job.IJob
Returns true if this job was cancelled.
isCancelled() - Method in class com.northconcepts.datapipeline.job.Job
Returns true if this job was cancelled.
isCaptureElapsedTime() - Static method in class com.northconcepts.datapipeline.core.DataEndpoint
Indicates if all endpoints (readers and writers) should record their processing time.
isCascadeValues() - Method in class com.northconcepts.datapipeline.xml.XmlField
 
isCaseSensitive() - Method in class com.northconcepts.datapipeline.filter.rule.Contains
 
isCausedBy(Class<? extends Throwable>) - Method in exception com.northconcepts.datapipeline.core.DataException
Returns true if this exception was caused by (or one of its nested exceptions was caused by) the specified exception.
isCauseInterruptedException() - Method in exception com.northconcepts.datapipeline.core.DataException
Returns true if the nested exception indicates that a thread was interrupted.
isChildNode() - Method in class com.northconcepts.datapipeline.core.Node
Indicates if this record has a parent record (i.e.
isCloneRecord() - Method in class com.northconcepts.datapipeline.core.TeeReader
Indicates if a copy of the original record should be sent to the writer (default false), otherwise the original record is sent to the writer.
isCloseBeforeAddingRecord() - Method in class com.northconcepts.datapipeline.group.CloseWindowStrategy
Returns true if the window should be closed before adding the record or false if (the default).
isClosed() - Method in class com.northconcepts.datapipeline.core.DataEndpoint
Indicates if this endpoint has finished transferring data.
isCommitBatch() - Method in class com.northconcepts.datapipeline.jdbc.JdbcUpsertWriter
Returns true if this reader calls commit on the connection after every batch is sent.
isCommitBatch() - Method in class com.northconcepts.datapipeline.jdbc.JdbcWriter
Returns true if this reader calls commit on the connection after every batch is sent.
isCompressed() - Method in class com.northconcepts.datapipeline.file.FileReader
Indicates if the data is compressed and should be decompressed as it is being read.
isCompressed() - Method in class com.northconcepts.datapipeline.file.FileWriter
Indicates if the data should be compressed as it is being written (default false).
isContinueOnException() - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer
 
isDebug() - Method in class com.northconcepts.datapipeline.buffer.BufferedReader
 
isDebug() - Method in class com.northconcepts.datapipeline.email.EmailReader
 
isDebug() - Method in class com.northconcepts.datapipeline.eventbus.EventBus
Indicates if the bus should emit debug log messages when events are published or delivered and during the shutdown process.
isDebug() - Method in class com.northconcepts.datapipeline.filesystem.amazons3.AmazonS3FileSystem
 
isDebug() - Method in class com.northconcepts.datapipeline.group.GroupByReader
 
isDebug() - Method in class com.northconcepts.datapipeline.json.JsonRecordReader
 
isDebug() - Method in class com.northconcepts.datapipeline.xml.XmlReader
 
isDebug() - Method in class com.northconcepts.datapipeline.xml.XmlRecordReader
 
isDeleted() - Method in class com.northconcepts.datapipeline.core.Record
 
isDigit(int) - Method in class com.northconcepts.datapipeline.core.ParsingReader
 
isDistinct() - Method in class com.northconcepts.datapipeline.jdbc.sql.select.QuerySelection
 
isEmpty() - Method in class com.northconcepts.datapipeline.core.Record
Returns true if all fields in this record are null.
isEnabled() - Static method in class com.northconcepts.datapipeline.core.Messages
 
isEvaluateExpressions() - Method in class com.northconcepts.datapipeline.excel.ExcelReader
 
isExceptionOnFailure() - Method in class com.northconcepts.datapipeline.transform.TransformingReader
 
isExceptionOnFailure() - Method in class com.northconcepts.datapipeline.transform.TransformingWriter
 
isExceptionOnFailure() - Method in class com.northconcepts.datapipeline.validate.ValidatingReader
 
isExcludeNulls() - Method in class com.northconcepts.datapipeline.group.GroupByReader
 
isExhausted() - Method in class com.northconcepts.datapipeline.core.DataReader
Returns true if this stream has already returned a null indicating that no further reads are possible.
isFailed() - Method in class com.northconcepts.datapipeline.job.AbstractJob
Returns true if this job has completed unsuccessfully.
isFailed() - Method in interface com.northconcepts.datapipeline.job.IJob
Returns true if this job has completed unsuccessfully.
isFailed() - Method in class com.northconcepts.datapipeline.job.Job
Returns true if this job has completed unsuccessfully.
isFailOnException() - Method in class com.northconcepts.datapipeline.core.AsyncMultiReader
 
isFailOnLimitationNotice() - Method in class com.northconcepts.datapipeline.twitter.TwitterFilterStreamReader
 
isFieldNamesInFirstRow() - Method in class com.northconcepts.datapipeline.core.AbstractReader
 
isFieldNamesInFirstRow() - Method in class com.northconcepts.datapipeline.core.AbstractWriter
 
isFieldNamesInFirstRow() - Method in class com.northconcepts.datapipeline.core.TextWriter
 
isFieldType(FieldType) - Method in class com.northconcepts.datapipeline.filter.FieldFilter
 
IsFieldType - Class in com.northconcepts.datapipeline.filter.rule
 
IsFieldType(FieldType) - Constructor for class com.northconcepts.datapipeline.filter.rule.IsFieldType
 
isFinished() - Method in class com.northconcepts.datapipeline.core.AsyncMultiReader.ReaderThread
 
isFinished() - Method in class com.northconcepts.datapipeline.job.AbstractJob
Returns true if this job has finished running.
isFinished() - Method in interface com.northconcepts.datapipeline.job.IJob
Returns true if this job has finished running.
isFinished() - Method in class com.northconcepts.datapipeline.job.Job
Returns true if this job has finished running.
isFinished() - Method in class com.northconcepts.datapipeline.multiplex.DeMux
 
isFlushOnWrite() - Method in class com.northconcepts.datapipeline.core.TextWriter
Indicates if the underlying java.io.BufferedWriter should be flushed after each record is written.
isFlushOnWrite() - Method in class com.northconcepts.datapipeline.file.FileWriter
Indicates if the underlying java.io.BufferedWriter should be flushed after each record is written.
isForceQuote() - Method in class com.northconcepts.datapipeline.csv.CSVWriter
Returns true if all values will be quoted, even if they are not null or empty strings.
isIgnoreEmptyText() - Method in class com.northconcepts.datapipeline.xml.XmlRecordReader
 
isIgnoreNamespaces() - Method in class com.northconcepts.datapipeline.xml.XmlReader
Indicates if namespaces on elements and attributes are ignored when matching expressions (default to true).
isIgnoreNamespaces() - Method in class com.northconcepts.datapipeline.xml.XmlRecordReader
Indicates if namespaces on elements and attributes are to be removed (default to true).
isInstanceOfJavaType(Class<?>) - Method in class com.northconcepts.datapipeline.filter.FieldFilter
 
IsInstanceOfJavaType - Class in com.northconcepts.datapipeline.filter.rule
 
IsInstanceOfJavaType(Class<?>) - Constructor for class com.northconcepts.datapipeline.filter.rule.IsInstanceOfJavaType
 
isJavaType(Class<?>) - Method in class com.northconcepts.datapipeline.filter.FieldFilter
 
IsJavaType - Class in com.northconcepts.datapipeline.filter.rule
 
IsJavaType(Class<?>) - Constructor for class com.northconcepts.datapipeline.filter.rule.IsJavaType
 
isLastFieldConsumesRemaining() - Method in class com.northconcepts.datapipeline.fixedwidth.FixedWidthReader
 
isLenient() - Method in class com.northconcepts.datapipeline.transform.SelectFields
 
isLetter(int) - Method in class com.northconcepts.datapipeline.core.ParsingReader
 
isLookupById() - Method in class com.northconcepts.datapipeline.twitter.TwitterUserLookupReader
 
isLookupByScreenName() - Method in class com.northconcepts.datapipeline.twitter.TwitterUserLookupReader
 
isMapTextRecordsToFields() - Method in class com.northconcepts.datapipeline.xml.XmlRecordReader
 
isMarker() - Method in class com.northconcepts.datapipeline.json.builder.JsonDetailMarker
 
isMarker() - Method in class com.northconcepts.datapipeline.json.builder.JsonNode
 
isMarker(ExpressionContext) - Method in class com.northconcepts.datapipeline.xml.builder.XmlDetailMarker
 
isMarker(ExpressionContext) - Method in class com.northconcepts.datapipeline.xml.builder.XmlNode
 
isMuteUser() - Method in class com.northconcepts.datapipeline.twitter.TwitterFollowWriter
 
isMuteUser() - Method in class com.northconcepts.datapipeline.twitter.TwitterUnfollowWriter
 
isNewLine(int) - Method in class com.northconcepts.datapipeline.core.ParsingReader
 
isNotArray() - Method in class com.northconcepts.datapipeline.core.Field
 
isNotArray() - Method in class com.northconcepts.datapipeline.core.ValueNode
 
isNotFieldType(FieldType) - Method in class com.northconcepts.datapipeline.filter.FieldFilter
 
isNotFinished() - Method in class com.northconcepts.datapipeline.core.AsyncMultiReader.ReaderThread
 
isNotInstanceOfJavaType(Class<?>) - Method in class com.northconcepts.datapipeline.filter.FieldFilter
 
isNotJavaType(Class<?>) - Method in class com.northconcepts.datapipeline.filter.FieldFilter
 
isNotNull() - Method in class com.northconcepts.datapipeline.core.Field
 
isNotNull() - Method in class com.northconcepts.datapipeline.core.ValueNode
 
IsNotNull() - Method in class com.northconcepts.datapipeline.filter.FieldFilter
 
IsNotNull - Class in com.northconcepts.datapipeline.filter.rule
 
IsNotNull() - Constructor for class com.northconcepts.datapipeline.filter.rule.IsNotNull
 
isNotRecord() - Method in class com.northconcepts.datapipeline.core.Field
 
isNotRecord() - Method in class com.northconcepts.datapipeline.core.ValueNode
 
isNull() - Method in class com.northconcepts.datapipeline.core.CompositeValue
 
isNull() - Method in class com.northconcepts.datapipeline.core.Field
 
isNull() - Method in class com.northconcepts.datapipeline.core.ValueNode
 
isNull() - Method in class com.northconcepts.datapipeline.filter.FieldFilter
 
IsNull - Class in com.northconcepts.datapipeline.filter.rule
 
IsNull() - Constructor for class com.northconcepts.datapipeline.filter.rule.IsNull
 
isOpen() - Method in class com.northconcepts.datapipeline.core.DataEndpoint
Indicates if this endpoint is ready for reading or writing.
isOverwriteFields() - Method in class com.northconcepts.datapipeline.transform.lookup.LookupTransformer
 
isPaused() - Method in class com.northconcepts.datapipeline.job.AbstractJob
Returns true if this job is currently paused.
isPaused() - Method in interface com.northconcepts.datapipeline.job.IJob
Returns true if this job is currently paused.
isPaused() - Method in class com.northconcepts.datapipeline.job.Job
Returns true if this job is currently paused.
isPollingRequired() - Method in class com.northconcepts.datapipeline.buffer.BufferStrategy
Indicates if the BufferStrategy.shouldClose(RecordBuffer, BufferedReader, Record) method should be called every second for open buffers -- even if no new data is present -- to release any data that may have been collected (passing in a null record).
isPollingRequired() - Method in class com.northconcepts.datapipeline.group.CloseWindowStrategy
Indicates if the {@link #shouldClose(Window, GroupByReader, Record) method should be called every second for open windows -- even if no new data is present -- to release any data that may have been collected (passing in a null record).
isPollingRequired() - Method in class com.northconcepts.datapipeline.group.CreateWindowStrategy
Indicates if the {@link #shouldCreate(GroupByReader, Record) method should be called every second -- even if no new data is present -- to allow windows to be created (passing in a null record).
isPretty() - Method in class com.northconcepts.datapipeline.json.SimpleJsonWriter
Indicates if line breaks and indentations should be added to output (default false).
isPretty() - Method in class com.northconcepts.datapipeline.xml.SimpleXmlWriter
Indicates if line breaks and indentations should be added to output (default false).
isPretty() - Method in class com.northconcepts.datapipeline.xml.XmlWriter
Indicates if line breaks and indentations should be added to output (default false).
isQuantity() - Method in interface com.northconcepts.datapipeline.expression.ASTNode
True if this node represents a literal of variable, false if it represents an expression.
isRateLimitExceeded() - Method in class com.northconcepts.datapipeline.twitter.TwitterProxyReader
 
isRateLimitExceeded() - Method in class com.northconcepts.datapipeline.twitter.TwitterReader
 
isRecord() - Method in class com.northconcepts.datapipeline.core.ArrayValue
 
isRecord() - Method in class com.northconcepts.datapipeline.core.Field
 
isRecord() - Method in class com.northconcepts.datapipeline.core.Record
 
isRecord() - Method in class com.northconcepts.datapipeline.core.SingleValue
 
isRecord() - Method in class com.northconcepts.datapipeline.core.ValueNode
 
isRecordBreak(JsonXmlNode) - Method in class com.northconcepts.datapipeline.json.JsonRecordReader
 
isRecordBreak(XmlNode) - Method in class com.northconcepts.datapipeline.xml.XmlReader
 
isRecordBreak(XmlNode) - Method in class com.northconcepts.datapipeline.xml.XmlRecordReader
 
isRecordCountBigInteger() - Method in class com.northconcepts.datapipeline.core.DataEndpoint
Indicates if this endpoint's record-count is too big (over 1000000000000000000L or 1.0e+18) for a long and should be retrieved as a BigInteger using DataEndpoint.getRecordCountAsBigInteger().
isRecordStackTraceInMessage() - Method in class com.northconcepts.datapipeline.transform.TransformingReader
 
isRecordStackTraceInMessage() - Method in class com.northconcepts.datapipeline.transform.TransformingWriter
 
isRecordStackTraceInMessage() - Method in class com.northconcepts.datapipeline.validate.ValidatingReader
 
isRemoveDocumentId() - Method in class com.northconcepts.datapipeline.mongodb.MongoReader
Indicates if the document "_id" property should be removed from the resulting records (defaults to true).
isReturnOrphans() - Method in class com.northconcepts.datapipeline.twitter.TwitterUserLookupReader
Indicates if records failing the lookup should be returned — instead of being deleted (default is false).
isRunning() - Method in class com.northconcepts.datapipeline.job.AbstractJob
Returns true if this job is currently running.
isRunning() - Method in interface com.northconcepts.datapipeline.job.IJob
Returns true if this job is currently running.
isRunning() - Method in class com.northconcepts.datapipeline.job.Job
Returns true if this job is currently running.
isRunning() - Method in class com.northconcepts.datapipeline.meter.Meter
 
isSkipEmptyRows() - Method in class com.northconcepts.datapipeline.core.AbstractReader
Indicates that rows with only null values should not be returned by the reader (default is false).
isStopOnWriterEOF() - Method in class com.northconcepts.datapipeline.eventbus.EventBusReader
Indicates if this reader should stop reading from the event bus when any event bus writer on the same topic finishes (default to true).
isTabular() - Method in class com.northconcepts.datapipeline.core.FieldList
Indicates if all the fields match against a flat record (i.e.
isTabular() - Method in class com.northconcepts.datapipeline.core.FieldPath
Indicates if this path matches against a flat record (i.e.
isThrowExceptionOnMissingField() - Method in class com.northconcepts.datapipeline.filter.FieldFilter
 
isThrowExceptionOnMissingField() - Method in class com.northconcepts.datapipeline.transform.FieldTransformer
 
isTransacted() - Method in class com.northconcepts.datapipeline.jms.JmsSettings
 
isTrimFields() - Method in class com.northconcepts.datapipeline.csv.CSVReader
 
isTrue(ExpressionContext) - Method in class com.northconcepts.datapipeline.json.builder.JsonLogicalExpression
 
isTrue(ExpressionContext) - Method in class com.northconcepts.datapipeline.xml.builder.XmlLogicalExpression
 
isTruncateFields() - Method in class com.northconcepts.datapipeline.fixedwidth.FixedWidthWriter
 
isUseSheetColumnCount() - Method in class com.northconcepts.datapipeline.excel.ExcelReader
 
isValueNode() - Method in class com.northconcepts.datapipeline.core.Node
Returns true if this node is a ValueNode (Record, ArrayValue, or SingleValue).
isValueNode() - Method in class com.northconcepts.datapipeline.core.ValueNode
 
isValueNotSet() - Method in class com.northconcepts.datapipeline.core.Field
 
isValueSet() - Method in class com.northconcepts.datapipeline.core.Field
 
iterator() - Method in class com.northconcepts.datapipeline.core.ArrayValue
 
iterator() - Method in class com.northconcepts.datapipeline.core.FieldList
 
iterator() - Method in class com.northconcepts.datapipeline.core.Record
 
iterator() - Method in class com.northconcepts.datapipeline.core.RecordList
 
ITwitterConverter - Interface in com.northconcepts.datapipeline.twitter
 
IUpsert - Interface in com.northconcepts.datapipeline.jdbc.upsert
 

J

JAVA_ARRAY_SIZE - Static variable in class com.northconcepts.datapipeline.core.Field
 
JAVA_OBJECT_SIZE - Static variable in class com.northconcepts.datapipeline.core.Field
 
JavaBeanReader - Class in com.northconcepts.datapipeline.javabean
Obtains records from an object using bean introspection and reflection.
JavaBeanReader(String, Object) - Constructor for class com.northconcepts.datapipeline.javabean.JavaBeanReader
 
JdbcLookup - Class in com.northconcepts.datapipeline.transform.lookup
 
JdbcLookup(Connection, String, int...) - Constructor for class com.northconcepts.datapipeline.transform.lookup.JdbcLookup
 
JdbcLookup(Connection, String) - Constructor for class com.northconcepts.datapipeline.transform.lookup.JdbcLookup
 
JdbcMultiWriter - Class in com.northconcepts.datapipeline.jdbc
Writes records to a database table using 1 or more connections; each connection writing asynchronously using a separate thread.
JdbcMultiWriter(DataSource, int, int, String) - Constructor for class com.northconcepts.datapipeline.jdbc.JdbcMultiWriter
 
JdbcReader - Class in com.northconcepts.datapipeline.jdbc
Obtains records from a database query.
JdbcReader(Connection, String) - Constructor for class com.northconcepts.datapipeline.jdbc.JdbcReader
 
JdbcReader(Connection, String, Object...) - Constructor for class com.northconcepts.datapipeline.jdbc.JdbcReader
 
JdbcReader(Connection, String, Object[], int[]) - Constructor for class com.northconcepts.datapipeline.jdbc.JdbcReader
 
JdbcUpsertWriter - Class in com.northconcepts.datapipeline.jdbc
Writes records to a database table using the upsert idiom (attempt to insert, but update if duplicate key exists).
JdbcUpsertWriter(Connection, String, IUpsert, String...) - Constructor for class com.northconcepts.datapipeline.jdbc.JdbcUpsertWriter
 
JdbcUpsertWriter(Connection, String, String...) - Constructor for class com.northconcepts.datapipeline.jdbc.JdbcUpsertWriter
 
JdbcValueReader - Interface in com.northconcepts.datapipeline.jdbc
 
JdbcWriter - Class in com.northconcepts.datapipeline.jdbc
Writes records to a database table.
JdbcWriter(Connection, String) - Constructor for class com.northconcepts.datapipeline.jdbc.JdbcWriter
 
JmsAcknowledgeMode - Enum in com.northconcepts.datapipeline.jms
 
JmsConnection - Class in com.northconcepts.datapipeline.jms
A connection to Java Message Service (JMS) provider.
JmsConnection(JmsSettings) - Constructor for class com.northconcepts.datapipeline.jms.JmsConnection
 
JmsDestinationType - Enum in com.northconcepts.datapipeline.jms
Constants for the type of messaging to use.
JmsReader - Class in com.northconcepts.datapipeline.jms
Read Records from a Java Message Service (JMS) provider.
JmsReader(JmsSettings) - Constructor for class com.northconcepts.datapipeline.jms.JmsReader
Connects to a Java Message Service server.
Apache ActiveMQ Example:
Properties props = new Properties();
props.setProperty(Context.INITIAL_CONTEXT_FACTORY,"org.apache.activemq.jndi.ActiveMQInitialContextFactory");
props.setProperty(Context.PROVIDER_URL,"tcp://localhost:61616");
DataReader reader = new JmsReader(props, JmsDestinationType.QUEUE, "queueName");
JmsSettings - Class in com.northconcepts.datapipeline.jms
The configuration used to connect to a JmsReader or JmsWriter.
JmsSettings(String, JmsDestinationType, Properties) - Constructor for class com.northconcepts.datapipeline.jms.JmsSettings
 
JmsSettings(String, JmsDestinationType) - Constructor for class com.northconcepts.datapipeline.jms.JmsSettings
 
JmsWriter - Class in com.northconcepts.datapipeline.jms
Write Records to a Java Message Service (JMS) provider.
JmsWriter(JmsSettings) - Constructor for class com.northconcepts.datapipeline.jms.JmsWriter
Connects to a Java Message Service server.
Apache ActiveMQ Example:
Properties props = new Properties();
props.setProperty(Context.INITIAL_CONTEXT_FACTORY,"org.apache.activemq.jndi.ActiveMQInitialContextFactory");
props.setProperty(Context.PROVIDER_URL,"tcp://localhost:61616");
DataWriter writer = new JmsWriter(props, JmsDestinationType.TOPIC, "topicName");
Job - Class in com.northconcepts.datapipeline.job
Used to run, manage, and track pipelines.
Job(DataReader, DataWriter) - Constructor for class com.northconcepts.datapipeline.job.Job
 
JobCallback<R extends DataReader,W extends DataWriter> - Interface in com.northconcepts.datapipeline.job
 
JobCallback.Helper - Class in com.northconcepts.datapipeline.job
 
JobLifecycleListener - Interface in com.northconcepts.datapipeline.job
 
jobs - Static variable in class com.northconcepts.datapipeline.job.AbstractJob
 
JobTemplate - Interface in com.northconcepts.datapipeline.job
JobTemplate is the base type for classes that transfer records from DataReaders to DataWriters.
JobTemplateImpl - Class in com.northconcepts.datapipeline.job
 
JobTemplateImpl() - Constructor for class com.northconcepts.datapipeline.job.JobTemplateImpl
 
join(long) - Method in class com.northconcepts.datapipeline.multiplex.DeMux
Waits at most millis milliseconds for the feeder process to finish reading records from the source reader and sending them to downstream readers.
join(long, int) - Method in class com.northconcepts.datapipeline.multiplex.DeMux
Waits at most millis milliseconds plus nanos nanoseconds for the feeder process to finish reading records from the source reader and sending them to downstream readers.
join() - Method in class com.northconcepts.datapipeline.multiplex.DeMux
Waits for the feeder process to finish reading records from the source reader and sending them to downstream readers.
join(Record, RecordList, List<?>) - Method in class com.northconcepts.datapipeline.transform.lookup.LookupTransformer
 
JsonArray - Class in com.northconcepts.datapipeline.json.builder
 
JsonArray() - Constructor for class com.northconcepts.datapipeline.json.builder.JsonArray
 
JsonConditionalNode - Class in com.northconcepts.datapipeline.json.builder
 
JsonConditionalNode(JsonNode, String) - Constructor for class com.northconcepts.datapipeline.json.builder.JsonConditionalNode
 
JsonDetailMarker - Class in com.northconcepts.datapipeline.json.builder
 
JsonDetailMarker(JsonNode) - Constructor for class com.northconcepts.datapipeline.json.builder.JsonDetailMarker
 
JsonExpression - Class in com.northconcepts.datapipeline.json.builder
 
JsonExpression(String) - Constructor for class com.northconcepts.datapipeline.json.builder.JsonExpression
 
JsonField - Class in com.northconcepts.datapipeline.json.builder
 
JsonField(String, JsonValue) - Constructor for class com.northconcepts.datapipeline.json.builder.JsonField
 
JsonFragment - Class in com.northconcepts.datapipeline.json.builder
 
JsonFragment(JsonNode) - Constructor for class com.northconcepts.datapipeline.json.builder.JsonFragment
 
JsonLogicalExpression - Class in com.northconcepts.datapipeline.json.builder
 
JsonLogicalExpression(String) - Constructor for class com.northconcepts.datapipeline.json.builder.JsonLogicalExpression
 
JsonNode - Class in com.northconcepts.datapipeline.json.builder
 
JsonNode() - Constructor for class com.northconcepts.datapipeline.json.builder.JsonNode
 
JsonNodeType - Enum in com.northconcepts.datapipeline.json.builder
 
JsonNodeWriter - Class in com.northconcepts.datapipeline.json.builder
 
JsonObject - Class in com.northconcepts.datapipeline.json.builder
 
JsonObject() - Constructor for class com.northconcepts.datapipeline.json.builder.JsonObject
 
JsonPrimitive - Class in com.northconcepts.datapipeline.json.builder
 
JsonPrimitive(String) - Constructor for class com.northconcepts.datapipeline.json.builder.JsonPrimitive
 
JsonReader - Class in com.northconcepts.datapipeline.json
 
JsonReader(File) - Constructor for class com.northconcepts.datapipeline.json.JsonReader
 
JsonReader(Reader) - Constructor for class com.northconcepts.datapipeline.json.JsonReader
 
JsonRecordReader - Class in com.northconcepts.datapipeline.json
 
JsonRecordReader(JsonParser) - Constructor for class com.northconcepts.datapipeline.json.JsonRecordReader
 
JsonTemplate - Class in com.northconcepts.datapipeline.json.builder
 
JsonTemplate() - Constructor for class com.northconcepts.datapipeline.json.builder.JsonTemplate
 
JsonValue - Class in com.northconcepts.datapipeline.json.builder
 
JsonValue() - Constructor for class com.northconcepts.datapipeline.json.builder.JsonValue
 
JsonWriter - Class in com.northconcepts.datapipeline.json
 
JsonWriter(JsonTemplate, File) - Constructor for class com.northconcepts.datapipeline.json.JsonWriter
 
JsonWriter(JsonTemplate, Writer) - Constructor for class com.northconcepts.datapipeline.json.JsonWriter
 

K

K - Static variable in class com.northconcepts.datapipeline.meter.Meter
 
keySet() - Method in class com.northconcepts.datapipeline.core.Node
 
keySet() - Method in interface com.northconcepts.datapipeline.core.Session
 
keySet() - Method in class com.northconcepts.datapipeline.core.Session.SessionImpl
 

L

last(String, String, boolean) - Method in class com.northconcepts.datapipeline.group.GroupByReader
 
last(String, String) - Method in class com.northconcepts.datapipeline.group.GroupByReader
 
last(String, boolean) - Method in class com.northconcepts.datapipeline.group.GroupByReader
 
lastRecord - Variable in class com.northconcepts.datapipeline.core.DataEndpoint
 
lastRow - Variable in class com.northconcepts.datapipeline.core.AbstractReader
 
left(int) - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer
 
limit(int) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.Select
 
limit(int, int) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.Select
 
limitedRecords(long) - Static method in class com.northconcepts.datapipeline.buffer.BufferStrategy
Closes the buffer after the specified amount of records have been collected.
limitedRecords(long) - Static method in class com.northconcepts.datapipeline.group.CloseWindowStrategy
Closes the window after the specified amount of records has been collected.
limitedTime(String, long) - Static method in class com.northconcepts.datapipeline.buffer.BufferStrategy
Closes buffers after the specified datetime field has increased by a set amount of time since it was first seen.
limitedTime(long) - Static method in class com.northconcepts.datapipeline.group.CloseWindowStrategy
Closes windows after they've been open for the specified time.
limitedTime(String, long) - Static method in class com.northconcepts.datapipeline.group.CloseWindowStrategy
Closes windows after the specified datetime field has increased by a set amount of time since it was first seen.
limitedTimeFromLastUpdate(long) - Static method in class com.northconcepts.datapipeline.buffer.BufferStrategy
Closes buffers after the specified time has elapsed since the last record was added.
limitedTimeFromLastUpdateOrLimitedRecords(long, long) - Static method in class com.northconcepts.datapipeline.buffer.BufferStrategy
Closes buffers after the specified time has elapsed since the last record was added or the specified amount of records have been collected.
limitedTimeFromOpen(long) - Static method in class com.northconcepts.datapipeline.buffer.BufferStrategy
Closes buffers after they've been open for the specified time.
limitedTimeFromOpenOrLimitedRecords(long, long) - Static method in class com.northconcepts.datapipeline.buffer.BufferStrategy
Closes buffers after they've been open for the specified time or the specified amount of records have been collected.
limitOpened(int) - Static method in class com.northconcepts.datapipeline.group.CreateWindowStrategy
Opens a new window if there are less currently open than the specified number.
LimitReader - Class in com.northconcepts.datapipeline.core
A proxy that can skip a number of upstream records, limit the number of records sent downstream, or both.
LimitReader(DataReader) - Constructor for class com.northconcepts.datapipeline.core.LimitReader
 
LimitReader(DataReader, Long, Long) - Constructor for class com.northconcepts.datapipeline.core.LimitReader
 
LimitReader(DataReader, Integer, Integer) - Constructor for class com.northconcepts.datapipeline.core.LimitReader
 
LimitReader(DataReader, long) - Constructor for class com.northconcepts.datapipeline.core.LimitReader
 
LinedTextWriter - Class in com.northconcepts.datapipeline.core
Abstract super-class for writing records to a text stream.
LinedTextWriter(File, boolean) - Constructor for class com.northconcepts.datapipeline.core.LinedTextWriter
 
LinedTextWriter(File) - Constructor for class com.northconcepts.datapipeline.core.LinedTextWriter
 
LinedTextWriter(Writer) - Constructor for class com.northconcepts.datapipeline.core.LinedTextWriter
 
LineParser - Class in com.northconcepts.datapipeline.core
 
LineParser(BufferedReader, char[][]) - Constructor for class com.northconcepts.datapipeline.core.LineParser
 
LineParser(String, char[][]) - Constructor for class com.northconcepts.datapipeline.core.LineParser
 
listBuckets() - Method in class com.northconcepts.datapipeline.filesystem.amazons3.AmazonS3FileSystem
Returns the buckets owned by the authenticated user.
listen(TwitterStream) - Method in class com.northconcepts.datapipeline.twitter.TwitterFilterStreamReader
 
listen(TwitterStream) - Method in class com.northconcepts.datapipeline.twitter.TwitterSampleStreamReader
 
listFolder(String, String) - Method in class com.northconcepts.datapipeline.filesystem.amazons3.AmazonS3FileSystem
Returns the objects in the specified bucket's folder.
listRootFolder(String) - Method in class com.northconcepts.datapipeline.filesystem.amazons3.AmazonS3FileSystem
Returns the root objects in the specified bucket.
lock - Variable in class com.northconcepts.datapipeline.core.AsyncReader
 
log - Static variable in class com.northconcepts.datapipeline.core.DataObject
 
log() - Static method in class com.northconcepts.datapipeline.core.Functions
Logs all aliased functions know to the expression language to the debug level.
log - Static variable in class com.northconcepts.datapipeline.core.RecordList
 
log - Static variable in class com.northconcepts.datapipeline.diagnostic.Diagnostic
 
log - Static variable in class com.northconcepts.datapipeline.eventbus.EventBus
 
log() - Method in class com.northconcepts.datapipeline.job.AbstractJob
 
log() - Method in class com.northconcepts.datapipeline.job.Job
 
log - Static variable in class com.northconcepts.datapipeline.multiplex.DeMux
 
log - Static variable in class com.northconcepts.datapipeline.multiplex.SplitWriter
 
Lookup - Class in com.northconcepts.datapipeline.transform.lookup
Searches for data in another source to merge with each record passing through this lookup's transformer -- the streaming version of a join.
Lookup() - Constructor for class com.northconcepts.datapipeline.transform.lookup.Lookup
 
lookup(Integer) - Static method in enum com.northconcepts.datapipeline.twitter.TwitterErrorCode
 
LookupTransformer - Class in com.northconcepts.datapipeline.transform.lookup
 
LookupTransformer(FieldList, Lookup, Node.DuplicateNodeAction) - Constructor for class com.northconcepts.datapipeline.transform.lookup.LookupTransformer
 
LookupTransformer(FieldList, Lookup, boolean) - Constructor for class com.northconcepts.datapipeline.transform.lookup.LookupTransformer
Deprecated.
LookupTransformer(FieldList, Lookup) - Constructor for class com.northconcepts.datapipeline.transform.lookup.LookupTransformer
 
lowerCase() - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer
 
lowerCaseFirstChar() - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer
 

M

M - Static variable in class com.northconcepts.datapipeline.meter.Meter
 
MailChimpClient - Interface in com.northconcepts.datapipeline.mailchimp
 
MailChimpClient.Proxy - Class in com.northconcepts.datapipeline.mailchimp
 
MailChimpListMemberReader - Class in com.northconcepts.datapipeline.mailchimp
Reads the list of subscribed, unsubscribed, and cleaned members from a MailChimp list.
MailChimpListMemberReader(String, String) - Constructor for class com.northconcepts.datapipeline.mailchimp.MailChimpListMemberReader
 
MailStore - Enum in com.northconcepts.datapipeline.email
 
main(String[]) - Static method in class com.northconcepts.datapipeline.diagnostic.Diagnostic
 
match(char, String) - Method in interface com.northconcepts.datapipeline.core.IParser
 
match(char) - Method in interface com.northconcepts.datapipeline.core.IParser
 
match(CharSequence, String) - Method in interface com.northconcepts.datapipeline.core.IParser
 
match(char[], String) - Method in interface com.northconcepts.datapipeline.core.IParser
 
match(CharSequence) - Method in interface com.northconcepts.datapipeline.core.IParser
 
match(char[]) - Method in interface com.northconcepts.datapipeline.core.IParser
 
match(char, String) - Method in class com.northconcepts.datapipeline.core.LineParser
 
match(char) - Method in class com.northconcepts.datapipeline.core.LineParser
 
match(CharSequence, String) - Method in class com.northconcepts.datapipeline.core.LineParser
 
match(char[], String) - Method in class com.northconcepts.datapipeline.core.LineParser
 
match(CharSequence) - Method in class com.northconcepts.datapipeline.core.LineParser
 
match(char[]) - Method in class com.northconcepts.datapipeline.core.LineParser
 
match(char, String) - Method in class com.northconcepts.datapipeline.core.Parser
 
match(char) - Method in class com.northconcepts.datapipeline.core.Parser
 
match(CharSequence, String) - Method in class com.northconcepts.datapipeline.core.Parser
 
match(CharSequence) - Method in class com.northconcepts.datapipeline.core.Parser
 
match(char[], String) - Method in class com.northconcepts.datapipeline.core.Parser
 
match(char[]) - Method in class com.northconcepts.datapipeline.core.Parser
 
match(int) - Method in class com.northconcepts.datapipeline.core.ParsingReader
 
match(char, String) - Method in class com.northconcepts.datapipeline.core.StringParser
 
match(char) - Method in class com.northconcepts.datapipeline.core.StringParser
 
match(CharSequence, String) - Method in class com.northconcepts.datapipeline.core.StringParser
 
match(CharSequence) - Method in class com.northconcepts.datapipeline.core.StringParser
 
match(char[], String) - Method in class com.northconcepts.datapipeline.core.StringParser
 
match(char[]) - Method in class com.northconcepts.datapipeline.core.StringParser
 
matchCHARACTER() - Method in class com.northconcepts.datapipeline.core.ParsingReader
 
matchDIGIT() - Method in class com.northconcepts.datapipeline.core.ParsingReader
 
matchDIGITS() - Method in class com.northconcepts.datapipeline.core.ParsingReader
 
matchDOUBLE() - Method in class com.northconcepts.datapipeline.core.ParsingReader
 
matchINTEGER() - Method in class com.northconcepts.datapipeline.core.ParsingReader
 
matchNEWLINE() - Method in class com.northconcepts.datapipeline.core.ParsingReader
 
matchNEWLINES() - Method in class com.northconcepts.datapipeline.core.ParsingReader
 
max(String, String, boolean) - Method in class com.northconcepts.datapipeline.group.GroupByReader
 
max(String, String) - Method in class com.northconcepts.datapipeline.group.GroupByReader
 
max(String, boolean) - Method in class com.northconcepts.datapipeline.group.GroupByReader
 
max(String) - Method in class com.northconcepts.datapipeline.group.GroupByReader
 
MAX_BATCH_SIZE - Static variable in class com.northconcepts.datapipeline.twitter.TwitterUserLookupReader
 
MAX_DISPLAY_STRING - Static variable in class com.northconcepts.datapipeline.core.Field
 
MAX_ENV_VALUE_LENGTH - Static variable in class com.northconcepts.datapipeline.diagnostic.Diagnostic
 
MAX_QUEUE_SIZE - Static variable in class com.northconcepts.datapipeline.multiplex.DeMux
 
maximum(String) - Method in class com.northconcepts.datapipeline.group.AggregateReader
Deprecated.
 
MemoryReader - Class in com.northconcepts.datapipeline.memory
Obtains records from an in-memory RecordList.
MemoryReader(RecordList) - Constructor for class com.northconcepts.datapipeline.memory.MemoryReader
 
MemoryWriter - Class in com.northconcepts.datapipeline.memory
Writes records to an in-memory RecordList.
MemoryWriter() - Constructor for class com.northconcepts.datapipeline.memory.MemoryWriter
 
MemoryWriter(RecordList) - Constructor for class com.northconcepts.datapipeline.memory.MemoryWriter
 
Message - Class in com.northconcepts.datapipeline.core
 
Message(Message.Level, String, Throwable) - Constructor for class com.northconcepts.datapipeline.core.Message
 
Message(Message.Level, Throwable) - Constructor for class com.northconcepts.datapipeline.core.Message
 
Message(Message.Level, String, boolean) - Constructor for class com.northconcepts.datapipeline.core.Message
 
Message(Message.Level, String) - Constructor for class com.northconcepts.datapipeline.core.Message
 
Message.Level - Enum in com.northconcepts.datapipeline.core
 
Messages - Class in com.northconcepts.datapipeline.core
Thread-local container for messages and exceptions originating in asynchronous operations.
Messages() - Constructor for class com.northconcepts.datapipeline.core.Messages
 
Meter - Class in com.northconcepts.datapipeline.meter
 
Meter() - Constructor for class com.northconcepts.datapipeline.meter.Meter
 
Metered - Interface in com.northconcepts.datapipeline.meter
 
MeteredInputStream - Class in com.northconcepts.datapipeline.meter
 
MeteredInputStream(InputStream) - Constructor for class com.northconcepts.datapipeline.meter.MeteredInputStream
 
MeteredOutputStream - Class in com.northconcepts.datapipeline.meter
 
MeteredOutputStream(OutputStream) - Constructor for class com.northconcepts.datapipeline.meter.MeteredOutputStream
 
MeteredReader - Class in com.northconcepts.datapipeline.meter
A proxy that measures the rate (bytes/second) at which data is read.
MeteredReader(DataReader) - Constructor for class com.northconcepts.datapipeline.meter.MeteredReader
 
MeteredWriter - Class in com.northconcepts.datapipeline.meter
A proxy that measures the rate (bytes/second) at which data is written.
MeteredWriter(DataWriter) - Constructor for class com.northconcepts.datapipeline.meter.MeteredWriter
 
millisecondsToDate() - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer
 
millisecondsToDateTime() - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer
 
min(String, String, boolean) - Method in class com.northconcepts.datapipeline.group.GroupByReader
 
min(String, String) - Method in class com.northconcepts.datapipeline.group.GroupByReader
 
min(String, boolean) - Method in class com.northconcepts.datapipeline.group.GroupByReader
 
min(String) - Method in class com.northconcepts.datapipeline.group.GroupByReader
 
minimum(String) - Method in class com.northconcepts.datapipeline.group.AggregateReader
Deprecated.
 
MINIMUM_BUFFER_SIZE - Static variable in class com.northconcepts.datapipeline.core.AsyncReader
 
MINIMUM_PART_SIZE - Static variable in class com.northconcepts.datapipeline.filesystem.amazons3.AmazonS3FileSystem
 
MINUTE - Static variable in class com.northconcepts.datapipeline.schedule.HourlyScheduler
 
minutesToDate() - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer
 
minutesToDateTime() - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer
 
MongoReader - Class in com.northconcepts.datapipeline.mongodb
Reads documents from a MongoDB database collection.
MongoReader(String, String) - Constructor for class com.northconcepts.datapipeline.mongodb.MongoReader
Connects to the MongoDB server in localhost on the default port 27017.
MongoReader(MongoClient, String, String) - Constructor for class com.northconcepts.datapipeline.mongodb.MongoReader
Connects to the MongoDB server as specified in MongoClient.
MongoWriter - Class in com.northconcepts.datapipeline.mongodb
Writes records to a MongoDB database collection.
MongoWriter(String, String) - Constructor for class com.northconcepts.datapipeline.mongodb.MongoWriter
Connects to the MongoDB server in localhost on the default port 27017.
MongoWriter(MongoClient, String, String) - Constructor for class com.northconcepts.datapipeline.mongodb.MongoWriter
Connects to the MongoDB server as specified in MongoClient.
move(int, int) - Method in class com.northconcepts.datapipeline.core.RecordList
 
moveField(int, int) - Method in class com.northconcepts.datapipeline.core.Record
 
moveField(String, int) - Method in class com.northconcepts.datapipeline.core.Record
 
moveFieldAfter(String, String) - Method in class com.northconcepts.datapipeline.core.Record
 
moveFieldAfter(FieldPath, FieldPath) - Method in class com.northconcepts.datapipeline.core.Record
 
MoveFieldAfter - Class in com.northconcepts.datapipeline.transform
See FieldPath for supported field name expressions.
MoveFieldAfter(String, String) - Constructor for class com.northconcepts.datapipeline.transform.MoveFieldAfter
 
moveFieldBefore(String, String) - Method in class com.northconcepts.datapipeline.core.Record
 
moveFieldBefore(FieldPath, FieldPath) - Method in class com.northconcepts.datapipeline.core.Record
 
MoveFieldBefore - Class in com.northconcepts.datapipeline.transform
See FieldPath for supported field name expressions.
MoveFieldBefore(String, String) - Constructor for class com.northconcepts.datapipeline.transform.MoveFieldBefore
 
MultiWriter - Class in com.northconcepts.datapipeline.core
Writes records to multiple DataWriter.
MultiWriter() - Constructor for class com.northconcepts.datapipeline.core.MultiWriter
 
MultiWriter(MultiWriter.WriteStrategy) - Constructor for class com.northconcepts.datapipeline.core.MultiWriter
 
MultiWriter(DataWriter...) - Constructor for class com.northconcepts.datapipeline.core.MultiWriter
 
MultiWriter.AvailableCapacityWriteStrategy - Class in com.northconcepts.datapipeline.core
Writes each record to a single writer by choosing the one with the highest available capacity (DataWriter.available() If all writers have identical capacities, this strategy behaves like MultiWriter.RoundRobinWriteStrategy and writes to each writer in turn.
MultiWriter.ReplicateWriteStrategy - Class in com.northconcepts.datapipeline.core
Writes each record to all writers.
MultiWriter.RoundRobinWriteStrategy - Class in com.northconcepts.datapipeline.core
Divides records evenly between all writers by cycling through the list and writing each record to a single writer in turn.
MultiWriter.WriteStrategy - Class in com.northconcepts.datapipeline.core
 
mute(String) - Method in class com.northconcepts.datapipeline.twitter.TwitterProvider
 
MySqlUpsert - Class in com.northconcepts.datapipeline.jdbc.upsert
 
MySqlUpsert() - Constructor for class com.northconcepts.datapipeline.jdbc.upsert.MySqlUpsert
 

N

name - Variable in class com.northconcepts.datapipeline.core.DataObject
 
name(String) - Method in class com.northconcepts.datapipeline.core.FieldPath
Appends a new field name segment to this field path.
never() - Static method in class com.northconcepts.datapipeline.group.CloseWindowStrategy
Never closes open windows.
newField(JsonXmlNode, JsonToken, String, JsonLocation) - Method in class com.northconcepts.datapipeline.json.JsonRecordReader
 
newJsonSystemOutWriter() - Static method in class com.northconcepts.datapipeline.core.StreamWriter
Creates a new instance of StreamWriter writing JSON to System.out.
newNode(JsonXmlNode, JsonToken, String, JsonLocation) - Method in class com.northconcepts.datapipeline.json.JsonRecordReader
 
newProvider() - Method in enum com.northconcepts.datapipeline.excel.ExcelDocument.ProviderType
 
newSystemErrWriter() - Static method in class com.northconcepts.datapipeline.core.StreamWriter
Creates a new instance of StreamWriter writing to System.err.
newSystemOutWriter() - Static method in class com.northconcepts.datapipeline.core.StreamWriter
Creates a new instance of StreamWriter writing to System.out.
newValue(JsonXmlNode, JsonToken, Object) - Method in class com.northconcepts.datapipeline.json.JsonRecordReader
 
newWorkbook() - Method in class com.northconcepts.datapipeline.excel.PoiSxssfProvider
 
newXmlSystemOutWriter() - Static method in class com.northconcepts.datapipeline.core.StreamWriter
Creates a new instance of StreamWriter writing XML to System.out.
nextBatch(ObjectListing) - Method in class com.northconcepts.datapipeline.filesystem.amazons3.AmazonS3FileSystem
Returns the next set of paged objects.
nextMessage(int) - Method in enum com.northconcepts.datapipeline.email.EmailReadDirection
 
nextNode(ExpressionContext, JsonGenerator) - Method in class com.northconcepts.datapipeline.json.builder.JsonNodeWriter
 
nextNode() - Method in class com.northconcepts.datapipeline.json.JsonRecordReader
 
nextRecord() - Method in class com.northconcepts.datapipeline.buffer.RecordBuffer
 
nextRecord() - Method in class com.northconcepts.datapipeline.group.Window
 
Ngrams - Class in com.northconcepts.datapipeline.transform
Extracts each run/sequence of N words from the source field and stores them in a target field as an array.
Ngrams(String, String, int, Locale) - Constructor for class com.northconcepts.datapipeline.transform.Ngrams
 
Ngrams(String, String, int) - Constructor for class com.northconcepts.datapipeline.transform.Ngrams
 
Node - Class in com.northconcepts.datapipeline.core
Node is the base class for all persistent data in Data Pipeline.
Node() - Constructor for class com.northconcepts.datapipeline.core.Node
 
Node.DuplicateNodeAction - Enum in com.northconcepts.datapipeline.core
DuplicateNodeAction lists all actions that can be taken automatically when a target field already exists during a record copy or lookup.
Node.NodeType - Enum in com.northconcepts.datapipeline.core
NodeType lists all concrete data node types used in Data Pipeline.
NodeVisitor - Class in com.northconcepts.datapipeline.core
 
NodeVisitor() - Constructor for class com.northconcepts.datapipeline.core.NodeVisitor
 
noResults(Record, List<?>) - Method in class com.northconcepts.datapipeline.transform.lookup.LookupTransformer
 
notContains(String, boolean) - Method in class com.northconcepts.datapipeline.filter.FieldFilter
 
NotFilter - Class in com.northconcepts.datapipeline.eventbus.filter
 
NotFilter(EventFilter...) - Constructor for class com.northconcepts.datapipeline.eventbus.filter.NotFilter
 
NotPart - Class in com.northconcepts.datapipeline.jdbc.sql.select
 
NotPart(QueryCriteriaPart) - Constructor for class com.northconcepts.datapipeline.jdbc.sql.select.NotPart
 
NotRule - Class in com.northconcepts.datapipeline.filter.rule
 
NotRule(FieldFilterRule) - Constructor for class com.northconcepts.datapipeline.filter.rule.NotRule
 
NULL - Static variable in interface com.northconcepts.datapipeline.eventbus.EventFilter
 
NULL - Static variable in interface com.northconcepts.datapipeline.job.JobCallback
 
NULL - Static variable in interface com.northconcepts.datapipeline.job.JobLifecycleListener
 
nullCallback() - Static method in class com.northconcepts.datapipeline.job.JobCallback.Helper
 
NullFilter - Class in com.northconcepts.datapipeline.eventbus.filter
 
NullFilter() - Constructor for class com.northconcepts.datapipeline.eventbus.filter.NullFilter
 
nullToExpression(String) - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer
 
nullToValue(String) - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer
 
nullToValue(Date) - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer
 
nullToValue(Date) - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer
 
nullToValue(Time) - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer
 
nullToValue(int) - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer
 
nullToValue(long) - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer
 
nullToValue(BigInteger) - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer
 
nullToValue(short) - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer
 
nullToValue(byte) - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer
 
nullToValue(boolean) - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer
 
nullToValue(char) - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer
 
nullToValue(BigDecimal) - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer
 
nullToValue(double) - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer
 
nullToValue(float) - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer
 
nullToValue(byte[]) - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer
 
nullValue() - Static method in class com.northconcepts.datapipeline.core.ValueNode
 
nullValue(FieldType) - Static method in class com.northconcepts.datapipeline.core.ValueNode
 
NullWriter - Class in com.northconcepts.datapipeline.core
Discards records.
NullWriter() - Constructor for class com.northconcepts.datapipeline.core.NullWriter
 
numberToBigDecimal() - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer
 
numberToBigInteger() - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer
 
numberToBoolean() - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer
Converts the field's value to true if non-zero, otherwise false.
numberToDate(String, long) - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer
 
numberToDate(long) - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer
 
numberToDateTime(String, long) - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer
 
numberToDateTime(long) - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer
 
numberToDays() - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer
 
numberToDouble() - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer
 
numberToHours() - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer
 
numberToInt() - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer
 
numberToInterval(String, String) - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer
 
numberToInterval(String) - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer
 
numberToLong() - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer
 
numberToMillisecond() - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer
 
numberToMinutes() - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer
 
numberToMonths() - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer
 
numberToSeconds() - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer
 
numberToString(DecimalFormat) - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer
 
numberToString(String) - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer
 
numberToYears() - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer
 

O

object() - Method in class com.northconcepts.datapipeline.json.builder.JsonArray
 
object(String) - Method in class com.northconcepts.datapipeline.json.builder.JsonConditionalNode
 
object() - Method in class com.northconcepts.datapipeline.json.builder.JsonConditionalNode
 
object(String) - Method in class com.northconcepts.datapipeline.json.builder.JsonDetailMarker
 
object() - Method in class com.northconcepts.datapipeline.json.builder.JsonDetailMarker
 
object() - Method in class com.northconcepts.datapipeline.json.builder.JsonNode
 
object(String) - Method in class com.northconcepts.datapipeline.json.builder.JsonNode
 
object(String) - Method in class com.northconcepts.datapipeline.json.builder.JsonObject
 
object() - Method in class com.northconcepts.datapipeline.json.builder.JsonTemplate
 
onBytesMessage(BytesMessage) - Method in class com.northconcepts.datapipeline.jms.JmsReader
 
onDuplicate(Record) - Method in class com.northconcepts.datapipeline.core.RemoveDuplicatesReader
Called for each duplicate record.
onEvent(Event<?>) - Method in interface com.northconcepts.datapipeline.eventbus.UntypedEventListener
 
onException(Event<?>, Throwable, Object) - Method in interface com.northconcepts.datapipeline.eventbus.ExceptionListener
 
onFailure() - Method in class com.northconcepts.datapipeline.job.AbstractJob
 
onFailure(R, W, Record, Throwable) - Method in interface com.northconcepts.datapipeline.job.JobCallback
 
onFailure(Throwable) - Method in class com.northconcepts.datapipeline.retry.RetryingOperation
 
onFailure(Record, Throwable) - Method in class com.northconcepts.datapipeline.retry.RetryingReader
 
onFailure(Record, Throwable) - Method in class com.northconcepts.datapipeline.retry.RetryingWriter
 
onFailure(Record, Transformer, DataException, String, Messages) - Method in class com.northconcepts.datapipeline.transform.TransformingReader
 
onFailure(Record, Transformer, DataException, String, Messages) - Method in class com.northconcepts.datapipeline.transform.TransformingWriter
 
onFinish() - Method in class com.northconcepts.datapipeline.job.AbstractJob
 
onFinish() - Method in class com.northconcepts.datapipeline.job.Job
Called when this job finishes.
onFinish(Job) - Method in interface com.northconcepts.datapipeline.job.JobLifecycleListener
 
onLimitExceeded(TwitterRateLimit) - Method in interface com.northconcepts.datapipeline.twitter.IApiLimitPolicy
 
onMapMessage(MapMessage) - Method in class com.northconcepts.datapipeline.jms.JmsReader
 
onMessage(Message) - Method in class com.northconcepts.datapipeline.jms.JmsReader
 
onObjectMessage(ObjectMessage) - Method in class com.northconcepts.datapipeline.jms.JmsReader
 
onPause() - Method in class com.northconcepts.datapipeline.job.AbstractJob
 
onPause() - Method in class com.northconcepts.datapipeline.job.Job
Called when this job is paused.
onPause(Job) - Method in interface com.northconcepts.datapipeline.job.JobLifecycleListener
 
onProgress(R, W, Record) - Method in interface com.northconcepts.datapipeline.job.JobCallback
 
onRateLimitExceeded() - Method in class com.northconcepts.datapipeline.twitter.TwitterProxyReader
 
onRateLimitExceeded() - Method in class com.northconcepts.datapipeline.twitter.TwitterReader
 
onRecord(Record) - Method in interface com.northconcepts.datapipeline.eventbus.RecordListener
 
onResume() - Method in class com.northconcepts.datapipeline.job.AbstractJob
 
onResume(Job) - Method in interface com.northconcepts.datapipeline.job.JobLifecycleListener
 
onShuttingDown(EventBus) - Method in interface com.northconcepts.datapipeline.eventbus.EventBusLifecycleListener
 
onShuttingDown(EventBus) - Method in interface com.northconcepts.datapipeline.eventbus.ShutdownListener
 
onStart() - Method in class com.northconcepts.datapipeline.job.AbstractJob
 
onStart() - Method in class com.northconcepts.datapipeline.job.Job
Called when this job starts.
onStart(Job) - Method in interface com.northconcepts.datapipeline.job.JobLifecycleListener
 
onStartUp(EventBus) - Method in interface com.northconcepts.datapipeline.eventbus.EventBusLifecycleListener
 
onStreamMessage(StreamMessage) - Method in class com.northconcepts.datapipeline.jms.JmsReader
 
onSuccess() - Method in class com.northconcepts.datapipeline.job.AbstractJob
 
onSuccess(R, W) - Method in interface com.northconcepts.datapipeline.job.JobCallback
 
onTextMessage(TextMessage) - Method in class com.northconcepts.datapipeline.jms.JmsReader
 
onTheadFinished(AsyncMultiReader.ReaderThread) - Method in class com.northconcepts.datapipeline.core.AsyncMultiReader
 
onUnique(Record) - Method in class com.northconcepts.datapipeline.core.RemoveDuplicatesReader
Called for each unique record.
onUserFound(Long, String, Record) - Method in class com.northconcepts.datapipeline.twitter.TwitterUserLookupReader
Called for each user found.
onUserNotFound(Long, String, Record) - Method in class com.northconcepts.datapipeline.twitter.TwitterUserLookupReader
Called for each user not found.
open() - Method in class com.northconcepts.datapipeline.avro.AvroReader
 
open() - Method in class com.northconcepts.datapipeline.avro.AvroWriter
 
open() - Method in class com.northconcepts.datapipeline.buffer.BufferedReader
 
open() - Method in class com.northconcepts.datapipeline.buffer.RecordBuffer
 
open() - Method in class com.northconcepts.datapipeline.core.AbstractReader
 
open() - Method in class com.northconcepts.datapipeline.core.AbstractWriter
 
open() - Method in class com.northconcepts.datapipeline.core.AsyncMultiReader
 
open() - Method in class com.northconcepts.datapipeline.core.AsyncReader
 
open() - Method in class com.northconcepts.datapipeline.core.AsyncWriter
 
open() - Method in class com.northconcepts.datapipeline.core.DataEndpoint
Makes this endpoint ready for reading or writing.
open() - Method in class com.northconcepts.datapipeline.core.DataEndpointGroup
 
open() - Method in class com.northconcepts.datapipeline.core.LimitReader
 
open() - Method in class com.northconcepts.datapipeline.core.MultiWriter
 
open() - Method in class com.northconcepts.datapipeline.core.ProxyReader
 
open() - Method in class com.northconcepts.datapipeline.core.ProxyWriter
 
open() - Method in class com.northconcepts.datapipeline.core.RemoveDuplicatesReader
 
open() - Method in class com.northconcepts.datapipeline.core.SequenceReader
 
open() - Method in class com.northconcepts.datapipeline.core.SortingReader
 
open() - Method in class com.northconcepts.datapipeline.core.StreamWriter
 
open() - Method in class com.northconcepts.datapipeline.core.TeeReader
 
open() - Method in class com.northconcepts.datapipeline.core.TextReader
 
open() - Method in class com.northconcepts.datapipeline.email.EmailReader
 
open() - Method in class com.northconcepts.datapipeline.eventbus.EventBusReader
 
open() - Method in class com.northconcepts.datapipeline.eventbus.EventBusWriter
 
open(InputStream) - Method in class com.northconcepts.datapipeline.excel.ExcelDocument
 
open(File) - Method in class com.northconcepts.datapipeline.excel.ExcelDocument
 
open() - Method in class com.northconcepts.datapipeline.excel.ExcelReader
 
open() - Method in class com.northconcepts.datapipeline.excel.ExcelWriter
 
open() - Method in class com.northconcepts.datapipeline.file.FileSystemInfoReader
 
open() - Method in class com.northconcepts.datapipeline.filesystem.amazons3.AmazonS3FileSystem
Opens a connection to the Amazon S3 file system.
open() - Method in class com.northconcepts.datapipeline.filter.FilteringReader
 
open() - Method in class com.northconcepts.datapipeline.fixedwidth.FixedWidthReader
 
open() - Method in class com.northconcepts.datapipeline.group.AggregateReader
Deprecated.
 
open() - Method in class com.northconcepts.datapipeline.group.GroupByReader
 
open() - Method in class com.northconcepts.datapipeline.group.Window
 
open() - Method in class com.northconcepts.datapipeline.instagram.InstagramLocationMediaReader
 
open() - Method in class com.northconcepts.datapipeline.instagram.InstagramLocationReader
 
open() - Method in class com.northconcepts.datapipeline.instagram.InstagramSelfFollowedByReader
 
open() - Method in class com.northconcepts.datapipeline.instagram.InstagramSelfFollowsReader
 
open() - Method in class com.northconcepts.datapipeline.instagram.InstagramSelfMediaReader
 
open() - Method in class com.northconcepts.datapipeline.instagram.InstagramTagMediaReader
 
open() - Method in class com.northconcepts.datapipeline.instagram.InstagramTagReader
 
open() - Method in class com.northconcepts.datapipeline.instagram.InstagramUserMediaReader
 
open() - Method in class com.northconcepts.datapipeline.jdbc.JdbcMultiWriter
 
open() - Method in class com.northconcepts.datapipeline.jdbc.JdbcReader
 
open() - Method in class com.northconcepts.datapipeline.jdbc.JdbcUpsertWriter
 
open() - Method in class com.northconcepts.datapipeline.jdbc.JdbcWriter
 
open() - Method in class com.northconcepts.datapipeline.jms.JmsConnection
 
open(JmsSettings, Session) - Method in enum com.northconcepts.datapipeline.jms.JmsDestinationType
Opens the type of message channel.
open() - Method in class com.northconcepts.datapipeline.jms.JmsReader
 
open() - Method in class com.northconcepts.datapipeline.jms.JmsWriter
 
open() - Method in class com.northconcepts.datapipeline.json.JsonWriter
 
open() - Method in class com.northconcepts.datapipeline.json.SimpleJsonWriter
 
open() - Method in class com.northconcepts.datapipeline.mailchimp.MailChimpListMemberReader
 
open() - Method in class com.northconcepts.datapipeline.memory.MemoryReader
 
open() - Method in class com.northconcepts.datapipeline.mongodb.MongoReader
 
open() - Method in class com.northconcepts.datapipeline.mongodb.MongoWriter
 
open() - Method in class com.northconcepts.datapipeline.multiplex.SplitWriter
 
open() - Method in class com.northconcepts.datapipeline.pdf.PdfWriter
 
open() - Method in class com.northconcepts.datapipeline.retry.RetryingReader
 
open() - Method in class com.northconcepts.datapipeline.retry.RetryingWriter
 
open() - Method in class com.northconcepts.datapipeline.rtf.RtfWriter
 
open() - Method in class com.northconcepts.datapipeline.template.TemplateWriter
 
open() - Method in class com.northconcepts.datapipeline.transform.TransformingReader
 
open() - Method in class com.northconcepts.datapipeline.transform.TransformingWriter
 
open() - Method in class com.northconcepts.datapipeline.twitter.TwitterPageableReader
 
open() - Method in class com.northconcepts.datapipeline.twitter.TwitterProxyReader
 
open() - Method in class com.northconcepts.datapipeline.twitter.TwitterReader
 
open() - Method in class com.northconcepts.datapipeline.twitter.TwitterSearchReader
 
open(String, String) - Method in class com.northconcepts.datapipeline.twitter.TwitterStreamProvider
 
open() - Method in class com.northconcepts.datapipeline.twitter.TwitterUserLookupReader
 
open() - Method in class com.northconcepts.datapipeline.xml.SimpleXmlWriter
 
open() - Method in class com.northconcepts.datapipeline.xml.XmlReader
 
open() - Method in class com.northconcepts.datapipeline.xml.XmlWriter
 
openWorkbook(File) - Method in class com.northconcepts.datapipeline.excel.PoiXssfSaxProvider
 
openWorkbook(InputStream) - Method in class com.northconcepts.datapipeline.excel.PoiXssfSaxProvider
 
Operation(String) - Constructor for class com.northconcepts.datapipeline.transform.BasicFieldTransformer.Operation
 
or(BufferStrategy...) - Static method in class com.northconcepts.datapipeline.buffer.BufferStrategy
Closes buffers if any of the supplied strategies request it.
or(FieldFilterRule...) - Method in class com.northconcepts.datapipeline.filter.FieldFilter
 
or(CloseWindowStrategy...) - Static method in class com.northconcepts.datapipeline.group.CloseWindowStrategy
Closes windows if any of the supplied strategies request it.
or(CreateWindowStrategy...) - Static method in class com.northconcepts.datapipeline.group.CreateWindowStrategy
Opens a new window if any of the supplied strategies request it.
or(boolean, QueryCriteriaPart) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.QueryCriteria
 
or(QueryCriteriaPart) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.QueryCriteria
 
or(String, Object...) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.QueryCriteria
 
or(boolean, String, Object...) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.QueryCriteria
 
orderBy(String...) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.Select
 
orderBy(String, boolean) - Method in class com.northconcepts.datapipeline.jdbc.sql.select.Select
 
OrFilter - Class in com.northconcepts.datapipeline.eventbus.filter
Matches any one of a set of filers -- filer A || filer B || filer C.
OrFilter(EventFilter...) - Constructor for class com.northconcepts.datapipeline.eventbus.filter.OrFilter
 
OrPart - Class in com.northconcepts.datapipeline.jdbc.sql.select
 
OrPart() - Constructor for class com.northconcepts.datapipeline.jdbc.sql.select.OrPart
 
OrRule - Class in com.northconcepts.datapipeline.filter.rule
 
OrRule() - Constructor for class com.northconcepts.datapipeline.filter.rule.OrRule
 
OrRule(FieldFilterRule...) - Constructor for class com.northconcepts.datapipeline.filter.rule.OrRule
 

P

P - Static variable in class com.northconcepts.datapipeline.meter.Meter
 
padLeft(int, char) - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer
 
padRight(int, char) - Method in class com.northconcepts.datapipeline.transform.BasicFieldTransformer
 
parent - Variable in class com.northconcepts.datapipeline.xml.builder.XmlNode
 
parse(String) - Static method in class com.northconcepts.datapipeline.core.FieldPath
Converts a field path expression into a FieldPath object.
parse(String, String, String, Boolean) - Static method in class com.northconcepts.datapipeline.csv.CSVReader
Utility method to quickly parse lines of CSV text.
ParseException - Exception in com.northconcepts.datapipeline.expression
 
ParseException() - Constructor for exception com.northconcepts.datapipeline.expression.ParseException
 
ParseException(String) - Constructor for exception com.northconcepts.datapipeline.expression.ParseException
 
ParseException(Throwable) - Constructor for exception com.northconcepts.datapipeline.expression.ParseException
 
ParseException(String, Throwable) - Constructor for exception com.northconcepts.datapipeline.expression.ParseException
 
parseExpression(String) - Static method in class com.northconcepts.datapipeline.expression.ExpressionHelper
 
parseLine(String, String, String, Boolean) - Static method in class com.northconcepts.datapipeline.csv.CSVReader
Utility method to quickly parse a line of CSV text.
parseLogicalExpression(String) - Static method in class com.northconcepts.datapipeline.expression.ExpressionHelper
 
Parser - Class in com.northconcepts.datapipeline.core
 
Parser(Reader) - Constructor for class com.northconcepts.datapipeline.core.Parser
 
Parser(String) - Constructor for class com.northconcepts.datapipeline.core.Parser
 
parser - Variable in class com.northconcepts.datapipeline.core.ParsingReader
 
ParsingReader - Class in com.northconcepts.datapipeline.core
Abstract super-class for obtaining records from a text stream using a parser.
ParsingReader(File) - Constructor for class com.northconcepts.datapipeline.core.ParsingReader
 
ParsingReader(Reader) - Constructor for class com.northconcepts.datapipeline.core.ParsingReader
 
PatternMatch - Class in com.northconcepts.datapipeline.filter.rule
 
PatternMatch() - Constructor for class com.northconcepts.datapipeline.filter.rule.PatternMatch
 
PatternMatch(String...) - Constructor for class com.northconcepts.datapipeline.filter.rule.PatternMatch
 
PatternMatch(String, int) - Constructor for class com.northconcepts.datapipeline.filter.rule.PatternMatch
 
patternMatches(String...) - Method in class com.northconcepts.datapipeline.filter.FieldFilter
 
patternNotMatches(String...) - Method in class com.northconcepts.datapipeline.filter.FieldFilter
 
pause() - Method in class com.northconcepts.datapipeline.job.AbstractJob
 
pause() - Method in interface com.northconcepts.datapipeline.job.IJob
 
pause() - Method in class com.northconcepts.datapipeline.job.Job
 
PdfWriter - Class in com.northconcepts.datapipeline.pdf
Writes records to a PDF document stream.
PdfWriter(File) - Constructor for class com.northconcepts.datapipeline.pdf.PdfWriter
 
PdfWriter(OutputStream) - Constructor for class com.northconcepts.datapipeline.pdf.PdfWriter
 
peek(int) - Method in class com.northconcepts.datapipeline.core.DataReader
Looks ahead to return the next record at the specified index without reading it or null if one does not exist.
peek(int) - Method in interface com.northconcepts.datapipeline.core.IParser
 
peek(int) - Method in class com.northconcepts.datapipeline.core.LineParser
 
peek(int) - Method in class com.northconcepts.datapipeline.core.Parser
 
peek(int) - Method in class com.northconcepts.datapipeline.core.StringParser
 
peekCHARACTER() - Method in class com.northconcepts.datapipeline.core.ParsingReader
 
peekSequence(int, int) - Method in interface com.northconcepts.datapipeline.core.IParser
 
peekSequence(int, int) - Method in class com.northconcepts.datapipeline.core.LineParser
 
peekSequence(int, int) - Method in class com.northconcepts.datapipeline.core.Parser
 
peekSequence(int, int) - Method in class com.northconcepts.datapipeline.core.StringParser
 
peekString(CharSequence) - Method in interface com.northconcepts.datapipeline.core.IParser
 
peekString(char[]) - Method in interface com.northconcepts.datapipeline.core.IParser
 
peekString(CharSequence) - Method in class com.northconcepts.datapipeline.core.LineParser
 
peekString(char[]) - Method in class com.northconcepts.datapipeline.core.LineParser
 
peekString(CharSequence) - Method in class com.northconcepts.datapipeline.core.Parser
 
peekString(char[]) - Method in class com.northconcepts.datapipeline.core.Parser
 
peekString(CharSequence) - Method in class com.northconcepts.datapipeline.core.StringParser
 
peekString(char[]) - Method in class com.northconcepts.datapipeline.core.StringParser
 
peekStringArray(CharSequence[]) - Method in interface com.northconcepts.datapipeline.core.IParser
 
peekStringArray(char[][]) - Method in interface com.northconcepts.datapipeline.core.IParser
 
peekStringArray(CharSequence[]) - Method in class com.northconcepts.datapipeline.core.LineParser
 
peekStringArray(char[][]) - Method in class com.northconcepts.datapipeline.core.LineParser
 
peekStringArray(CharSequence[]) - Method in class com.northconcepts.datapipeline.core.