com.northconcepts.datapipeline.core

Class ConcurrentRecordList

java.lang.Object

com.northconcepts.datapipeline.core.RecordList

com.northconcepts.datapipeline.core.ConcurrentRecordList

All Implemented Interfaces:

JsonSerializable, RecordSerializable, Serializable, Cloneable, Iterable<Record>

public class ConcurrentRecordList
extends RecordList

See Also:

Serialized Form

Field Summary

Fields inherited from class com.northconcepts.datapipeline.core.RecordList

log

Fields inherited from interface com.northconcepts.datapipeline.core.RecordSerializable

SERIALIZED_CLASS_NAME, TYPE

Constructor Summary

Constructors

Constructor and Description
ConcurrentRecordList()
ConcurrentRecordList(DataReader reader)
ConcurrentRecordList(int initialCapacity)
ConcurrentRecordList(Record... records)

Method Summary

Modifier and Type	Method and Description
RecordList	add(int index, Record record) Inserts a record at the specified position in this list, shifting any record at or after index to the right.
RecordList	add(Record... records) Appends all the specified records to the end of this list.
RecordList	addAll(DataReader reader) Writes all the records in the specified reader to the end of this list.
ConcurrentRecordList	clone() Returns a new RecordList that is a copy of this RecordList.
RecordList	findAll(Filter filter)
int	findFirst(Filter filter, int from)
int	findLast(Filter filter, int from)
void	forEach(Consumer<? super Record> consumer) Performs the given action for each record in this list.
Record	get(int index) Returns the record at the specified position in this list.
ReadWriteLock	getReadWriteLock()
int	getRecordCount() Returns the number of records in this list -- an alias for RecordList.size().
List<Record>	getRecords() Returns a list of records.
long	getSizeInBytes()
Iterator<Record>	iterator() Returns an iterator over the records in this list.
RecordList	move(int oldIndex, int newIndex) Moves the index field at the oldIndex to the newIndex, shifting any existing elements at or after newIndex to the right.
Stream<Record>	parallelStream() Returns a parallel Stream of the records in this list.
RecordList	set(int index, Record record) Replaces the record at the specified position in this list with a new record.
RecordList	sort(RecordComparator comparator)
RecordList	sort(RecordComparator comparator, boolean cacheFieldIndexes)
Stream<Record>	stream() Returns a sequential Stream of the records in this list.
RecordList	sublist(int fromIndex, boolean cloneRecords)
RecordList	sublist(int fromIndex, int toIndex, boolean cloneRecords)
String	toString()

Methods inherited from class com.northconcepts.datapipeline.core.RecordList

addAll, addAll, clear, ensureCapacity, fromArrayValue, fromBinary, fromBinary, fromBinary, fromRecord, getValuesAsArray, isEmpty, isNotEmpty, size, toArrayValue, toBinary, toBinary, toBinary, toDataReader, toRecord

Methods inherited from class java.lang.Object

equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface java.lang.Iterable

spliterator

Methods inherited from interface com.northconcepts.datapipeline.core.RecordSerializable

fromArrayValue, fromArrayValue, fromArrayValue, fromJson, fromJson, newInstanceFromRecord, newInstanceFromRecord, toArrayValue, toJson, toJson, toJson, toRecord

Methods inherited from interface com.northconcepts.datapipeline.core.JsonSerializable

newInstanceFromJson

Constructor Detail

ConcurrentRecordList

public ConcurrentRecordList()

ConcurrentRecordList

public ConcurrentRecordList(int initialCapacity)

ConcurrentRecordList

public ConcurrentRecordList(Record... records)

ConcurrentRecordList

public ConcurrentRecordList(DataReader reader)

Method Detail

getReadWriteLock

public ReadWriteLock getReadWriteLock()

iterator

public Iterator<Record> iterator()

Description copied from class: RecordList

Returns an iterator over the records in this list.

Specified by:

iterator in interface Iterable<Record>

Overrides:

iterator in class RecordList

clone

public ConcurrentRecordList clone()

Description copied from class: RecordList

Returns a new RecordList that is a copy of this RecordList.

Overrides:

clone in class RecordList

getRecords

public List<Record> getRecords()

Description copied from class: RecordList

Returns a list of records.

Overrides:

getRecords in class RecordList

forEach

public void forEach(Consumer<? super Record> consumer)

Description copied from class: RecordList

Performs the given action for each record in this list.

Specified by:

forEach in interface Iterable<Record>

Overrides:

forEach in class RecordList

stream

public Stream<Record> stream()

Description copied from class: RecordList

Returns a sequential Stream of the records in this list.

Overrides:

stream in class RecordList

parallelStream

public Stream<Record> parallelStream()

Description copied from class: RecordList

Returns a parallel Stream of the records in this list.

Overrides:

parallelStream in class RecordList

getRecordCount

public int getRecordCount()

Description copied from class: RecordList

Returns the number of records in this list -- an alias for RecordList.size().

Overrides:

getRecordCount in class RecordList

get

public Record get(int index)

Description copied from class: RecordList

Returns the record at the specified position in this list.

Overrides:

get in class RecordList

add

public RecordList add(Record... records)

Description copied from class: RecordList

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

Overrides:

add in class RecordList

add

public RecordList add(int index,
                      Record record)

Description copied from class: RecordList

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

Overrides:

add in class RecordList

set

public RecordList set(int index,
                      Record record)

Description copied from class: RecordList

Replaces the record at the specified position in this list with a new record.

Overrides:

set in class RecordList

move

public RecordList move(int oldIndex,
                       int newIndex)

Description copied from class: RecordList

Moves the index field at the oldIndex to the newIndex, shifting any existing elements at or after newIndex to the right.

Overrides:

move in class RecordList

addAll

public RecordList addAll(DataReader reader)

Description copied from class: RecordList

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

Overrides:

addAll in class RecordList

sublist

public RecordList sublist(int fromIndex,
                          int toIndex,
                          boolean cloneRecords)

Overrides:

sublist in class RecordList

sublist

public RecordList sublist(int fromIndex,
                          boolean cloneRecords)

Overrides:

sublist in class RecordList

sort

public RecordList sort(RecordComparator comparator,
                       boolean cacheFieldIndexes)

Overrides:

sort in class RecordList

sort

public RecordList sort(RecordComparator comparator)

Overrides:

sort in class RecordList

findFirst

public int findFirst(Filter filter,
                     int from)

Overrides:

findFirst in class RecordList

findLast

public int findLast(Filter filter,
                    int from)

Overrides:

findLast in class RecordList

findAll

public RecordList findAll(Filter filter)

Overrides:

findAll in class RecordList

getSizeInBytes

public long getSizeInBytes()

Overrides:

getSizeInBytes in class RecordList

toString

public String toString()

Overrides:

toString in class RecordList