Class ShardedWriter.GeneralShardedConsumer<T>

java.lang.Object

org.ojalgo.netio.ShardedWriter<T>

org.ojalgo.netio.ShardedWriter.GeneralShardedConsumer<T>

All Implemented Interfaces:

Closeable, AutoCloseable, ToFileWriter<T>

Enclosing class:

ShardedWriter<T>

static final class ShardedWriter.GeneralShardedConsumer<T>
extends ShardedWriter<T>

Nested Class Summary

Nested classes/interfaces inherited from class ShardedWriter

ShardedWriter.GeneralShardedConsumer<T>, ShardedWriter.PowerOf2ShardedConsumer<T>

Nested classes/interfaces inherited from interface ToFileWriter

ToFileWriter.Builder<F>

Field Summary

Fields

Modifier and Type	Field	Description
private final ToIntFunction<T>	myDistributor
private final int	myNumberOfShards
private final ToFileWriter<T>[]	myWriters

Fields inherited from interface ToFileWriter

NULL

Constructor Summary

Constructors

Constructor	Description
GeneralShardedConsumer(ToIntFunction<T> distributor, ToFileWriter<T>[] consumers)

Method Summary

Modifier and Type	Method	Description
void	write(T item)	Write the item to the consumer.

Methods inherited from class ShardedWriter

close, of

Methods inherited from class Object

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

Methods inherited from interface ToFileWriter

writeBatch

Field Details

myWriters

private final ToFileWriter<T>[] myWriters

myDistributor

private final ToIntFunction<T> myDistributor

myNumberOfShards

private final int myNumberOfShards

Constructor Details

GeneralShardedConsumer

GeneralShardedConsumer(ToIntFunction<T> distributor,
 ToFileWriter<T>[] consumers)

Method Details

write

public void write(T item)

Description copied from interface: ToFileWriter

Write the item to the consumer.

Parameters:

item - The item to be written